实体的创建
/**
* 后台管理员
*/
@Data
@Document
@Accessors(chain = true)
public class SystemAdminUser {
/**
* ID
*/
@Id
private ObjectId id;
/**
* 账号
*/
private String username;
/**
* 密码（加密）
*/
private String password;
/**
* 用户名
*/
private String nick;
/**
* 状态
* @see com.gxzn.comEnum.GlobalStatusEnum
*/
private Integer status;
/**
* 学校ID，仅学校账号有
*/
private ObjectId schoolId;
/**
* 创建时间
*/
private Date createTime;
/**
* 更新时间
*/
private Date updateTime;
}@Document：指定文档（表）名
@Transient：不会在文档中插入该字段
@Id：指定id字段
注意：不建议使用包装对象类型数据，可能在表中出现null字段
自带对象
BasicDBObject
类似于Object，但是是JSON格式
示例：
@RequestParam(defaultValue = "{}") String extend
BasicDBObject.parse("{}")查询
<T> List<T> find(Query query, Class<T> entityClass)
<T> List<T> find(final Query query, Class<T> entityClass, String collectionName)根据id查询文档
<T> T findById(Object id, Class<T> entityClass)
<T> T findById(Object id, Class<T> entityClass, String collectionName)查询并修改
<T> T findAndModify(Query query, Update update, Class<T> entityClass)
<T> T findAndModify(Query query, Update update, Class<T> entityClass, String collectionName)
<T> T findAndModify(Query query, Update update, FindAndModifyOptions options, Class<T> entityClass)
<T> T findAndModify(Query query, Update update, FindAndModifyOptions options, Class<T> entityClass, String collectionName)查询并删除
<T> T findAndRemove(Query query, Class<T> entityClass)
<T> T findAndRemove(Query query, Class<T> entityClass, String collectionName)总数统计
long count(Query query, Class<?> entityClass)
long count(final Query query, String collectionName)
long count(Query query, Class<?> entityClass, String collectionName)添加
void insert(Object objectToSave)
void insert(Object objectToSave, String collectionName)修改
WriteResult upsert(Query query, Update update, Class<?> entityClass)
WriteResult upsert(Query query, Update update, String collectionName)
WriteResult upsert(Query query, Update update, Class<?> entityClass, String collectionName)
WriteResult updateFirst(Query query, Update update, Class<?> entityClass)
WriteResult updateFirst(final Query query, final Update update, final String collectionName)
WriteResult updateFirst(Query query, Update update, Class<?> entityClass, String collectionName)
WriteResult updateMulti(Query query, Update update, Class<?> entityClass)
WriteResult updateMulti(final Query query, final Update update, String collectionName)
WriteResult updateMulti(final Query query, final Update update, Class<?> entityClass, String collectionName)删除
WriteResult remove(Object object)
WriteResult remove(Object object, String collection)
WriteResult remove(Query query, String collectionName)
WriteResult remove(Query query, Class<?> entityClass)
WriteResult remove(Query query, Class<?> entityClass, String collectionName)存在
boolean exists(Query query, Class<?> entityClass)
boolean exists(Query query, String collectionName)
boolean exists(Query query, Class<?> entityClass, String collectionName)
boolean exists = mongoTemplate.exists(new Query(Criteria.where("enterpriseId").is(enterpriseId)), EnterpriseToken.class);Query
new Query(Criteria criteria)Criteria
where
and
is
ne
lt // 小于
lte // 小于等于
gt // 大于
gte // 大于等于
in
nin
mod
all
size
exists
type
not
regex
withinSphere
withinfindAndModify
findAndModify(query,update,options,entityClass)
StrUtil.isNotBlank(Str)：判断非空，含空字符串
currentDate
update.currentDate("updateDate");$currentDate操作符是只用在更新操作上，不可以用在insert操作，更新日期类型的字段时建议使用$currentDate操作符，因为它是直接取的数据库服务端的时间，而使用new Date()设置日期取的是当前服务器上的时间，容易造成误差。
Query query = new Query();
query.addCriteria(where("keyword").is(keyword).and("app_no").is(Constant.APP_NO));
Update update = new Update();
update.inc("number", 1);
update.currentDate("updateDate");
update.setOnInsert("createDate", new Date());
mongoTemplate.findAndModify(query, update, FindAndModifyOptions.options().upsert(true), SearchKeyword.class);排序查询
Query query = new Query();
query.with(new Sort(Sort.Direction.DESC, "number"));
query.limit(pageSize);
List<SearchKeyword> searchKeywordList = mongoTemplate.find(query, SearchKeyword.class);注意：springboot2.2.1（含）以上的版本Sort已经不能再实例化了，构造方法已经是私有的了，使用Sort.by构造
List<Role> roles = mongoTemplate.find(query.skip((pageIndex - 1) * pageSize).limit(pageSize).with(
Sort.by(Sort.Direction.DESC, "_id")
), Role.class);按中文排序
List<DepartmentListRespVo> list = mongoTemplate.find(
new Query(
Criteria.where(FieldUtil.get(Department::getStatus)).is(GlobalStatusEnum.STATUS_NORMAL.value())
).with(Sort.by(Sort.Direction.ASC, FieldUtil.get(Department::getName)))
.collation(Collation.of(Locale.CHINESE).numericOrdering(true)),
DepartmentListRespVo.class,
ClassUtil.getTableName(Department.class)
);多个排序条件
// 查员工
List<DepartmentUserRespVo> user = mongoTemplate.find(
new Query(
Criteria.where(FieldUtil.get(User::getDepartmentId)).is(item.getId())
.and(FieldUtil.get(User::getStatus)).is(GlobalStatusEnum.STATUS_NORMAL.value())
).with(Sort.by(Sort.Direction.DESC, FieldUtil.get(User::getPrincipal)))
.with(Sort.by(Sort.Direction.ASC, FieldUtil.get(Department::getName)))
.collation(Collation.of(Locale.CHINESE).numericOrdering(true)),
DepartmentUserRespVo.class,
ClassUtil.getTableName(User.class)
);Criteria
多条件或
Criteria c1 = null;
c1.orOperator(
where("usr.realname").regex(keyword),
where("user.info.name").regex(keyword),
where("user.weId").is(weId),
where("user.mobile").regex(keyword)
);顺序
注意sort -> skip -> limit的顺序
数组字段长度过滤
Criteria.where("circleIdList.0").exists(true)批量添加
mongoTemplate.insert(list, Finance.COLLECTION_NAME);字段不含字符匹配
// regex具有正则匹配功能，比如字段不以班主任开头
and("jobTitle").regex("^(?!班主任)")打印执行日志
logging:
level:
org.springframework.data.mongodb.core.MongoTemplate: DEBUGSpringBoot配置
# 数据
spring:
data:
mongodb:
host: 192.168.137.100
port: 27017
database: gxzn
username: gxzn
password: gxzn