添加:mongo-java-driver-3.2.2.jar 驱动地址:http://central.maven.org/maven2/org/mongodb/mongo-java-driver/
主要代码:
//我的mongoDb 没有密码
// 连接到 mongodb 服务
MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
// 连接到数据库//如果选择的数据库是不存在的则自动创建数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("huang");
System.out.println("Connect to database successfully");
//选择集合 //如果集合不存在则创建这个集合
MongoCollection<Document> collection = mongoDatabase.getCollection("linqing");
System.out.println("选择集合成功");
// mongoDatabase.createCollection("testhuang");
// System.out.println("集合创建成功");
//插入文档
/**
* 1. 创建文档 org.bson.Document 参数为key-value的格式
* 2. 创建文档集合List<Document>
* 3. 将文档集合插入数据库集合中 mongoCollection.insertMany(List<Document>) 插入单个文档可以用 mongoCollection.insertOne(Document)
* */
Document document = new Document("name", "huanglinqing").
append("sex", "man").
append("age", 22).
append("like", "handsome");
List<Document> documents = new ArrayList<Document>();
documents.add(document);
collection.insertMany(documents);
System.out.println("文档插入成功");
//检索所有文档
/**
* 1. 获取迭代器FindIterable<Document>
* 2. 获取游标MongoCursor<Document>
* 3. 通过游标遍历检索出的文档集合
* */
FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
while(mongoCursor.hasNext()){
System.out.println(mongoCursor.next());
}
//更新文档 将文档中likes=100的文档修改为likes=200
collection.updateMany(Filters.eq("age", 22), new Document("$set",new Document("age",19)));
//检索查看结果
FindIterable<Document> findIterable1 = collection.find();
MongoCursor<Document> mongoCursor1 = findIterable1.iterator();
while(mongoCursor1.hasNext()){
System.out.println(mongoCursor1.next());
}
//删除
//删除符合条件的第一个文档
// collection.deleteOne(Filters.eq("likes", 200));
// //删除所有符合条件的文档
// collection.deleteMany (Filters.eq("likes", 200));
源码位置:https://github.com/huanglinqing123/Java_Connect_MongoDb.git
欢迎关注技术公众号,微信号搜索ColorfulCode 代码男人
分享技术文章,投稿分享,不限技术种类,不限技术深度,让更多人因为分享而受益。