Java中获取MongoDB连接的方法详解
更新时间：2019年10月11日 10:04:03 作者：德邦总管
这篇文章主要介绍了Java中获取MongoDB连接的方法详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
首先是所需jar包，Maven中的配置如下：
<dependency> <groupId>org.mongodb</groupId> <artifactId>mongodb-driver</artifactId> <version>3.4.1</version> </dependency> <dependency> <groupId>org.mongodb</groupId> <artifactId>bson</artifactId> <version>3.4.1</version> </dependency> <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-mongodb</artifactId> <version>1.7.0.RELEASE</version> </dependency> <dependency> <groupId>org.mongodb</groupId> <artifactId>mongo-java-driver</artifactId> <version>3.9.1</version> </dependency>
获取连接的代码如下（本中用的是模板类）：
List<ServerAddress> addrs = new ArrayList<ServerAddress>(); addrs.add(new ServerAddress(dataSource.getSourceIp(), Integer.valueOf(dataSource.getSourcePort()))); List<MongoCredential> credentials = new ArrayList<MongoCredential>(); credentials.add(MongoCredential.createScramSha1Credential(dataSource.getUsername(), dataSource.getSourceName(), dataSource.getPassword().toCharArray())); MongoClient mongoClient = new MongoClient(addrs, credentials); MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient, dataSource.getSourceName()); MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory); mongoTemplate.getCollectionNames();
或者用如下方式获取：
ServerAddress serverAddress = new ServerAddress("192.168.16.121",27017);
List<ServerAddress> addrs = new ArrayList<ServerAddress>();
addrs.add(serverAddress);
//MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码
MongoCredential credential = MongoCredential.createScramSha1Credential("root", "admin", "123456Ab".toCharArray());
List<MongoCredential> credentials = new ArrayList<MongoCredential>();
credentials.add(credential);
//通过连接认证获取MongoDB连接
MongoClient mongoClient = new MongoClient(addrs,credentials);
//连接到数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("admin");
mongoDatabase.getCollection("test").find().iterator();
// 关闭数据库连接
mongoClient.close();
附带简单增删改查的例子：
package test;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import org.junit.Test;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.WriteResult;
import bean.Book;
import bean.Good;
import bean.ShopDO;
import net.sf.json.JSONObject;
public class MongoTemplateTest {
public static MongoTemplate mongoTemplate = getMongoTemplate();
public static void main(String[] args) {
System.out.println(mongoTemplate.getCollectionNames());
}
public static MongoTemplate getMongoTemplate(){
String host = "192.168.16.121";
int port = 27017;
String databaseName = "test";
String username = "root";
String password = "123456Ab";
//ServerAddress(host,port)两个参数分别为 IP地址 端口号
ServerAddress serverAddress = new ServerAddress(host,port);
List<ServerAddress> addrs = new ArrayList<ServerAddress>();
addrs.add(serverAddress);
//MongoCredential.createScramSha1Credential(username,source,password)三个参数分别为 用户名 数据库名称 密码
MongoCredential credential = MongoCredential.createScramSha1Credential(username, databaseName, password.toCharArray());
List<MongoCredential> credentials = new ArrayList<MongoCredential>();
credentials.add(credential);
//通过连接认证获取MongoDB连接
MongoClient mongoClient = new MongoClient(addrs,credentials);
MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient, databaseName);
MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory);
return mongoTemplate;
}
/**
* 插入数据
*/
@Test
public void save(){
ShopDO shop1 = new ShopDO(100L,"菜鸟教程");
ShopDO shop2 = new ShopDO(101L,"有道笔记");
mongoTemplate.save(shop1,"col");
mongoTemplate.save(shop2,"col");
System.out.println("mongoDB插入数据成功,集合为col,文档为："+mongoTemplate.getCollection("col"));
}
@Test
public void save1(){
Book book = new Book(22L,"英语","32.5");
mongoTemplate.save(book,"col");
}
@Test
public void save2(){
Good good = new Good(new HashMap<String,String>(){{put("id","1");put("name","动物");}});
mongoTemplate.save(good,"col");
}
@Test
public void save3(){
mongoTemplate.save(JSONObject.fromObject("{\"这样\":\"we\",\"好吧\":\"hai\"}"),"col");
System.out.println("mongoDB插入数据成功,集合为col,文档为："+mongoTemplate.getCollection("col"));
}
/**
* 查询所有
*/
@Test
public void findAll(){
List<ShopDO> list = mongoTemplate.findAll(ShopDO.class,"col");
System.out.println("mongoDB查询数据成功,集合为col,文档为：");
for (ShopDO shopDO:list){
System.out.println(shopDO.getNo()+"/"+shopDO.getName());
}
}
/**
* 单条件查询
*/
@Test
public void simpleQuery(){
Query query = Query.query(Criteria.where("no").is(100L));
List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col");
System.out.println("mongoDB按条件ID查询数据成功,集合为col,文档为：");
for (ShopDO shopDO:list){
System.out.println(shopDO.getNo()+"/"+shopDO.getName());
}
}
/**
* 多条件查询
*/
@Test
public void muchQuery(){
Criteria criteria = new Criteria();
//or是条件或查询，and是条件与查询
criteria.orOperator(
Criteria.where("no").is(100),
Criteria.where("name").is("菜鸟教程"));
Query query = new Query(criteria); //组合查询放入query
Sort sort = new Sort(new Sort.Order(Sort.Direction.DESC,"no")); //结果集进行排序
query.with(sort);
List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col");
System.out.println("mongoDB组合查询数据成功,集合为col,文档为：");
for (ShopDO shopDO:list){
System.out.println(shopDO.getNo()+"/"+shopDO.getName());
}
}
/**
* 分页查询
*/
@Test
public void LimitQuery(){
Query query = new Query();
query.skip(1).limit(3);
List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col");
System.out.println("mongoDB分页查询下标为1开始总共3行数据,集合为col,文档为：");
for (ShopDO shopDO:list){
System.out.println(shopDO.getNo()+"/"+shopDO.getName());
}
}
/**
* 模糊查询
*/
@Test
public void LikeQuery(){
Query query = new Query(Criteria.where("name").regex("菜鸟"));
List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col");
System.out.println("mongoDB查询名称叫菜鸟的数据成功,集合为col,文档为：");
for (ShopDO shopDO:list){
System.out.println(shopDO.getNo()+"/"+shopDO.getName());
}
Update update = new Update();
update.set("name","菜鸟教程old");
WriteResult wr = mongoTemplate.updateMulti(query,update,"col");
System.out.println("mongoDB更新数据成功,集合为col,行数为：" + wr.getN());
}
/**
* 更新
*/
@Test
public void update(){
Query query = new Query(Criteria.where("no").is(100));
List<ShopDO> list = mongoTemplate.find(query,ShopDO.class,"col");
System.out.println("mongoDB查询no为100的数据成功,集合为col,文档为：");
for (ShopDO shopDO:list){
System.out.println(shopDO.getNo()+"/"+shopDO.getName());
}
Update update = new Update();
update.set("name","菜鸟教程new");
WriteResult wr = mongoTemplate.updateFirst(query,update,"col");
System.out.println("mongoDB更新数据成功,集合为col,行数为：" + wr.getN());
}
/**
* 删除
*/
@Test
public void delete(){
Query query = new Query(Criteria.where("no").is(1));
WriteResult result = mongoTemplate.remove(query, "col");
System.out.println("mongoDB删除数据成功,集合为col,行数为：" + result.getN() + "删除的ID为"+result.getUpsertedId());
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了SpringCloud服务的平滑上下线的方法,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2019-06-06
这篇文章主要介绍了Springboot源码 TargetSource解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-08-08
这篇文章主要介绍了Java泛型机制必要性及原理解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-05-05
关于ScheduledThreadPoolExecutor不执行的原因分析
这篇文章主要介绍了关于ScheduledThreadPoolExecutor不执行的原因分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-08-08
这篇文章主要介绍了Maven进阶多环境配置与应用,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2022-08-08
这篇文章主要介绍了SpringBoot整合MyBatis-Plus的示例代码,使用 MyBatis-Plus 可以减少大量的开发时间，单表的增删改查可以不用写 sql 语句，本文主要介绍整合需要主要事项，需要的朋友可以参考下2022-03-03
idea使用外置tomcat配置springboot详细步骤
昨天小编遇到一个问题使用springboot自带的tomcat启动没有任何问题，不知道idea使用外置tomcat配置springboot该如何设置的，今天小编给大家分享一篇教程帮助大家解决这个问题2021-07-07
springBoot controller,service,dao,mapper,model层的作用说明
这篇文章主要介绍了springBoot controller,service,dao,mapper,model层的作用说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-11-11
Java单例模式是看起来以及用起来简单的一种设计模式,但是就实现方式以及原理来说,也并不浅显,下面这篇文章主要给大家详细介绍了Java中单例模式,需要的朋友可以参考下2021-12-12
详解IntelliJ IDEA 中如何配置多个jdk版本即(1.7和1.8两个jdk都可用)
这篇文章主要介绍了详解IntelliJ IDEA 中如何配置多个jdk版本即(1.7和1.8两个jdk都可用)，非常具有实用价值，需要的朋友可以参考下2017-11-11
最新评论