本文共 2819 字,大约阅读时间需要 9 分钟。
首先需要下载并配置MongoDB的Java驱动。可以通过以下两种方式获取:
通过Maven添加依赖
在Maven项目中添加以下依赖项:org.mongodb mongodb-driver 3.5.0
如果手动下载,需要获取以下三个JAR包:
org.mongodb:bson:jar:3.5.0
org.mongodb:mongodb-driver-core:jar:3.5.0
org.mongodb:mongodb-driver:jar:3.5.0
启动MongoDB
在开始操作之前,请确保MongoDB服务已启动。完成前期准备后,使用MongoClient连接数据库并获取集合:
MongoClient client = new MongoClient("192.168.248.136", 27017);MongoDatabase sang = client.getDatabase("sang");MongoCollection c = sang.getCollection("c1");
插入单条数据:
Document d1 = new Document();d1.append("name", "三国演义").append("author", "罗贯中");c.insertOne(d1);
插入多条数据:
Listcollections = new ArrayList<>();Document d1 = new Document();d1.append("name", "三国演义").append("author", "罗贯中");collections.add(d1);Document d2 = new Document();d2.append("name", "红楼梦").append("author", "曹雪芹");collections.add(d2);c.insertMany(collections);
修改单条数据:
c.updateOne(Filters.eq("author", "罗贯中"), new Document("$set", new Document("name", "三国演义123")));
修改多条数据:
c.updateMany(Filters.eq("author", "罗贯中"), new Document("$set", new Document("name", "三国演义456")));
删除单条数据:
c.deleteOne(Filters.eq("author", "罗贯中"));
删除多条数据:
c.deleteMany(Filters.eq("author", "罗贯中"));
FindIterabledocuments = c.find();MongoCursor iterator = documents.iterator();while (iterator.hasNext()) { System.out.println(iterator.next());}
FindIterabledocuments = c.find(Filters.eq("author", "罗贯中"));MongoCursor iterator = documents.iterator();while (iterator.hasNext()) { System.out.println(iterator.next());}
如果需要验证数据库权限,使用以下方式:
ServerAddress serverAddress = new ServerAddress("192.168.248.128", 27017);ListcredentialsList = new ArrayList<>();MongoCredential mc = MongoCredential.createScramSha1Credential("readuser", "sang", "123".toCharArray());credentialsList.add(mc);MongoClient client = new MongoClient(serverAddress, credentialsList);MongoDatabase sang = client.getDatabase("sang");MongoCollection c = sang.getCollection("c1");
可通过MongoClientOptions设置连接超时等参数:
ServerAddress serverAddress = new ServerAddress("192.168.248.128", 27017);ListcredentialsList = new ArrayList<>();MongoCredential mc = MongoCredential.createScramSha1Credential("rwuser", "sang", "123".toCharArray());credentialsList.add(mc);MongoClientOptions options = MongoClientOptions.builder() .connectTimeout(1000 * 10) // 设置连接超时为10秒 .maxWaitTime(1000 * 10) // 设置最大等待时间为10秒 .build();MongoClient client = new MongoClient(serverAddress, credentialsList, options);MongoDatabase sang = client.getDatabase("sang");MongoCollection c = sang.getCollection("c1");
通过以上步骤,您可以高效地进行MongoDB数据的增删改查操作,并通过合理配置实现对数据库的安全访问和连接管理。
转载地址:http://odar.baihongyu.com/