1. 背景

本节使用 Java 操作 mongDB。

2.知识

MongoDB 简介

MongoDB是一个文档型数据库，它将数据存储在类似json的文档中。

特点：

数据以JSON方式存储，处理数据最自然，支持数组和嵌套对象。
查询也以JSON方式，支持筛选和排序，聚合。

Spring Data MongoDB 简介

我们使用 Spring Data MongoDB 类库来操作 MongoDB。

Spring Data for MongoDB是 Spring Data 项目的一部分，该项目旨在为新数据存储提供熟悉且一致的基于 Spring 的编程模型，同时保留特定于存储的特性和功能。

文档主页：https://spring.io/projects/spring-data-mongodb#overview

3. SpringBoot 项目中集成 MongoDB

1、添加依赖
在的 pom.xml 文件中编辑：

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

2、配置数据连接的信息
在 application.yml 编辑：
如下所示，配置了mongoDB 的服务地址，端口，连接账户密码等。

spring:
  data:
    mongodb:
      host: "localhost"
      port: 27017
      username: "root"
      password: "123456"
      database: "new_db"
      authentication-database: "admin"

3、配置注入的 MongoTemplate

实际已经能访问了，这一步是可选操作。

@Configuration
public class MongoConfig {
    /*
    在开发过程中，如果com.mongodb.WriteResult任何 MongoDB 操作返回的包含错误，记录或抛出异常是很方便的。
    在开发过程中忘记这样做是很常见的，然后最终得到一个看起来运行成功的应用程序，而实际上，数据库并没有按照您的预期进行修改。
    您可以将 的WriteResultChecking属性设置为MongoTemplate以下值之一：EXCEPTION或NONE，分别用于抛出Exception或不执行任何操作。
    默认值是使用 的WriteResultChecking值NONE。
     */
    @Bean
    MongoTemplate mongoTemplate(MongoDatabaseFactory factory, MongoConverter converter) {
        MongoTemplate mongoTemplate = new MongoTemplate(factory, converter);
        mongoTemplate.setWriteResultChecking(WriteResultChecking.EXCEPTION);
        return mongoTemplate;
    }

}

4. 代码示例

下面写个基本增删改查。

先要配置实体类
比如我写了个简单的实体类。

@Document 注解，它指定了 collection 的名字，类似数据库的表
@Id 注解，指定了 mongoDB 的 Id 字段，对应 _id 字段。

/**
 * 存货
 */
@Data
@Document(collection = "inventory")
public class Inventory implements Serializable {
    @Id
    String _id;
    String item;
    String status;
    String size;
    List<String> instock;

}

查询全部

    public List<Inventory> getEntityList() {
        Query query = new Query();
        return mongoTemplate.find(query, Inventory.class);
    }

插入一条记录

    public Inventory insert(Inventory myEntity) {
        Inventory insert = mongoTemplate.insert(myEntity);
        return insert;
    }

计算count

    public long count() {
        Query query = new Query();
        return mongoTemplate.count(query, Inventory.class);
    }

查询一条记录

    public Inventory selectOne(String id) {
        return mongoTemplate.findById(id, Inventory.class);
    }

查询多条记录

    public List<Inventory> findSome(Object itemName) {
        Query query = new Query();
        query.addCriteria(Criteria.where("item").is(itemName));
        return mongoTemplate.find(query, Inventory.class);
    }

按ID删除

    public Inventory deleteById(String id) {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is(id));
        return mongoTemplate.findAndRemove(query, Inventory.class);
    }

按ID更新记录

    public long updateById(String id, String status) {
        Query query = new Query(Criteria.where("_id").is(id));
        Update update = new Update();
        update.set("status", status);
        UpdateResult updateResult = mongoTemplate.updateFirst(query, update, Inventory.class);
        long modifiedCount = updateResult.getModifiedCount();
        return modifiedCount;
    }

模糊查询

    
    public List<Inventory> selectList(String itemName, int pageIndex, int pageSize) {
        // 使用正则的查询
        Query query = new Query(Criteria.where("item").regex("^.*" + itemName + ".*$"))
                .skip((pageIndex - 1) * pageSize)
                .limit(pageSize);
        return mongoTemplate.find(query, Inventory.class);
    }

创建索引

    public void createIndex(String filedName) {
        IndexOptions indexOptions = new IndexOptions();
        indexOptions.unique(false);//是否唯一索引
        Bson ascending = Indexes.ascending(filedName);
        mongoTemplate.getCollection("inventory").createIndex(ascending, indexOptions);
    }

查看有哪些索引

    public List<String> getAllIndex2() {
        ListIndexesIterable<Document> lst = mongoTemplate.getCollection("inventory").listIndexes();
        List<String> result = StreamSupport.stream(lst.spliterator(), false).map(Document::toString).collect(Collectors.toList());
        return result;
    }