上手mongodb

• 2019 年 10 月 3 日
• 筆記

上手MongoDB

MongoDB 是一個跨平台的，面向文檔的資料庫，如果你了解spring-data-jpa的使用, 那麼恭喜你,你已經可以使用mongodb做開發了

使用這種類型的資料庫還是挺方便的,最小的存儲單位是一個文檔,但是文檔有什麼欄位,有多少欄位它都不關心,而mysql這樣的典型的關係型資料庫,開發之前得把表設計的明明白白的,說不定還得預留幾個欄位以備不時之需,因為後續再改就麻煩了

。它支援的數據結構非常鬆散，是類似 JSON 的 BSON 格式，因此可以存儲比較複雜的數據類型。

體系結構

一個MongoDB實例支援多個database並存,同時一個database中可以包含多個collection,所以大家都說它是介於關係資料庫和非關係資料庫之間，因為它的組成結構真的特別像關係型資料庫

支援的數據類型

注意點:

• 當我們再在命令行窗口通過命令行進行數據的讀寫時,如果我們這樣寫 {"XXX",2}, 它會默認把2處理成浮點類型,而不是整形
• 每一個文檔唯一身份id是 _id , 前面有個下劃線

使用命令行進行數據的讀寫

點擊文檔官網

• 開啟本地的mongo伺服器(用來保存數據)打開之後,就別關了

默認使用的埠是 27017

mongod -dbpath=指定文件夾當作數據存儲路徑 --port 埠號

• 連接資料庫(客戶端,進行CRUD)

// 在本機直接用下面的命令,模擬連接本機的mongodb  mongo  // 連接遠程的mongo  mongo 192.168.88.88

• 退出

exit

• 選擇資料庫

默認選中的資料庫是test庫

// 如果數據名不存在,默認直接把它創建出來,並且直接選中它使用  user 資料庫名

• 查看當前資料庫

db

• 保存一條數據

入參位置的bson, 注意key的部分是沒有雙引號的  db.集合名.insert({content:"哈哈,保存了數據"})

• 查詢全部數據, 默認按照_id從小到大排序

db.集合名.find()

• 返回滿足條件的全部數據

入參部分的查詢條件 bson同樣是json格式  db.集合名.find({id:"123"})

• 返回滿足條件的第一條數據

入參部分的查詢條件 bson同樣是json格式  db.集合名.findOne({id:"123"})

• 根據限制的數量, 返回滿足條件的數據

入參部分的查詢條件 bson同樣是json格式  db.集合名.find({id:"123"}).limit(1)

• 更新文檔

db.集合名.update(條件,修改後的數據)    // 下面的這條修改語句存在問題,只會保留name欄位  db.集合.update({_id:"1"},{name:"新名字"})    // 保留其他欄位的寫法 db.集合名.update({條件},{$set:{新的值} })  db.集合.update({_id:"1"},{$set:{name:"新名字"}})  

• 刪除文檔

db.集合.remove(條件)    // 刪除全部  db.集合.remove({}) 

• 統計數量

db.spit.count()    db.spit.count({條件})

• 使用正則實現.模糊查詢
  /將被模糊查詢的字元串/

db.集合名.find({content:/將被模糊查詢的字元串/})    //匹配以XXX開頭的文檔  db.集合名.find({content:/^XXX/})

• 大於,小於,不等於

db.集合名.find({"參考的欄位":{$gt:value}}) // 查找參考的欄位大於value值的文檔  $lt 小於  $lte 小於等於  $gte 大於等於  $ne 不等於 

• 包含和不包含

db.集合名.find({_id:{$in:["1","2","3"]}})  db.集合名.find({_id:{$nin:["1","2","3"]}})

• 條件連接

$and:[{},{},{}]  // 查詢id 大於1000,小於2000的文檔  db.集合名.find({$and:[{_id:{$gte:1000}},{_id:{$lte:2000}}]})    $or:[{},{},{}]

• 實現列值的增長

db.集合名.update({_id:"12"},{$inc:{number:NumberInt(1)}})

• 按照某個欄位排序

db.集合名.find({}).sort(欄位:1) // 1是升序    db.集合名.find({}).sort(欄位:-1) // -1是降序    // 先按照欄位1升序, 如果欄位1的值相同,按照欄位2降序排序  db.集合名.find({}).sort(欄位:1| 欄位2:-1)    

Java操作MongoDB

添加坐標

 <dependency>        <groupId>org.mongodb</groupId>        <artifactId>mongodb-driver</artifactId>        <version>3.6.3</version>    </dependency>  

配置文件

server:    port: 9002    data:      mongodb:        host: 192.168.88.130        database: 資料庫名字

使用mongo官方提供的java的驅動包,相當於jdbc

// 連接mongo伺服器  MongoClient client = new MongoClient("192.168.88.130");  // 得到想操作的資料庫  MongoDatabase db = client.getDatabase("資料庫名");  // 得到想要操作的集合  MongoCollection<Document> collection = db.getCollection("集合名");    // todo CRUD with collection    // 釋放資源  client.close();  

查詢全部

FindIterable<Document> documents = collection.find();    for (Document document : documents) {          System.out.println(document);      }

根據限制條件查詢

• 查詢出content欄位為"我很開心"全部文檔

// 條件查詢限制為  userid==123  BasicDBObject bson = new BasicDBObject("content", "我很開心");    FindIterable<Document> documents = collection.find(bson);

• 封裝條件,查詢訪問量大於1000的,可以還可以更換成gt gte等等

//    find(visit:{$gt:1000})  BasicDBObject bson = new BasicDBObject("visits", new BasicDBObject("$gt",1000));    FindIterable<Document> documents = collection.find(bson);

我發現如果是使用_id當作限制條件,此時如果_id的類型是原生的objectid類型的話,是查詢不處任何結果的,但是如果換成我們自定義的_id, 就可以當成限制條件匹配出相應的文檔

添加一個文檔

_id不能重複

HashMap<String, Object> map = new HashMap<>();  map.put("_id","10");  map.put("content","啊");  map.put("article","嘻嘻嘻嘻嘻");  Document document = new Document(map);  collection.insertOne(document);

添加嵌套文檔

Document document = new Document();    // 插入普通欄位  document.put("_id","123");  document.put("key1","value1");  document.put("key2","value2");  document.put("key3","value3");    Document doc = new Document();  doc.put("key4","value4");  // 嵌套文檔  document.put("docDetail",doc);    collection.insertOne(document)

更新

• 更新數值類型的數,在原來的基礎上增加

// 使用$inc ,在將入參2位置對應的文檔的指定欄位增加指定的數  BasicDBObject newDoc = new  BasicDBObject().append("$inc",new BasicDBObject().append("thumbup",1));    // 第一個參數是限制條件找到要被更新的bson, 第二個參數是將被改變的值  collection.updateOne(new  BasicDBObject().append("content","我是新的content"),newDoc);  

• 更新普通字元串類型

// 使用$set ,在將入參2位置對應的文檔的指定欄位更新為指定的值  BasicDBObject newDoc = new  BasicDBObject().append("$set",new BasicDBObject().append("nickname","朱昌武"));    // 第一個參數是限制條件找到要被更新的bson, 第二個參數是將被改變的值  collection.updateOne(new  BasicDBObject().append("_id","1"),newDoc);

替換文檔

同樣,如果入參1位置的過濾條件,使用的_id是原生ObjectId類型的話,匹配不出任何結果

BasicDBObject bson = new BasicDBObject("_id", "5d4fd7cb92cb2acaf109a46e");    //   Document filter = new Document();  //   filter.append("_id", "5d4fd7cb92cb2acaf109a46e");    Document replacement = new Document();  replacement.append("key1","我替換了一第一個文檔");    collection.replaceOne(bson,replacement);

刪除文檔

// 刪除一個  Document filter = new Document();  filter.append("hello", "world");    collection.deleteOne(filter);    // 刪除多個  Document document = new Document();    // 第一個參數是限制條件找到要被更新的bson, 第二個參數是將被改變的值   collection.deleteMany(document);

SpringDataMongoDB

編寫Repository層,進行簡單的CRUD

spring-data-mongodb的用法和jpa是一樣的,Spring很強大,一統天下

• 引入啟動器

• 配置文件,和上面的一樣

• 編寫DAO層

public interface SpitRepository   extends MongoRepository<Spit,String> {}

它內置了簡單的增刪改查的方法,可以分頁,也可以使用Spring對jpql的高級封裝比如findByXXX等

MongoTemplate的使用:

更新

如果被更新的文檔沒有該條記錄,就會創建出這個field,然後賦值

Query query = new Query();  Criteria criteria = new Criteria();  query.addCriteria(Criteria.where("_id").is("5d50cee71e5a931d2cd72e43"));    Update update = new Update();  update.set("key1","新的值");    // 只會更新滿足條件的第一條  入參位置1  query作用: 根據條件找出對應的doc  入參位置2  update作用:  進行更新的操作  mongoTemplate.updateFirst(query,update,"集合");

使用下面的函數也能達到相同更新的效果

  mongoTemplate.upsert(query,update,"集合");

批量更新:

批量更新滿足條件的doc,只要前面的條件滿足, 就會被更新, 不存在的欄位會添加上去, 存在的被更新掉

Query query = new Query();  query.addCriteria(Criteria.where("nickname").is("恩恩"));    Update update = new Update();  update.set("share","2");  // 同樣, key8不存在,就新添加進去    // 只會更新滿足條件的第一條  mongoTemplate.updateMulti(query,update,"spit");

僅僅更新滿足條件的第一個

Query query = new Query();  query.addCriteria(Criteria.where("nickname").is("恩恩"));    Update update = new Update();  update.set("share","2");  // 同樣, key8不存在,就新添加進去    // 只會更新滿足條件的第一條  mongoTemplate.updateFirst(query,update,"spit");

給指定的欄位增加指定的數量, 注意點是, 如果嘗試對字元串增加指定的數,不報錯,但是也不會改變原來的值

Query query = new Query();  query.addCriteria(Criteria.where("_id").is("1"));    Update update = new Update();  update.inc("thumbup",3); // 給指定的欄位增加指定的數量    // 只會更新滿足條件的第一條  mongoTemplate.updateFirst(query,update,"spit");  

重命名文檔的某個key

Query query = new Query();  Criteria criteria = new Criteria();  query.addCriteria(Criteria.where("_id").is("1"));    Update update = new Update();  update.rename("_class","新的class"); // 給指定的欄位增加指定的數量    // 只會更新滿足條件的第一條  mongoTemplate.updateFirst(query,update,"spit");

移除key

update.unset("新的class");

在現有的文檔基礎上,嵌入文檔

Query query = new Query();  Criteria criteria = new Criteria();  query.addCriteria(Criteria.where("_id").is("1"));    Update update = new Update();    Spit spit = new Spit();  spit.set_id("666");  spit.setContent("我的被嵌套進來的文檔");    update.addToSet("childSpit",spit);  // 只會更新滿足條件的第一條  mongoTemplate.updateFirst(query,update,"spit");

修改被嵌入的文檔

Query query = new Query();  Criteria criteria = new Criteria();  // 通過  添加條件定位出 指定的嵌套文檔  query.addCriteria(Criteria.where("_id").is("1").and("childSpit._id").is("666"));    Update update = new Update();    // todo 通過這樣條件  欄位名.$.field  update.set("childSpit.$.content","嵌套文檔的conntent被改變了");    // 只會更新滿足條件的第一條  mongoTemplate.updateFirst(query,update,"spit");

刪除嵌套文檔

Query query = new Query();  Criteria criteria = new Criteria();  // 通過  添加條件定位出 指定的嵌套文檔  query.addCriteria(Criteria.where("_id").is("1").and("childSpit._id").is("666"));    Update update = new Update();    update.unset("childSpit.$");    // 只會更新滿足條件的第一條  mongoTemplate.updateFirst(query,update,"spit");

使用:MongoTemplate 提高效率的場景

在點贊的業務中,給某個帖子點贊的邏輯如下:

• 前端提交帖子的id, 後端根據id查詢一次資料庫,把帖子查出來
• 給帖子的贊數+1
• 把帖子更新進資料庫

前前後後使用了兩次查詢,下面使用MongoTemplate,可以實現和資料庫一次交互,完成更新

Query query = new Query();  query.addCriteria(Criteria.where("_id").is("前端提交的id"));  Update update = new Update();  update.inc("贊的欄位",1); // 自增1  mongoTemplate.updateFirst(query,update,"集合名字");

參考部落格:illustriousness
參考部落格: tbyang