先引入mongo-java-dirver驱动

1
2
3
4
5
6
<!-- mongo-java-dirver -->
<dependency>
    
<groupId>org.mongodb</groupId>
    
<artifactId>mongo-java-driver</artifactId>
    
<version>
3.4
.
2
</version>
</dependency>

代码操作演示：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
package 
com.simple.database.test;
 
import 
java.util.ArrayList;
import 
java.util.List;
 
import 
org.bson.Document;
import 
org.bson.conversions.Bson;
 
import 
com.mongodb.MongoClient;
import 
com.mongodb.client.FindIterable;
import 
com.mongodb.client.MongoCollection;
import 
com.mongodb.client.MongoCursor;
import 
com.mongodb.client.MongoDatabase;
import 
com.mongodb.client.model.Filters;
 
/**
 
* java操作MongoDB
 
* @author root
 
*/
public 
class 
HelloMongoDB {
 
    
public 
static 
void 
main(String[] args) {
        
try 
{
//          1、连接到MongoDB服务
            
MongoClient mc = 
new 
MongoClient(
"127.0.0.1"
, 
27017
);
 
//          2、连接到指定数据库
            
MongoDatabase db = mc.getDatabase(
"demodb"
);
             
//          3、创建集合
//          db.createCollection("simplelife");
             
//          4、获取集合
            
MongoCollection<Document> collection = db.getCollection(
"users"
);
 
//          5、插入文档数据
//          insertCollectionData(collection);
             
//          6、查询文档数据
            
findCollectionData(collection);
             
//          7、更新文档数据
//          将文档中likes=100的文档修改为likes=200   
            
updateCollectionData(collection);
             
//          8、删除第一个文档数据
            
collection.deleteMany(Filters.eq(
"likes"
,
200
));
            
collection.deleteOne(Filters.eq(
"likes"
,
100
));
        
} 
catch 
(Exception e) {
            
e.printStackTrace();
            
System.out.println(e.getClass().getName() + 
"……" 
+ e.getMessage());
        
}
 
    
}
 
    
private 
static 
void 
updateCollectionData(
            
MongoCollection<Document> collection) {
        
Bson filter = Filters.eq(
"likes"
, 
100
);
        
Document update = 
new 
Document(
"$set"
, 
new 
Document(
"likes"
, 
200
));
        
collection.updateMany(filter, update);
    
}
 
    
private 
static 
void 
findCollectionData(MongoCollection<Document> collection) {
        
FindIterable<Document> findIterable = collection.find();
        
MongoCursor<Document> mongoCursor = findIterable.iterator();
        
while
(mongoCursor.hasNext()){
            
System.out.println(mongoCursor.next());
        
}
    
}
 
    
/**
     
* 插入文档 1、创建文档org.bson.Document参数为key-value的格式
     
* 2、创建文档集合List<Document>
     
* 3、将文档集合插入数据库集合：mongoCollection.insertMany(List<Document>)
     
* 插入单个文档可以用 ：mongoCollection.insertOne(Document)
     
*/
    
private 
static 
void 
insertCollectionData(
            
MongoCollection<Document> collection) {
        
Document document = 
new 
Document(
"title"
, 
"MongoDB"
);
        
document.append(
"description"
, 
"database"
).append(
"likes"
, 
100
)
                
.append(
"by"
, 
"Fly"
);
        
List<Document> documents = 
new 
ArrayList<>();
        
documents.add(document);
        
collection.insertMany(documents);
        
System.out.println(
"文档插入成功！"
);
    
}
}