MongoDB 学习笔记4 - Java 使用 MongoDB

2021-07-28 11:02:18 浏览数 (1)

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 文件中编辑:

代码语言:javascript复制
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>

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

代码语言:javascript复制
spring:
  data:
    mongodb:
      host: "localhost"
      port: 27017
      username: "root"
      password: "123456"
      database: "new_db"
      authentication-database: "admin"

3、配置注入的 MongoTemplate

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

代码语言:javascript复制
@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 字段。
代码语言:javascript复制
/**
 * 存货
 */
@Data
@Document(collection = "inventory")
public class Inventory implements Serializable {
    @Id
    String _id;
    String item;
    String status;
    String size;
    List<String> instock;

}

查询全部

代码语言:javascript复制
    public List<Inventory> getEntityList() {
        Query query = new Query();
        return mongoTemplate.find(query, Inventory.class);
    }

插入一条记录

代码语言:javascript复制
    public Inventory insert(Inventory myEntity) {
        Inventory insert = mongoTemplate.insert(myEntity);
        return insert;
    }

计算count

代码语言:javascript复制
    public long count() {
        Query query = new Query();
        return mongoTemplate.count(query, Inventory.class);
    }

查询一条记录

代码语言:javascript复制
    public Inventory selectOne(String id) {
        return mongoTemplate.findById(id, Inventory.class);
    }

查询多条记录

代码语言:javascript复制
    public List<Inventory> findSome(Object itemName) {
        Query query = new Query();
        query.addCriteria(Criteria.where("item").is(itemName));
        return mongoTemplate.find(query, Inventory.class);
    }

按ID删除

代码语言:javascript复制
    public Inventory deleteById(String id) {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is(id));
        return mongoTemplate.findAndRemove(query, Inventory.class);
    }

按ID更新记录

代码语言:javascript复制
    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;
    }

模糊查询

代码语言:javascript复制
    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);
    }

创建索引

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

查看有哪些索引

代码语言:javascript复制
    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;
    }

6. 扩展

我的代码示例见:https://github.com/vir56k/java_demo/tree/master/mongo_demo

7.参考:

https://docs.spring.io/spring-boot/docs/current/reference/html/features.html#features.nosql.mongodb

https://spring.io/projects/spring-data-mongodb#overview

https://www.jianshu.com/p/7cdf2761a9f3

https://github.com/spring-projects/spring-data-book

https://docs.spring.io/spring-data/mongodb/docs/3.2.3/reference/html/#mongo-template.instantiating

END

0 人点赞