java连接Mongodb实现增删改查
本文实例为大家分享了java连接Mongodb实现增删改查的具体代码，供大家参考，具体内容如下
1.创建maven项目
org.mongodb mongodb-driver 3.4.1
2.编写代码
1.查询所有
packagecom.czxy.mongodb;
importcom.alibaba.fastjson.JSON;
importcom.mongodb.*;
importjava.util.List;
importjava.util.Set;
publicclassFind{
publicstaticvoidmain(String[]args){
//客户端链接
MongoClientmongodbClint=newMongoClient("localhost",27017);
//获取所有的数据库
ListdatabaseNames=mongodbClint.getDatabaseNames();
for(StringdatabaseName:databaseNames){
System.out.println("数据库名称"+databaseName);
}
//连接指定的数据库
DBdb=mongodbClint.getDB("text");
//获取当前数据库下的所有集合名称
SetcollectionNames=db.getCollectionNames();
for(Stringdbname:collectionNames){
System.out.println("集合名称"+dbname);
}
//连接指定的集合
DBCollectioncollection=db.getCollection("stus");
//数据集合信息
DBCursordbObjects=collection.find();
while(dbObjects.hasNext()){
//读取数据
DBObjectnext=dbObjects.next();
//json格式转换
Stusparse=JSON.parseObject(next.toString(),Stus.class);
//数据输出
System.out.println(parse);
}
}
}
2.添加数据
packagecom.czxy.mongodb;
importcom.mongodb.MongoClient;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoDatabase;
importorg.bson.Document;
importjava.util.HashMap;
importjava.util.Map;
publicclassInsert{
publicstaticvoidmain(String[]args){
//获取连接
MongoClientmongodbClint=newMongoClient("localhost",27017);
//连接数据库
MongoDatabasedatabase=mongodbClint.getDatabase("text");
//获取对象
MongoCollectionstus=database.getCollection("stus");
Mapmap=newHashMap();
map.put("name","诸葛亮");
map.put("sex","男");
map.put("age",35.0);
map.put("address","南阳");
Documentdocument=newDocument(map);
System.out.println(document);
stus.insertOne(document);
}
}
3.删除
packagecom.czxy.mongodb;
importcom.mongodb.BasicDBObject;
importcom.mongodb.MongoClient;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoDatabase;
importorg.bson.Document;
/**
*删除
*/
publicclassDelete{
publicstaticvoidmain(String[]args){
//获取连接
MongoClientlocation=newMongoClient("localhost",27017);
//连接数据库
MongoDatabasedatabase=location.getDatabase("text");
//获取集合封账对象
MongoCollectioncollection=database.getCollection("stus");
//删除的条件
BasicDBObjectdbObject=newBasicDBObject("name","诸葛亮");
//删除符合条件的第一个
collection.deleteOne(dbObject);
//删除符合条件的所有
//collection.deleteMany(newBasicDBObject("name","lisi"));
}
}
4.修改
packagecom.czxy.mongodb;
importcom.mongodb.BasicDBObject;
importcom.mongodb.MongoClient;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoDatabase;
importorg.bson.Document;
importjava.awt.*;
publicclassUpdate{
publicstaticvoidmain(String[]args){
//获取连接
MongoClientmongoClient=newMongoClient();
//连接数据库
MongoDatabasedatabase=mongoClient.getDatabase("text");
//得到集合封装队象
MongoCollectionstuo=database.getCollection("stus");
//查询条件
BasicDBObjectupFind=newBasicDBObject("name","wangwu");
//修改的值
BasicDBObjectupNew=newBasicDBObject("$set",newBasicDBObject("address","高老庄"));
//修改符合条件的第一个值
stuo.updateOne(upFind,upNew);
//修改符合条件的全部
//stuo.updateMany(upFind,upNew);
}
}
5.条件查询
packagecom.czxy.mongodb;
importcom.alibaba.fastjson.JSON;
importcom.mongodb.BasicDBObject;
importcom.mongodb.MongoClient;
importcom.mongodb.client.FindIterable;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoDatabase;
importorg.bson.Document;
publicclassFindEq{
publicstaticvoidmain(String[]args){
//获取连接
MongoClientmongoClient=newMongoClient();
//连接数据库
MongoDatabasedatabase=mongoClient.getDatabase("text");
//得到集合封装队象
MongoCollectionstus=database.getCollection("stus");
//查询条件
BasicDBObjectfind=newBasicDBObject("name","wangwu");
//得到查询结果
FindIterableresults=stus.find(find);
//集合遍历
for(Documentresult:results){
//格式转换
Strings=JSON.toJSONString(result);
//查询结果输出
System.out.println(JSON.parseObject(s,Stus.class));
}
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。