0
点赞
收藏
分享

微信扫一扫

SpringCloudAlibaba 项目搭建九(MongoDB集成使用)

爱写作的小土豆 2022-03-11 阅读 46

一、MongoDB

  • MongoDB是一个基于分布式文件存储 [1]  的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。
  • MongoDB是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的。它支持的数据结构非常松散,是类似json的bson格式,因此可以存储比较复杂的数据类型。Mongo最大的特点是它支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且还支持对数据建立索引。
  • 安装:
    •  linux 安装  MongoDB:传送门
    • Docker 安装 MongoDB:传送门

二、MongoDB 引入使用

2.1、pom 文件 添加依赖

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

2.2、修改 application.yml 配置,添加Redis 配置

# 应用服务 WEB 访问端口
server:
  port: 8801
spring:
  # mongodb 配置
  data:
    mongodb:
      host: **.**.**.**
      port: 8893
      username: admin
      password: admin
      database: admin

2.3、添加 MongoDBController 测试

package cn.piesat.testdemo.controller;


import com.alibaba.druid.support.json.JSONUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.*;

@RestController
@RequestMapping("/mongo")
public class MongoDBController {

    @Autowired
    public MongoTemplate mongoTemplate;


    @GetMapping("/save")
    public String save() {
        Map<String, Object> map = new HashMap<>();
        map.put("_id", "id_1");
        map.put("name", "王京");
        map.put("age", "18");
        this.mongoTemplate.save(map, "collectionName1");
        return "新增成功";
    }

    @GetMapping("/remove")
    public String remove() {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is("id_1"));
        mongoTemplate.remove(query, Map.class, "collectionName1");
        return "删除成功";
    }

    @GetMapping("/update")
    public String update() {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is("id_1"));
        Update update = new Update();
        update.set("age", "120");
        mongoTemplate.upsert(query, update, Map.class, "collectionName1");
        return "更新成功";
    }

    @GetMapping("/getCollectionNames")
    public String getCollectionNames() {
        Set<String> set = this.mongoTemplate.getCollectionNames();
        return JSONUtils.toJSONString(set);
    }

    @GetMapping("/getOne")
    public String getOne() {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is("id_1"));
        Map resutl = this.mongoTemplate.findOne(query, Map.class, "collectionName1");
        return JSONUtils.toJSONString(resutl);
    }

    @GetMapping("/list")
    public String list() {
        Query query = new Query();
        query.addCriteria(Criteria.where("name").is("王京"));
        List<Map> maps = mongoTemplate.find(query, Map.class, "collectionName1");
        List<Map> all = mongoTemplate.findAll(Map.class);
        System.out.println(JSONUtils.toJSONString(all));
        return JSONUtils.toJSONString(maps);
    }


}

2.4、启动项目,访问接口测试

新增:http://localhost:8802/mongo/save

查询:http://localhost:8802/mongo/list ​​​​​​注:以上内容仅提供参考和交流,请勿用于商业用途,如有侵权联系本人删除!

举报

相关推荐

0 条评论