记录一次简单的spring cloud整合mongodb(单机测试版本)

我会带着你远行 2023-02-26 15:22 12阅读 0赞

一.引入依赖

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

二.配置连接

spring:
      data:
        mongodb:
          uri: mongodb://admin:123456@192.168.1.63:27017/admin

三.连接工具类

1.bean的注释

@Document(collection = "person")
    public class Testdata2Cheng implements Serializable {
    
        @Id
        private String id;
        @Field("PARTY_ID")
        private String partyid;
        @Field("FULL_NAME")
        private String fullname;
        @Field("CREATED_STAMP")
        private String createdstamp;

@Document(collection = "person") 对应mongodb表名

@Id 主键

@Field("PARTY_ID") 对应mongodb字段名

2.方法引用模板

@Autowired
    private MongoTemplate mongoTemplate;

/**
     * spring 2019/11/20
     */
    @Api(description = "订单列表及列表页的相关接口")
    @Controller
    @RequestMapping("testZoomConfigController")
    public class TestZoomConfigController {
        private static final Logger logger = LoggerFactory.getLogger(TestZoomConfigController.class);
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        @ApiOperation("goZoom")
        @RequestMapping(value = "goZoom", method = RequestMethod.GET)
        @ResponseBody
        public ResponseEntity<?> goZoom() {
            List users = mongoTemplate.findAll(Testdata2.class);
            return ResponseEntity.ok(users);
        }
    
        @ApiOperation("goZoom1")
        @RequestMapping(value = "goZoom1", method = RequestMethod.GET)
        @ResponseBody
        public ResponseEntity<?> goZoom1(@RequestParam("type") Integer type) {
    
            Pattern pattern = null;
            if (type == 1) {
                //完全匹配 "
                pattern = Pattern.compile("^9$", Pattern.CASE_INSENSITIVE);
                logger.warn("1***********************************************************");
            } else if (type == 2) {
                //右匹配
                pattern = Pattern.compile("^.*9$", Pattern.CASE_INSENSITIVE);
                logger.warn("2***********************************************************");
            } else if (type == 3) {
                //左匹配
                pattern = Pattern.compile("^9.*$", Pattern.CASE_INSENSITIVE);
                logger.warn("3***********************************************************");
            } else if (type == 4) {
                //模糊匹配
                pattern = Pattern.compile("^.*9.*$", Pattern.CASE_INSENSITIVE);
                logger.warn("4***********************************************************");
            } else {
                return ResponseEntity.ok("错误");
            }
            Query query1 = new Query().limit(10);
            query1.addCriteria(Criteria.where("name").regex(pattern));
            List users = mongoTemplate.find(query1, Testdata2.class);
            return ResponseEntity.ok(users);
        }
    
    
        @ApiOperation("goZoom2")
        @RequestMapping(value = "goZoom2", method = RequestMethod.GET)
        @ResponseBody
        public ResponseEntity<?> goZoom2(@RequestParam("sk") Integer sk, @RequestParam("ad") Boolean ad) {
    
            Query query1 = new Query();
            //设置模糊查询
            Pattern pattern = Pattern.compile("^.*先.*$", Pattern.CASE_INSENSITIVE);
            query1.addCriteria(Criteria.where("FULL_NAME").regex(pattern));
            //设置分页
            query1.skip(sk).limit(5);
            //设置排序
            if (ad) {
                query1.with(Sort.by(Sort.Order.desc("FULL_NAME")));
            } else {
                query1.with(Sort.by(Sort.Order.asc("FULL_NAME")));
            }
            List vos = mongoTemplate.find(query1, Testdata2Cheng.class);
            return ResponseEntity.ok(vos);
        }
    
    }