Mongodb: java 使用Repository连接mongodb集群

矫情吗；* 2022-11-16 00:59 143阅读 0赞

1.搭建集群  
2.POM

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

3.application.properties:  
spring.data.mongodb.uri=mongodb://188.131.172.xx:27017,81.70.228.xx:27017,124.71.204.xx:27017/test?maxPoolSize=512

4.实体类

package tju.SpringBootPostServer.domain;
    
    import org.springframework.data.annotation.Id;
    import org.springframework.data.mongodb.core.mapping.Document;
    
    @Document(collection = "userinfo")
    public class UserInfo {
     
        @Id
        private String id;
     
        private String name;
    
    	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;
    	}
        
    }

1.  Repository

package tju.SpringBootPostServer.dao;
    
    import org.springframework.data.mongodb.repository.MongoRepository;
    
    import tju.SpringBootPostServer.domain.UserInfo;
    
    public interface UserInfoRepository extends MongoRepository<UserInfo,String> {
    }

1.  Controller

package tju.SpringBootPostServer.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import tju.SpringBootPostServer.dao.UserInfoRepository;
    import tju.SpringBootPostServer.domain.UserInfo;
    
    @RestController
    public class MongoController {
     
        @Autowired
        UserInfoRepository userInfoRepository;
     
        @GetMapping("/addMongo")
        public String addMongo(){
           UserInfo userInfo=new UserInfo();
            userInfo.setId(String.valueOf(System.currentTimeMillis() / 10000));
            userInfo.setName(userInfo.getId() + "'s name");
            userInfoRepository.save(userInfo);
            return userInfo.toString();
        }
    }