net.ymate.platform.persistence.mongodb

Interface IMongoSession

All Superinterfaces:

AutoCloseable, IDestroyable, ISession<IMongoConnectionHolder>

All Known Implementing Classes:

DefaultMongoSession

@Ignored
public interface IMongoSession
extends ISession<IMongoConnectionHolder>

Author:

刘镇 (suninformation@163.com) on 15/11/21 下午12:07

Method Summary

Modifier and Type	Method and Description
<T extends IEntity,RESULT> <any>	aggregate(Class<T> entity, Class<RESULT> resultClass, Aggregation... aggregations) 聚合
<T extends IEntity> long	count(Class<T> entity) 计算查询结果总记录数量
<T extends IEntity> long	count(Class<T> entity, Query filter) 计算查询结果总记录数量
<T extends IEntity> long	count(Class<T> entity, QueryBuilder filter) 计算查询结果总记录数量
<T extends IEntity> long	delete(Class<T> entity, Collection<Serializable> ids) 批量删除指定ID的记录
<T extends IEntity> T	delete(Class<T> entity, Serializable id) 删除指定ID的记录
<T extends IEntity> long	delete(List<T> entities) 根据实体执行记录批量删除
<T extends IEntity> T	delete(T entity) 根据实体执行记录删除
<T extends IEntity,RESULT> <any>	distinct(Class<T> entity, Class<RESULT> resultClass, String fieldName) 去重
<T extends IEntity,RESULT> <any>	distinct(Class<T> entity, Class<RESULT> resultClass, String fieldName, Query query) 去重
<T extends IEntity,RESULT> <any>	distinct(Class<T> entity, Class<RESULT> resultClass, String fieldName, QueryBuilder query) 去重
<T extends IEntity> boolean	exists(Class<T> entity, Query filter) 判断指定条件的实体记录是否存在
<T extends IEntity> boolean	exists(Class<T> entity, QueryBuilder filter) 判断指定条件的实体记录是否存在
<T extends IEntity> boolean	exists(Class<T> entity, Serializable id) 判断指定ID的实体记录是否存在
<T extends IEntity> IResultSet<T>	find(Class<T> entity) 根据实体执行查询全部
<T extends IEntity> IResultSet<T>	find(Class<T> entity, Query filter) 根据实体执行查询
<T extends IEntity> IResultSet<T>	find(Class<T> entity, QueryBuilder filter) 根据实体执行查询
<T extends IEntity> IResultSet<T>	find(Class<T> entity, QueryBuilder filter, OrderBy orderBy) 根据实体执行查询
<T extends IEntity> IResultSet<T>	find(Class<T> entity, QueryBuilder filter, OrderBy orderBy, Page page) 根据实体执行分页查询
<T extends IEntity> IResultSet<T>	find(Class<T> entity, QueryBuilder filter, Page page) 根据实体执行分页查询
<T extends IEntity> IResultSet<T>	find(Class<T> entity, Query filter, OrderBy orderBy) 根据实体执行查询
<T extends IEntity> IResultSet<T>	find(Class<T> entity, Query filter, OrderBy orderBy, Page page) 根据实体执行分页查询
<T extends IEntity> IResultSet<T>	find(Class<T> entity, Query filter, Page page) 根据实体执行分页查询
<T extends IEntity> T	find(Class<T> entity, Serializable id) 通过ID查找指定的实体对象
<T extends IEntity> T	findFirst(Class<T> entity, Query filter) 根据指定key条件执行查询
<T extends IEntity> T	findFirst(Class<T> entity, QueryBuilder filter) 根据指定key条件执行查询
<T extends IEntity> T	findFirst(Class<T> entity, QueryBuilder filter, OrderBy orderBy) 根据指定key条件执行查询
<T extends IEntity> T	findFirst(Class<T> entity, Query filter, OrderBy orderBy) 根据指定key条件执行查询
<T extends IEntity> <any>	getCollection(Class<T> entity) 获取数据库集合对象
<T extends IEntity> List<T>	insert(List<T> entities) 根据实体执行记录批量插入
<T extends IEntity> T	insert(T entity) 根据实体执行记录插入
<T extends IEntity,RESULT> <any>	mapReduce(Class<T> entity, Class<RESULT> resultClass, String mapFunction, String reduceFunction) MapReduce
<T extends IEntity> <any>	mapReduce(Class<T> entity, String mapFunction, String reduceFunction) MapReduce
<T extends IEntity> List<T>	update(List<T> entities) 根据实体执行批量更新
<T extends IEntity> List<T>	update(List<T> entities, Fields filter) 根据实体执行批量更新
<T extends IEntity> T	update(T entity) 根据实体执行更新
<T extends IEntity> T	update(T entity, Fields filter) 根据实体执行更新

Methods inherited from interface net.ymate.platform.core.persistence.ISession

getConnectionHolder, getId, getSessionEventListener, setSessionEventListener

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

getCollection

<T extends IEntity> <any> getCollection(Class<T> entity)

获取数据库集合对象

Type Parameters:

T - 实体类型

Parameters:

entity - 实体类

Returns:

返回对应实体类型的数据库集合对象

find

<T extends IEntity> IResultSet<T> find(Class<T> entity,
                                       Query filter)
                                throws Exception

根据实体执行查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

Returns:

返回全部结果数据

Throws:

Exception - 可能产生的异常

find

<T extends IEntity> IResultSet<T> find(Class<T> entity)
                                throws Exception

根据实体执行查询全部

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

Returns:

返回全部结果数据

Throws:

Exception - 可能产生的异常

find

<T extends IEntity> IResultSet<T> find(Class<T> entity,
                                       QueryBuilder filter)
                                throws Exception

根据实体执行查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

Returns:

返回全部结果数据

Throws:

Exception - 可能产生的异常

find

<T extends IEntity> IResultSet<T> find(Class<T> entity,
                                       Query filter,
                                       OrderBy orderBy)
                                throws Exception

根据实体执行查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

orderBy - 排序条件

Returns:

返回全部结果数据

Throws:

Exception - 可能产生的异常

find

<T extends IEntity> IResultSet<T> find(Class<T> entity,
                                       QueryBuilder filter,
                                       OrderBy orderBy)
                                throws Exception

根据实体执行查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

orderBy - 排序条件

Returns:

返回全部结果数据

Throws:

Exception - 可能产生的异常

find

<T extends IEntity> IResultSet<T> find(Class<T> entity,
                                       Query filter,
                                       Page page)
                                throws Exception

根据实体执行分页查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

page - 分页查询对象

Returns:

返回结果数据

Throws:

Exception - 可能产生的异常

find

<T extends IEntity> IResultSet<T> find(Class<T> entity,
                                       QueryBuilder filter,
                                       Page page)
                                throws Exception

根据实体执行分页查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

page - 分页查询对象

Returns:

返回结果数据

Throws:

Exception - 可能产生的异常

find

<T extends IEntity> IResultSet<T> find(Class<T> entity,
                                       Query filter,
                                       OrderBy orderBy,
                                       Page page)
                                throws Exception

根据实体执行分页查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

orderBy - 排序条件

page - 分页查询对象

Returns:

返回结果数据

Throws:

Exception - 可能产生的异常

find

<T extends IEntity> IResultSet<T> find(Class<T> entity,
                                       QueryBuilder filter,
                                       OrderBy orderBy,
                                       Page page)
                                throws Exception

根据实体执行分页查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

orderBy - 排序条件

page - 分页查询对象

Returns:

返回结果数据

Throws:

Exception - 可能产生的异常

findFirst

<T extends IEntity> T findFirst(Class<T> entity,
                                Query filter)
                         throws Exception

根据指定key条件执行查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

Returns:

返回结果集中第一条数据

Throws:

Exception - 可能产生的异常

findFirst

<T extends IEntity> T findFirst(Class<T> entity,
                                QueryBuilder filter)
                         throws Exception

根据指定key条件执行查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

Returns:

返回结果集中第一条数据

Throws:

Exception - 可能产生的异常

findFirst

<T extends IEntity> T findFirst(Class<T> entity,
                                Query filter,
                                OrderBy orderBy)
                         throws Exception

根据指定key条件执行查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

orderBy - 排序条件

Returns:

返回结果集中第一条数据

Throws:

Exception - 可能产生的异常

findFirst

<T extends IEntity> T findFirst(Class<T> entity,
                                QueryBuilder filter,
                                OrderBy orderBy)
                         throws Exception

根据指定key条件执行查询

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 过滤条件

orderBy - 排序条件

Returns:

返回结果集中第一条数据

Throws:

Exception - 可能产生的异常

find

<T extends IEntity> T find(Class<T> entity,
                           Serializable id)
                    throws Exception

通过ID查找指定的实体对象

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

id - 记录Id

Returns:

返回实体对象

Throws:

Exception - 可能产生的异常

count

<T extends IEntity> long count(Class<T> entity)
                        throws Exception

计算查询结果总记录数量

Type Parameters:

T - 指定实体类型

Parameters:

entity - 实体类对象

Returns:

返回记录数量

Throws:

Exception - 可能产生的异常

count

<T extends IEntity> long count(Class<T> entity,
                               Query filter)
                        throws Exception

计算查询结果总记录数量

Type Parameters:

T - 指定实体类型

Parameters:

entity - 实体类对象

filter - 过滤条件

Returns:

返回总记录数量

Throws:

Exception - 可能产生的异常

count

<T extends IEntity> long count(Class<T> entity,
                               QueryBuilder filter)
                        throws Exception

计算查询结果总记录数量

Type Parameters:

T - 指定实体类型

Parameters:

entity - 实体类对象

filter - 过滤条件

Returns:

返回总记录数量

Throws:

Exception - 可能产生的异常

exists

<T extends IEntity> boolean exists(Class<T> entity,
                                   Serializable id)
                            throws Exception

判断指定ID的实体记录是否存在

Type Parameters:

T - 指定实体类型

Parameters:

entity - 实体类对象

id - 记录Id

Returns:

返回true表示记录存在

Throws:

Exception - 可能产生的异常

exists

<T extends IEntity> boolean exists(Class<T> entity,
                                   Query filter)
                            throws Exception

判断指定条件的实体记录是否存在

Type Parameters:

T - 指定实体类型

Parameters:

entity - 实体类对象

filter - 条件对象

Returns:

返回true表示记录存在

Throws:

Exception - 可能产生的异常

exists

<T extends IEntity> boolean exists(Class<T> entity,
                                   QueryBuilder filter)
                            throws Exception

判断指定条件的实体记录是否存在

Type Parameters:

T - 指定实体类型

Parameters:

entity - 实体类对象

filter - 条件对象

Returns:

返回true表示记录存在

Throws:

Exception - 可能产生的异常

aggregate

<T extends IEntity,RESULT> <any> aggregate(Class<T> entity,
                                           Class<RESULT> resultClass,
                                           Aggregation... aggregations)
                                    throws Exception

聚合

Type Parameters:

T - 指定实体类型

RESULT - 指定结果类型

Parameters:

entity - 实体类对象

resultClass - 结果类对象

aggregations - 聚合条件表达式

Returns:

返回聚合结果集迭代器对象

Throws:

Exception - 可能产生的异常

distinct

<T extends IEntity,RESULT> <any> distinct(Class<T> entity,
                                          Class<RESULT> resultClass,
                                          String fieldName)
                                   throws Exception

去重

Type Parameters:

T - 指定实体类型

RESULT - 指定结果类型

Parameters:

entity - 实体类对象

resultClass - 结果类对象

fieldName - 属性名称

Returns:

返回去重结果集迭代器对象

Throws:

Exception - 可能产生的异常

distinct

<T extends IEntity,RESULT> <any> distinct(Class<T> entity,
                                          Class<RESULT> resultClass,
                                          String fieldName,
                                          Query query)
                                   throws Exception

去重

Type Parameters:

T - 指定实体类型

RESULT - 指定结果类型

Parameters:

entity - 实体类对象

resultClass - 结果类对象

fieldName - 属性名称

query - 过滤条件

Returns:

返回去重结果集迭代器对象

Throws:

Exception - 可能产生的异常

distinct

<T extends IEntity,RESULT> <any> distinct(Class<T> entity,
                                          Class<RESULT> resultClass,
                                          String fieldName,
                                          QueryBuilder query)
                                   throws Exception

去重

Type Parameters:

T - 指定实体类型

RESULT - 指定结果类型

Parameters:

entity - 实体类对象

resultClass - 结果类对象

fieldName - 属性名称

query - 过滤条件

Returns:

返回去重结果集迭代器对象

Throws:

Exception - 可能产生的异常

mapReduce

<T extends IEntity,RESULT> <any> mapReduce(Class<T> entity,
                                           Class<RESULT> resultClass,
                                           String mapFunction,
                                           String reduceFunction)
                                    throws Exception

MapReduce

Type Parameters:

T - 指定实体类型

RESULT - 指定结果类型

Parameters:

entity - 实体类对象

resultClass - 结果类对象

mapFunction - 关联Map映射的JavaScript脚本函数

reduceFunction - 关联Reduces的JavaScript脚本函数

Returns:

返回MapReduce结果集迭代器对象

Throws:

Exception - 可能产生的异常

mapReduce

<T extends IEntity> <any> mapReduce(Class<T> entity,
                                    String mapFunction,
                                    String reduceFunction)
                             throws Exception

MapReduce

Type Parameters:

T - 指定实体类型

Parameters:

entity - 实体类对象

mapFunction - 关联Map映射的JavaScript脚本函数

reduceFunction - 关联Reduces的JavaScript脚本函数

Returns:

返回MapReduce结果集迭代器对象

Throws:

Exception - 可能产生的异常

update

<T extends IEntity> T update(T entity)
                      throws Exception

根据实体执行更新

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

Returns:

返回更新之前的实体对象

Throws:

Exception - 可能产生的异常

update

<T extends IEntity> T update(T entity,
                             Fields filter)
                      throws Exception

根据实体执行更新

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

filter - 更新字段过滤集合

Returns:

返回更新之前的实体对象

Throws:

Exception - 可能产生的异常

update

<T extends IEntity> List<T> update(List<T> entities)
                            throws Exception

根据实体执行批量更新

Type Parameters:

T - 指定结果集数据类型

Parameters:

entities - 实体对象集合

Returns:

返回更新之前的实体对象集合

Throws:

Exception - 可能产生的异常

update

<T extends IEntity> List<T> update(List<T> entities,
                                   Fields filter)
                            throws Exception

根据实体执行批量更新

Type Parameters:

T - 指定结果集数据类型

Parameters:

entities - 实体对象集合

filter - 更新字段过滤集合

Returns:

返回更新之前的实体对象集合

Throws:

Exception - 可能产生的异常

insert

<T extends IEntity> T insert(T entity)
                      throws Exception

根据实体执行记录插入

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

Returns:

返回插入后的实体对象

Throws:

Exception - 可能产生的异常

insert

<T extends IEntity> List<T> insert(List<T> entities)
                            throws Exception

根据实体执行记录批量插入

Type Parameters:

T - 指定结果集数据类型

Parameters:

entities - 实体对象集合

Returns:

返回插入后的实体对象集合

Throws:

Exception - 可能产生的异常

delete

<T extends IEntity> T delete(T entity)
                      throws Exception

根据实体执行记录删除

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

Returns:

返回删除之前的实体对象

Throws:

Exception - 可能产生的异常

delete

<T extends IEntity> T delete(Class<T> entity,
                             Serializable id)
                      throws Exception

删除指定ID的记录

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

id - 记录唯一标识

Returns:

返回删除之前的实体对象

Throws:

Exception - 可能产生的异常

delete

<T extends IEntity> long delete(List<T> entities)
                         throws Exception

根据实体执行记录批量删除

Type Parameters:

T - 指定结果集数据类型

Parameters:

entities - 实体对象集合

Returns:

返回删除操作影响记录数量

Throws:

Exception - 可能产生的异常

delete

<T extends IEntity> long delete(Class<T> entity,
                                Collection<Serializable> ids)
                         throws Exception

批量删除指定ID的记录

Type Parameters:

T - 指定结果集数据类型

Parameters:

entity - 实体对象

ids - 记录唯一标识集合

Returns:

返回删除操作影响记录数量

Throws:

Exception - 可能产生的异常