MongoDB基本操作

• 1.Docker安装MongoDb
• 2.数据库操作
• 3.集合操作
• 4.文档操作
• 5.SpringBoot集成MongoDB
• • 5.1.基于MongoTemplate 的CRUD
  • 5.2.基于MongoRepository的CRUD

MongoDB中文文档

注意

• 文档中的键/值对是有序的
• MongoDB区分类型和大小写
• MongoDB的文档不能有重复的键
• 键不能含有 (空字符)。这个字符用来表示键的结尾
• .和$有特别的意义，只有在特定环境下才能使用
• 以下划线"_"开头的键是保留的(不是严格要求的)

#拉取镜像 
docker pull mongo:latest

#创建和启动容器 
docker run -d --restart=always -p 27017:27017 --name mymongo -v /data/db:/data/db -d mongo

#进入容器 
docker exec -it mymongo/bin/bash 

#使用MongoDB客户端进行操作 
mongo 

#查询所有的数据库 
show dbs 

• Help查看命令提示 db.help()
• 切换/创建数据库 use 数据库名
• 查询所有数据库 show dbs
• 查看当前使用的数据库 db.getName()
• 显示当前db状态 db.stats()
• 当前db版本db.version()
• 查看当前db的链接机器地址 db.getMongo
• 删除当前使用数据库 db.dropDatabase()

• 创建集合（表）db.createCollection( "集合名")
• 查看数据库中所有集合（表） show collections
• 得到指定名称的集合 db.getCollection("集合名")
• 查看集合状态 db.printCollectionStats()
• 删除集合db.集合名.drop()

• 插入文档 db.集合名.save({name:'zhangsan',age:21,sex:true})
• 查询所有文档 db.集合名.find()
• 条件查询

db.User.find({name:"zhangsan"})
相当于
select * from User where name = 'zhangsan';

db.User.find({age:21}, {'name':1, 'age':1})
相当于
select name, age from User where age = 21;

db.User.find().sort({age:1})
相当于
select * from User order by age;

db.User.find().skip(0).limit(3)
相当于
select * from User skip 2 limit 3；

db.User.find({age:{$in:[21,26,32]}})
相当于
select * from User where age in (21, 26, 32)；

db.User.find({age:{$gt:20}}).count()
相当于
select count(*) from User where age >20;

db.User.find({$or:[{age:21}, {age:28}]})
相当于
select * from User where age = 21 or age = 28

db.User.find({name:"zs", age:28})
相当于
select * from User where name ='zs' and age = 28;

• 更新文档

db.User.update({name:"zhangsan"}, {$set:{age:100, sex:0}})
相当于
update Userset age = 100, sex = 0 where name = 'user1'

• 删除文档

根据id删除
db.User.remove(id)
删除所有
db.User.remove({})

• 聚合操作

• 创建索引 db.User.createIndex({"name":1})

1、创建SpringBoot工程

2、导入依赖

	org.springframework.boot
    spring-boot-starter-data-mongodb
    2.6.6

3、配置文件application.yml中添加

#配置mongoDB地址
spring:
  data:
    mongodb:
    	  #mongodb://192.168.140.100:27017/数据名.集合名
      uri: mongodb://192.168.140.100:27017/why_datebase.test

• 添加文档

    @Autowired
    private MongoTemplate mongoTemplate;

    @Test
    void testInsert() {
        User user = new User();
        user.setName("陈三");
        user.setAge(25);
        //向User表中插入数据
        User user1 = mongoTemplate.insert(user);
    }

• 查询表中所有文档

    @Test
    void testFind(){
        List all = mongoTemplate.findAll(User.class);
        for (User user : all) {
            System.err.println(user);
        }
    }

• 根据id查询

   @Test
    void testFindById(){
        //根据id查询
        User user = mongoTemplate.findById("625c06dae63b0056f5f21fc8", User.class);
        System.err.println(user);
    }

• and查询

    @Test
    void findUserListAnd(){
        Query query = new Query(Criteria.where("name").is("张三").and("age").is(25));
        //条件查询 where name = '张三' and age = 25
        List users = mongoTemplate.find(query, User.class);
        System.err.println(users);
    }

• or查询

    @Test
    void findUserListOr(){
        //条件查询：where name = '张三' or id = ‘625c066b8d584444626116ae’
        Criteria name = Criteria.where("name").is("张三");
        Criteria id = Criteria.where("id").is("625c066b8d584444626116ae");
        Criteria criteria = new Criteria();
        //合并or的查询条件
        criteria.orOperator(name,id);
        Query query = new Query();
        query.addCriteria(criteria);
        List users = mongoTemplate.find(query, User.class);
        System.err.println(users);
    }

• 模糊查询

    @Test
    void testLike(){
        String name = "三";
        String regex = String.format("%s%s%s","^.*",name,".*$");
        //Pattern.CASE_INSENSITIVE : 忽略大小写
        Pattern pattern = Pattern.compile(regex,Pattern.CASE_INSENSITIVE);
        Query query = new Query(Criteria.where("name").regex(pattern));
        //这样写也可以
        //Query query = new Query(Criteria.where("name").regex("三"));
        //模糊查询 where name like '三'
        List users = mongoTemplate.find(query, User.class);
        for (User user : users) {
            System.err.println(user);
        }
    }

• 分页查询

    @Test
    void findPage(){
        //分页查询
        Integer pageNo = 1;
        Integer pageSize = 2;
        Query query = new Query(Criteria.where("age").is(25));
        //查询记录数
        long count = mongoTemplate.count(query, User.class);
        System.err.println("表中记录数量为："+count);
        //分页  skip:指定起始页，limit:指定每页记录数
        query.skip((pageNo-1)*pageSize).limit(pageSize);
        List users = mongoTemplate.find(query, User.class);
        for (User user : users) {
            System.err.println(user);
        }
    }

• 更新文档

    @Test
    void testUpdate(){
        //根据id查询记录
        User user = mongoTemplate.findById("625cfda8fe25dc25be4edd26", User.class);
        //设置要修改的值
        user.setName("裂空座");
        user.setAge(30);
        user.setEmail("246786324@qq.com");
        //修改
        Query query = new Query(Criteria.where("id").is(user.getId()));
        Update update = new Update();
        update.set("name",user.getName());
        update.set("age",user.getAge());
        update.set("email",user.getEmail());
        UpdateResult upsert = mongoTemplate.upsert(query, update, User.class);
        long matchedCount = upsert.getMatchedCount();
        System.err.println("影响行数："+matchedCount);
    }

• 删除文档

    @Test
    void testRemove(){
        Query query = new Query(Criteria.where("id").is("625cf65138b887613da7d143"));
        DeleteResult remove = mongoTemplate.remove(query, User.class);
        long deletedCount = remove.getDeletedCount();
        System.err.println("删除记录数量："+deletedCount);
    }

• 插入文档

    @Autowired
    private UserRepository userRepository;

    @Test
    void testInsert() {
        User user = new User();
        user.setName("水箭龟");
        user.setAge(12);
        User save = userRepository.save(user);
        System.err.println(save);
    }

• 查询所有

    @Test
    void testFind(){
        //查询User表中所有数据
        List users = userRepository.findAll();
        for (User user : users) {
            System.err.println(user);
        }
    }

• 根据Id查找

    @Test
    void testFindById(){
        //根据id查询
        User user = userRepository.findById("625cf664e8279d312cf32095").get();
        System.err.println(user);
    }

• and查询

    @Test
    void findUserListAnd(){
        //条件查询 where name = '喷火龙' and age = 11
        User user = new User();
        user.setName("喷火龙");
        user.setAge(11);
        Example example = Example.of(user);
        List users = userRepository.findAll(example);
        for (User user1 : users) {
            System.err.println(user1);
        }
    }

• 模糊查询

    @Test
    void testLike(){
        //模糊查询 where email like '126'
        //设置模糊查询的匹配规则
        ExampleMatcher matcher = ExampleMatcher.matching()
                .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING) //containing包含
                .withIgnoreCase(true);//忽略大小写
        User user = new User();
        user.setEmail("126");
        Example example = Example.of(user,matcher);
        List users = userRepository.findAll(example);
        for (User user1 : users) {
            System.err.println(user1);
        }
    }

• 分页查询

    @Test
    void findPage(){
        //分页查询
        //page：0表示第一页，1表示第二也......
        Pageable pageable = PageRequest.of(1, 3);
        Page page = userRepository.findAll(pageable);
        int totalPages = page.getTotalPages();
        List users = page.getContent();
        long totalElements = page.getTotalElements();
        System.err.println("总页数："+totalPages);
        System.err.println(users);
        System.err.println("总记录条数："+totalElements);
    }

• 更新文档

    @Test
    void testUpdate(){
        //根据id查询记录
        User user = userRepository.findById("625cf664e8279d312cf32095").get();
        user.setAge(20);
        user.setEmail("8888888@qq.com");
        //修改
        //save(): 如果id值存在就修改，如果id值不存在就添加
        User save = userRepository.save(user);
        System.err.println(save);
    }

• 删除文档

    @Test
    void testRemove(){
        userRepository.deleteById("625cf77371fb253316589586");
        //userRepository.deleteAll(); 删除所有
    }