介绍
今天就跟大家聊聊有关使用java怎么连接Mongodb并实现增删改查操作,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
1。创建maven项目
& lt; dependency> ,,,,,& lt; groupId> org.mongodb ,,,,,& lt; artifactId> mongodb-driver ,,,,,& lt; version> 3.4.1 & lt;/dependency>
<强> 2。编写代码强>
<强> 1。查询所有强>
package com.czxy.mongodb; , import com.alibaba.fastjson.JSON; import com.mongodb。*; , import 并不知道; import java.util.Set; , public class  Find { public 才能;static  void main (String [], args), { ,,,//客户端链接 ,,,MongoClient mongodbClint =, new MongoClient (“localhost",, 27017); ,,,//,获取所有的数据库 ,,,List, databaseNames =, mongodbClint.getDatabaseNames (); ,,,for (String databaseName :数据库名),{ ,,,,,System.out.println(“数据库名称,“+数据库名); ,,,} ,,,//,连接指定的数据库 ,,,DB DB =, mongodbClint.getDB (“text"); , ,,,//获取当前数据库下的所有集合名称 ,,,Set , collectionNames =, db.getCollectionNames (); ,,,for (String dbname : collectionNames), { ,,,,,System.out.println(“集合名称,“+ dbname); ,,,} ,,,//,连接指定的集合 ,,,DBCollection collection =, db.getCollection (“stus"); ,,,,//,数据集合信息 ,,,DBCursor dbObjects =, collection.find (); , ,,,while (dbObjects.hasNext ()) { ,,,,,//读取数据 ,,,,,DBObject next =, dbObjects.next (); ,,,,,//,json 格式转换 ,,,,,Stus parse =, JSON.parseObject (next.toString (),, Stus.class); ,,,,,//,数据输出 ,,,,,System.out.println(解析); ,,,} ,,} }
<强> 2。添加数据强>
package com.czxy.mongodb; , import com.mongodb.MongoClient; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; import org.bson.Document; , import java.util.HashMap; import java.util.Map; , public class  Insert { public 才能;static  void main (String [], args), { ,,,//,获取连接 ,,,MongoClient mongodbClint =, new MongoClient (“localhost",, 27017); ,,,//,连接数据库 ,,,MongoDatabase database =, mongodbClint.getDatabase (“text"); ,,,//,获取对象 ,,,MongoCollection, stus =, database.getCollection (“stus"); ,,,Map<字符串,Object>,地图=new HashMap (); ,,,map.put (“name",,“诸葛亮“); ,,,map.put (“sex",,“男”); ,,,map.put (“age",, 35.0); ,,,map.put (“address",,“南阳“); ,,,Document Document =, new 文档(地图); ,,,System.out.println(文档); ,,,stus.insertOne(文档); ,,} }
<强> 3。删除强>
package com.czxy.mongodb; , import com.mongodb.BasicDBObject; import com.mongodb.MongoClient; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; import org.bson.Document; ,/* * ,*删除 ,*/public class  Delete { public 才能;static  void main (String [], args), { ,,,//获取连接 ,,,MongoClient 位置=,new MongoClient (“localhost",, 27017); ,,,//,连接数据库 ,,,MongoDatabase database =, location.getDatabase (“text"); ,,,//获取集合封账对象 ,,,MongoCollection, collection =, database.getCollection (“stus"); ,,,//,删除的条件 null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null null 使用java怎么连接Mongodb并实现增删改查操作