package com.hoo.test;
import java.net.UnknownHostException;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.util.JSON;
/**
* <b>function:</b>MongoDB 简单示例
* @author flychao88
* @file SimpleTest.java
* @package com.hoo.test
* @project MongoDB
* @version 1.0
*/
public class SimpleTest {
public static void main(String[] args) throws UnknownHostException, MongoException {
Mongo mg = new Mongo();
//查询所有的Database
for (String name : mg.getDatabaseNames()) {
System.out.println("dbName: " + name);
}
DB db = mg.getDB("test");
//查询所有的聚集集合
for (String name : db.getCollectionNames()) {
System.out.println("collectionName: " + name);
}
DBCollection users = db.getCollection("users");
//查询所有的数据
DBCursor cur = users.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));
}
}
2、 完成CRUD操作,首先建立一个MongoDB4CRUDTest.java,基本测试代码如下:
package com.hoo.test;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;
import org.bson.types.ObjectId;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import com.mongodb.BasicDBObject;
import com.mongodb.Bytes;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.QueryOperators;
import com.mongodb.util.JSON;
/**
* <b>function:</b>实现MongoDB的CRUD操作
* @package com.hoo.test
* @project MongoDB
*/
public class MongoDB4CRUDTest {
private Mongo mg = null;
private DB db;
private DBCollection users;
@Before
public void init() {
try {
mg = new Mongo();
//mg = new Mongo("localhost", 27017);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (MongoException e) {
e.printStackTrace();
}
//获取temp DB;如果默认没有创建,mongodb会自动创建
db = mg.getDB("temp");
//获取users DBCollection;如果默认没有创建,mongodb会自动创建
users = db.getCollection("users");
}
@After
public void destory() {
if (mg != null)
mg.close();
mg = null;
db = null;
users = null;
System.gc();
}
public void print(Object o) {
System.out.println(o);
}
}
3、 添加操作
在添加操作之前,我们需要写个查询方法,来查询所有的数据。代码如下:
/**
* <b>function:</b> 查询所有数据
*/
private void queryAll() {
print("查询users的所有数据:");
//db游标
DBCursor cur = users.find();
while (cur.hasNext()) {
print(cur.next());
}
}
@Test
public void add() {
//先查询所有数据
queryAll();
print("count: " + users.count());
DBObject user = new BasicDBObject();
user.put("name", "hoojo");
user.put("age", 24);
//users.save(user)保存,getN()获取影响行数
//print(users.save(user).getN());
//扩展字段,随意添加字段,不影响现有数据
user.put("sex", "男");
print(users.save(user).getN());
//添加多条数据,传递Array对象
print(users.insert(user, new BasicDBObject("name", "tom")).getN());
//添加List集合
List<DBObject> list = new ArrayList<DBObject>();
list.add(user);
DBObject user2 = new BasicDBObject("name", "lucy");
user.put("age", 22);
list.add(user2);
//添加List集合
print(users.insert(list).getN());
//查询下数据,看看是否添加成功
print("count: " + users.count());
queryAll();
}
4、 删除数据
@Test
public void remove() {
queryAll();
print("删除id = 4de73f7acd812d61b4626a77:" + users.remove(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).getN());
print("remove age >= 24: " + users.remove(new BasicDBObject("age", new BasicDBObject("$gte", 24))).getN());
}
5、 修改数据
@Test
public void modify() {
print("修改:" + users.update(new BasicDBObject("_id", new ObjectId("4dde25d06be7c53ffbd70906")), new BasicDBObject("age", 99)).getN());
print("修改:" + users.update(
new BasicDBObject("_id", new ObjectId("4dde2b06feb038463ff09042")),
new BasicDBObject("age", 121),
true,//如果数据库不存在,是否添加
false//多条修改
).getN());
print("修改:" + users.update(
new BasicDBObject("name", "haha"),
new BasicDBObject("name", "dingding"),
true,//如果数据库不存在,是否添加
true//false只修改第一天,true如果有多条就不修改
).getN());
//当数据库不存在就不修改、不添加数据,当多条数据就不修改
//print("修改多条:" + coll.updateMulti(new BasicDBObject("_id", new ObjectId("4dde23616be7c19df07db42c")), new BasicDBObject("name", "199")));
}
6、 查询数据
@Test
public void query() {
//查询所有
//queryAll();
//查询id = 4de73f7acd812d61b4626a77
print("find id = 4de73f7acd812d61b4626a77: " + users.find(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).toArray());
//查询age = 24
print("find age = 24: " + users.find(new BasicDBObject("age", 24)).toArray());
//查询age >= 24
print("find age >= 24: " + users.find(new BasicDBObject("age", new BasicDBObject("$gte", 24))).toArray());
print("find age <= 24: " + users.find(new BasicDBObject("age", new BasicDBObject("$lte", 24))).toArray());
print("查询age!=25:" + users.find(new BasicDBObject("age", new BasicDBObject("$ne", 25))).toArray());
print("查询age in 25/26/27:" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.IN, new int[] { 25, 26, 27 }))).toArray());
print("查询age not in 25/26/27:" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.NIN, new int[] { 25, 26, 27 }))).toArray());
print("查询age exists 排序:" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.EXISTS, true))).toArray());
print("只查询age属性:" + users.find(null, new BasicDBObject("age", true)).toArray());
print("只查属性:" + users.find(null, new BasicDBObject("age", true), 0, 2).toArray());
print("只查属性:" + users.find(null, new BasicDBObject("age", true), 0, 2, Bytes.QUERYOPTION_NOTIMEOUT).toArray());
//只查询一条数据,多条去第一条
print("findOne: " + users.findOne());
print("findOne: " + users.findOne(new BasicDBObject("age", 26)));
print("findOne: " + users.findOne(new BasicDBObject("age", 26), new BasicDBObject("name", true)));
//查询修改、删除
print("findAndRemove 查询age=25的数据,并且删除: " + users.findAndRemove(new BasicDBObject("age", 25)));
//查询age=26的数据,并且修改name的值为Abc
print("findAndModify: " + users.findAndModify(new BasicDBObject("age", 26), new BasicDBObject("name", "Abc")));
print("findAndModify: " + users.findAndModify(
new BasicDBObject("age", 28), //查询age=28的数据
new BasicDBObject("name", true), //查询name属性
new BasicDBObject("age", true), //按照age排序
false, //是否删除,true表示删除
new BasicDBObject("name", "Abc"), //修改的值,将name修改成Abc
true,
true));
queryAll();
}
mongoDB不支持联合查询、子查询,这需要我们自己在程序中完成。将查询的结果集在Java查询中进行需要的过滤即可。
7、 其他操作
public void testOthers() {
DBObject user = new BasicDBObject();
user.put("name", "hoojo");
user.put("age", 24);
//JSON 对象转换
print("serialize: " + JSON.serialize(user));
//反序列化
print("parse: " + JSON.parse("{ \"name\" : \"hoojo\" , \"age\" : 24}"));
print("判断temp Collection是否存在: " + db.collectionExists("temp"));
//如果不存在就创建
if (!db.collectionExists("temp")) {
DBObject options = new BasicDBObject();
options.put("size", 20);
options.put("capped", 20);
options.put("max", 20);
print(db.createCollection("account", options));
}
//设置db为只读
db.setReadOnly(true);
//只读不能写入数据
db.getCollection("test").save(user);
}
分享到:
相关推荐
java操作mongodb增删改查mongodb查询 in like 修改自增
NULL 博文链接:https://425826501.iteye.com/blog/2188199
最近有一个需求是要实时获取到新插入到MongoDB的数据,而插入程序本身已经有一套处理逻辑,所以不方便直接在插入程序里写相关程序,传统的数据库大多自带这种触发器机制,但是Mongo没有相关的函数可以用(也可能我...
在项目中灵活运用面向文档的存储方式。了解MongoDB的无模式数据模型如何处理文档、集合和多个数据库之间的关系。...利用分片水平扩展MongoDB,了解其对应用的影响。Java、PHP、Python和Ruby的应用实例应有尽有。
Mongo Storm库使您可以在Storm拓扑中利用MongoDB。 它包括两个主要组成部分。 MongoDB操作日志和任何受MongoDB限制的集合的出水口,如果您希望减少从出水口传输的数据量,则可以将文档过滤到特定的touples。 或者,...
NOSQL UNDO利用内置的NoSQL数据库的日志记录和快照机制,并且能够撤消只要日志中存在的操作。 当前,NoSQL撤消仅支持MongoDB,可以将其扩展为支持其他NoSQL数据库。入门这些说明将为您提供在本地计算机上运行并运行...
把保存维度,计算频数,过期维度数据等操作,使用lua脚本结合在一起,可以减少网络IO,提高性能 mongodb mongodb本身的聚合函数统计维度,支持很多比如:max,min,sum,avg,first,last,标准差,采样标准差,...
【博客个人资源】 包含前端、后端、移动开发、操作...Java、Python、Node.js、Spring Boot、Django、Express、MySQL、PostgreSQL、MongoDB、React、Angular、Vue、Bootstrap、Material-UI、Redis、Docker、Kubernetes
数据库:选择适当的关系型数据库(如MySQL、PostgreSQL等)或非关系型数据库(如MongoDB)来存储用户信息、商品数据和订单信息。 安全性考虑: 用户认证与授权:采用安全的用户认证和授权机制,确保用户身份的安全...
很长一段时间 Java 的响应式只能同 MongoDB、Redis 等这些非关系型数据库进行交互。而目前我们大部分的数据还是存放在关系型数据库中,大部分情况下 Java 使用 JDBC 来操作关系型数据库,而 JDBC 是阻塞的、同步的。...
5.1 利用NumPy和pandas对CSV文件进行写操作 110 5.2 NumPy.npy与pandas DataFrame 112 5.3 使用PyTables存储数据 115 5.4 Pandas DataFrame与HDF5仓库之间的读写操作 118 5.5 使用pandas读写Excel文件 120 5.6 ...
其他:logback,lombok,fastjson, 全局异常和高复用状态类封装、 利用mysql主键自增特性实现单车连续编号 学习这个项目的时候,对其思路做了笔记,我这里按照自己的写法,与其略有不同, 但是基本思路都是一样的...
使用具有统一接口(作为JSON数据)的数据库来实现和利用CRUD操作。 待处理的数据验证和测试机制使用的技术栈开发全栈应用程序组成; 角度+9 Java +15(Spring启动) 卡塔琳娜跑冬眠Tomcat服务器数据库(MSSQL,...
微信小程序前端框架:采用微信官方提供的小程序开发框架,利用其丰富的组件和API,实现与微信生态的无缝对接。 后端服务:可能采用了Node.js、Java或其他服务端技术,搭建RESTful API,以支持商品展示、订单处理等...
该小程序利用了微信的庞大用户基础和便捷的操作界面,为企事业单位提供了一个易于使用的项目管理工具。以下是该小程序的主要技术特点和功能介绍: 技术特点: 前端框架:采用了流行的前端开发框架,如Taro或uni-...
RS Web服务示例该项目包含两个JAX-RS Web服务的实现: 记忆服务返回查询java.lang.management.MemoryMXBean的结果人事服务演示对存储在Mongo数据库中的任意Person对象的CRUD操作。 使用访问该数据库。 其他有趣的...
Docker Compose利用Docker Engine并编排运行应用程序所需完成的操作。 您还可以使用普通Docker运行项目,只要您执行与Docker Compose配置相同的操作即可。 具体来说,您将需要创建3个容器: 一个仅数据的容器,它将...
无论是开发前端还是后端,都可以利用GraphQL代码生成器从GraphQL模式和GraphQL文档(查询/变异/订阅/片段)生成输出。 通过分析架构和文档并进行解析,GraphQL代码生成器可以基于预定义模板或基于自定义用户定义...
项目说明 该项目是一个典型的由Spring Cloud管理的微服务...Redis延迟消费的项目是利用的Redis的键过期通知来完成的,需要开启Redis的键过期通知配置,对性能有所损耗!项目中实现了分布式锁,防止集群的时候 重复消费