MongoRepository怎么修改数据
发布网友
发布时间：2022-04-07 16:01
共4个回答
懂视网
时间：2022-04-07 20:22
对这四大方法的实现，为了不让MongoDB的更多细节公开，所以，更多的内核只能在仓储中实现了，呵呵
public PagedResult<TEntity> GetModel(int pageIndex, int pageSize)
{
return GetModel(i => true, pageIndex, pageSize);
}
public PagedResult<TEntity> GetModel(System.Linq.Expressions.Expression<Func<TEntity, bool>> expression, int pageIndex, int pageSize)
{
return GetModel(expression, new Dictionary<Expression<Func<TEntity, object>>, bool>(), pageIndex, pageSize);
}
public PagedResult<TEntity> GetModel(
Dictionary<Expression<Func<TEntity, object>>, bool> fields,
int pageIndex,
int pageSize)
{
return GetModel(i => true, fields, pageIndex, pageSize);
}
public PagedResult<TEntity> GetModel(
Expression<Func<TEntity, bool>> expression,
Dictionary<Expression<Func<TEntity, object>>, bool> fields,
int pageIndex,
int pageSize)
{
SortDefinition<TEntity> sorts = new ObjectSortDefinition<TEntity>(new { });
foreach (var item in fields)
{
if (item.Value)
sorts = sorts.Ascending(item.Key);
else
sorts = sorts.Descending(item.Key);
}
var skip = (pageIndex - 1) * pageSize;
var limit = pageSize;
var recordCount = _table.CountAsync<TEntity>(i => true).Result;
return new PagedResult<TEntity>(
recordCount,
(int)(recordCount + pageSize - 1) / pageSize,
pageSize,
pageIndex,
_table.Find(expression)
.Sort(sorts)
.Skip(skip)
.Limit(limit)
.ToListAsync().Result);
}
ＯＫ，现在你可以在业务层去调用它了，基本上面四个方法可以满足你的一切需求了，呵呵！
看下在ＵＩ层对它的调用，本ＤＥＭＯ没有ＢＬＬ层，呵呵
//
// GET: /Background/
public ActionResult Index(int sort = 0, int page = 1)
{
Dictionary<Expression<Func<WebManageUsers, object>>, bool> sortList = new System.Collections.Generic.Dictionary<Expression<Func<WebManageUsers, object>>, bool>();
sortList.Add(i => i.LoginName, sort == 0);
var model = _webManageUsersRepository.GetModel(sortList,page, 10);
return View(model);
}
怎么样，看了上面代码是否心里痒痒了，哈哈，赶快去开发你自己的MongoDB仓储吧！
MongoDB学习笔记~为IMongoRepository接口添加了排序和表达式树，针对官方驱动
标签：
热心网友
时间：2022-04-07 17:30
用Repository的功能，先继承MongoRepository<T,
TD>接口，其中T为仓库保存的bean类，TD为该bean的唯一标识的类型，一般为ObjectId。之后在service中注入该接口就可以
使用，无需实现里面的方法，spring会根据定义的规则自动生成。
例：
public interface PersonRepository extends
MongoRepository<Person, ObjectId>{
//这里可以添加额外的查询方法
｝
但是MongoRepository实现了的只是最基本的增删改查的功能，要想增加额外的查询方法，可以按照以下规则定义接口的方法。自定义查询方
法，格式为“findBy+字段名+方法后缀”，方法传进的参数即字段的值，此外还支持分页查询，通过传进一个Pageable对象，返回Page集合。
例：
public interface PersonRepository extends
MongoRepository<Person, ObjectId>{
//查询大于age的数据
public Page<Proct> findByAgeGreaterThan(int age,Pageable page) ;
｝
下面是支持的查询类型，每三条数据分别对应：（方法后缀，方法例子，mongodb原生查询语句）
GreaterThan(大于)
findByAgeGreaterThan(int age)
{"age" : {"$gt" : age}}
LessThan（小于）
findByAgeLessThan(int age)
{"age" : {"$lt" : age}}
Between（在...之间）
findByAgeBetween(int from, int to)
{"age" : {"$gt" : from, "$lt" : to}}
IsNotNull, NotNull（是否非空）
findByFirstnameNotNull()
{"age" : {"$ne" : null}}
IsNull, Null（是否为空）
findByFirstnameNull()
{"age" : null}
Like（模糊查询）
findByFirstnameLike(String name)
{"age" : age} ( age as regex)
(No keyword) findByFirstname(String name)
{"age" : name}
Not（不包含）
findByFirstnameNot(String name)
{"age" : {"$ne" : name}}
Near（查询地理位置相近的）
findByLocationNear(Point point)
{"location" : {"$near" : [x,y]}}
Within（在地理位置范围内的）
findByLocationWithin(Circle circle)
{"location" : {"$within" : {"$center" : [ [x, y], distance]}}}
Within（在地理位置范围内的）
findByLocationWithin(Box box)
{"location" : {"$within" : {"$box" : [ [x1, y1], x2, y2]}}}
尽管以上查询功能已经很丰富，但如果还不能满足使用情况的话可以用一下方法---基于mongodb原本查询语句的查询方式。
例：在原接口中加入
@Query("{ 'name':{'$regex':?2,'$options':'i'}, sales': {'$gte':?1,'$lte':?2}}")
public Page<Proct> findByNameAndAgeRange(String name,double ageFrom,double ageTo,Pageable page);
注释Query里面的就是mongodb原来的查询语法，我们可以定义传进来的查询参数，通过坐标定义方法的参数。
还可以在后面指定要返回的数据字段，如上面的例子修改如下，则只通过person表里面的name和age字段构建person对象。
@Query(value="{ 'name':{'$regex':?2,'$options':'i'}, sales':{'$gte':?1,'$lte':?2}}",fields="{ 'name' : 1, 'age' : 1}")
public Page<Proct> findByNameAndAgeRange(String name,double ageFrom,double ageTo,Pageable page);
热心网友
时间：2022-04-07 18:48
eg:
/**
* 把name的mail订阅状态更新为flag
*/
public void updateMailFlag(String name, String flag) throws Exception{
opterations.updateFirst(new Query(new Criteria("name").is(name)),
new Update().set("flag", flag), EmailInfo.class);
}
热心网友
时间：2022-04-07 20:23
MongoRepository中的
save（）来进行更新操作，不过注意哦，实体类中需要声明iD哦，不然是不会对原有记录进行覆盖的
