springboot分布式文件存储数据库mongod-kb88凯时官网登录

目录

• 1、mongodb服务
• 2、创建springboot项目
• 3、添加mongodb依赖
• 4、application.yml配置
• 5、实体类
• 6、通过mongorepository实现增删改查
• 7、通过mongotemplate实现增删改查
• 8、测试

mongodb 是一个基于分布式文件存储的数据库。由 c 语言编写，旨在为 web 应用提供可扩展的高性能数据存储kb88凯时官网登录的解决方案。

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

1、mongodb服务

mongodb的安装支持windows和linux等平台，具体在不同平台的下载安装请查看相关大佬博文。

2、创建springboot项目

此处通过idea工具创建，springboot选择2.7.0版本，具体不再描述。

3、添加mongodb依赖

spring data mongdb 是spring data的下的一个模块，在springboot中整合mongodb就需要添加spring data mongdb的依赖，添加spring data mongdb依赖的方式有两种：

创建springboot项目时勾选spring data mongodb

在pom.xml文件中添加spring data mongodb依赖

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

4、application.yml配置

spring:
  data:
    mongodb:
      uri: mongodb://127.0.0.1:27017/mongodb_test

或

spring:
  data:
    mongodb:
      host: 127.0.0.1 #指定mongodb服务地址
      port: 27017 #指定端口，默认就为27017
      database: mongodb #指定使用的数据库(集合)
      authentication-database: admin # 登录认证的逻辑库名
      username: admin #用户名
      password: abc123456 #密码

mongodb数据库与mysql不一样 mysql 一个普通用户可以管理多个数据库，但是mongo每一个库都有一个独立的管理用户，连接时需要输入对应用户密码。

5、实体类

@data
@document(collection = "article") //指定要对应的文档名（表名）
@accessors(chain = true) //链式访问
public class article {
    /**
     * 文章主键
     */
    @id
    private string id;
    /**
     * 文章名
     */
    private string name;
    /**
     * 文章内容
     */
    private string content;
}

@data
@document(collection = "book")
public class book {
    @id
    private string id;
    private string name;
    private string type;
    private string description;
}

其中注解含义如下：

• @document，文档是 mongodb 中最基本的数据单元，由键值对组成，类似于 json 格式，可以存储不同字段，字段的值可以包括其他文档，数组和文档数组；
• @id（主键）：用来将成员变量的值映射为文档的_id的值；
• @indexed（索引）： 索引是一种特殊的数据结构，存储在一个易于遍历读取的数据集合中，能够对数据库文档中的数据进行排序。索引能极大提高文档查询效率，如果没有设置索引，mongodb 会遍历集合中的整个文档，选取符合查询条件的文档记录。这种查询效率是非常低的；
• @field（字段）： 文档中的字段，类似于 mysql 中的列；
• @aggregation（聚合）： 聚合主要用于数据处理，例如统计平均值、求和等；

6、通过mongorepository实现增删改查

持久层继承mongorepository

public interface articlerepository extends mongorepository {
    /**
     * 根据id查询文章
     * @param id
     * @return
     */
    list
 findbyid(string id);
}

注意，接口需要起名findby 主键名，否则会报找不到属性的错误。

业务层

@service
@requiredargsconstructor
public class articleservice {
    private final articlerepository articlerepository;
    /**
     * 添加文章
     *
     * @param article
     * @return
     */
    public int create(article article) {
        article save = articlerepository.save(article);
        return 1;
    }
    /**
     * 删除文章
     *
     * @param ids
     */
    public int delete(list ids) {
        list
 deletelist = new arraylist<>();
        for(string id:ids){
            article article = new article();
            article.setid(id);
            deletelist.add(article);
        }
        articlerepository.deleteall(deletelist);
        return ids.size();
    }
    /**
     * 查询文章
     * @param id
     * @return
     */
    public list
 get(string id) {
        return articlerepository.findbyid(id);
    }
}

控制层

@restcontroller
@requestmapping("/article")
@requiredargsconstructor
public class articlecontroller {
    private final articleservice articleservice;
    @postmapping("/create")
    public string create(@requestbody article article) {
        int result = articleservice.create(article);
        if (result > 0) {
            return "文章创建成功";
        } else {
            return "文章创建失败";
        }
    }
    @postmapping("/delete")
    public string delete(@requestparam("ids") list ids) {
        int count = articleservice.delete(ids);
        if (count > 0) {
            return "删除了"   count   "篇文章";
        } else {
            return "删除文章失败";
        }
    }
    @postmapping("/get")
    public list
 get(string id) {
        list
 list = articleservice.get(id);
        return list;
    }
}

7、通过mongotemplate实现增删改查

业务层

@service
@requiredargsconstructor
public class bookservice {
    private final mongotemplate mongotemplate;
    /**
     * 添加文章
     *
     * @param book
     * @return
     */
    public int create(book book) {
        book save = mongotemplate.save(book);
        return 1;
    }
    /**
     * 删除文章
     *
     * @param id
     */
    public int delete(string id) {
        list deletelist = new arraylist<>();
        query query = new query();
        query.addcriteria(criteria.where("id").is(id));
        mongotemplate.remove(query,book.class);
        return 1;
    }
    /**
     * 查询文章
     * @param id
     * @return
     */
    public book get(string id) {
        book byid = mongotemplate.findbyid(id, book.class);
        return byid;
    }
}

控制层

@restcontroller
@requestmapping("/book")
@requiredargsconstructor
public class bookcontroller {
    private final bookservice bookservice;
    @postmapping("/create")
    public string create(@requestbody book book) {
        int result = bookservice.create(book);
        if (result > 0) {
            return "图书创建成功";
        } else {
            return "图书创建失败";
        }
    }
    @postmapping("/delete")
    public string delete(@requestparam("id") string id) {
        int count = bookservice.delete(id);
        if (count > 0) {
            return "删除了"   count   "篇图书";
        } else {
            return "删除图书失败";
        }
    }
    @postmapping("/get")
    public book get(string id) {
        book book = bookservice.get(id);
        return book;
    }
}

注意：通过mongotemplate查询时，实体类的id字段类型需为string类型，否则查询为null。

8、测试

通过postman工具测试

创建文章和图书，分布对应两种方式

数据库中记录如下

查询文章和图书

删除文章和图书