首先是所需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()); } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持小牛知识库。
问题内容: 我的程序需要打开大量连接(Mongo)。我得到了错误: 打开的连接太多,无法再打开 在819个连接之后。我已经知道我们可以增加此限制。但这不是我的想法。我正在考虑关闭MongoClient对象,然后在800个连接后再次创建一个新对象。 我的想法是使用新的mongoClient对象将关闭所有连接,并且当我再次启动/创建它时,连接将再次打开直到800。因此不会给出错误。(让我知道此方法是否
本文向大家介绍详解Java 连接MongoDB集群的几种方式,包括了详解Java 连接MongoDB集群的几种方式的使用技巧和注意事项,需要的朋友参考一下 先决条件 先运行mongodb肯定是必须的,然后导入以下包: MongoClient MongoClient()实例表示到数据库的连接池; 你将只需要MongoClient类的一个实例,即使有多个线程也是一样。 重要: 通常,您只能为给定的Mo
本文向大家介绍Java中如何获取mysql连接的3种方法总结,包括了Java中如何获取mysql连接的3种方法总结的使用技巧和注意事项,需要的朋友参考一下 前言 本文主要来说说三种 Java 中获取 mysql 连接的方式,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍: 第一种:传统的连接方式; 第二种:读取配置文件方式; 第三种:数据库连接池。 一、传统的连接方式: 首先在 sr
本文向大家介绍python实现连接mongodb的方法,包括了python实现连接mongodb的方法的使用技巧和注意事项,需要的朋友参考一下 本文实例讲述了python实现连接mongodb的方法。分享给大家供大家参考。具体分析如下: 通过pymongo可以很容易的链接到mongodb,下面的代码链接到本地mongodb,数据库为mydb,并检索出mycollection中的所有数据输出,简单的
本文向大家介绍MongoDB中MapReduce的使用方法详解,包括了MongoDB中MapReduce的使用方法详解的使用技巧和注意事项,需要的朋友参考一下 前言 玩过Hadoop的小伙伴对MapReduce应该不陌生,MapReduce的强大且灵活,它可以将一个大问题拆分为多个小问题,将各个小问题发送到不同的机器上去处理,所有的机器都完成计算后,再将计算结果合并为一个完整的解决方案,这就是所谓
我有一个Hibernate和光数据源的Spring Boot项目。如果我使用注入的SessionFactory对象来获取会话对象,几天后,我会发现与数据库操作相关的任何方法都有这样的异常(只有重新启动才能解决这个问题): 似乎手动使用的会话使此问题。(我有类似的项目,具有相同的配置和功能,但没有注入SessionFactory和Session...我根本没有这样的问题) 应用程序. yaml: 数