在Java中使用MongoDB的方法詳解

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

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

一、mongoDB簡介

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

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

類似于

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

3. 使用場景：

1、應用不需要事務；

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

3、應用存儲的數(shù)據(jù)很大達到TB級別以上；

4、應用需要大量的地理位置查詢簡單的來說就是數(shù)據(jù)量比較大，而且主要是查詢操作，而且不需要事務支持

二、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

當然也可以自己封裝一個工具類

 @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é)果的別名
    //如果需要多連表就在寫一個
    //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(
                    //連表條件
                    cusAndInfoLookup,
                    //cusAndInfoLookup1,
                    //查詢條件
                    Aggregation.match(criteria),
                    //最后查詢結(jié)果集顯示字段
                    Aggregation.project("pmLineCode", "prodItemCode", "prodItemName", "performance", "growthRate", "monthPerformance", "fullMonthPerformance", "SysProduct.productPicUrl"));