使用mongodb思路
- 引入spring boot mongodb jar包
- 配置mongodb相关信息
- 测试使用
引入mongodb jar包
在spring boot demo工程pom.xml文件中新增
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
mongodb相关配置
- 在application.properties中配置,3.0以上版本支持如下配置
spring.data.mongodb.uri=mongodb://test:test@127.0.0.1:27016/test
- 自定义配置
如果我们想配置mongodb连接池,默认是没有提供配置方式,所以需要自定义完成配置
(1) 新建mongo.properties,配置内容如下
mongodb.custom.host=127.0.0.1
mongodb.custom.port=27016
#mongodb.custom.replica-set=
mongodb.custom.username=test
mongodb.custom.password=test
mongodb.custom.database=report
mongodb.custom.authentication-database=test
mongodb.custom.connections-per-host=20
mongodb.custom.min-connections-per-host=20
(2) 重写MongoDbFactory,创建client和Factory,代码如下
package com.geneseeq.access.config;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;
@Configuration
@PropertySource("classpath:config/mongo.properties")
public class MongoConfig {
@Value("${mongodb.custom.host}")
private String host;
@Value("${mongodb.custom.port}")
private Integer port;
// @Value("${mongodb.custom.replica-set}")
// private String replicaSet;
@Value("${mongodb.custom.username}")
private String username;
@Value("${mongodb.custom.password}")
private String password;
@Value("${mongodb.custom.database}")
private String database;
@Value("${mongodb.custom.authentication-database}")
private String authenticationDatabase;
@Value("${mongodb.custom.connections-per-host}")
private Integer connectionsPerHost = 10;
@Value("${mongodb.custom.min-connections-per-host}")
private Integer minConnectionsPerHost = 2;
// 覆盖默认的MongoDbFactory
@Bean
MongoDbFactory mongoDbFactory() {
//客户端配置(连接数、副本集群验证)
MongoClientOptions.Builder builder = new MongoClientOptions.Builder();
builder.connectionsPerHost(connectionsPerHost);
builder.minConnectionsPerHost(minConnectionsPerHost);
// if (replicaSet != null) {
// builder.requiredReplicaSetName(replicaSet);
// }
MongoClientOptions mongoClientOptions = builder.build();
// MongoDB地址列表
List<ServerAddress> serverAddresses = new ArrayList<>();
ServerAddress serverAddress = null;
try {
serverAddress = new ServerAddress(host, port);
} catch (UnknownHostException e) {
e.printStackTrace();
}
serverAddresses.add(serverAddress);
System.out.println("serverAddresses:" + serverAddresses.toString());
// 连接认证
List<MongoCredential> mongoCredentialList = new ArrayList<>();
if (username != null) {
mongoCredentialList.add(MongoCredential.createScramSha1Credential(
username,
authenticationDatabase != null ? authenticationDatabase : database,
password.toCharArray()));
}
System.out.println("mongoCredentialList:" + mongoCredentialList.toString());
//创建客户端和Factory
MongoClient mongoClient = new MongoClient(serverAddresses, mongoCredentialList, mongoClientOptions);
MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient, database);
return mongoDbFactory;
}
}
测试
- 创建mongodb document bean类
package com.geneseeq.access.model;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;
import java.io.Serializable;
@Document(collection = "test")
public class BaseOrder implements Serializable {
private static final long serialVersionUID = 77220451538889640L;
@Field("_id")
private String _id;
@Field("id")
private String id;
@Field("user_name")
private String userName;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getPassWord() {
return passWord;
}
public void setPassWord(String passWord) {
this.passWord = passWord;
}
private String passWord;
public String get_id() {
return _id;
}
public void set_id(String _id) {
this._id = _id;
}
}
- 实现操作mongodb service
package com.geneseeq.access.service.mongodb.impl;
import com.geneseeq.access.model.BaseOrder;
import com.geneseeq.access.service.mongodb.TestMongoService;
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.stereotype.Service;
@Service("TestMongoService")
public class TestMongoServiceImpl implements TestMongoService {
@Autowired
private MongoTemplate mongoTemplate;
@Override
public void saveBaseOrder(BaseOrder baseOrder) {
mongoTemplate.save(baseOrder);
}
@Override
public void upsertOrder(BaseOrder baseOrder) {
Query query = new Query();
query.addCriteria(Criteria.where("_id").is(baseOrder.get_id()));
Update update = new Update();
update.set("user_name", baseOrder.getUserName());
update.set("id", baseOrder.getId());
// update.set("passWord", baseOrder.getPassWord());
mongoTemplate.upsert(query, update, BaseOrder.class);
}
}
- controller实现
package com.geneseeq.access.controller;
import com.geneseeq.access.GeneseeqAccessApplication;
import com.geneseeq.access.model.BaseOrder;
import com.geneseeq.access.service.mongodb.TestMongoService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@Controller
@RequestMapping("/test")
public class TestController {
private static final Logger log = LoggerFactory.getLogger(TestController.class);
@Autowired
private TestMongoService testMongoService;
@RequestMapping(value = "/info", method = RequestMethod.GET)
@ResponseBody
public Object getOrder(HttpServletRequest request, HttpServletResponse response){
try{
BaseOrder baseOrder = new BaseOrder();
baseOrder.set_id("1238");
baseOrder.setId("gys");
baseOrder.setPassWord("asfas");
baseOrder.setUserName("ewqerq");
//testMongoService.saveBaseOrder(baseOrder);
testMongoService.upsertOrder(baseOrder);
return baseOrder;
} catch (Exception e){
log.error("failed, error is: "+ e);
return null;
}
}
}
- 发送GET请求,url路径为:/test/info
- 查看mongodb是否存在数据
{ "_id" : "1238", "user_name" : "ewqerq", "id" : "gys" }