使用Java-Maven操作MongoDB增删改查

文章目录

1. 环境配置
2. 单元测试
- 2.1 查询记录
- 2.2 新增记录
- 2.3 更新记录
- 2.4 删除记录

1. 环境配置

pom.xml 依赖

<dependencies><!-- mongodb驱动 --><dependency><groupId>org.mongodb</groupId><artifactId>mongodb-driver</artifactId><version>3.6.3</version></dependency><!-- 单元测试 --><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.10</version><scope>test</scope></dependency></dependencies><!--Maven插件--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

2. 单元测试

命令行创建数据库

use spitdb

创建集合spit并添加数据

db.spit.insert({_id:"1",content:"996还是007,年轻人该何去何从",userid:"1012",nickname:"忧郁猫",visits:NumberInt(2020)});
db.spit.insert({_id:"2",content:"关于秃头程序员如何护发",userid:"1013",nickname:"李大富",visits:NumberInt(1023)});
db.spit.insert({_id:"3",content:"不会做饭的程序员不是一个好厨子",userid:"1013",nickname:"李大嘴",visits:NumberInt(111)});
db.spit.insert({_id:"4",content:"人到中年就发福",userid:"1014",nickname:"土肥圆",visits:NumberInt(1223)});
db.spit.insert({_id:"4",content:"从删库跑路到精通java",userid:"1014",nickname:"工程狗",parentid:"2",visits:NumberInt(1223)});

2.1 查询记录

@Testpublic void findTest() {// 创建连接MongoClient client = new MongoClient("192.168.1.90", 27017);// 获取数据库对象MongoDatabase spitdb = client.getDatabase("spitdb");// 获取集合MongoCollection<Document> spit = spitdb.getCollection("spit");// 获取集合中的文档 查询所有FindIterable<Document> documents = spit.find();// 条件查询 查询 userid为 1013的记录BasicDBObject dbObject = new BasicDBObject("userid", "1013");FindIterable<Document> filterFind = spit.find(dbObject);// 条件查询 查询浏览量 大于 1000 的记录BasicDBObject gtObject = new BasicDBObject("visits", new BasicDBObject("$gt", 1000));FindIterable<Document> gtFilterFind = spit.find(gtObject);// 展示查询结果for (Document doc : gtFilterFind) {System.out.println("_id: " + doc.get("_id"));System.out.println("content: " + doc.getString("content"));System.out.println("userid: " + doc.getString("userid"));System.out.println("nickname: " + doc.getString("nickname"));System.out.println("--------------------------------------------");}// 关闭连接client.close();}

2.2 新增记录

@Testpublic void saveTest() {// 创建连接MongoClient client = new MongoClient("192.168.1.90", 27017);// 获取数据库对象MongoDatabase spitdb = client.getDatabase("spitdb");// 获取集合MongoCollection<Document> spit = spitdb.getCollection("spit");// 添加一条数据Map<String, Object> map = new HashMap<String, Object>();map.put("_id", "5");map.put("content", "人到中年不得已,一顿能吃三碗米");map.put("userdid", "1015");map.put("nickname", "李富贵");map.put("publishtime", new Date());Document document = new Document(map);spit.insertOne(document);// 获取集合中的文档 查询所有FindIterable<Document> documents = spit.find();// 展示查询结果for (Document doc : documents) {System.out.println("_id: " + doc.get("_id"));System.out.println("content: " + doc.getString("content"));System.out.println("userid: " + doc.getString("userid"));System.out.println("nickname: " + doc.getString("nickname"));System.out.println("--------------------------------------------");}// 关闭连接client.close();}

2.3 更新记录

@Testpublic void updateTest() {// 创建连接MongoClient client = new MongoClient("192.168.1.90", 27017);// 获取数据库对象MongoDatabase spitdb = client.getDatabase("spitdb");// 获取集合MongoCollection<Document> spit = spitdb.getCollection("spit");// 更新一条记录 把 nickname = 李富贵更改为张富贵Document document = new Document("nickname", "张富贵");UpdateResult a = spit.updateOne(Filters.eq("nickname", "李富贵"), new Document("$set", document));// 获取集合中的文档 查询所有FindIterable<Document> documents = spit.find();// 展示查询结果for (Document doc : documents) {System.out.println("_id: " + doc.get("_id"));System.out.println("content: " + doc.getString("content"));System.out.println("userid: " + doc.getString("userid"));System.out.println("nickname: " + doc.getString("nickname"));System.out.println("--------------------------------------------");}// 关闭连接client.close();}

2.4 删除记录

@Testpublic void deleteTest() {// 创建连接MongoClient client = new MongoClient("192.168.1.90", 27017);// 获取数据库对象MongoDatabase spitdb = client.getDatabase("spitdb");// 获取集合MongoCollection<Document> spit = spitdb.getCollection("spit");// 删除一条记录 如果有多个记录符合条件 那么根据添加时间删除最早的一条DeleteResult res = spit.deleteOne(Filters.eq("userid", "1014"));System.out.println(res);// 获取集合中的文档 查询所有FindIterable<Document> documents = spit.find();// 展示查询结果for (Document doc : documents) {System.out.println("_id: " + doc.get("_id"));System.out.println("content: " + doc.getString("content"));System.out.println("userid: " + doc.getString("userid"));System.out.println("nickname: " + doc.getString("nickname"));System.out.println("--------------------------------------------");}// 关闭连接client.close();}

使用Java-Maven操作MongoDB增删改查相关推荐

Java原始客户端操作Mongodb 增删改查
Document方式操作增删改查 1.导入Pom依赖 2.java客户端代码 1.导入Pom依赖 <dependency><groupId>org.mongodb</gr ...
Java操作MongoDB增删改查的基本操作
今天来讲一讲我们如何使用Java来对MongoDB进行增删改查目录一,Java链接MongoDB 导入MongoDB驱动包获取链接对象关闭链接二,Java操作MongoDB 查看库,查看集合 ...
springMVC操作mongoDB增删改查
下面是mongoDb简单的增删改查(新闻类) 附:query.addCriteria(Criteria.where("modelId").ne("").ne(n ...
nodejs操作mongodb增删改查
1. Mac系统上安装使用Homebrew安装 $ brew updata // 更新Homebrew的package数据库 $ brew install mongodb 2. 启动MongoDB ...
MongoDB 增删改查
MongoDB 增删改查学习目标: 学习内容: 使用步骤数据库创建数据库删除数据库集合创建集合删除集合文档查找文档使用 find()查找文档使用 findOne()查找文档使用 ...
数据库——MongoDB增删改查
MongoDB增删改查操作本文包含对数据库.集合以及文档的基本增删改查操作数据库操作 #1.增 use config #如果数据库不存在,则创建并切换到该数据库,存在则直接切换到指定数据库.#2. ...
JDBC：JAVA连接Mysql实现增删改查
总有特别赶的时候,小高叫你如何速通JAVA连接数据库Mysql实现增删改查.CV战士一.前置准备工作 1. 安装IDEA,配置JAVA环境 2. 安装Mysql,配置Mysql环境变量 3. 安装S ...
Java 实现Gbase数据库增删改查功能
Java 实现Gbase数据库增删改查功能具体代码如下主要: 要记得在官网下载驱动包gbase-connector-java-8.3-bin.jar package com.advance.JDB ...
oracle将查询结果声明为伪表,Oracle查询操作（增删改查，伪表，高级查询）实例讲解...
SQL查询操作:增删改查一.SQL操作符算术操作符 + - * / 比较操作符 = != < > <= >= BETWEEN--AND IN LINK IS NULL 逻辑 ...

使用Java-Maven操作MongoDB增删改查

文章目录

1. 环境配置

2. 单元测试

2.1 查询记录

2.2 新增记录

2.3 更新记录

2.4 删除记录

使用Java-Maven操作MongoDB增删改查相关推荐

最新文章

热门文章