先引入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("文档插入成功！");
    }
}