更新时间: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接口参考请参见官方文档。
父主题: 基于Java连接实例