MongoDB简单操作（java版）

 1 <dependency>
 2     <groupId>org.mongodb</groupId>
 3     <artifactId>mongo-java-driver</artifactId>
 4     <version>3.2.2</version>
 5 </dependency>
 6 <dependency>
 7     <groupId>junit</groupId>
 8     <artifactId>junit</artifactId>
 9     <version>4.12</version>
10 </dependency>

  1 package com.skyer.test;
  2 
  3 import java.util.ArrayList;
  4 import java.util.Arrays;
  5 import java.util.List;
  6 
  7 import org.bson.Document;
  8 import org.junit.After;
  9 import org.junit.Before;
 10 import org.junit.Test;
 11 
 12 import com.mongodb.BasicDBObject;
 13 import com.mongodb.MongoClient;
 14 import com.mongodb.MongoClientURI;
 15 import com.mongodb.QueryOperators;
 16 import com.mongodb.client.ListIndexesIterable;
 17 import com.mongodb.client.MongoCollection;
 18 import com.mongodb.client.MongoCursor;
 19 import com.mongodb.client.MongoDatabase;
 20 import com.mongodb.client.result.DeleteResult;
 21 import com.mongodb.client.result.UpdateResult;
 22 
 23 public class TestMongo {
 24 
 25     // 声明相关变量
 26     MongoClientURI connectionString = null;
 27     MongoClient mongoClient = null;
 28     MongoDatabase database = null;
 29     MongoCollection<Document> collection = null;
 30 
 31     /**
 32      * 获取相关对象
 33      */
 34     @Before
 35     public void getConnection() {
 36         connectionString = new MongoClientURI("mongodb://192.168.88.128:27017"); // 服务器连接地址
 37         mongoClient = new MongoClient(connectionString); // 获取客户端对象
 38         database = mongoClient.getDatabase("skyer"); // 获取数据库
 39         collection = database.getCollection("test"); // 获取连接
 40     }
 41 
 42     /**
 43      * 添加一个
 44      */
 45     @Test
 46     public void insert() {
 47         Document doc = new Document("name", "skyer")
 48                             .append("type", "database")
 49                             .append("count", 1)
 50                             .append("versions", Arrays.asList("v2.7", "v4.2", "v7.2"))
 51                             .append("info", new Document("x", 27).append("y", 42));
 52         collection.insertOne(doc);
 53     }
 54 
 55     /**
 56      * 批量添加
 57      */
 58     @Test
 59     public void insertMany() {
 60         List<Document> docs = new ArrayList<Document>();
 61         for (int i = 0; i < 100; i++) {
 62             docs.add(new Document("i", i));
 63         }
 64         collection.insertMany(docs);
 65     }
 66 
 67     /**
 68      * 查询首个
 69      */
 70     @Test
 71     public void queryFirst() {
 72         Document doc = collection.find().first();
 73         System.out.println(doc.toJson());
 74     }
 75 
 76     /**
 77      * 查询全部
 78      */
 79     @Test
 80     public void findAll() {
 81         for (Document doc : collection.find()) {
 82             System.out.println(doc.toJson());
 83         }
 84     }
 85 
 86     /**
 87      * 查询全部
 88      */
 89     @Test
 90     public void findAll2() {
 91         MongoCursor<Document> cursor = collection.find().iterator();
 92         while (cursor.hasNext()) {
 93             System.out.println(cursor.next().toJson());
 94         }
 95     }
 96     
 97     /**
 98      * 分页查询
 99      */
100     @Test
101     public void findByPage() {
102         MongoCursor<Document> cursor = collection.find().skip(0).limit(5).iterator(); // 查询前五个记录
103         while (cursor.hasNext()) {
104             System.out.println(cursor.next().toJson());
105         }
106     }
107     
108     /**
109      * 查询一个
110      */
111     @Test
112     public void findOne() {
113         Document doc = collection.find(new Document("i", 27)).first(); // 查询i值为27的记录
114         System.out.println(doc.toJson());
115     }
116 
117     /**
118      * 条件查询
119      */
120     @Test
121     public void findByCondition1() {
122         BasicDBObject condition = new BasicDBObject("i", new BasicDBObject(QueryOperators.GT, 95)); // 查询i大于95的记录
123         MongoCursor<Document> cursor = collection.find(condition).iterator();
124         while (cursor.hasNext()) {
125             System.out.println(cursor.next().toJson());
126         }
127     }
128     
129     /**
130      * 条件查询
131      */
132     @Test
133     public void findByCondition2() { 
134         BasicDBObject condition = new BasicDBObject(QueryOperators.AND, 
135                                                      new BasicDBObject[] {
136                                                          new BasicDBObject().append("i", new BasicDBObject(QueryOperators.GT, 95)), 
137                                                          new BasicDBObject().append("i", new BasicDBObject(QueryOperators.LTE, 97))
138                                                      }); // 查询95<i<=97的记录
139         MongoCursor<Document> cursor = collection.find(condition).iterator();
140         while (cursor.hasNext()) {
141             System.out.println(cursor.next().toJson());
142         }
143     }
144     
145     /**
146      * 条件查询：in
147      */
148     @Test
149     public void testIn() {
150         BasicDBObject condition = new BasicDBObject("i", new BasicDBObject(QueryOperators.IN, new int[] {27, 42}));
151         MongoCursor<Document> cursor = collection.find(condition).iterator();
152         while (cursor.hasNext()) {
153             System.out.println(cursor.next().toJson());
154         }
155     }
156     
157     /**
158      * 条件查询：not in
159      */
160     @Test
161     public void testNotIn() {
162         BasicDBObject condition = new BasicDBObject("i", new BasicDBObject(QueryOperators.NIN, new int[] {34, 47}));
163         MongoCursor<Document> cursor = collection.find(condition).iterator();
164         while (cursor.hasNext()) {
165             System.out.println(cursor.next().toJson());
166         }
167     }
168     
169     /**
170      * 创建普通索引
171      */
172     @Test
173     public void createIndex() {
174         String result = collection.createIndex(new BasicDBObject("name", 1));
175         System.out.println(result);
176     }
177     
178     /**
179      * 创建文本索引
180      */
181     @Test
182     public void createTextIndex() {
183         String result = collection.createIndex(new Document("name", "text"));
184         System.out.println(result);
185     }
186 
187     /**
188      * 获取所有索引
189      */
190     @Test
191     public void getAllIndex() {
192         ListIndexesIterable<Document> list = collection.listIndexes();
193         for (Document doc : list) {
194             System.out.println(doc.toJson());
195         }
196     }
197     
198     /**
199      * 删除
200      */
201     @Test
202     public void testDelete() {
203         DeleteResult result = collection.deleteOne(new BasicDBObject("i", 2));
204         System.out.println(result.getDeletedCount());
205     }
206 
207     /**
208      * 批量删除
209      */
210     @Test
211     public void testDeleteMany() {
212         DeleteResult result = collection.deleteMany(new BasicDBObject("i", new BasicDBObject(QueryOperators.IN, new int[] {
213                 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10
214         })));
215         System.out.println(result.getDeletedCount());
216     }
217     
218     /**
219      * 更新
220      */
221     @Test
222     public void testUpdateOne() {
223         UpdateResult result = collection.updateOne(new BasicDBObject("i", 10), new Document("$set", new Document("i", 110)));
224         System.out.println(result.getMatchedCount());
225     }
226 
227     /**
228      * 释放资源
229      */
230     @After
231     public void releaseConnection() {
232         mongoClient.close();
233     }
234 
235 }