一、前端篇
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`
相关注解讲解
@Document是一个注解，用于修饰类。它的作用是将这个类的一个对象映射为 MongoDB 中一条文档数据。属性value和collection用来指定操作的集合名称。@Id是一个注解，用于修饰成员变量或方法。它的作用是将成员变量的值映射为文档的_id的值。@Field是一个注解，用于修饰成员变量或方法。它的作用是将成员变量以及值映射为文档中的一个键值对。属性name和value用来指定在文档中的键的名称，默认为成员变量名。@Transient是一个注解，用于修饰成员变量或方法。它的作用是指定该成员变量不参与文档的序列化。
创建实体类
创建包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);}}
2.2python调用MongoDB
分布式数据库NoSQL(七)——Python 访问MongoDB
