MongoTemplate使用
2020-07-05 本文已影响0人
knock
MongoTemplate使用
package com.yyd.web.ssm.entity;
import com.alibaba.fastjson.JSONArray;
import org.springframework.data.mongodb.core.mapping.Document;
/***
* @ClassName: MongoEntity
* @Description: TODO
* @author: yanyd
* @Date: 14:25 2020/4/18
* @version : V1.0
*/
@Document(collection = "def_mongo")
public class MongoEntity {
private String age;
private String name;
private String sex;
private Double num;
private String birth;
private JSONArray arr;
public Double getNum() {
return num;
}
public void setNum(Double num) {
this.num = num;
}
public JSONArray getArr() {
return arr;
}
public void setArr(JSONArray arr) {
this.arr = arr;
}
public String getAge() {
return age;
}
public void setAge(String age) {
this.age = age;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
public String getBirth() {
return birth;
}
public void setBirth(String birth) {
this.birth = birth;
}
}
package com.yyd.web.ssm;
import com.alibaba.fastjson.JSON;;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.mongodb.DBObject;
import com.yyd.web.ssm.entity.MongoEntity;
import com.yyd.web.ssm.webUtils.mongodb.MongoDBClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.Aggregation;
import org.springframework.data.mongodb.core.aggregation.AggregationResults;
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 java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
/***
* @ClassName: MongoTest
* @Description: TODO
* @author: yanyd
* @Date: 14:05 2020/4/18
* @version : V1.0
*/
public class MongoTest {
private static Logger LOGGER = LoggerFactory.getLogger(MongoTest.class);
private static MongoDBClient mongoDBClient = new MongoDBClient();
private static MongoTemplate mongoTemplate = mongoDBClient.getMongoTemplate();
// db.getCollection('db1').update({},{"$addToSet":{"info":{"$each": [ {"d":"c"}, {"d":"a"},{"d":"b"} ] ,"$sort": { "d": 1 }, "$slice": 3}}},false,true) //$push有重复值
// db.getCollection('db1').update({},{"$pull":{"info":{"$in": [ {"d":"d"},9240] }}},false,true)
public static void main(String[] args) {
pull();
}
public static void insert() {
//insert
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
MongoEntity mongoEntity = new MongoEntity();
mongoEntity.setAge("18");
mongoEntity.setName("test");
mongoEntity.setSex("M");
mongoEntity.setNum(1.2);
mongoEntity.setBirth(simpleDateFormat.format(new Date()));
mongoTemplate.save(mongoEntity);
}
public static void query_and() {
//and
Query query = new Query();
query.addCriteria(new Criteria("name").regex("test"));
query.addCriteria(new Criteria("birth").gte("2020-04-19 14:34:50").lte("2020-04-22 13:34:50"));
query.addCriteria(new Criteria("age").in(new String[]{"18", "19", "20"}));
query.addCriteria(new Criteria("num").is(1.2));
List<MongoEntity> mongoEntityList = mongoTemplate.find(query, MongoEntity.class);
LOGGER.info(JSON.toJSONString(mongoEntityList));
}
public static void query_or() {
//or
Query query = new Query();
query.addCriteria(new Criteria().orOperator(new Criteria("name").is("test"), new Criteria("name").is("test1")));
query.addCriteria(new Criteria("age").is("18"));
List<MongoEntity> mongoEntityList = mongoTemplate.find(query, MongoEntity.class);
LOGGER.info(JSON.toJSONString(mongoEntityList));
}
public static void query_sort_skip_limit() {
//query_sort_skip_limit
Query query = new Query();
query.addCriteria(new Criteria("name").regex("test"));
query.with(new Sort(new Sort.Order(Sort.Direction.ASC, "birth")));
query.skip(0);
query.limit(1);
List<MongoEntity> mongoEntityList = mongoTemplate.find(query, MongoEntity.class);
LOGGER.info(JSON.toJSONString(mongoEntityList));
}
public static void update() {
//update
Update update = new Update();
update.set("param", "param1");
mongoTemplate.updateFirst(new Query().addCriteria(new Criteria("name").is("test2")), update, MongoEntity.class);
}
public static void push_addSet() {
//push_addSet
Update update = new Update();
JSONArray jsonArray = new JSONArray();
JSONObject jsonObject = new JSONObject();
jsonObject.put("k1", "v");
JSONObject jsonObject1 = new JSONObject();
jsonObject1.put("k2", "v");
jsonArray.add(jsonObject);
jsonArray.add(jsonObject1);
//拆分插入
//update.addToSet("param1").each(jsonArray);
//直接插入数组
update.addToSet("param1", jsonArray);
mongoTemplate.updateFirst(new Query().addCriteria(new Criteria("name").is("test2")), update, MongoEntity.class);
}
public static void pull() {
//pull
Update update = new Update();
JSONArray jsonArray = new JSONArray();
JSONObject jsonObject = new JSONObject();
jsonObject.put("k1", "v");
JSONObject jsonObject1 = new JSONObject();
jsonObject1.put("k2", "v");
jsonArray.add(jsonObject);
jsonArray.add(jsonObject1);
update.pull("param1", jsonArray);
mongoTemplate.updateFirst(new Query().addCriteria(new Criteria("name").is("test2")), update, MongoEntity.class);
}
public static void aggregate() {
//aggregate
Aggregation customerAgg = Aggregation.newAggregation(
Aggregation.project("name", "age", "sex", "birth", "num", "arr"),
Aggregation.match(new Criteria("name").regex("test")),
Aggregation.unwind("arr"),
Aggregation.group("name", "age")
.sum("num").as("num")//统计sum总数
.count().as("count")//统计按 name,age分组的个数
.addToSet("num").as("num_addToSet")//将每组的num字段数据添加到num_addToSet数组中 并去重
.push("num").as("num_push")//将每组的num字段数据添加到num_addToSet数组中 不去重
.first("num").as("num_first")//显示每组第一条数据的num字段数据
.last("num").as("num_last")//显示每组最后一条数据的num字段数据
.min("num").as("num_min")//显示每组数据最小的num字段数据
.max("num").as("num_max"),//显示每组数据最大的num字段数据
Aggregation.sort(new Sort(new Sort.Order(Sort.Direction.ASC, "num"))),
Aggregation.skip(0L),
Aggregation.limit(100L)
);
AggregationResults<DBObject> aggregationResults = mongoTemplate.aggregate(customerAgg, MongoEntity.class, DBObject.class);
Iterator<DBObject> iterator = aggregationResults.iterator();
while (iterator.hasNext()) {
DBObject dbObject = iterator.next();
LOGGER.info(dbObject.toMap().toString());
}
}
}
//多个$and $or的情况
Query query = new Query();
Criteria[] list=new Criteria[2];
Criteria criteria = new Criteria().andOperator(new Criteria("age").is("test"), new Criteria("age").is("test1"));
list[0]=criteria;
list[1]=criteria;
query.addCriteria(new Criteria().andOperator(list));
System.out.println(query.toString());
List<MongoEntity> mongoEntityList = mongoTemplate.find(query, MongoEntity.class);
log.info(JSON.toJSONString(mongoEntityList));
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-mongodb</artifactId>
<version>1.10.15.RELEASE</version>
</dependency>
