mongodb在Java环境下简单使用,简单记录,简单增删查改。
配置环境:
mongodb 3.0.6 + window7 64bit
使用maven配置 jar管理
<dependency> <groupId>org.testng</groupId> <artifactId>testng</artifactId> <version>6.9.4</version> <scope>test</scope> </dependency> <dependency> <groupId>org.mongodb</groupId> <artifactId>mongo-java-driver</artifactId> <version>3.0.2</version> </dependency>
windows下面直接解压缩:
D:\data\mongdb\mongodb-win32-x86_64-3.0.6\bin>mongod.exe --dbpath D:\data\mongdb\mongodb-win32-x86_64-3.0.6\db (如果dbpathh有空格之类的使用双引号)
直接上代码,非常简单的代码,都是类似操作,基本大同小异:
package com.***.common.dbtest.mongo; import java.util.ArrayList; import java.util.Date; import java.util.List; import org.bson.Document; import org.testng.annotations.Test; import com.mongodb.BasicDBObject; import com.mongodb.MongoClient; import com.mongodb.client.FindIterable; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCursor; import com.mongodb.client.MongoDatabase; import com.mongodb.client.model.UpdateOptions; import com.mongodb.client.result.DeleteResult; import com.mongodb.client.result.UpdateResult; /** * simple query database (mongodb) * @author dennis zhao * @Date 2015-08-05 * @27202787@qq.com * {@link http://www.runoob.com/mongodb/mongodb-tutorial.html} * enviorment mongodb 3.0.6 window7 64bit */ public class MongoDbSimpleQuery { /** * get database object * @return */ @SuppressWarnings("resource") private MongoDatabase getDb() { MongoClient mongo = new MongoClient(host, port); MongoDatabase db = mongo.getDatabase("abo"); return db; } /** * get table data (as collection) * @return */ @SuppressWarnings("rawtypes") private MongoCollection getCollection() { MongoDatabase db = getDb(); MongoCollection<Document> table = db.getCollection("user_info"); return table; } @SuppressWarnings({ "unchecked", "rawtypes" }) @Test public void initData() { // add list collection vale List<Document> list = new ArrayList<Document>(); Document user1 = new Document("name", "abo").append("age", 35); Document user2 = new Document("name", "dennis").append("age", 36); Document user3 = new Document("name", "aaa").append("age", 17); Document user4 = new Document("name", "bbb").append("age", 18); Document user5 = new Document("name", "ccc").append("age", 24).append("sex", "M"); Document user6 = new Document("name", "ddd").append("age", 26); Document user7 = new Document("name", "eee").append("age", 16); Document user8 = new Document("name", "clys").append("age", 40); Document user9 = new Document("name", "myboole").append("age", 27).append("sex", "F"); Document user10 = new Document("name", "琪琪").append("age", 24); Document user11 = new Document("name", "哈宝").append("age", 28); Document user12 = new Document("name", "蓝莓").append("age", 57); list.add(user1);list.add(user2);list.add(user3);list.add(user4);list.add(user5);list.add(user6); list.add(user7);list.add(user8);list.add(user9);list.add(user10);list.add(user11);list.add(user12); MongoCollection table = getCollection(); table.insertMany(list); queryAll(table); } /** * add one data */ @Test public void add() { MongoCollection table = getCollection(); Document document = new Document(); document.put("name", "newData"); document.put("age", 20); document.put("systemDate", new Date()); table.insertOne(document); } /** * update data by query */ @Test public void update() { MongoCollection table = getCollection(); Document query = new Document(); query.put("name", "newData"); BasicDBObject newDoc = new BasicDBObject(); newDoc.put("name", "updateData"); newDoc.put("age", 28); UpdateOptions options = new UpdateOptions(); options.upsert(true); BasicDBObject updateObj = new BasicDBObject(); updateObj.put("$set", newDoc); UpdateResult result = table.updateMany(query, updateObj, options); System.out.println(result.toString()); queryAll(table); } /** * delete data */ @Test public void delete() { MongoCollection table = getCollection(); Document document = new Document(); document.put("name", "updateData"); DeleteResult result = table.deleteMany(document); } // @Test private void queryAll(MongoCollection table) { System.out.println("Query user all data."); // MongoCollection table = getCollection(); MongoCursor cur = table.find().iterator(); while (cur.hasNext()) { System.out.println(cur.next()); } } /** * * find one data(by sort) */ @Test public void findOne() { MongoCollection table = getCollection(); BasicDBObject dbObject = new BasicDBObject(); // mongodb order by age(-1 desc,1 asc) dbObject.put("age", 1); FindIterable iterate = table.find().sort(dbObject).limit(1); System.out.println(iterate.iterator().tryNext()); } /** * * mongodb paging query (by sort) * @param pageIndex * */ private void findPage(int pageIndex) { int pageSize = 3; MongoCollection table = getCollection(); BasicDBObject dbObject = new BasicDBObject(); dbObject.put("age", -1); MongoCursor cursor = table.find().sort(dbObject).limit(pageSize) .skip((pageIndex - 1) * pageSize).iterator(); System.out.println("current page index :" + pageIndex); while (cursor.hasNext()) { System.out.println(cursor.next()); } } @Test public void findPage() { findPage(1); findPage(2); } /** * * equal query */ @Test public void equalQuery() { MongoCollection table = getCollection(); BasicDBObject dbObject = new BasicDBObject(); dbObject.put("age", 24); MongoCursor cursor = table.find(dbObject).iterator(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } /** * * in collections query */ @Test public void findInCollections() { List<Integer> list = new ArrayList<Integer>(4); list.add(20); list.add(28); list.add(25); list.add(13); MongoCollection table = getCollection(); BasicDBObject dbObject = new BasicDBObject(); dbObject.put("age", new BasicDBObject("$in", list)); MongoCursor cursor = table.find(dbObject).iterator(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } /** * * between A and B query */ @Test public void findBeteenAnd() { MongoCollection table = getCollection(); BasicDBObject dbObject = new BasicDBObject(); dbObject.put("age", new BasicDBObject("$gt", 15).append("$lt", 26)); MongoCursor cursor = table.find(dbObject).iterator(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } /** * * not equal query */ @Test public void findNotEqual() { MongoCollection table = getCollection(); BasicDBObject dbObject = new BasicDBObject(); dbObject.put("age", new BasicDBObject("$ne", 17)); MongoCursor cursor = table.find(dbObject).iterator(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } /** * * multi condition query */ @Test public void findMultiQuery() { MongoCollection table = getCollection(); List<BasicDBObject> objects = new ArrayList<BasicDBObject>(); objects.add(new BasicDBObject("age", new BasicDBObject("$ne", 25))); objects.add(new BasicDBObject("name", "abo")); BasicDBObject query = new BasicDBObject(); query.put("$and", objects); MongoCursor cursor = table.find(query).iterator(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } /** * * regular pattern query */ @Test public void findRegexQuery() { MongoCollection table = getCollection(); BasicDBObject regexQuery = new BasicDBObject(); regexQuery.put("name", new BasicDBObject("$regex", "[a-z]*e$")); // System.out.println(regexQuery.toString()); MongoCursor cursor = table.find(regexQuery).iterator(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } public static final int port = 27017; public static final String host = "127.0.0.1"; //mongodb-win32-x86_64-3.0.6\bin>mongod.exe --dbpath D:\data\mongdb\mongodb-win32-x86_64-3.0.6\db (windows start mongodb) }
相关推荐
环境配置: myeclipse 8 6 mongodb 3 0 spring 4 0 6">spring4 整合MongoDB详细讲解项目源码 Mongo DB 是目前在IT行业非常流行的一种非关系型数据库 NoSql 其灵活的数据存储方式备受当前IT从业人员的青睐 Mongo DB很...
作为基于分布式文件存储的数据库,在目前的云计算实践中,MongoDB炙手可热。《深入云计算(MongoDB管理与开发实战详解)》系统全面的介绍了MongoDB开发、管理、维护和性能优化等方方面面。详细而深入,对MongoDB的开发...
java使用mongodb数据库,简单搭建windows环境。
源于线上环境部署mongodb时屏蔽了外网访问mongodb,所以使用不了mongochef这样方便的远程连接工具,便Mongodb提供的java api实现的的网页版管理 未设置登录权限相关模块,低交换性方便嵌入到现有的项目 关于 电子...
源于线上环境部署mongodb时屏蔽了外网访问mongodb,所以使用不了mongochef这样方便的远程连接工具,便Mongodb提供的java api实现的的网页版管理。未设置登录权限相关模块,低耦合性 方便嵌入到现有的项目
作为基于分布式文件存储的数据库,在目前的云计算实践中,MongoDB炙手可热。《深入云计算(MongoDB管理与开发实战详解)》系统全面的介绍了MongoDB开发、管理、维护和性能优化等方方面面。详细而深入,对MongoDB的开发...
使用 Jersey、Maven 和 MongoDB 的示例 Java REST 服务该项目使用 Java、Maven、Mongotemplate 和一个名为 Jersey 的 JAX-RS 库来创建一个简单的 REST API 应用程序。 该应用程序是可执行的,并且已经在 Linux 环境...
用Java编写的简单git服务器 建立和运行 下载并安装Java开发工具包11的最后一个版本与NPM。 适用于Mac的Java- 适用于Linux的Java- 使用以下命令构建VGit的完整发行版: ./gradlew fullBuild 编译后的发行版位于...
节俭聊天会员13512014穆罕默德·亚菲13512066卡尔文·萨德瓦(Calvin Sadewa) 使用Apache Thrift的简单聊天应用程序。先决条件安装MongoDB。 确保mongod在27017端口上运行安装Java JDK 1.8 安装Gradle,将其添加到...
简单直观的用户界面,用于在数据库之间创建映射并跟踪实时迁移。 用于在RDBMS中创建任何类型的联接的通用工具。 一次创建映射并使用导出/导入功能将映射迁移到其他环境。 查看/编辑/删除现有映射的映射功能。 停止/...
当然,首先你需要在自己电脑上安装spark环境,简单说下,在这里下载spark,同时需要配置好JAVA,Scala环境。 这里建议使用Jupyter notebook,会比较方便,在环境变量中这样设置 PYSPARK_DRIVER_PYTHON=jupyter ...
#Overview 在高层次上,该项目有 3 个部分: ... 完全异步并且非常快。 一个 kafka 消费者(一个单独的进程),它... API 和仪表板使用 Spring 4.x 控制器构建,理想情况下,在生产中摄取 API 和仪表板应在单独的进程上运
使用kotlin语言开发,基于SpringBoot+MongoDB,您需要拥有MongoDB以及Java8以上的运行环境 数据库配置文件位于:src/main/resources/application.properties 日志配置文件位于:src/main/resources/log4j.properties...
java查看spring源码#微服务与 Docker、Spring Boot、Spring Cloud 和 Axon 这是关于如何构建由多个协作微服务组成的 CQRS 微服务应用程序的重要演示。 它将以下所有元素组合在一起以生成一个逻辑应用程序 - 一个简单...
不能保证它们已经在可比的环境中通过了全面的测试,并且对于因使用它们引起的任何损坏或数据丢失,我们概不负责。 在任何非测试环境中使用之前,您有责任检查和测试您彻底运行的所有脚本。社交名流社会数据参考架构...
UPUPW控制面板集成网站运行环境所需功能,简单几步即可创建PHP,JSP,ASP/ASP.NET站点。 UPUPW控制面板独特的ANK控制区可随时切换为Apache前端、Nginx前端Apache后端、Kangle前端三种运行模式。 UPUPW创建的PHP...
UPUPW控制面板集成网站运行环境所需功能,简单几步即可创建PHP,JSP,ASP/ASP.NET站点。 UPUPW控制面板独特的ANK控制区可随时切换为Apache前端、Nginx前端Apache后端、Kangle前端三种运行模式。 UPUPW创建的PHP...
不能保证它们已经在可比的环境中通过了全面的测试,并且对于因使用它们引起的任何损坏或数据丢失,我们概不负责。 在任何非测试环境中使用之前,您有责任检查和测试您彻底运行的所有脚本。高容量数据馈送HVDF项目是...
1、确保本地有java8的运行时环境,然后可以直接将项目clone到本地,idea中启动。 2、你可以下载编译好的zip包到本地,unzip解压 ,无论是window还是linux或mac os 都可以使用java -jar命令启动。注意解压后会有一个...
通过在命令提示符下键入gradle ,确保gradle可以正常工作。 接口定义语言 IDL位于src/main/proto/rpcchat.proto 从Java到Proto 运行gradle generateProto 结果位于src/generated/main/grpc和src/generated/main/...