1. 程式人生 > >MongoDB-JAVA-Driver 3.2版本常用代碼全整理(1) - 增刪改

MongoDB-JAVA-Driver 3.2版本常用代碼全整理(1) - 增刪改

tails posit 第一個 2.x 做了 alt private 依賴 while

轉載,原文連接: http://blog.csdn.net/autfish/article/details/51356537

MongoDB的3.x版本Java驅動相對2.x做了全新的設計,類庫和使用方法上有很大區別。例如用Document替換BasicDBObject、通過Builders類構建Bson替代直接輸入$命令等,本文整理了基於3.2版本的常用增刪改查操作的使用方法。為了避免冗長的篇幅,分為增刪改、查詢、聚合、地理索引等幾部分。

創建一個maven項目,添加依賴

[java] view plain copy print?技術分享技術分享
  1. <dependencies>
  2. <dependency>
  3. <groupId>org.mongodb</groupId>
  4. <artifactId>mongodb-driver</artifactId>
  5. <version>3.2.2</version>
  6. </dependency>
  7. </dependencies>

非maven項目可自行下載jar包

http://central.maven.org/maven2/org/mongodb/mongo-java-driver/3.2.2/mongo-java-driver-3.2.2.jar

創建基礎代碼測試連接

[java] view plain copy print?技術分享技術分享
  1. public class CudExamples {
  2. public static void main(String[] args) throws ParseException {
  3. //根據實際環境修改ip和端口
  4. MongoClient mongoClient = new MongoClient("localhost", 27017);
  5. MongoDatabase database = mongoClient.getDatabase("lesson");
  6. MongoCollection<Document> mc = database.getCollection("language");
  7. //插入一個文檔
  8. mc.insertOne(new Document("oop", "java"));
  9. System.out.println(mc.findOneAndDelete(new Document("oop", "java")));
  10. mongoClient.close();
  11. }
  12. }

如果輸出結果為Document{{_id=573099877bee0e1710d52f4b, oop=java}}表示環境配置正確。

改造CudExamples類以方便演示每種操作對集合的影響

[java] view plain copy print?技術分享技術分享
  1. public class CudExamples {
  2. public static void main(String[] args) throws ParseException {
  3. MongoClient mongoClient = new MongoClient("localhost", 27017);
  4. MongoDatabase database = mongoClient.getDatabase("lesson");
  5. CudExamples client = new CudExamples(database);
  6. client.show();
  7. mongoClient.close();
  8. }
  9. private MongoDatabase database;
  10. public CudExamples(MongoDatabase database) {
  11. this.database = database;
  12. }
  13. public void show() {
  14. MongoCollection<Document> mc = database.getCollection("language");
  15. //每次執行前清空集合以方便重復運行
  16. mc.drop();
  17. mc.insertOne(new Document("oop", "java"));
  18. printCollection("insert java", mc);
  19. }
  20. //打印查詢的結果集
  21. public void printCollection(String doing, MongoCollection<Document> mc) {
  22. System.out.println(doing);
  23. FindIterable<Document> iterable = mc.find();
  24. iterable.forEach(new Block<Document>() {
  25. public void apply(final Document document) {
  26. System.out.println(document);
  27. }
  28. });
  29. System.out.println("------------------------------------------------------");
  30. System.out.println();
  31. }
  32. }

如上面代碼所示,把所有的操作集中在show()方法中演示,並且在執行後打印集合以觀察對集合的影響。下面來填充show()方法,註意需要靜態導入Updates.*

import static com.mongodb.client.model.Updates.*;

[java] view plain copy print?技術分享技術分享
  1. mc.insertOne(new Document("oop", "java"));
  2. printCollection("insert java", mc);
  3. //插入一個包含兩個字段的文檔
  4. Document doc = new Document("oop", "csharp").append("copyright", "microsoft");
  5. mc.insertOne(doc);
  6. printCollection("insert csharp", mc);
  7. //查找並修改一個文檔
  8. mc.findOneAndReplace(new Document("oop", "java"), new Document("oop", "java").append("copyright", "oracle"));
  9. printCollection("findAndReplace java", mc);
  10. //刪除一個文檔
  11. mc.deleteOne(new Document("oop", "java"));
  12. printCollection("delete java", mc);
  13. //刪除全部文檔
  14. mc.deleteMany(new Document());
  15. printCollection("delete all", mc);
  16. //重新插入測試文檔
  17. mc.insertOne(new Document("oop", "java").append("copyright", "oracle"));
  18. mc.insertOne(new Document("oop", "csharp").append("copyright", "microsoft"));
  19. printCollection("insert java,csharp and swift", mc);
  20. //$set 文檔中存在指定字段則修改,沒有則添加
  21. mc.updateMany(new Document(), set("rank", 100));
  22. printCollection("$set all rank 100", mc);
  23. //$unset 文檔中存在指定字段則刪除該字段
  24. mc.updateOne(new Document("oop", "csharp"), unset("rank"));
  25. printCollection("unset csharp rank", mc);
  26. //$inc 文檔中存在指定字段則相加,沒有則添加
  27. mc.updateOne(new Document("oop", "csharp"), inc("rank", 30));
  28. printCollection("$inc csharp rank 30", mc);
  29. mc.updateOne(new Document("oop", "csharp"), inc("rank", 31));
  30. printCollection("$inc csharp rank 31", mc);
  31. //$setOnInsert 在更新時指定upsert=true並實際觸發了插入操作時生效
  32. mc.updateOne(new Document("oop", "swift").append("copyright", "apple"), setOnInsert("rank", 100), new UpdateOptions().upsert(true));
  33. printCollection("$setOnInsert rank 100 for swift", mc);
  34. //$mul 相乘
  35. mc.updateOne(new Document("oop", "java"), mul("rank", 0.2));
  36. printCollection("$mul java rank: 0.2", mc);
  37. //$rename 重命名
  38. mc.updateMany(new Document(), rename("rank", "ranks"));
  39. printCollection("$rename all rank to ranks", mc);
  40. //$min 取當前值和指定值之間比較小的
  41. mc.updateMany(new Document(), min("ranks", 50));
  42. printCollection("$min all ranks: 50", mc);
  43. //$max 取當前值和指定值之間比較大的
  44. mc.updateMany(new Document(), max("ranks", 40));
  45. printCollection("$max all ranks: 40", mc);
  46. //$currentDate
  47. mc.updateMany(new Document("oop", "java"), currentDate("add"));
  48. printCollection("$currentDate java", mc);
  49. //$currentTimestamp
  50. mc.updateMany(new Document("oop", "java"), currentTimestamp("lastModified"));
  51. printCollection("$currentTimestamp java", mc);
  52. //$addToSet 添加一個元素到不重復集合
  53. mc.updateMany(new Document("oop", "java"), addToSet("keywords", "for"));
  54. mc.updateMany(new Document("oop", "java"), addToSet("keywords", "for"));
  55. printCollection("$addToSet java keywords: for", mc);
  56. //$addEachToSet 添加一組元素到不重復集合
  57. mc.updateMany(new Document("oop", "java"), addEachToSet("keywords", Arrays.asList("while", "true", "do", "new", "override")));
  58. mc.updateMany(new Document("oop", "java"), addEachToSet("keywords", Arrays.asList("while", "true", "do", "new", "override")));
  59. printCollection("$addEachToSet java keywords: while,true,do,new,override", mc);
  60. //$popFirst 刪除第一個元素
  61. mc.updateMany(new Document("oop", "java"), popFirst("keywords"));
  62. printCollection("$popFirst java keywords", mc);
  63. //$popLast 刪除最後一個元素
  64. mc.updateMany(new Document("oop", "java"), popLast("keywords"));
  65. printCollection("$popLast java keywords", mc);
  66. //$pull 刪除指定元素
  67. mc.updateMany(new Document("oop", "java"), pull("keywords", "new"));
  68. printCollection("$pull java keywords: new", mc);
  69. //$pullByFilter 根據Filters刪除
  70. mc.updateMany(new Document("oop", "java"), pullByFilter(Filters.gte("keywords", "true")));
  71. printCollection("$pullByFilter java keywords: true", mc);
  72. //$pullAll 刪除一組元素
  73. mc.updateMany(new Document("oop", "java"), pullAll("keywords", Arrays.asList("while", "true", "do", "new", "override")));
  74. printCollection("$pullAll java keywords", mc);
  75. //$push 添加一個元素到可重復集合
  76. mc.updateMany(new Document("oop", "java"), push("scores", 89));
  77. printCollection("$push java scores: 89", mc);
  78. //$pushEach 添加一組元素到可重復集合
  79. mc.updateMany(new Document("oop", "java"), pushEach("scores", Arrays.asList(89, 90, 92)));
  80. printCollection("$pushEach java scores: 89,90,92", mc);
  81. //在集合的指定位置插入一組元素
  82. mc.updateMany(new Document("oop", "java"), pushEach("scores", Arrays.asList(11, 12, 13), new PushOptions().position(0)));
  83. printCollection("$pushEach java scores: 11,12,13 at position 0", mc);
  84. //在集合的指定位置插入一組元素並倒序排列
  85. mc.updateMany(new Document("oop", "java"), pushEach("scores", Arrays.asList(40, 41), new PushOptions().sort(-1)));
  86. printCollection("$pushEach java scores: 40,41 and sort(-1)", mc);
  87. //在集合的指定位置插入一組元素, 倒序排列後保留前3個
  88. mc.updateMany(new Document("oop", "java"), pushEach("scores", Arrays.asList(60, 61), new PushOptions().sort(-1).slice(3)));
  89. printCollection("$pushEach java scores: 60,61 and sort(-1) and slice(3)", mc);
  90. //插入一組內嵌文檔
  91. Bson bson = pushEach("experts",
  92. Arrays.asList(new Document("first", "Rod").append("last", "Johnson"),
  93. new Document("first", "Doug").append("last", "Cutting")));
  94. mc.updateOne(new Document("oop", "java"), bson);
  95. printCollection("$pushEach", mc);
  96. //combine 組合Bson
  97. bson = combine(set("author", "James Gosling"), set("version", "8.0"));
  98. mc.updateOne(new Document("oop", "java"), bson);
  99. printCollection("$combine", mc);

(完)

MongoDB-JAVA-Driver 3.2版本常用代碼全整理(1) - 增刪改