不管用的是什么数据库，增删改查肯定少不了。现在就用SpringBoot整合MongoDB来做一套增删改查练练手。
环境配置：
MongoDB 4.2.2
SpringBoot 2.1.4
首先，在项目的pom文件里引入SpringBoot整合MongoDB的架包；
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
第二步，在application.properties里加入MongoDB的配置信息；
spring.data.mongodb.uri=mongodb://127.0.0.1:27017/log_info
相较于其他数据库的配置，MongoDB的配置非常精简；
第三步，直接调用MongoTemplate实现增加改查；
import java.text.ParsePosition;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.regex.Pattern;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Sort;
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.util.StringUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import com.example.demo.entity.User;
import com.mongodb.client.result.DeleteResult;
import com.mongodb.client.result.UpdateResult;
/**
*
* @author 程就人生
* @date 2020年1月9日
*/
@RestController
public class MongodbController {
@Autowired
private MongoTemplate mongoTemplate;
@GetMapping("/add")
public void add(){
List<User> userList = new ArrayList<User>();
User user;
for(int i=0;i<100;i++){
user = new User();
user.setName("用户" + i);
user.setSex((byte)(i%2==0?1:0));
user.setBrithday(new Date());
user.setAddress("江苏省 苏州市");
userList.add(user);
}
//批量添加,单个对象用insert
userList = (List<User>) mongoTemplate.insertAll(userList);
System.out.println("新增影响行数：" + userList.size());
}
/**
* 修改语句
* @param id
* @param name
*
*/
@GetMapping("/update")
public void update(String id, String name){
//修改条件
Query query = new Query();
Criteria criteria = new Criteria();
//此处必须用and，用where时实现
criteria.and("_id").is(id);
query.addCriteria(criteria);
Update update = new Update();
update.set("name", name);
//updateFirst总是修改第一条
UpdateResult updateResult = mongoTemplate.updateMulti(query, update, User.class);
System.out.println("修改影响行数：" + updateResult.getModifiedCount());
}
/**
* 删除语句
* @param id
*
*/
@GetMapping("/remove")
public void remove(String id){
Query query = new Query();
Criteria criteria = new Criteria();
criteria.and("_id").is(id);
query.addCriteria(criteria);
DeleteResult deleteResult = mongoTemplate.remove(query,User.class);
System.out.println("删除影响行数：" + deleteResult.getDeletedCount());
}
/**
* 查询列表
* @return
*
*/
@GetMapping("/list")
public List<User> list(String name, Byte sex, String brithday){
Query query = new Query();
//查询条件设置
Criteria criteria = new Criteria();
//查询条件设置
Pattern pattern = null;
if(!StringUtils.isEmpty(name)){
//用正则匹配进行模糊查询，完全匹配 ："^王$"，右匹配： "^.*王$"，左匹配："^王.*$"，模糊匹配："^.*王.*$"
pattern = Pattern.compile("^.*" + name + ".*$", Pattern.CASE_INSENSITIVE);
criteria.and("name").regex(pattern);
}
if(sex != null){
//is完全匹配
criteria.and("sex").is(sex);
}
//操作时间
if(!StringUtils.isEmpty(brithday)){
//日期的比较
Date startDate = fromStringToDate("yyyy-MM-dd", brithday);
//大于等于,大于用gt，小于等于用lte，小于用lt
criteria.and("brithday").gte(startDate);
}
query.addCriteria(criteria);
//获取信息总条数
Long count = mongoTemplate.count(query, User.class);
System.out.println("数据总共：" + count + "条");
//查询10条
query.limit(10);
//跳过前10数据,用于分页查询
//query.skip(10);
//设置排序
Sort sort = new Sort(Sort.Direction.DESC, "brithday");
query.with(sort);
return mongoTemplate.find(query, User.class);
}
/**
* 将string转换成Date格式
* @param formatStr
* @param strDate
* @return
*/
public static Date fromStringToDate(String formatStr, String strDate) {
SimpleDateFormat formatter = new SimpleDateFormat(formatStr);
ParsePosition pos = new ParsePosition(0);
Date strtodate = formatter.parse(strDate, pos);
return strtodate;
}
}
最后，测试
新增测试，这里采用批量新增，在浏览器地址栏输入http://localhost:8080/add，然后在MongoDB客户端查看运行结果；
新增结果图
修改测试，拷贝第二个的id，将其name修改掉，浏览器地址栏输入：
http://localhost:8080/update?id=5e1723f0555bbb34ec9e779e&name=的点点滴滴
修改测试结果图
删除测试，拷贝第三个的id，在浏览器地址栏输入：
http://localhost:8080/remove?id=5e1723f0555bbb34ec9e779f
删除测试结果
查询测试，查询name中包含19的数据，并查看结果：
查询测试
还有其他的两个查询条件，不妨试一试，看看效果如何。
MongoDB的配置文件为何如此简单呢？那些默认的参数又在哪里？
spring-boot-starter-data-mongodb架包自动封装了配置参数，不配置参数时，采用默认值，这些都可以通过MongoProperties类来查看，如果要扩展多数据源，则可以通过覆盖MongoProperties属性文件来实现。
package org.springframework.boot.autoconfigure.mongo;
import com.mongodb.MongoClientURI;
import org.springframework.boot.context.properties.ConfigurationProperties;
/**
* 默认是通过spring.data.mongodb这个前缀来获取配置文件的
*/
@ConfigurationProperties(prefix = "spring.data.mongodb")
public class MongoProperties {
/**
* Default port used when the configured port is {@code null}.
*/
public static final int DEFAULT_PORT = 27017;//默认端口号
/**
* Default URI used when the configured URI is {@code null}.
*/
public static final String DEFAULT_URI = "mongodb://localhost/test";//默认test数据库
/**
* Mongo server host. Cannot be set with URI.
*/
private String host;
/**
* Mongo server port. Cannot be set with URI.
*/
private Integer port = null;
/**
* Mongo database URI. Cannot be set with host, port and credentials.
*/
private String uri;
/**
* Database name.
*/
private String database;
/**
* Authentication database name.
*/
private String authenticationDatabase;
/**
* GridFS database name.
*/
private String gridFsDatabase;
/**
* Login user of the mongo server. Cannot be set with URI.
*/
private String username;
/**
* Login password of the mongo server. Cannot be set with URI.
*/
private char[] password;
/**
* Fully qualified name of the FieldNamingStrategy to use.
*/
private Class<?> fieldNamingStrategy;
public String getHost() {
return this.host;
}
public void setHost(String host) {
this.host = host;
}
public String getDatabase() {
return this.database;
}
public void setDatabase(String database) {
this.database = database;
}
public String getAuthenticationDatabase() {
return this.authenticationDatabase;
}
public void setAuthenticationDatabase(String authenticationDatabase) {
this.authenticationDatabase = authenticationDatabase;
}
public String getUsername() {
return this.username;
}
public void setUsername(String username) {
this.username = username;
}
public char[] getPassword() {
return this.password;
}
public void setPassword(char[] password) {
this.password = password;
}
public Class<?> getFieldNamingStrategy() {
return this.fieldNamingStrategy;
}
public void setFieldNamingStrategy(Class<?> fieldNamingStrategy) {
this.fieldNamingStrategy = fieldNamingStrategy;
}
public String getUri() {
return this.uri;
}
public String determineUri() {
return (this.uri != null) ? this.uri : DEFAULT_URI;
}
public void setUri(String uri) {
this.uri = uri;
}
public Integer getPort() {
return this.port;
}
public void setPort(Integer port) {
this.port = port;
}
public String getGridFsDatabase() {
return this.gridFsDatabase;
}
public void setGridFsDatabase(String gridFsDatabase) {
this.gridFsDatabase = gridFsDatabase;
}
public String getMongoClientDatabase() {
if (this.database != null) {
return this.database;
}
return new MongoClientURI(determineUri()).getDatabase();
}
}
网友评论