spring-boot-learning-MongoDB

2022-07-17 22:49:28

NoSQL可以极大提高互联网系统的性能，但是它有一些致命的缺陷，其中最为严重的就是计算功能卡分有限，例如，在一个10 万数据量的List 中，我只需要满足特定条件的元素在Red is 中，使用集合或者列表，你只有先把元素取出，然后才能通过条件筛选一个个得到你想要的数据，这显然存在比较大的问题

Reids中，对于那些需要缓存而且经常需要统计、分析和查询的数据，显然就不是那么便捷。

这就需要MongoDB来实现了，需要统计、按条件查询和分析的数据，它提供了支持，它可以说是一个最接近于关系数据库的NoSQL 。

MongoDB的特点：将数据存储为一个文档，数据结构由键值（ key-value ）对组成。

这里的Mongo DB 文档类似于JSON 数据集，所以很容易转化成为Java POJO 对象或者JavaScript 对
象，这些字段值还可以包含其他文档、数组及文档数组

需要加入mongoDB-starter依赖

<!--加入mongodb依赖-->
        <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-mongodb -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
            <version>2.3.2.RELEASE</version>
        </dependency>

如果用到json的操作，还可以引入阿里巴巴的fastjson的开发包

springboot为我们自动创建的mongoDB的Bean：

向配置文件加入mongodb配置

编写一个和mongodb文档对应要存储的实体类：

@Document
public class User implements Serializable {

   private String id;
   private String name;
   private Integer age;
   private Integer grade;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    public Integer getGrade() {
        return grade;
    }

    public void setGrade(Integer grade) {
        this.grade = grade;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=‘" + id + ‘\‘‘ +
                ", name=‘" + name + ‘\‘‘ +
                ", age=" + age +
                ", grade=" + grade +
                ‘}‘;
    }
}

可能使用的注解包括以下内容

@Id - 文档的唯一标识，在mongodb中为ObjectId，它是唯一的，通过时间戳+机器标识+进程ID+自增计数器
　　（确保同一秒内产生的Id不会冲突）构成。

@Document - 把一个java类声明为mongodb的文档，可以通过collection参数指定这个类对应的文档。
　　　　　　@Document(collection=“mongodb”) mongodb对应表

@DBRef - 声明类似于关系数据库的关联关系。ps：暂不支持级联的保存功能，当你在本实例中修改了DERef对象
　　　　里面的值时，单独保存本实例并不能保存DERef引用的对象，
　　　　它要另外保存，如下面例子的Person和Account。

@Indexed - 声明该字段需要索引，建索引可以大大的提高查询效率。

@CompoundIndex - 复合索引的声明，建复合索引可以有效地提高多字段的查询效率。

@GeoSpatialIndexed - 声明该字段为地理信息的索引。

@Transient - 映射忽略的字段，该字段不会保存到mongodb。

@PersistenceConstructor - 声明构造函数，作用是把从数据库取出的数据实例化为对象。

注意：因为数据库的规范采用下划线分隔，二java一般采用驼峰式命名，所以可以使用@Field进行设置

指定该属性在mongodb里面使用的保存名字

插入一条记录：

cotroller：

  @Autowired
    UserService service;


    //http://localhost:8988/insert?id=110&name=quan&age=222&grade=223
    @RequestMapping("/insert")
    public User insertUser(User user){
//        User user = new User();
//        user.setAge(23);
//
//        user.setGrade(98);
//        user.setName("quqquq");
        service.insertUser(user);
        return user;
    }

UserService接口：

public interface UserService {
    public void insertUser(User user);

UserServiceImpl接口：

注意：这里需要标注@Service和定义扫描的包，spring才会将它自动装配进来

MongoTemplate不需要自己创建，只需要在配置文件中配置和mongo‘db相关内容就行

@Service
public class UserServiceImpl implements UserService{
    @Autowired
    private MongoTemplate mongoTemplate;

    @Override
    public void insertUser(User user) {
        mongoTemplate.insert(user);
    }

注意：mongoTemplate.save(user) 也是可以进行mongodb的存储的。

save和insert的区别：

若增加的数据的主键已经存在，insert会抛出一个主键重复的异常。不会保存数据

而save会直接对已经存在的数据进行修改。

删除：

    public DeleteResult deleteUser(String id);

    /**
     * 1使用主键构建出一个准则，
     * 2使用MongoTemplate的remove方法进行删除操作
     * 3返回一个DeleteResult对象，记录此次操作记录。
     *      属性deletedCount代表删除文档的条数
     * @param id
     * @return
     */

    @Override
    public DeleteResult deleteUser(String id) {
        Criteria criteria = Criteria.where("id").is(id);
        Query query = Query.query(criteria);
        DeleteResult result =mongoTemplate.remove(query,User.class);
        return result;
    }

注意：使用remove方法的时候，需要指定文档对应的实体类的class

    @RequestMapping("/delUser/{id}")
    public DeleteResult delUser(@PathVariable("id") String id){
        return service.deleteUser(id);
    }

更新：

    /**
     * 1通过构建Query对象确认更新什么内容，这里使用主键确认对应的文档
     * 2定义一个更新对象，定义的时候同时设置了对username的更新
     * 3通过更新对象的set方法设置相关内容的更新
     * 4使用MongoTemplate执行更新。
     *      注意：有两个更新方法，updateFirst(只执行第一个确定对象) updateMulti(执行所有确定对象)
     * 5更新方法的返回值：
     *      "matchedCount": Query对象匹配的文档数
     *     "modifiedCount": 被更新的文档数
     *     "upsertedId": 如果存在更新而插入文档的情况返回插入文档的信息
     * @param user
     * @return
     */

这里只给出实现类的方法：

    @Override
    public UpdateResult upUser(User user) {
        Criteria criteria = Criteria.where("id").is(user.getId());
        Query query = Query.query(criteria);
        //定义更新对象，随便更新name；
        Update update = Update.update("name",user.getName());
        update.set("age",user.getAge());
        update.set("grade",user.getGrade());

        UpdateResult updateResult = mongoTemplate.updateFirst(query,update,User.class);
        return updateResult;
    }

一开始：

请求之后：

结果：

spring-boot-learning-MongoDB

码农公寓

相关文章