java访问mongodb_Java中获取MongoDB连接的方法详解
首先是所需jar包,Maven中的配置如下:
org.mongodb
mongodb-driver
3.4.1
org.mongodb
bson
3.4.1
org.springframework.data
spring-data-mongodb
1.7.0.RELEASE
org.mongodb
mongo-java-driver
3.9.1
获取连接的代码如下(本中用的是模板类):
List addrs = new ArrayList();
addrs.add(new ServerAddress(dataSource.getSourceIp(), Integer.valueOf(dataSource.getSourcePort())));
List credentials = new ArrayList();
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 addrs = new ArrayList();
addrs.add(serverAddress);
//MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码
MongoCredential credential = MongoCredential.createScramSha1Credential("root", "admin", "123456Ab".toCharArray());
List credentials = new ArrayList();
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 addrs = new ArrayList();
addrs.add(serverAddress);
//MongoCredential.createScramSha1Credential(username,source,password)三个参数分别为 用户名 数据库名称 密码
MongoCredential credential = MongoCredential.createScramSha1Credential(username, databaseName, password.toCharArray());
List credentials = new ArrayList();
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(){{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 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 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 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 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 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 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());
}
}
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
java访问mongodb_Java中获取MongoDB连接的方法详解相关推荐
- java调用javascript函数_[Java教程]JavaScript函数的4种调用方法详解
[Java教程]JavaScript函数的4种调用方法详解 0 2016-08-09 00:00:12 在JavaScript中,函数是一等公民,函数在JavaScript中是一个数据类型,而非像C# ...
- linux ipset 流量,linux中ipset命令的使用方法详解
linux中ipset命令的使用方法详解 发布时间:2020-10-25 17:07:19 来源:脚本之家 阅读:97 作者:lijiaocn 栏目:服务器 ipset介绍 iptables是在lin ...
- python中验证码连通域分割的方法详解
python中验证码连通域分割的方法详解 这篇文章主要给大家介绍了关于python中验证码连通域分割的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用python具有一定的参考学习价值,需 ...
- python中search用法_Python中的python re.search方法详解
re.search扫描整个字符串并返回第一个成功的匹配,若string中包含pattern子串,则返回Match对象,否则返回None,注意,如果string中存在多个pattern子串,只返回第一个 ...
- python怎么横着输出_对python3中, print横向输出的方法详解
对python3中, print横向输出的方法详解 Python 2 : print打印的时候,如果结尾有逗号,打出来时候不会换行.但是在python3里面就不行了. Python3: 3.0的pri ...
- Python精讲:在Python中遍历字典的三大方法详解
欢迎你来到站长在线的站长学堂学习Python知识,本文学习的是<在Python中遍历字典的三大方法详解>.本知识点主要内容有:使用字典对象的items()方法可以遍历字典的项和字典的&qu ...
- vue ajax highcharts,在vue项目中引入highcharts图表的方法(详解)
npm进行highchars的导入,导入完成后就可以进行highchars的可视化组件开发了 npm install highcharts --save 1.components目录下新建一个char ...
- Linux中history历史命令使用方法详解
在/etc/profile里添加如下:#History export HISTTIMEFORMAT="[%F %T]" HISTDIR=/home/common/.hist if ...
- php中读取大文件实现方法详解
php中读取大文件实现方法详解 来源: 时间:2013-09-05 19:27:01 阅读数:6186 分享到:0 [导读] 本文章来给各位同学介绍php中读取大文件实现方法详解吧,有需要了解 ...
最新文章
- RDLC 2010设计器的数据源无法找到静态类作为数据源
- latex精要(1)-安装与helloworld
- 波特率_不同波特率CAN总线系统如何进行数据收发
- 03 ZooKeeper底层原理剖析与命令实战
- 面试中遇到的“黑嘴”现象
- 简单操作stm32f10xIO端口配置
- Java语言十五讲——第二讲 ClassLoader
- excel减法函数_会计小白的EXCEL学习笔记
- 互联网无处不在的“推荐算法”解析
- 谈谈测试过程中常见的几个问题
- 智能合约--如何实现可升级的智能合约
- 把废旧监控改无人机遥控车红外远程摄像头
- html显示已知范围标量,【单选题】下列哪个HTML5元素用于显示已知范围内的标量测量...
- 笔记本损耗60 计算机提示,笔记本电脑寿命短,你可能犯了这3个错误
- 【Nas/群晖/服务器】FRP内网穿透实现外网访问
- [python八卦] zz 一位大牛整理的Python资源
- MBA-day33 绝对值的几何意义
- 记录一下自己的本本,DELL 640M铲掉XP,重装VISTA的过程
- 科技创业的新规律:先创业、再创意
- MIPI解决方案 ICN6202:MIPI DSI转LVDS转换芯片
热门文章
- nginx设置 二级域名 指定端口
- linux查看基础硬件信息
- 线性表操作的基本应用
- MySQL官方备份_Mysqlbackup 备份详解(mysql官方备份工具)
- c++检测ip是否匹配子网掩码_网络工程师从入门到精通通俗易懂系列 | ARP和IP这篇文章讲的相当详细了,这么基础的知识往往也是最容易遗忘的!...
- 服务器此时无法接受控制信息,您无法修改域或信任信息,因为无法联系一个主域控制器(PDC)仿真器,请确认当前域的PDC仿真器和网络都联机并正常运行。...
- Nginx----基础
- 2018.10.20 NOIP模拟 蛋糕(线段树+贪心/lis)
- EntityFramwork常见问题
- XP Embedded:不同的用户使用不同的外壳程序