更新时间:2024-01-18 GMT+08:00

完整示例

package mongodbdemo;
import org.bson.*;
import com.mongodb.*;
import com.mongodb.client.*;
public class MongodbDemo {
    public static void main(String[] args) {
       // 认证用的用户名和密码直接写到代码中有很大的安全风险,建议在配置文件或者环境变量中存放(密码应密文存放、使用时解密),确保安全;
       // 本示例以用户名和密码保存在环境变量中为例,运行本示例前请先在本地环境中设置环境变量(环境变量名称请根据自身情况进行设置)EXAMPLE_USERNAME_ENV和EXAMPLE_PASSWORD_ENV。
       String userName = System.getenv("EXAMPLE_USERNAME_ENV");
       String rwuserPassword = System.getenv("EXAMPLE_PASSWORD_ENV");
       String mongoUri = "mongodb://" + userName + ":" + rwuserPassword + "@10.66.187.127:27017/admin";
       MongoClientURI connStr = new MongoClientURI(mongoUri);
       MongoClient mongoClient = new MongoClient(connStr);
       try {
           // 使用名为 someonedb 的数据库
           MongoDatabase database = mongoClient.getDatabase("someonedb");
           // 取得集合/表 someonetable 句柄
           MongoCollection<Document> collection = database.getCollection("someonetable");
            // 准备写入数据
           Document doc = new Document();
           doc.append("key", "value");
           doc.append("username", "jack");
           doc.append("age", 31);
            // 写入数据
           collection.insertOne(doc);
           System.out.println("insert document: " + doc);
            // 读取数据
           BsonDocument filter = new BsonDocument();
           filter.append("username", new BsonString("jack"));
           MongoCursor<Document> cursor = collection.find(filter).iterator();
           while (cursor.hasNext()) {
               System.out.println("find document: " + cursor.next());
           }
       } finally {
           //关闭连接
           mongoClient.close();
       }
   }
}

更多Java接口参考请参见官方文档