mongodb学习笔记

阅读数: 次 2022-01-17

mongodb学习笔记

一、介绍

1、mongodb

MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。

MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。

2、nosql数据库

NoSQL(NoSQL = Not Only SQL )，意即”不仅仅是SQL”。

反之非关系型数据库。

3、mongodb特点

（1）海量数据存储

（2）非结构化

二、mongodb安装

1、docker拉取镜像

2、安装

3、测试

进入admin库，创建用户admin，123456

三、mongodb概念

1、和mysql对比

2、数据存储对比

类似json的格式，叫bson格式。

3、数据库

一个mongodb中可以建立多个数据库。

查看所有数据库：show dbs

查看当前数据库：db

切换数据库：use 数据库名

4、客户端工具

MongoDB Compass

Robo 3T

navicat for mongodb

四、数据库操作

1、连接

（1）客户端连接

标准 URI 连接语法：

1	mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]

（2）本地命令行

通过 shell 连接 MongoDB 服务：

$ ./mongo

（3）docker

//连接
docker   exec  -it   mongo   mongo   数据库名
//认证
db.auth("用户名","密码")

2、数据库的操作

db.createUser({ user:’admin’,pwd:’123456’,roles:[ { role:’root’, db: ‘admin’}]});

（1）创建和切换数据库

1	use DATABASE_NAME

如果数据库不存在，则创建数据库，否则切换到指定数据库。

（2）删除数据库

1	db.dropDatabase()

删除当前数据库，默认为 test，你可以使用 db 命令查看当前数据库名。

3、集合操作

(1)创建集合

1	db.createCollection(name,option)

（2）删除集合

1	db.collectionName.drop()

4、文档操作

（1）插入文档

1
2
3

db.COLLECTION_NAME.insert(document)
或
db.COLLECTION_NAME.save(document)

3.2 版本之后新增了 db.collection.insertOne() 和 db.collection.insertMany()

db.collection.insertOne(
   <document>,
   {
      writeConcern: <document>
   }
)

db.collection.insertMany(
   [ <document 1> , <document 2>, ... ],
   {
      writeConcern: <document>,
      ordered: <boolean>
   }
)

（2）查询文档

1	db.collection.find(query, projection)

查询所有：

查询部分：

操作	格式	范例	RDBMS中的类似语句
等于	`{<key>:<value>`}	`db.col.find({"by":"菜鸟教程"}).pretty()`	`where by = '菜鸟教程'`
小于	`{<key>:{$lt:<value>}}`	`db.col.find({"likes":{$lt:50}}).pretty()`	`where likes < 50`
小于或等于	`{<key>:{$lte:<value>}}`	`db.col.find({"likes":{$lte:50}}).pretty()`	`where likes <= 50`
大于	`{<key>:{$gt:<value>}}`	`db.col.find({"likes":{$gt:50}}).pretty()`	`where likes > 50`
大于或等于	`{<key>:{$gte:<value>}}`	`db.col.find({"likes":{$gte:50}}).pretty()`	`where likes >= 50`
不等于	`{<key>:{$ne:<value>}}`	`db.col.find({"likes":{$ne:50}}).pretty()`	`where likes != 50`

多条件，默认是and连接。

or连接：

（3）更新文档

MongoDB 使用 update() 和 save() 方法来更新集合中的文档。

db.collection.update(
   <query>,
   <update>,
   {
     upsert: <boolean>,
     multi: <boolean>,
     writeConcern: <document>
   }
)

（4）删除文档

db.collection.remove(
   <query>,
   {
     justOne: <boolean>,
     writeConcern: <document>
   }
)

5、索引操作

索引是提高查询效率。

1	>db.collection.createIndex(keys, options)

语法中 Key 值为你要创建的索引字段，1 为指定按升序创建索引，如果你想按降序来创建索引指定为 -1 即可。

6、排序

sort({字段名:升序和降序})

升序 1

降序 -1

7、分页

limit()

1	>db.COLLECTION_NAME.find().limit(NUMBER)

8、聚合

达式	描述	实例
$sum	计算总和。	db.mycol.aggregate([{$group : {_id : “$by_user”, num_tutorial : {$sum : “$likes”}}}])
$avg	计算平均值	db.mycol.aggregate([{$group : {_id : “$by_user”, num_tutorial : {$avg : “$likes”}}}])
$min	获取集合中所有文档对应值得最小值。	db.mycol.aggregate([{$group : {_id : “$by_user”, num_tutorial : {$min : “$likes”}}}])
$max	获取集合中所有文档对应值得最大值。	db.mycol.aggregate([{$group : {_id : “$by_user”, num_tutorial : {$max : “$likes”}}}])

五、springboot整合spring-data-mongoDB

1、创建一个springboot项目

2、导入依赖

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

3、配置mongodb

spring:
  #数据源配置
  data:
    mongodb:
      #主机地址
      host: 47.97.254.33
      #默认端口是27017
      port: 27017
      #数据库
      database: yan
      #用户名（用户必须具有读写文档的权限）
      username: un1queyan
      #密码（使用单引号引起来）
      password: '123456'
      #也可以使用uri连接
      #uri: mongodb://47.97.254.33:27017/hs
      #如果数据库需要密码认证
      #uri: mongodb://admin:123456@47.97.254.33:27017/hs

4、实体类映射

package com.example.springbootdatamongo.mongo.domain;

import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;

import java.util.Date;

@Data
@Document(collection = "student")
public class Student {

    @Id
    private   int  id;
    private  int  sid;
//    @Field(name = "sname")
    private  String  sname;
    private  String  age;
    private  String  sex;
    private Date   begin;
}

5、Dao编写

package com.example.springbootdatamongo.mongo.dao;

import com.example.springbootdatamongo.mongo.domain.Student;
import org.springframework.data.mongodb.repository.MongoRepository;

public interface StudentDao extends MongoRepository<Student,String> {
}

6、测试

package com.example.springbootdatamongo;

import com.example.springbootdatamongo.mongo.dao.StudentDao;
import com.example.springbootdatamongo.mongo.domain.Student;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.Date;

@SpringBootTest
class SpringBootDataMongoApplicationTests {
    @Autowired
    private StudentDao  studentDao;

    @Test
    void   test1(){
        Student  student=new Student();
        student.setSid(1009);
        student.setSname("ljh");
        student.setAge("30");
        student.setBegin(new Date());

        student  = studentDao.insert(student);
        System.out.println(student);
    }
}

7、文档CRUD

（1）添加文档

@Test
    void   test1(){
        Student  student=new Student();
        student.setSid(1009);
        student.setSname("ljh");
        student.setAge("30");
        student.setBegin(new Date());

        student  = studentDao.insert(student);
        System.out.println(student);
    }

（2）查询文档

查询所有：

@Test
void   test2(){
    List<Student> all = studentDao.findAll();
    all.forEach(System.out::println);
}

查询单个：

@Test
void   test3(){
    Optional<Student> optional = studentDao.findById("61ca86f87e23536b789be572");
    System.out.println(optional.get());
}

排序：

@Test
void   test4(){
    Sort  sort=Sort.by(Sort.Order.desc("age"));
    studentDao.findAll(sort);
}

分页：

@Test
void   test5(){
    Pageable   page=Pageable.ofSize(2);
    Page<Student> studentPage = studentDao.findAll(page);
    List<Student> students = studentPage.getContent();

    students.forEach(System.out::println);
}

（3）修改文档

@Test
void   test6(){
    Student  student=new Student();
    student.setId("61ca86f87e23536b789be572");
    student.setSname("ljh22222");

    studentDao.save(student);
}

（4）删除文档

@Test
void   test7(){
    studentDao.deleteAll();
}

@Test
void   test8(){
    studentDao.deleteById("61ca86f87e23536b789be572");
}