注册

Java操作MongoDB数据库示例分享

下面是“Java操作MongoDB数据库示例分享”的完整攻略。

1.前置条件

在操作MongoDB数据库前,要确保以下条件已经满足:

  • 安装MongoDB数据库,并启动MongoDB服务;
  • 需要MongoDB的Java驱动包,可以在官网下载,或者使用Maven下载。

2.示例一:连接MongoDB数据库

下面是一个简单的Java程序,用于连接MongoDB数据库并输出MongoDB中的所有数据库名。

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.MongoException;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.stream.Collectors;

public class ConnectMongoDB {
    public static void main(String[] args) {
        Logger.getLogger("org.mongodb.driver").setLevel(Level.WARNING);
        try {
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient mongo = new MongoClient(uri);
            MongoDatabase db = mongo.getDatabase("testdb");
            List dbs = mongo.listDatabaseNames().into(new ArrayList<>());
            System.out.println("MongoDB databases:");
            System.out.println(dbs.stream().collect(Collectors.joining(", ")));
            mongo.close();
        } catch (MongoException e) {
            e.printStackTrace();
        }
    }
}

可以看到,上述Java程序首先使用MongoClientURI来连接MongoDB数据库(在此我们使用的是本地MongoDB)并获取MongoDatabase对象,然后通过listDatabaseNames方法获取MongoDB中的所有数据库名,并打印输出这些数据库名。

3.示例二:插入数据到MongoDB数据库

下面是一个Java程序,用于插入数据到MongoDB数据库中。

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

public class InsertMongoDB {
    public static void main(String[] args){
        try {
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient mongo = new MongoClient(uri);
            MongoDatabase db = mongo.getDatabase("testdb");
            MongoCollection collection = db.getCollection("test");
            Document doc = new Document("name", "John")
                    .append("age", 30)
                    .append("city", "New York");
            collection.insertOne(doc);
            mongo.close();
            System.out.println("Data inserted successfully");
        } catch (MongoException e) {
            e.printStackTrace();
        }
    }
}

上述Java程序使用MongoClientURI连接MongoDB数据库(在此我们使用的是本地MongoDB)并获取MongoCollection对象,然后使用Document对象创建一个文档,最后通过insertOne方法将该文档插入到MongoDB数据库中。

4. 总结

本文介绍了Java操作MongoDB数据库的两个示例,一个用于连接MongoDB数据库并输出MongoDB中的所有数据库名,另一个用于插入数据到MongoDB数据库中。通过这两个示例,读者可以深入了解MongoDB数据库在Java程序中的使用,同时也可以掌握MongoDB的基本操作。