Java连接MongoDB

一、MongoDB简介

MongoDB是一个基于分布式文件存储的开源数据库。它的数据存储方式是以BSON（一种二进制的JSON格式）为中心的，可以存储对象和数组数据类型。MongoDB是一个面向文档的数据库，而非关系型数据库，在使用上有着比较大的不同。

二、Java连接MongoDB

Java可以通过maven依赖的方式引用MongoDB官方提供的Java Driver。

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

然后在Java代码中使用MongoClient连接MongoDB服务器。以下为示例代码：

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoDatabase;

public class MongoConnectivity {
    public static void main( String args[] ) {
        try {
            // 连接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);
            
            // 获取数据库
            MongoDatabase database = client.getDatabase("mydb");
            
            // 打印数据库名称
            System.out.println("MongoDB database name: " + database.getName());
            
            // 关闭连接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }
}

上述代码连接了本地MongoDB服务器，并指定了要使用的数据库。然后获取该数据库对象，并打印出数据库的名称。最后，关闭MongoClient连接。

三、MongoDB操作

1. 插入数据

使用MongoDB的Java Driver通过以下代码来向指定的集合中插入一条数据：

import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

public class InsertData {
    public static void main( String args[] ) {
        try {
            // 连接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);

            // 获取数据库
            MongoDatabase database = client.getDatabase("mydb");

            // 获取集合
            MongoCollection collection = database.getCollection("mycollection");

            // 插入数据
            Document doc = new Document("name", "MongoDB")
                    .append("type", "database")
                    .append("count", 1);
            collection.insertOne(doc);

            // 关闭连接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }    
}

2. 查询数据

查询MongoDB中的数据可以使用以下代码段：

import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

public class QueryData {
    public static void main( String args[] ) {
        try {
            // 连接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);
            
            // 获取数据库
            MongoDatabase database = client.getDatabase("mydb");
            
            // 获取集合
            MongoCollection collection = database.getCollection("mycollection");
          
            // 查询数据
            FindIterable cursor = collection.find(Filters.eq("name", "MongoDB"));
            for (Document doc : cursor) {
               System.out.println(doc.toJson());
            }
            
            // 关闭连接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }    
}

3. 更新数据

使用以下代码段可以更新符合条件的数据：

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.Updates;

public class UpdateData {
    public static void main( String args[] ) {
        try {
            // 连接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);

            // 获取数据库
            MongoDatabase database = client.getDatabase("mydb");

            // 获取集合
            MongoCollection collection = database.getCollection("mycollection");

            // 更新数据
            collection.updateMany(Filters.eq("name", "MongoDB"), Updates.set("count", 2));

            // 关闭连接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }    
}

4. 删除数据

使用以下代码段可以删除符合条件的数据：

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

public class DeleteData {
    public static void main( String args[] ) {
        try {
            // 连接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);

            // 获取数据库
            MongoDatabase database = client.getDatabase("mydb");

            // 获取集合
            MongoCollection collection = database.getCollection("mycollection");

            // 删除数据
            collection.deleteMany(Filters.eq("name", "MongoDB"));

            // 关闭连接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }    
}

四、小结

本文介绍了Java连接MongoDB的基本方法，以及如何进行增删改查操作。MongoDB是一个非常灵活的数据库，可以根据应用情况选择不同的存储方式和查询方式，能够更好地满足应用的需求。