Mongodb前后端整合篇

一、前端篇

1.1mongoose介绍

Mongoose 是一个对象文档模型库，官网 http://www.mongoosejs.net/
方便使用代码操作 mongodb 数据库
pnpm i mongoose@5.13.15

1.2初步使用

import mongoose from 'mongoose';
//设置 strictQuery 为 true
mongoose.set('strictQuery', true);
//3. 连接 mongodb 服务                        数据库的名称,没有会自动创建
mongoose.connect('mongodb://user:pwd@ip:27017/admin2');
console.log('1111111');
//4. 设置回调
// 设置连接成功的回调  once 一次   事件回调函数只执行一次
mongoose.connection.once('open', () => {console.log('连接成功');//5. 创建文档的结构对象//设置集合中文档的属性以及属性值的类型const BookSchema = new mongoose.Schema({name: String,author: String,price: Number});//6. 创建模型对象  对文档操作的封装对象const BookModel = mongoose.model('book', BookSchema);//7. 新增文档//7. 新增BookModel.create({name: '西游记111111111111111',author: '吴承恩',price: 19.9}, (err, data) => {//判断是否有错误if (err) {console.log(err);return;}//如果没有出错, 则输出插入后的文档对象console.log(data);// //8. 关闭数据库连接 (项目运行过程中, 不会添加该代码)// mongoose.disconnect();});}
);// 设置连接错误的回调
mongoose.connection.on('error', () => {console.log('连接失败');
});//设置连接关闭的回调
mongoose.connection.on('close', () => {console.log('连接关闭');
});// 关闭 mongodb 的连接
// setTimeout(() => {
//   mongoose.disconnect();
// }, 2000)

1.3字段类型

1.4字段值验证

Mongoose 有一些内建验证器，可以对字段值进行验证

必填项

title: {
type: String,
required: true // 设置必填项
},

默认值

author: {
type: String,
default: '匿名' //默认值
},

唯一值

username: {
type: String,
unique: true
},
## unique 需要 重建集合 才能有效果

总结

 let BookSchema = new mongoose.Schema({name: {type: String,required: true, // 表明该属性必须不为空unique: true// 设置为独一无二的},author: {type: String,default: '匿名'},//类型style: {type: String,//枚举enum: ['言情','城市','志怪','恐怖']},price: Number});

1.5CURD

数据库的基本操作包括四个，增加（create），删除（delete），修改（update），查（read）

增加

import mongoose from 'mongoose';
// 设置 strictQuery 为 true
mongoose.set('strictQuery', true);
// 连接 MongoDB 服务
mongoose.connect('mongodb://user:1213@118.89.91.246:27017/admin2');
console.log('1111111');// 设置连接成功、失败和关闭的回调
mongoose.connection.once('open', () => {console.log('连接成功');// 定义 Phone 文档结构const PhoneSchema = new mongoose.Schema({brand: String,color: String,price: Number,tags: [String],});// 创建 Phone 模型const PhoneModel = mongoose.model('phone', PhoneSchema);// 批量插入 Phone 记录PhoneModel.insertMany([{brand: '华为',color: '灰色',price: 2399,tags: ['电量大', '屏幕大', '信号好'],},{brand: '小米',color: '白色',price: 2099,tags: ['电量大', '屏幕大', '信号好'],},], (err, data) => {if (err) {throw err;}console.log('写入成功');mongoose.connection.close();});
});mongoose.connection.on('error', () => {console.log('连接失败');
});mongoose.connection.on('close', () => {console.log('连接关闭');
});

删除

删除一条数据
SongModel.deleteOne({_id:'5dd65f32be6401035cb5b1ed'}, function(err){
if(err) throw err;
console.log('删除成功');
mongoose.connection.close();
});批量删除
SongModel.deleteMany({author:'Jay'}, function(err){
if(err) throw err;
console.log('删除成功');
mongoose.connection.close();
});

更新

更新一条数据
SongModel.updateOne({author: 'JJ Lin'}, {author: '林俊杰'}, function (err) {
if(err) throw err;
mongoose.connection.close();
});批量更新数据
SongModel.updateMany({author: 'Leehom Wang'}, {author: '王力宏'}, function (err) {
if(err) throw err;
mongoose.connection.close();
});

查询

查询一条数据
SongModel.findOne({author: '王力宏'}, function(err, data){
if(err) throw err;
console.log(data);
mongoose.connection.close();
});
//根据 id 查询数据
SongModel.findById('5dd662b5381fc316b44ce167',function(err, data){
if(err) throw err;
console.log(data);
mongoose.connection.close();
});批量查询数据
//不加条件查询
SongModel.find(function(err, data){
if(err) throw err;
console.log(data);
mongoose.connection.close();
});
//加条件查询
SongModel.find({author: '王力宏'}, function(err, data){
if(err) throw err;
console.log(data);
mongoose.connection.close();
});

条件控制

运算符

在 mongodb 不能 > < >= <= !== 等运算符，需要使用替代符号
> 使用 $gt
< 使用 $lt
>= 使用 $gte
<= 使用 $lte
!== 使用 $ne
db.students.find({id:{$gt:3}}); id号比3大的所有的记录

逻辑运算

$or 逻辑或的情况
db.students.find({KaTeX parse error: Expected 'EOF', got '}' at position 23: …e:18},{age:24}]}̲); `and 逻辑与的情况db.students.find({$and: [{age: {$lt:20}}, {age: {$gt: 15}}]});正则匹配条件中可以直接使用 JS 的正则语法，通过正则可以进行模糊查询

1.6个性化读取

字段筛选

//0:不要的字段
//1:要的字段
SongModel.find().select({_id:0,title:1}).exec(function(err,data){
if(err) throw err;
console.log(data);
mongoose.connection.close();
});

数据排序

//sort 排序
//1:升序
//-1:倒序
SongModel.find().sort({hot:1}).exec(function(err,data){
if(err) throw err;
console.log(data);
mongoose.connection.close();
});

数据截取

//skip 跳过 limit 限定
SongModel.find().skip(10).limit(10).exec(function(err,data){
if(err) throw err;
console.log(data);
mongoose.connection.close();
});

二、后端篇

`2.1Java`操作`MongoDB`

方式一原生`Java（了解）`

方式一采用的原生Java操作MongoDB

前期准备

首先我们需要驱动，MongoDB的Java驱动我们可以直接在Maven中央仓库去下载，也可以创建Maven工程添加如下依赖：

<dependency><groupId>org.mongodb</groupId><artifactId>mongodb-driver</artifactId><version>3.5.0</version>
</dependency>

获取集合

所有准备工作完成之后，我们首先需要一个MongoClient，如下：

MongoClient client = new MongoClient("192.168.248.136", 27017);

然后通过如下方式获取一个数据库，如果要获取的数据库本身就存在，直接获取到，不存在MongoDB会自动创建：

MongoDatabase sang = client.getDatabase("sang");

然后通过如下方式获取一个名为c1的集合，这个集合存在的话就直接获取到，不存在的话MongoDB会自动创建出来，如下：

MongoCollection<Document> c = sang.getCollection("c1");

有了集合之后，我们就可以向集合中插入数据了。

增加操作

和在shell中的操作一样，我们可以一条一条的添加数据，也可以批量添加，添加单条数据操作如下：

Document d1 = new Document();
d1.append("name", "三国演义").append("author", "罗贯中");
c.insertOne(d1);

添加多条数据的操作如下：

List<Document> collections = new ArrayList<Document>();
Document d1 = new Document();
d1.append("name", "三国演义").append("author", "罗贯中");
collections.add(d1);
Document d2 = new Document();
d2.append("name", "红楼梦").append("author", "曹雪芹");
collections.add(d2);
c.insertMany(collections);

当然也可以通过 Robo 3T查看修改结果：db.集合名.find()
在这里插入图片描述

修改操作
可以修改查到的第一条数据，操作如下：

c.updateOne(Filters.eq("author", "罗贯中"), new Document("$set", new Document("name",

上例中小伙伴们也看到了修改器要如何使用，不管是inc，用法都一致，我这里不再一个一个演示。也可以修改查到的所有数据，如下：

c.updateMany(Filters.eq("author", "罗贯中"), new Document("$set", new Document("name", "三国演义456")));

删除操作

可以删除查到的一条数据，如下：

c.deleteOne(Filters.eq("author", "罗贯中"));

也可以删除查到的所有数据：

c.deleteMany(Filters.eq("author", "罗贯中"));

Filters里边还有其他的查询条件，都是见名知意，不赘述。

查询操作

可以直接查询所有文档：

FindIterable<Document> documents = c.find();
MongoCursor<Document> iterator = documents.iterator();
while (iterator.hasNext()) {System.out.println(iterator.next());
}

也可以按照条件查询：

FindIterable<Document> documents = c.find(Filters.eq("author", "罗贯中"));
MongoCursor<Document> iterator = documents.iterator();
while (iterator.hasNext()) {System.out.println(iterator.next());
}

方式二`SpringBoot`

主要讲解SpringBoot操作MongoDB实现增删改查的功能

环境准备

1、pom.xml引入依赖

   <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-mongodb</artifactId></dependency>

创建application.yml

spring:application:name: mongo-testdata:mongodb:host: 192.168.1.8port: 27017database: testusername: mongopassword: '1213' # 密码按char[]处理。纯数字要加单引号，最好都加单引号authentication-database: adminauto-index-creation: true # 仅声明索引注解无效，必须显式声明。logging:level:root: warncom:example: debugpattern:console: '%-5level %C.%M[%line] - %msg%n'

概述

Spring Data

Spring 数据框架 JPA 、Redis、Elasticsearch、AMQP、MongoDB

`JdbcTemplate`
`RedisTemplate`
`ElasticTempalte`
`AmqpTemplate`
`MongoTemplate`

创建实体类

创建包com.changan.mongodb，包下建包entiy 用于存放实体类，创建实体类

package com.yanyu.mongotest.entity;import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;import java.io.Serializable;
@Data
@Document(collection = "student")
public class Student implements Serializable {@Idprivate Long id;private String name;private String sex;private String age;private String introduce;}

创建数据访问接口

com.changan.mongodb包下创建dao包，包下创建接口

package com.yanyu.mongotest.service;import com.yanyu.mongotest.entity.Student;import java.util.List;public interface StudentDao {void save(Student student);void update(Student student);List<Student> findAll();void delete(Integer id);
}

创建业务逻辑类

com.changan.mongodb包下创建impl包，包下创建类

package com.yanyu.mongotest.service;import com.yanyu.mongotest.entity.Student;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
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 org.springframework.stereotype.Component;import java.util.List;@Component
public class StudentDaoImpl implements StudentDao {@Autowiredprivate MongoTemplate mongoTemplate;/*** 新增信息* @param student*/@Overridepublic void save(Student student) {mongoTemplate.save(student);}/*** 修改信息* @param student*/@Overridepublic void update(Student student) {//修改的条件Query query = new Query(Criteria.where("id").is(student.getId()));//修改的内容Update update = new Update();update.set("name",student.getName());mongoTemplate.updateFirst(query,update,Student.class);//单条更新mongoTemplate.updateFirst(query, update, User.class);//多条更新mongoTemplate.updateMulti(query, update, User.class);//更新插入mongoTemplate.upsert(query,update,User.class);//返回值均为 updateResult//System.out.println("匹配条数:" + updateResult.getMatchedCount());//System.out.println("修改条数:" + updateResult.getModifiedCount());//System.out.println("插入id_:" + updateResult.getUpsertedId());}/*** 查询所有信息* @return*/@Overridepublic List<Student> findAll() {return mongoTemplate.findAll(Student.class);}/*** 根据id查询所有信息* @param id*/@Overridepublic void delete(Integer id) {Student byId = mongoTemplate.findById(id,Student.class);mongoTemplate.remove(byId);}}

常见查询

Criteria 是 Java Persistence API (JPA) 中的一个类，用于构建类型安全的查询。它提供了一种在不使用字符串查询语言（如 JPQL 或 SQL）的情况下创建查询的方式。通过使用 Criteria 类，你可以以编程方式构建查询，从而避免因手动编写查询字符串而产生的错误。

 @Testpublic void testQuery(){//基于 id 查询template.findById("1",User.class);//查询所有template.findAll(User.class);template.find(new Query(),User.class);//等值查询template.find(Query.query(Criteria.where("name").is("编程不良人")), User.class);// > gt  < lt  >= gte  <= ltetemplate.find(Query.query(Criteria.where("age").lt(25)),User.class);template.find(Query.query(Criteria.where("age").gt(25)),User.class);template.find(Query.query(Criteria.where("age").lte(25)),User.class);template.find(Query.query(Criteria.where("age").gte(25)),User.class);//andtemplate.find(Query.query(Criteria.where("name").is("编程不良人").and("age").is(23)),User.class);//orCriteria criteria = new Criteria().orOperator(Criteria.where("name").is("编程不良人_1"),Criteria.where("name").is("编程不良人_2"));template.find(Query.query(criteria), User.class);//and orCriteria criteria1 = new Criteria().and("age").is(23).orOperator(Criteria.where("name").is("编程不良人_1"),Criteria.where("name").is("编程不良人_2"));template.find(Query.query(criteria1), User.class);//sort 排序Query query = new Query();query.with(Sort.by(Sort.Order.desc("age")));//desc 降序  asc 升序template.find(query, User.class);//skip limit 分页Query queryPage = new Query();queryPage.with(Sort.by(Sort.Order.desc("age")))//desc 降序  asc 升序.skip(0) //起始条数.limit(4); //每页显示记录数template.find(queryPage, User.class);//count 总条数template.count(new Query(), User.class);//distinct 去重//参数 1:查询条件 参数 2: 去重字段  参数 3: 操作集合  参数 4: 返回类型template.findDistinct(new Query(), "name", User.class, String.class);//使用 json 字符串方式查询 Query query = new BasicQuery("{$or:[{name:'编程不良人'},{name:'徐凤年'}]}", "{name:0}");template.find(query, User.class);}

创建测试类

package com.yanyu.mongotest;import com.yanyu.mongotest.entity.Student;
import com.yanyu.mongotest.service.StudentDao;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;import java.util.List;@SpringBootTest
class MongoTestApplicationTests {@Autowiredprivate StudentDao studentDao;/*** 查询所有信息*/@Testpublic void findAll() {List<Student> all = studentDao.findAll();System.out.println(all.size());}/*** 新增信息*/@Testpublic void save() {Student student = new Student();student.setId(6l);student.setName("宋人头");studentDao.save(student);}/*** 修改信息*/@Testpublic void update() {Student student = new Student();student.setId(6l);student.setName("吴很帅");studentDao.update(student);}/*** 删除信息*/@Testpublic void delete() {studentDao.delete(6);}}