public class DefaultMongoSession extends AbstractSession<IMongoConnectionHolder> implements IMongoSession
| Constructor and Description |
|---|
DefaultMongoSession(IMongo owner) |
DefaultMongoSession(IMongo owner,
IMongoConnectionHolder connectionHolder) |
| Modifier and Type | Method and Description |
|---|---|
<T extends IEntity,RESULT> |
aggregate(Class<T> entity,
Class<RESULT> resultClass,
Aggregation... aggregations)
聚合
|
void |
close() |
<T extends IEntity> |
count(Class<T> entity)
计算查询结果总记录数量
|
<T extends IEntity> |
count(Class<T> entity,
Query filter)
计算查询结果总记录数量
|
<T extends IEntity> |
count(Class<T> entity,
QueryBuilder filter)
计算查询结果总记录数量
|
<T extends IEntity> |
delete(Class<T> entity,
Collection<Serializable> ids)
批量删除指定ID的记录
|
<T extends IEntity> |
delete(Class<T> entity,
Serializable id)
删除指定ID的记录
|
<T extends IEntity> |
delete(List<T> entities)
根据实体执行记录批量删除
|
<T extends IEntity> |
delete(T entity)
根据实体执行记录删除
|
<T extends IEntity,RESULT> |
distinct(Class<T> entity,
Class<RESULT> resultClass,
String fieldName)
去重
|
<T extends IEntity,RESULT> |
distinct(Class<T> entity,
Class<RESULT> resultClass,
String fieldName,
Query query)
去重
|
<T extends IEntity,RESULT> |
distinct(Class<T> entity,
Class<RESULT> resultClass,
String fieldName,
QueryBuilder query)
去重
|
<T extends IEntity> |
exists(Class<T> entity,
Query filter)
判断指定条件的实体记录是否存在
|
<T extends IEntity> |
exists(Class<T> entity,
QueryBuilder filter)
判断指定条件的实体记录是否存在
|
<T extends IEntity> |
exists(Class<T> entity,
Serializable id)
判断指定ID的实体记录是否存在
|
<T extends IEntity> |
find(Class<T> entity)
根据实体执行查询全部
|
<T extends IEntity> |
find(Class<T> entity,
Query filter)
根据实体执行查询
|
<T extends IEntity> |
find(Class<T> entity,
QueryBuilder filter)
根据实体执行查询
|
<T extends IEntity> |
find(Class<T> entity,
QueryBuilder filter,
OrderBy orderBy)
根据实体执行查询
|
<T extends IEntity> |
find(Class<T> entity,
QueryBuilder filter,
OrderBy orderBy,
Page page)
根据实体执行分页查询
|
<T extends IEntity> |
find(Class<T> entity,
QueryBuilder filter,
Page page)
根据实体执行分页查询
|
<T extends IEntity> |
find(Class<T> entity,
Query filter,
OrderBy orderBy)
根据实体执行查询
|
<T extends IEntity> |
find(Class<T> entity,
Query filter,
OrderBy orderBy,
Page page)
根据实体执行分页查询
|
<T extends IEntity> |
find(Class<T> entity,
Query filter,
Page page)
根据实体执行分页查询
|
<T extends IEntity> |
find(Class<T> entity,
Serializable id)
通过ID查找指定的实体对象
|
<T extends IEntity> |
findFirst(Class<T> entity,
Query filter)
根据指定key条件执行查询
|
<T extends IEntity> |
findFirst(Class<T> entity,
QueryBuilder filter)
根据指定key条件执行查询
|
<T extends IEntity> |
findFirst(Class<T> entity,
QueryBuilder filter,
OrderBy orderBy)
根据指定key条件执行查询
|
<T extends IEntity> |
findFirst(Class<T> entity,
Query filter,
OrderBy orderBy)
根据指定key条件执行查询
|
<T extends IEntity> |
getCollection(Class<T> entity)
获取数据库集合对象
|
IMongoConnectionHolder |
getConnectionHolder()
获取连接对象
|
IMongo |
getOwner() |
<T extends IEntity> |
insert(List<T> entities)
根据实体执行记录批量插入
|
<T extends IEntity> |
insert(T entity)
根据实体执行记录插入
|
<T extends IEntity,RESULT> |
mapReduce(Class<T> entity,
Class<RESULT> resultClass,
String mapFunction,
String reduceFunction)
MapReduce
|
<T extends IEntity> |
mapReduce(Class<T> entity,
String mapFunction,
String reduceFunction)
MapReduce
|
<T extends IEntity> |
update(List<T> entities)
根据实体执行批量更新
|
<T extends IEntity> |
update(List<T> entities,
Fields filter)
根据实体执行批量更新
|
<T extends IEntity> |
update(T entity)
根据实体执行更新
|
<T extends IEntity> |
update(T entity,
Fields filter)
根据实体执行更新
|
getId, getSessionEventListener, setSessionEventListenerclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetId, getSessionEventListener, setSessionEventListenerpublic DefaultMongoSession(IMongo owner, IMongoConnectionHolder connectionHolder)
public IMongo getOwner()
public IMongoConnectionHolder getConnectionHolder()
ISessiongetConnectionHolder in interface ISession<IMongoConnectionHolder>public void close()
throws Exception
close in interface AutoCloseableExceptionpublic <T extends IEntity> <any> getCollection(Class<T> entity)
IMongoSessiongetCollection in interface IMongoSessionT - 实体类型entity - 实体类public <T extends IEntity> IResultSet<T> find(Class<T> entity, Query filter) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件Exception - 可能产生的异常public <T extends IEntity> IResultSet<T> find(Class<T> entity) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象Exception - 可能产生的异常public <T extends IEntity> IResultSet<T> find(Class<T> entity, QueryBuilder filter) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件Exception - 可能产生的异常public <T extends IEntity> IResultSet<T> find(Class<T> entity, Query filter, OrderBy orderBy) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件orderBy - 排序条件Exception - 可能产生的异常public <T extends IEntity> IResultSet<T> find(Class<T> entity, QueryBuilder filter, OrderBy orderBy) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件orderBy - 排序条件Exception - 可能产生的异常public <T extends IEntity> IResultSet<T> find(Class<T> entity, Query filter, Page page) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件page - 分页查询对象Exception - 可能产生的异常public <T extends IEntity> IResultSet<T> find(Class<T> entity, QueryBuilder filter, Page page) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件page - 分页查询对象Exception - 可能产生的异常public <T extends IEntity> IResultSet<T> find(Class<T> entity, Query filter, OrderBy orderBy, Page page) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件orderBy - 排序条件page - 分页查询对象Exception - 可能产生的异常public <T extends IEntity> IResultSet<T> find(Class<T> entity, QueryBuilder filter, OrderBy orderBy, Page page) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件orderBy - 排序条件page - 分页查询对象Exception - 可能产生的异常public <T extends IEntity> T findFirst(Class<T> entity, Query filter) throws Exception
IMongoSessionfindFirst in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件Exception - 可能产生的异常public <T extends IEntity> T findFirst(Class<T> entity, QueryBuilder filter) throws Exception
IMongoSessionfindFirst in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件Exception - 可能产生的异常public <T extends IEntity> T findFirst(Class<T> entity, Query filter, OrderBy orderBy) throws Exception
IMongoSessionfindFirst in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件orderBy - 排序条件Exception - 可能产生的异常public <T extends IEntity> T findFirst(Class<T> entity, QueryBuilder filter, OrderBy orderBy) throws Exception
IMongoSessionfindFirst in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 过滤条件orderBy - 排序条件Exception - 可能产生的异常public <T extends IEntity> T find(Class<T> entity, Serializable id) throws Exception
IMongoSessionfind in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象id - 记录IdException - 可能产生的异常public <T extends IEntity> long count(Class<T> entity) throws Exception
IMongoSessioncount in interface IMongoSessionT - 指定实体类型entity - 实体类对象Exception - 可能产生的异常public <T extends IEntity> long count(Class<T> entity, Query filter) throws Exception
IMongoSessioncount in interface IMongoSessionT - 指定实体类型entity - 实体类对象filter - 过滤条件Exception - 可能产生的异常public <T extends IEntity> long count(Class<T> entity, QueryBuilder filter) throws Exception
IMongoSessioncount in interface IMongoSessionT - 指定实体类型entity - 实体类对象filter - 过滤条件Exception - 可能产生的异常public <T extends IEntity> boolean exists(Class<T> entity, Serializable id) throws Exception
IMongoSessionexists in interface IMongoSessionT - 指定实体类型entity - 实体类对象id - 记录IdException - 可能产生的异常public <T extends IEntity> boolean exists(Class<T> entity, Query filter) throws Exception
IMongoSessionexists in interface IMongoSessionT - 指定实体类型entity - 实体类对象filter - 条件对象Exception - 可能产生的异常public <T extends IEntity> boolean exists(Class<T> entity, QueryBuilder filter) throws Exception
IMongoSessionexists in interface IMongoSessionT - 指定实体类型entity - 实体类对象filter - 条件对象Exception - 可能产生的异常public <T extends IEntity,RESULT> <any> aggregate(Class<T> entity, Class<RESULT> resultClass, Aggregation... aggregations) throws Exception
IMongoSessionaggregate in interface IMongoSessionT - 指定实体类型RESULT - 指定结果类型entity - 实体类对象resultClass - 结果类对象aggregations - 聚合条件表达式Exception - 可能产生的异常public <T extends IEntity,RESULT> <any> distinct(Class<T> entity, Class<RESULT> resultClass, String fieldName) throws Exception
IMongoSessiondistinct in interface IMongoSessionT - 指定实体类型RESULT - 指定结果类型entity - 实体类对象resultClass - 结果类对象fieldName - 属性名称Exception - 可能产生的异常public <T extends IEntity,RESULT> <any> distinct(Class<T> entity, Class<RESULT> resultClass, String fieldName, Query query) throws Exception
IMongoSessiondistinct in interface IMongoSessionT - 指定实体类型RESULT - 指定结果类型entity - 实体类对象resultClass - 结果类对象fieldName - 属性名称query - 过滤条件Exception - 可能产生的异常public <T extends IEntity,RESULT> <any> distinct(Class<T> entity, Class<RESULT> resultClass, String fieldName, QueryBuilder query) throws Exception
IMongoSessiondistinct in interface IMongoSessionT - 指定实体类型RESULT - 指定结果类型entity - 实体类对象resultClass - 结果类对象fieldName - 属性名称query - 过滤条件Exception - 可能产生的异常public <T extends IEntity,RESULT> <any> mapReduce(Class<T> entity, Class<RESULT> resultClass, String mapFunction, String reduceFunction) throws Exception
IMongoSessionmapReduce in interface IMongoSessionT - 指定实体类型RESULT - 指定结果类型entity - 实体类对象resultClass - 结果类对象mapFunction - 关联Map映射的JavaScript脚本函数reduceFunction - 关联Reduces的JavaScript脚本函数Exception - 可能产生的异常public <T extends IEntity> <any> mapReduce(Class<T> entity, String mapFunction, String reduceFunction) throws Exception
IMongoSessionmapReduce in interface IMongoSessionT - 指定实体类型entity - 实体类对象mapFunction - 关联Map映射的JavaScript脚本函数reduceFunction - 关联Reduces的JavaScript脚本函数Exception - 可能产生的异常public <T extends IEntity> T update(T entity) throws Exception
IMongoSessionupdate in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象Exception - 可能产生的异常public <T extends IEntity> T update(T entity, Fields filter) throws Exception
IMongoSessionupdate in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象filter - 更新字段过滤集合Exception - 可能产生的异常public <T extends IEntity> List<T> update(List<T> entities) throws Exception
IMongoSessionupdate in interface IMongoSessionT - 指定结果集数据类型entities - 实体对象集合Exception - 可能产生的异常public <T extends IEntity> List<T> update(List<T> entities, Fields filter) throws Exception
IMongoSessionupdate in interface IMongoSessionT - 指定结果集数据类型entities - 实体对象集合filter - 更新字段过滤集合Exception - 可能产生的异常public <T extends IEntity> T insert(T entity) throws Exception
IMongoSessioninsert in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象Exception - 可能产生的异常public <T extends IEntity> List<T> insert(List<T> entities) throws Exception
IMongoSessioninsert in interface IMongoSessionT - 指定结果集数据类型entities - 实体对象集合Exception - 可能产生的异常public <T extends IEntity> T delete(T entity) throws Exception
IMongoSessiondelete in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象Exception - 可能产生的异常public <T extends IEntity> T delete(Class<T> entity, Serializable id) throws Exception
IMongoSessiondelete in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象id - 记录唯一标识Exception - 可能产生的异常public <T extends IEntity> long delete(List<T> entities) throws Exception
IMongoSessiondelete in interface IMongoSessionT - 指定结果集数据类型entities - 实体对象集合Exception - 可能产生的异常public <T extends IEntity> long delete(Class<T> entity, Collection<Serializable> ids) throws Exception
IMongoSessiondelete in interface IMongoSessionT - 指定结果集数据类型entity - 实体对象ids - 记录唯一标识集合Exception - 可能产生的异常Copyright © 2022. All rights reserved.