* //插入数据
* db.test_user.insert({"_id":2,"name":"神里","age":21,"birthday":"2000-07-07"})
*
@param
user
public
void
insert
(User user)
{
template.insert(user,
"test_user"
);
* //修改一条数据
* db.test_user.updateOne({"_id":"2"}, {$set:{"name":"神里"}})
*
@param
user
public
void
update
(User user)
{
Query
query
=
new
Query
();
query.addCriteria(Criteria.where(
"_id"
).is(user.getId()));
Update
update
=
new
Update
();
update.set(
"name"
,user.getName());
mongoTemplate.updateFirst(query,update,User.class,
"test_user"
);
* //删除一天数据
* db.test_user.remove({"_id":"3"});
*
@param
user
public
void
delete
(User user)
{
Query
query
=
new
Query
();
query.addCriteria(Criteria.where(
"_id"
).is(user.getId()));
mongoTemplate.remove(query,
"test_user"
);
* //查询数据
* db.test_user.find({"_id":"1"})
*
@param
user
*
@return
public
List<User>
select
(User user)
{
Query
query
=
new
Query
();
query.addCriteria(Criteria.where(
"_id"
).is(user.getId()));
return
mongoTemplate.find(query, User.class,
"test_user"
);
Query query = new Query();
query.addCriteria(Criteria.where("_id").is(user.getId()));
query.fields().include("name");
query.fields().exclude("name");
Criteria criteria = new Criteria();
criteria.orOperator(Criteria.where("name").is("影"),Criteria.where("age").is(21));
criteria.andOperator(Criteria.where("name").is("影"),Criteria.where("age").is(21));
query.addCriteria(criteria);
Sort sort = Sort.by(Sort.Direction.DESC, "_id");
Pageable pageable = PageRequest.of(0,3,sort);
query.with(pageable);
query.addCriteria(Criteria.where("birthday").gte("2000-01-01").lte("2022-09-09"));
分页查询条件
//SQL 查询出_id,fullName,carNo,healthDate 按某一字段降序
db.project.find({},{"_id":1,"healthNo":1,"fullName":1,"cardNo":1,"healthDate":1}).sort({"healthDate":-1}).limit(10)
* 获取体检报告列表
* @param current
* @param pageSize
* @return
public MongoPageResult getlist(Integer current,Integer pageSize,Long tenantId){
Sort sort = new Sort(Sort.Direction.DESC,"healthDate");
Query query = new Query();
query.fields().include("_id");
query.fields().include("healthNo");
query.fields().include("fullName");
query.fields().include("cardNo");
query.fields().include("healthDate");
query.with(sort);
query.addCriteria(Criteria.where("tenantId").is(tenantId));
Pageable pageable = new PageRequest(current,pageSize);
query.with(pageable);
long totalCount = template.count(query, "project");
List<Project> project = template.find(query, Project.class, "project");
long totalPage = totalCount % pageSize == 0 ? totalCount / pageSize : totalCount / pageSize + 1;
return new MongoPageResult(totalCount,current,pageSize,totalPage,project);
复制代码
- 1.5w
-
常金家的秋意
Elasticsearch