使用Spring Data MongoDB持久化文檔數(shù)據(jù)

go4it 發(fā)布于2019-06-26 17:20 / 3158人閱讀

摘要：介紹非關(guān)系型數(shù)據(jù)是文檔型數(shù)據(jù)，文檔是獨立的實體，文檔數(shù)據(jù)庫不適用于關(guān)聯(lián)關(guān)系明顯的數(shù)據(jù)提供了三種方式在應(yīng)用中使用通過注解實現(xiàn)對象文檔映射使用實現(xiàn)基于模板的數(shù)據(jù)庫訪問自動化的運行時生成功能注解將類型映射為文檔這是一個文檔指定覆蓋默認(rèn)的域名啟用

介紹

NoSQL：not only SQL,非關(guān)系型數(shù)據(jù)

MongoDB是文檔型數(shù)據(jù)，文檔是獨立的實體，文檔數(shù)據(jù)庫不適用于關(guān)聯(lián)關(guān)系明顯的數(shù)據(jù)

Spring Data MongoDB

Spring Data MongoDB提供了三種方式在Spring應(yīng)用中使用MongoDB

通過注解實現(xiàn)對象-文檔映射

使用MongoTemplate實現(xiàn)基于模板的數(shù)據(jù)庫訪問

自動化的運行時Repository生成功能

import java.util.Collection;
import java.util.LinkedHashSet;

import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;

/**
 * Spring Data MongoDB注解將Java類型映射為文檔
 */
@Document        //這是一個文檔
public class Order {

    @Id        //指定id
    private String id;
    
    @Field("client")        //覆蓋默認(rèn)的域名
    private String customer;
    
    private String type;
    
    private Collection items = new LinkedHashSet<>();

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getCustomer() {
        return customer;
    }

    public void setCustomer(String customer) {
        this.customer = customer;
    }

    public String getType() {
        return type;
    }

    public void setType(String type) {
        this.type = type;
    }

    public Collection getItems() {
        return items;
    }

    public void setItems(Collection items) {
        this.items = items;
    }
    
    
    
}

啟用MongoDB

通過@EnableJpaRepositories注解啟用Spring Data的自動化JPA Repository生成功能

@EnableMongoRepositories為MongoDB實現(xiàn)了相同的功能

第一種方式：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;

import com.mongodb.MongoClient;

/**
 * 
 * Spring Data MongoDB的配置
 *
 */
@Configuration
@EnableMongoRepositories(basePackages="com.adagio.db")    //啟用MongoDB的Repository功能
public class MongoConfig {

    /**
     * MongoTemplate Bean
     * @param mongoDbFactory
     * @return
     */
    @Bean
    public MongoOperations mongoTemplate(){
        return new MongoTemplate(mongoDbFactory());
    }
    
    /**
     * MongoDbFactory bean
     * @return
     */
    public MongoDbFactory mongoDbFactory(){
        return new SimpleMongoDbFactory(mongoClient(), "com.adagio.db");
    }
    
    /**
     * MongoClient bean
     * @return
     */
    public MongoClient mongoClient(){
        return new MongoClient("localhost");
    }
    
}

第二種方式

import java.util.Arrays;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.data.mongodb.config.AbstractMongoConfiguration;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;

import com.mongodb.Mongo;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;

/**
 * 
 * Spring Data MongoDB的配置
 * 擴(kuò)展AbstractMongoConfiguration
 *
 */
@Configuration
@EnableMongoRepositories(basePackages="com.adagio.db")    //啟用MongoDB的Repository功能
public class MongoConfig2 extends AbstractMongoConfiguration {

    @Override
    protected String getDatabaseName() {
        return "OrdersDB";        //指定數(shù)據(jù)庫名
    }

    @Autowired
    private Environment env;
    
    @Override
    public Mongo mongo() throws Exception {
//        return new MongoClient();        //創(chuàng)建Mongo客戶端
        
        //如果MongoDB服務(wù)器運行在其他的機(jī)器上
//        return new MongoClient("mongoServer");
        
        //如果MongoDB服務(wù)器監(jiān)聽的端口不是默認(rèn)端口27017
//        return new MongoClient("mongoServer", 37017);
        
        //如果MongoDB服務(wù)器在生產(chǎn)配置上，啟用了認(rèn)證功能
        MongoCredential credential = MongoCredential.createCredential(
                env.getProperty("mongo.username") , "OrdersDB", 
                env.getProperty("mongo.password").toCharArray());
        return new MongoClient(
                new ServerAddress("localhost", 37017),
                Arrays.asList(credential));
    }

    
}

為模型添加注解，實現(xiàn)MongoDB持久化

用于對象-文檔映射的Spring Data MongoDB注解

@Document 標(biāo)示映射到MongoDB文檔上的領(lǐng)域?qū)ο? 類似JPA @Entity注解

@Id 標(biāo)示某個域為ID域

@DbRef 標(biāo)示某個域要引用的其它的文檔，這個文檔有可能位于另一個數(shù)據(jù)庫中

@Field 為文檔域指定自定義的元數(shù)據(jù)

@Version 標(biāo)示某個屬性用作版域

注意：沒有添加注解的屬性，也會持久化為文檔中域，除非設(shè)置瞬時態(tài)(transient)

注意：Order.items屬性，不是關(guān)聯(lián)關(guān)系，會完全嵌入到Order中

使用MongoTemplate訪問MongoDB

配置類中配置的MongoTemplate bean,將其注入到使用的地方

@Autowired MongoOperations mongo;

MongoOperations是MongoTemplate所實現(xiàn)的接口

void save(Object objectToSave, String collectionName);

save第一個參數(shù)是新創(chuàng)建的對象，第二個參數(shù)是要保存的文檔存儲的名稱

編寫MongoDB Repository

使用Spring Data MongoDB來創(chuàng)建Repository

通過@EnableMongoRepositories注解啟用Spring Data MongoDB的Repository功能

通過擴(kuò)展MongoRepository接口，能夠繼承多個CRUD操作

查詢方式：

自定義查詢

指定查詢

混合定義查詢

//自定義查詢
    List findByCustomer(String customer);
    List getByCustomer(String customer);
    List readByCustomer(String customer);
    
    int countByCustomer(String customer);
    
    List findByCustomerLike(String customer);

    List findByCustomerAndType(String customer, String type);

    List getByType(String type);
        
    //指定查詢
    @Query("{customer:"Chuck Wagon"}")
    List findChucksOrders();

混合自定義的功能

首先，定義中間接口

import java.util.List;

public interface OrderOperations {

    List findOrderByType(String t);
}

編寫混合實現(xiàn)

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;


public class OrderOperationsimpl implements OrderOperations {

    @Autowired
    private MongoOperations mongo;        //注入MongoOperations
    @Override
    public List findOrderByType(String t) {
        String type = t.equals("NET") ? "WEB" : t;
        
        //創(chuàng)建查詢
        Criteria where = Criteria.where("type").is(type);
        Query query = Query.query(where);
        
        //執(zhí)行查詢
        return mongo.find(query, Order.class);
    }

}

引用：《Spring In Action 4》第十二章

越想快一點的時候，越慢
越想要的，越難以得到
抓到越緊，越是徒勞

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/19063.html

發(fā)表評論

登陸后可評論

0條評論

go4it

男|高級講師

我要關(guān)注我要私信

TA的文章

新的 Azure AD 漏洞讓黑客在不被發(fā)現(xiàn)的情況下暴力破解密碼

閱讀 1514·2021-10-11 10:59
ucloud，烏蘭察布快捷共享型云主機(jī)測評 – 基于AMD Rome EPYC2

閱讀 1887·2021-09-09 11:36
前端菜鳥筆記 Day-4 CSS布局

閱讀 1402·2019-08-30 15:55
css比較經(jīng)典的例子

閱讀 1332·2019-08-29 11:20
開發(fā)者日報 2019年3月30日

閱讀 3067·2019-08-26 13:39
還不會正則表達(dá)式？看這篇！

閱讀 1472·2019-08-26 13:37
JSONSERVER接口調(diào)試工具安裝配置

閱讀 1966·2019-08-26 12:11
手挽手帶你學(xué)VUE：一檔 VUE簡介以及常用內(nèi)部指令

閱讀 1328·2019-08-23 14:28

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

使用Spring Data MongoDB持久化文檔數(shù)據(jù)

相關(guān)文章