Docker安装MongoDB
1、拉取镜像
docker pull mongo:4.4
2、创建mongo数据持久化目录
mkdir /home/mongodb/data -p
3、运行容器
docker run -itd --name mongo -v /home/mongodb/data:/data/db -p 27017:27017 mongo:4.4 --auth
4、登录mongo容器，并进入到【admin】数据库
docker exec -it mongo mongo admin
5、创建一个用户，mongo 默认没有用户
db.createUser({ user:'root',pwd:'123456',roles:[ { role:'userAdminAnyDatabase', db: 'admin'},'readWriteAnyDatabase']});
【user:‘root’ 】：设置用户名为root
【pwd:‘123456’】：设置密码为123456
【role:‘userAdminAnyDatabase’】：只在admin数据库中可用，赋予用户所有数据库的userAdmin权限
【db: ‘admin’】：可操作的数据库
【‘readWriteAnyDatabase’】：赋予用户读写权限
6、连接mongo数据库
db.auth('root', '123456')
7、测试数据库，插入一条语句
db.user.insert({"name":"zhangsan","age":18})
8、测试数据库，查询刚才插入的语句
db.user.find()
SpringBoot整合mongoDB
1、添加依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId> <version>2.3.9.RELEASE</version> </dependency>
2、添加yml配置
spring: data: mongodb: uri: mongodb://root:123456@192.168.233.128:27017/admin
3、测试
package cn.tedu.springboot_quick; import cn.tedu.springboot_quick.entity.mongo.Person; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.data.domain.Sort; 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 java.util.List; @SpringBootTest class MongoDBTests { @Autowired public MongoTemplate mongoTemplate; /** * 保存 */ @Test public void save() { Person person = new Person(); person.setName("张三"); person.setAge(18); mongoTemplate.save(person); } /** * 多条件查询 */ @Test public void find() { //设置查询条件 age小于30,且person_name="张三" Criteria criteria = Criteria.where("age").lt(30) .and("person_name").is("张三"); //设置查询条件 Query query = new Query(criteria); //查询 List<Person> list = mongoTemplate.find(query, Person.class); for (Person person : list) { System.out.println(person); } } /** * 分页查询 */ @Test public void findPage() { //设置查询条件 age小于30,且person_name="张三" Criteria criteria = Criteria.where("age").lt(30) .and("person_name").is("张三"); //根据条件 查询总数 Query queryCount = new Query(criteria); long count = mongoTemplate.count(queryCount, Person.class); //查询当前页的数据列表, 查询第二页，每页查询2条 Query queryLimit = new Query(criteria) .with(Sort.by(Sort.Order.desc("age"))) .limit(2)//每页查询条数 .skip(0); //从第几页开始 （page-1）*size List<Person> list = mongoTemplate.find(queryLimit, Person.class); for (Person person : list) { System.out.println(person); } } /** * 更新数据 */ @Test public void update() { //设置查询条件 person_name="张三",且 age等于18 Criteria criteria = Criteria.where("person_name").is("张三").and("age").is(18); //设置更新条件 Query query = new Query(criteria); //设置更新数据 Update update = new Update(); update.set("name", "李四"); update.set("address","新华联梦想城"); mongoTemplate.upsert(query, update, Person.class); } /** * 删除数据 */ @Test public void dlete() { mongoTemplate.remove(Query.query(Criteria.where("person_name").is("王五")), Person.class); } }
