记录一下Eclipse集成 Mongo
1、pom.xml中增加依赖
<!-- mongo -->
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>2.12.4</version>
</dependency>
2、代码:
package com.iflytek.mongotest.dao; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; import org.apache.commons.lang.math.NumberUtils; import org.bson.BSONObject; import org.springframework.beans.factory.InitializingBean; import org.springframework.stereotype.Component; import com.google.gson.Gson; import com.google.gson.JsonArray; import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.DBObject; import com.mongodb.MongoClient; import com.mongodb.MongoClientOptions; import com.mongodb.ServerAddress; import com.mongodb.util.JSON; @Component public class MongoDao implements InitializingBean { /** * 集合名称 */ private MongoClient mongoClient; String dbName; String collectionName; @Override public void afterPropertiesSet() throws Exception { dbName = Cfg.get("sendsong.mongo.db"); collectionName = Cfg.get("sendsong.mongo.collection"); int connections = NumberUtils.toInt( Cfg.get("sendsong.mongo.connections"), 20); int timeout = NumberUtils.toInt(Cfg.get("sendsong.mongo.connections"), 3000); int waitNumber = NumberUtils.toInt( Cfg.get("sendsong.mongo.waitNumber"), 100); int maxwait = NumberUtils .toInt(Cfg.get("sendsong.mongo.maxwait"), 5000); MongoClientOptions.Builder build = new MongoClientOptions.Builder(); build.connectionsPerHost(connections); build.connectTimeout(timeout); build.threadsAllowedToBlockForConnectionMultiplier(waitNumber); build.maxWaitTime(maxwait); MongoClientOptions options = build.build(); String url = Cfg.get("sendsong.mongo.url"); List<ServerAddress> addresses = new ArrayList<ServerAddress>(); String[] addressStr = url.split(","); for (String str : addressStr) { String[] re = str.split(":"); ServerAddress address = new ServerAddress(re[0], Integer.parseInt(re[1])); addresses.add(address); } mongoClient = new MongoClient(addresses, options); } /** * 插入集合 * @param branchId * @param sendsongId */ public void insertSendsong(String branchId, long sendsongId) { DB db = mongoClient.getDB(dbName); DBCollection collection = db.getCollection(collectionName); DBObject object = new BasicDBObject(); object.put("sendsongid", sendsongId); object.put("branchid", branchId); object.put("status", SendSongStatus.ADD_TASK_SUCCESS); object.put("createtime", System.currentTimeMillis()); collection.insert(object); } /** * 查询所有集合 * @param brachid * @param sendsongId */ public void querSendsong(String brachid, long sendsongId) { DB db = mongoClient.getDB(dbName); DBCollection collection = db.getCollection("sendsonginfo"); DBCursor cur = collection.find(); while (cur.hasNext()) { System.out.println(cur.next()); } System.out.println(cur.count()); System.out.println(cur.getCursorId()); System.out.println(JSON.serialize(cur)); } /** * 查询单个集合 * @param brachid * @param sendsongId */ public void querySingle(String brachid, long sendsongId) { DB db = mongoClient.getDB(dbName); DBCollection collection = db.getCollection("sendsonginfo"); Map<String,Object> map=new HashMap<String, Object>(); map.put("sendsongid", 100); map.put("createtime", 1432L); DBCursor cur = collection.find(new BasicDBObject(map)); while (cur.hasNext()) { System.out.println(cur.next()); } } /** * 根据条件删除集合中的元素 * @param brachid * @param sendsongId */ public void delCollect() { DB db = mongoClient.getDB(dbName); DBCollection collection = db.getCollection("sendsonginfo"); Map<String,Object> map=new HashMap<String, Object>(); map.put("sendsongid", 100); map.put("createtime", 1432L); collection.remove(new BasicDBObject(map)); //collection.drop(); 删除集合里所有的元素 } //更新集合 public void updateCollect() { DB db = mongoClient.getDB(dbName); DBCollection collection = db.getCollection("sendsonginfo"); Map<String,Object> map=new HashMap<String, Object>(); map.put("sendsongid", 100); map.put("createtime", 1431L); Map<String,Object> map1=new HashMap<String, Object>(); map.put("sendsongid", 100); map.put("createtime", 1432L); //upsert when true, inserts a document if no document matches the update query criteria true:如果数据库里没有,则插入一条 //multi when true, updates all documents in the collection that match the update query criteria, true: 更新所有的记录 false:只更新第一条 collection.update(new BasicDBObject(map1), new BasicDBObject(map),true,false); } }
相关推荐
mongodb driver 集成mongo和mongodb扩展 log.php 发送日志类
松果Xongo 是 Java 的 Mongo + Fongo + Jongo 集成。 您可以查看各种数据库访问示例。 Friend 类将在所有这些中用作要存储的模型的示例。
Spring-Mongo-MVC 简单的JAVA应用程序证明了Mongo DB和Spring MVC之间的集成
将以下Maven依赖项添加到您的项目中: < dependency> < groupId>de.bwaldvogel</ groupId> < artifactId>mongo-java-server</ artifactId> < version>1.37.0</ version></ dependency>例public class SimpleTest { ...
使用自定义了时间和字符串的转换规则 存的时候 存字符串 读取的时候 转换为日期类型 但是在按时间查找的时候 也可以使用 下载后 直接运行 Test类 修改下MongodbConfiguration的mongoUrl 写的时候将时间转为字符串 ...
Java和MongoDB集成 使用Mongo Java驱动程序实现一个简单的程序来演示Mongo DB中的CRUD操作。 要求: •来自MongoDB社区版本。 •来自MongoDB指南针。 它提供了有效的用户界面来查看您的数据库,集合和文档,还允许...
该插件将MongoDB服务器与数据库/集合树,查询运行器和Shell控制台集成在一起。 插件兼容性 此插件是为IDEA 2019和更高版本构建的,需要JRE 1.8和Mongo 3。 如何安装? 从您的IDE下载此插件(Mongo插件) 配置步骤 ...
使用Mongo DB和PHP编写集成测试应该很容易(这是Java语言),该库使您可以在运行测试之前快速启动嵌入式Mongo DB服务器。 安装 该库会启动一个真正的Mongo DB服务器,因此您必须安装Java,然后使用composer安装该库...
本人亲测,可正常使用。 此包已经集成了bson、core、driver三个包的API,所以只需要引用这一个包即可。
Jmeter+Jenkins+maven接口自动化集成,超详细,环境大家围观
数据整合之春mongo 使用Spring和MongoDB集成csv数据的项目。 该项目的目标是创建一个API,以从.csv文件信息中加载和集成数据。 加载后,您可以在API中查询这些数据。 该项目进行了一些测试。 执行 要运行项目,您...
适用于MongoDB Java驱动程序的同步版本和异步版本。 您可以使用进行扩展。 它既快速又小-单元测试和集成测试仅涵盖13kB依赖性。 安装 Mongo映射器在Maven Central上。 将以下内容添加到您的pom.xml 。 玛文 ...
CDI集成 12.反应性MongoDB存储库 12.1。介绍 12.2。活性成分库 12.3。用法 12.4。特征 12.4.1。地理空间资源库查询 12.5。无限流与Tailable游标 13.审计 13.1。基本 13.1.1。基于注释的审计元数据 13.1.2。基于接口...
MongoSpark是一个基于Maven的Java项目,它显示了使用Mongodb Hadoop Connector将Spark与MongoDb集成。 最初,它不包含任何bigData分析,但将在不久的将来包含。 最初,该项目仅将一个馆藏的所有文档复制到另一个...
该压缩文件为spring整合mongodb的demo工程&直接使用java整合mongodb,兼容所有版本的mongodb,亲测可用。
SPRING-BOOT-CAMEL-MONGO-JDK8介绍示例 Spring Boot 应用程序,它集成了 Java 生态系统中一些最常用的顶级框架。 该示例还用于试验所有这些框架,以创建轻量级企业服务,该服务独立于外部容器运行,但仍提供企业就绪...
spring-mongo:Spring启动+ MongoDB集成
嵌入式mongo弹簧概述Spring TestContext Framework 提供注解驱动的单元和集成测试支持。 Fongo 是 MongoDB 的内存 Java 实现。 Embedded-mongo-spring 提供了一种在 Spring TestContext Framework 中使用 fgo 的方法...
mongo-testbed.zip,为mongodbjava集成测试开发提供便利mongo数据库测试框架
集成了solr自有的solrImpoerterHandle,使用这个jar包,可以从MongoDB同步数据到Solr,需要依赖solr-dataimporthandler-7.4.0以及mongo-java-driver-3.11.2