快捷導(dǎo)航

在Java中使用MongoDB的方法詳解

更新時(shí)間：2023年12月20日 08:32:08 作者：Ifnew

這篇文章主要給大家介紹了關(guān)于在Java中使用MongoDB的相關(guān)資料,要操作MongoDB數(shù)據(jù)庫(kù)你需要使用MongoDB的Java驅(qū)動(dòng)程序,文中通過(guò)代碼介紹的非常詳細(xì),需要的朋友可以參考下

一、mongoDB簡(jiǎn)介

MongoDB 是由 C++ 語(yǔ)言編寫的，基于分布式文件存儲(chǔ)的數(shù)據(jù)庫(kù)，是一個(gè)介于關(guān)系數(shù)據(jù)庫(kù)和非關(guān)系數(shù)據(jù)庫(kù)之間的產(chǎn)品，是最接近于關(guān)系型數(shù)據(jù)庫(kù)的 NoSQL 數(shù)據(jù)庫(kù)。
MongoDB 旨在為 WEB 應(yīng)用提供可擴(kuò)展的高性能數(shù)據(jù)存儲(chǔ)解決方案。

MongoDB 將數(shù)據(jù)存儲(chǔ)為一個(gè)文檔，數(shù)據(jù)結(jié)構(gòu)由鍵值(key=>value)對(duì)組成。MongoDB 文檔類似于JSON對(duì)象。字段值可以包含其他文檔，數(shù)組及文檔數(shù)組

類似于

2. MongoDB優(yōu)點(diǎn):數(shù)據(jù)處理能力強(qiáng)，內(nèi)存級(jí)數(shù)據(jù)庫(kù)，查詢速度快，擴(kuò)展性強(qiáng)，只是不支持事務(wù)。

3. 使用場(chǎng)景：

1、應(yīng)用不需要事務(wù)；

2、數(shù)據(jù)模型無(wú)法確定，經(jīng)常發(fā)生變更；

3、應(yīng)用存儲(chǔ)的數(shù)據(jù)很大達(dá)到TB級(jí)別以上；

4、應(yīng)用需要大量的地理位置查詢簡(jiǎn)單的來(lái)說(shuō)就是數(shù)據(jù)量比較大，而且主要是查詢操作，而且不需要事務(wù)支持

二、MongoDB與Mysql的區(qū)別

三、使用

1、安裝

安裝地址: http://www.mongodb.org/

github: https://github.com/mongodb/

2、在java中使用

引入依賴

      <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>

配置連接參數(shù)

    data:
    mongodb:
      host: 10.0.26.194
      username: wanttop2
      password: Testwanttop2
      port: 27017
      authentication-database: wanttop2
      database: wanttop2

直接使用mongoTemplate

當(dāng)然也可以自己封裝一個(gè)工具類

 @Autowired
    private MongoTemplate mongoTemplate;

單表查詢

        // 判斷 dataType 是否存在，如果存在則添加到查詢條件中
        if (performanceRank.getDataType() != null) {
            query.addCriteria(Criteria.where("dataType").is(performanceRank.getDataType()));
        }
        // 判斷 divisionCode 是否存在，如果存在則添加到查詢條件中
        if (performanceRank.getDivisionCode() != null) {
            query.addCriteria(Criteria.where("divisionCode").is(performanceRank.getDivisionCode()));

        }

        List<SysDimensionDataMarket> sysDimensionDataMarketList = MongoDBUtil.conditionalQuery(query, SysDimensionDataMarket.class, "SysDimensionDataMarket");

3、多表連接查詢

mongoDB中沒有sql的left join 和right join 的類似的概念而是用到了lookup管道操作符

mongoDB3.2版本新增（聚合管道$lookup操作）

完整代碼

    //連表
    LookupOperation cusAndInfoLookup = LookupOperation.newLookup().
                    from("SysProduct").//1.副表表名字
                    localField("prodItemCode").//2.主表的關(guān)聯(lián)字段
                    foreignField("productCode").//3.副表的關(guān)聯(lián)字段
                    as("SysProduct");//4.建議和1一致，結(jié)果的別名
    //如果需要多連表就在寫一個(gè)
    //LookupOperation cusAndInfoLookup1 = LookupOperation.newLookup().
    //                from("SysProduct").//1.副表表名字
    //               localField("prodItemCode").//2.主表的關(guān)聯(lián)字段
    //              foreignField("productCode").//3.副表的關(guān)聯(lián)字段
    //                as("SysProduct");//4.建議和1一致，結(jié)果的別名
            //多表的關(guān)聯(lián)條件，查詢條件均傳入到此
    //創(chuàng)建查詢條件
    Criteria criteria = new Criteria();
       if (totalPerformanceCross.getDataCrossType() != null) {
                criteria.and("dataCrossType").is(totalPerformanceCross.getDataCrossType());
            }
            // 判斷 areaCode 是否存在，如果存在則添加到查詢條件中
            if (totalPerformanceCross.getAreaCode() != null) {
                criteria.and("areaCode").is(totalPerformanceCross.getAreaCode());
            }
            // 判斷 companyCode 是否存在，如果存在則添加到查詢條件中
            if (totalPerformanceCross.getCompanyCode() != null) {
                criteria.and("companyCode").is(totalPerformanceCross.getCompanyCode());
            }
            //如果查詢的字段為附表則需要加上附表名字 
            if (totalPerformanceCross.getDateType() != null) {
                criteria.and("SysProduct.dateType").is(totalPerformanceCross.getDateType());
            }
      //多表的關(guān)聯(lián)條件，查詢條件均傳入到此
            Aggregation aggregation = Aggregation.newAggregation(
                    //連表?xiàng)l件
                    cusAndInfoLookup,
                    //cusAndInfoLookup1,
                    //查詢條件
                    Aggregation.match(criteria),
                    //最后查詢結(jié)果集顯示字段
                    Aggregation.project("pmLineCode", "prodItemCode", "prodItemName", "performance", "growthRate", "monthPerformance", "fullMonthPerformance", "SysProduct.productPicUrl"));