```
package cn.javaex.springboot.util;
import java.util.List;
import javax.annotation.PostConstruct;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Direction;
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.Component;
/**
* MongoDB 工具类
*/
@Component
public class MongoDBUtils {
public static MongoDBUtils mongoDBUtils;
@Autowired
private MongoTemplate mongoTemplate;
@PostConstruct
public void init() {
mongoDBUtils = this;
}
/**
* 保存数据对象，集合为数据对象中@Document 注解所配置的collection
*
* @param obj 数据对象
*/
public static void save(Object obj) {
mongoDBUtils.mongoTemplate.save(obj);
}
/**
* 指定集合保存数据对象
*
* @param obj 数据对象
* @param collectionName 集合名
*/
public static void save(Object obj, String collectionName) {
mongoDBUtils.mongoTemplate.save(obj, collectionName);
}
/**
* 根据数据对象中的id删除数据，集合为数据对象中@Document 注解所配置的collection
*
* @param obj 数据对象
*/
public static void delete(Object obj) {
mongoDBUtils.mongoTemplate.remove(obj);
}
/**
* 指定集合 根据数据对象中的id删除数据
*
* @param obj 数据对象
* @param collectionName 集合名
*/
public static void delete(Object obj, String collectionName) {
mongoDBUtils.mongoTemplate.remove(obj, collectionName);
}
/**
* 根据key，value到指定集合删除数据
*
* @param key 键
* @param value 值
* @param collectionName 集合名
*/
public static void deleteByKey(String key, Object value, String collectionName) {
Query query = new Query();
query.addCriteria(new Criteria(key).is(value));
mongoDBUtils.mongoTemplate.remove(query, collectionName);
}
/**
* 指定集合 修改数据，且仅修改找到的第一条数据
*
* @param accordingKey 修改条件 key
* @param accordingValue 修改条件 value
* @param updateKeys 修改内容 key数组
* @param updateValues 修改内容 value数组
* @param collectionName 集合名
*/
public static void updateFirst(String accordingKey, Object accordingValue,
String[] updateKeys, Object[] updateValues, String collectionName) {
Criteria criteria = Criteria.where(accordingKey).is(accordingValue);
Query query = Query.query(criteria);
Update update = new Update();
for (int i=0; i<updateKeys.length; i++) {
update.set(updateKeys[i], updateValues[i]);
}
mongoDBUtils.mongoTemplate.updateFirst(query, update, collectionName);
}
/**
* 指定集合修改数据，且修改所找到的所有数据
*
* @param accordingKey 修改条件 key
* @param accordingValue 修改条件 value
* @param updateKeys 修改内容 key数组
* @param updateValues 修改内容 value数组
* @param collectionName 集合名
*/
public static void updateAll(String accordingKey, Object accordingValue,
String[] updateKeys, Object[] updateValues, String collectionName) {
Criteria criteria = Criteria.where(accordingKey).is(accordingValue);
Query query = Query.query(criteria);
Update update = new Update();
for (int i = 0; i < updateKeys.length; i++) {
update.set(updateKeys[i], updateValues[i]);
}
mongoDBUtils.mongoTemplate.updateMulti(query, update, collectionName);
}
/**
* 根据条件查询出所有结果集 集合为数据对象中@Document 注解所配置的collection
*
* @param obj 数据对象
* @param findKeyArr 查询条件 key
* @param findValueArr 查询条件 value
* @return
*/
public static List<? extends Object> find(Object obj, String[] findKeyArr, Object[] findValueArr) {
Criteria criteria = null;
for (int i=0; i<findKeyArr.length; i++) {
if (i==0) {
criteria = Criteria.where(findKeyArr[i]).is(findValueArr[i]);
} else {
criteria.and(findKeyArr[i]).is(findValueArr[i]);
}
}
Query query = Query.query(criteria);
List<? extends Object> resultList = mongoDBUtils.mongoTemplate.find(query, obj.getClass());
return resultList;
}
/**
* 指定集合 根据条件查询出所有结果集
*
* @param obj 数据对象
* @param findKeyArr 查询条件 key
* @param findValueArr 查询条件 value
* @param collectionName 集合名
* @return
*/
public static List<? extends Object> find(Object obj, String[] findKeyArr, Object[] findValueArr, String collectionName) {
Criteria criteria = null;
for (int i=0; i<findKeyArr.length; i++) {
if (i==0) {
criteria = Criteria.where(findKeyArr[i]).is(findValueArr[i]);
} else {
criteria.and(findKeyArr[i]).is(findValueArr[i]);
}
}
Query query = Query.query(criteria);
List<? extends Object> resultList = mongoDBUtils.mongoTemplate.find(query, obj.getClass(), collectionName);
return resultList;
}
/**
* 指定集合 根据条件查询出所有结果集 并排倒序
*
* @param obj 数据对象
* @param findKeyArr 查询条件 key
* @param findValueArr 查询条件 value
* @param collectionName 集合名
* @param sort 排序字段
* @return
*/
public static List<? extends Object> find(Object obj, String[] findKeyArr, Object[] findValueArr, String collectionName ,String sort) {
Criteria criteria = null;
for (int i = 0; i < findKeyArr.length; i++) {
if (i == 0) {
criteria = Criteria.where(findKeyArr[i]).is(findValueArr[i]);
} else {
criteria.and(findKeyArr[i]).is(findValueArr[i]);
}
}
Query query = Query.query(criteria);
query.with(new Sort(Direction.DESC, sort));
List<? extends Object> resultList = mongoDBUtils.mongoTemplate.find(query, obj.getClass(), collectionName);
return resultList;
}
/**
* 根据条件查询出符合的第一条数据 集合为数据对象中 @Document 注解所配置的collection
*
* @param obj 数据对象
* @param findKeyArr 查询条件 key
* @param findValueArr 查询条件 value
* @return
*/
public static Object findOne(Object obj, String[] findKeyArr, Object[] findValueArr) {
Criteria criteria = null;
for (int i=0; i<findKeyArr.length; i++) {
if (i==0) {
criteria = Criteria.where(findKeyArr[i]).is(findValueArr[i]);
} else {
criteria.and(findKeyArr[i]).is(findValueArr[i]);
}
}
Query query = Query.query(criteria);
Object resultObj = mongoDBUtils.mongoTemplate.findOne(query, obj.getClass());
return resultObj;
}
/**
* 指定集合 根据条件查询出符合的第一条数据
*
* @param obj 数据对象
* @param findKeyArr 查询条件 key
* @param findValueArr 查询条件 value
* @param collectionName 集合名
* @return
*/
public static Object findOne(Object obj, String[] findKeyArr, Object[] findValueArr, String collectionName) {
Criteria criteria = null;
for (int i=0; i<findKeyArr.length; i++) {
if (i==0) {
criteria = Criteria.where(findKeyArr[i]).is(findValueArr[i]);
} else {
criteria.and(findKeyArr[i]).is(findValueArr[i]);
}
}
Query query = Query.query(criteria);
Object resultObj = mongoDBUtils.mongoTemplate.findOne(query, obj.getClass(), collectionName);
return resultObj;
}
/**
* 查询出所有结果集 集合为数据对象中 @Document 注解所配置的collection
*
* @param obj 数据对象
* @return
*/
public static List<? extends Object> findAll(Object obj) {
List<? extends Object> resultList = mongoDBUtils.mongoTemplate.findAll(obj.getClass());
return resultList;
}
/**
* 指定集合 查询出所有结果集
*
* @param obj 数据对象
* @param collectionName 集合名
* @return
*/
public static List<? extends Object> findAll(Object obj, String collectionName) {
List<? extends Object> resultList = mongoDBUtils.mongoTemplate.findAll(obj.getClass(), collectionName);
return resultList;
}
}
```
- JDK常用知识库
- JDK各个版本安装
- Java8流
- 算法
- 十大排序算法
- 冒泡排序
- 选择排序
- 插入排序
- 归并排序
- 快速排序
- 堆排序
- 希尔排序
- 计数排序
- 桶排序
- 基数排序
- 总结
- 常用工具类
- 浮点型计算
- 时间格式处理
- 常用功能点思路整理
- 登录
- 高并发
- 线程安全的单例模式
- Tomcat优化
- Tomcat之APR模式
- Tomcat启动过慢问题
- 常用的数据库连接池
- Druid连接池
- 缓存
- Redis
- SpringBoot整合Redis
- 依赖和配置
- RedisTemplate工具类
- 工具类使用方法
- Redis知识库
- Redis安装
- Redis配置参数
- Redis常用Lua脚本
- MongoDB
- SpringBoot操作MongoDB
- 依赖和配置
- MongoDB工具类
- 工具类使用方法
- 消息中间件
- ActiveMq
- SpringBoot整合ActiveMq
- 框架
- SpringBoot
- 定时任务
- 启动加载
- 事务
- JSP
- 静态类注入
- SpringSecurity
- Shiro
- 配置及整合
- 登陆验证
- 权限验证
- 分布式应用
- SpringMVC
- ORM框架
- Mybatis
- 增
- 删
- 改
- 查
- 程序员小笑话
- 我给你讲一个TCP的笑话吧
- 二进制笑话
- JavaScript的那点东西
- JavaScript内置对象及常见API详细介绍
- JavaScript实现Ajax 资源请求
- JavaScript干货
- 架构师成长之路
- JDK源码解析
- ArrayList源码解读
- 设计模式
- 微服务架构设计模式
- 逃离单体炼狱
- 服务的拆分策略
- 全面解析SpringMvc框架
- 架构设计的六大原则
- 并发集合
- JUC并发编程
- 搜索引擎
- Solr
- Solr的安装
- 分布式服务框架
- Dubbo
- 从零开始学HTMl
- 第一章-初识HTML
- 第二章-认识HTML标签