MongoDB快速入门笔记(八)之MongoDB的java驱动操作代码讲解

admin MariaDB

2023-12-04 0 1,018

MongoDB的Java驱动是线程安全的，对于一般的应用，只要一个Mongo实例即可，Mongo有个内置的连接池（池大小默认为10个）。

下面代码给大家介绍MongoDB的java驱动操作，具体代码如下所示：

import java.util.ArrayList;
import java.util.List;
import java.util.regex.Pattern;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
public class MongoZyh {
public static void main(String[] args) {
try {
// 连接到MongoDB服务,ServerAddress()两个参数分别为服务器地址和端口
ServerAddress serverAddress = new ServerAddress(\”localhost\”, 27017);
List<ServerAddress> addrs = new ArrayList<ServerAddress>();
addrs.add(serverAddress);
// 三个参数分别为用户名数据库名称密码
MongoCredential credential = MongoCredential
.createScramSha1Credential(\”zyh\”, \”admin\”,
\”zyh\”.toCharArray());
List<MongoCredential> credentials = new ArrayList<MongoCredential>();
credentials.add(credential);
// 通过连接认证获取MongoDB连接
MongoClient mongoClient = new MongoClient(addrs, credentials);
// 连接到数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase(\”zyhdb\”);
// 新建集合，执行后会在数据库里新建一个空的集合
// mongoDatabase.createCollection(\”student\”);
// System.out.println(\”新建集合成功\”);
// 获取集合，并往集合中插入数据
MongoCollection<Document> mongoCollection = mongoDatabase
.getCollection(\”student\”);
// 插入一条数据
// Document document = new Document();
// document.append(\”name\”, \”zhangsan\”);
// document.append(\”age\”, 28);
// mongoCollection.insertOne(document);
// System.out.println(\”插入一条数据成功\”);
// 插入多条数据
// List<Document> documentList = new ArrayList<Document>();
// Document document1 = new Document();
// document1.append(\”name\”, \”lisi\”);
// document1.append(\”age\”, 28);
// document1.append(\”sex\”, \”男\”);
// Document document2 = new Document();
// document2.append(\”name\”, \”wangwu\”);
// document2.append(\”age\”, 31);
// document2.append(\”sex\”, \”男\”);
// documentList.add(document1);
// documentList.add(document2);
// mongoCollection.insertMany(documentList);
// System.out.println(\”插入多条数据成功\”);
// 查询数据
// 查询集合中所有的数据
// FindIterable<Document> findIterable = mongoCollection.find();
// MongoCursor<Document> mongoCursor = findIterable.iterator();
// while (mongoCursor.hasNext()) {
// System.out.println(mongoCursor.next());
// }
// 根据条件查询
// Document query = new Document();
// query.put(\”age\”, new Document(\”$lt\”, 30));
// query.put(\”sex\”, \”男\”);
// query.put(\”name\”, query);
// 正则表达式查询
// Pattern pattern = Pattern.compile(\”^zhang\”);
// query.put(\”name\”, pattern);
// 排序
// Document sort = new Document();
// sort.put(\”name\”, -1); // 1是正序，-1是倒序
// FindIterable<Document> findIterable = mongoCollection.find(query)
// .sort(sort);
// MongoCursor<Document> mongoCursor = findIterable.iterator();
// while (mongoCursor.hasNext()) {
// Document doc = mongoCursor.next();
// System.out.print(\”name:\” + doc.get(\”name\”) + \”…\”);
// System.out.print(\”age:\” + doc.get(\”age\”) + \”…\”);
// System.out.println(\”sex:\” + doc.get(\”sex\”) + \”…\”);
// }
// mongoCollection.findOneAndUpdate(查询条件, 修改内容); // 查询出第一条数据并修改
// mongoCollection.findOneAndDelete(查询条件); // 查询出第一条数据并删除
// mongoCollection.findOneAndReplace(查询条件, 替换内容); // 查询出第一条数据并替换
// 修改数据
// Document query = new Document();
// query.put(\”age\”, 28);
// Document update = new Document();
// Document d = new Document();
// d.put(\”birthday\”, new Date());
// d.put(\”name\”, \”zhangsan\”);
// update.put(\”$set\”, d);
// mongoCollection.updateOne(query, update); // 修改查询到的第一条数据
// mongoCollection.updateMany(查询条件, 修改内容);// 修改查询到的所有数据
// 删除数据
// Document query = new Document();
// query.put(\”age\”, 28);
// mongoCollection.deleteOne(query); // 删除查询到的第一条数据
// mongoCollection.deleteMany(查询条件); // 删除查询到的所有数据
// mongoCollection.drop(); // 删除集合
} catch (Exception e) {
e.printStackTrace();
}
}
}