com.anwen.mongo.mapper

类 MongoPlusMapMapper

java.lang.Object

com.anwen.mongo.mapper.MongoPlusMapMapper

所有已实现的接口:

CommInjectQuery, InjectQuery

public class MongoPlusMapMapper
extends Object
implements InjectQuery

作者:

JiaChaoYang

构造器概要

构造器

构造器和说明
MongoPlusMapMapper(SqlExecute sqlExecute)

方法概要

限定符和类型	方法和说明
List<Map<String,Object>>	aggregateList(com.mongodb.client.ClientSession clientSession, String collectionName, AggregateChainWrapper<Map<String,Object>,?> queryChainWrapper)
List<Map<String,Object>>	aggregateList(String collectionName, AggregateChainWrapper<Map<String,Object>,?> queryChainWrapper)
long	count(com.mongodb.client.ClientSession clientSession, String collectionName) 获取总行数
long	count(com.mongodb.client.ClientSession clientSession, String collectionName, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper) 获取总行数
long	count(String collectionName) 获取总行数
long	count(String collectionName, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper) 获取总行数
String	createIndex(com.mongodb.client.ClientSession clientSession, String collectionName, org.bson.conversions.Bson bson) 创建索引，携带事务
String	createIndex(com.mongodb.client.ClientSession clientSession, String collectionName, org.bson.conversions.Bson bson, com.mongodb.client.model.IndexOptions indexOptions) 使用给定的键和选项创建索引。
String	createIndex(String collectionName, org.bson.conversions.Bson bson) 创建索引
String	createIndex(String collectionName, org.bson.conversions.Bson bson, com.mongodb.client.model.IndexOptions indexOptions) 使用给定的键和选项创建索引。
List<String>	createIndexes(com.mongodb.client.ClientSession clientSession, String collectionName, List<com.mongodb.client.model.IndexModel> indexes) 创建多个索引
List<String>	createIndexes(com.mongodb.client.ClientSession clientSession, String collectionName, List<com.mongodb.client.model.IndexModel> indexes, com.mongodb.client.model.CreateIndexOptions createIndexOptions) 创建多个索引
List<String>	createIndexes(String collectionName, List<com.mongodb.client.model.IndexModel> indexes) 创建多个索引
List<String>	createIndexes(String collectionName, List<com.mongodb.client.model.IndexModel> indexes, com.mongodb.client.model.CreateIndexOptions createIndexOptions) 创建多个索引
void	dropIndex(com.mongodb.client.ClientSession clientSession, String collectionName, org.bson.conversions.Bson keys) 在给定用于创建索引的键的情况下删除索引。
void	dropIndex(com.mongodb.client.ClientSession clientSession, String collectionName, org.bson.conversions.Bson keys, com.mongodb.client.model.DropIndexOptions dropIndexOptions) 在给定用于创建索引的键的情况下删除索引。
void	dropIndex(com.mongodb.client.ClientSession clientSession, String collectionName, String indexName) 删除给定其名称的索引。
void	dropIndex(com.mongodb.client.ClientSession clientSession, String collectionName, String indexName, com.mongodb.client.model.DropIndexOptions dropIndexOptions) 删除给定其名称的索引。
void	dropIndex(String collectionName, org.bson.conversions.Bson keys) 在给定用于创建索引的键的情况下删除索引。
void	dropIndex(String collectionName, org.bson.conversions.Bson keys, com.mongodb.client.model.DropIndexOptions dropIndexOptions) 在给定用于创建索引的键的情况下删除索引。
void	dropIndex(String collectionName, String indexName) 删除给定其名称的索引。
void	dropIndex(String collectionName, String indexName, com.mongodb.client.model.DropIndexOptions dropIndexOptions) 删除给定其名称的索引。
void	dropIndexes(com.mongodb.client.ClientSession clientSession, String collectionName) 删除此集合上的所有索引，但 _id 上的默认值除外。
void	dropIndexes(com.mongodb.client.ClientSession clientSession, String collectionName, com.mongodb.client.model.DropIndexOptions dropIndexOptions) 删除此集合上的所有索引，但 _id 上的默认值除外。
void	dropIndexes(String collectionName) 删除此集合上的所有索引，但 _id 上的默认值除外。
void	dropIndexes(String collectionName, com.mongodb.client.model.DropIndexOptions dropIndexOptions) 删除此集合上的所有索引，但 _id 上的默认值除外。
List<Map<String,Object>>	getByColumn(com.mongodb.client.ClientSession clientSession, String collection, String field, Object fieldValue)
List<Map<String,Object>>	getByColumn(String collectionName, String field, Object fieldValue) 根据某一列查询
Map<String,Object>	getById(com.mongodb.client.ClientSession clientSession, String collectionName, Serializable id)
Map<String,Object>	getById(String collectionName, Serializable id)
List<Map<String,Object>>	getByIds(com.mongodb.client.ClientSession clientSession, String collectionName, Collection<Serializable> ids)
List<Map<String,Object>>	getByIds(String collectionName, Collection<Serializable> ids)
com.mongodb.client.MongoCollection<org.bson.Document>	getMongoCollection(String collectionName) 获取当前操作对象的连接，以便使用MongoDriver的语法
LambdaAggregateChainInjectWrapper	lambdaAggregate()
LambdaQueryChainInjectWrapper	lambdaQuery()
LambdaUpdateChainInjectWrapper	lambdaUpdate()
Map<String,Object>	limitOne(com.mongodb.client.ClientSession clientSession, String collectionName, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper) 获取单个，返回T类型的对象 注：如果查询到大于一条数据，会取第一条返回
Map<String,Object>	limitOne(String collectionName, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper) 获取单个，返回T类型的对象 注：如果查询到大于一条数据，会取第一条返回
List<Map<String,Object>>	list(com.mongodb.client.ClientSession clientSession, String collectionName) 获取列表 返回Map类型的List
List<Map<String,Object>>	list(com.mongodb.client.ClientSession clientSession, String collectionName, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)
List<Map<String,Object>>	list(String collectionName) 获取列表 返回Map类型的List
List<Map<String,Object>>	list(String collectionName, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)
List<org.bson.Document>	listIndexes(com.mongodb.client.ClientSession clientSession, String collectionName) 获取此集合中的所有索引。
List<org.bson.Document>	listIndexes(String collectionName) 获取此集合中的所有索引。
Map<String,Object>	one(com.mongodb.client.ClientSession clientSession, String collectionName, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper) 获取单个，返回T类型的对象 注：如果查询到大于一条数据，会抛出MongoQueryException异常
Map<String,Object>	one(String collectionName, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper) 获取单个，返回T类型的对象 注：如果查询到大于一条数据，会抛出MongoQueryException异常
PageResult<Map<String,Object>>	page(com.mongodb.client.ClientSession clientSession, String collectionName, Integer pageNum, Integer pageSize) 分页
PageResult<Map<String,Object>>	page(com.mongodb.client.ClientSession clientSession, String collectionName, Integer pageNum, Integer pageSize, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)
PageResult<Map<String,Object>>	page(com.mongodb.client.ClientSession clientSession, String collectionName, PageParam pageParam) 分页
PageResult<Map<String,Object>>	page(com.mongodb.client.ClientSession clientSession, String collectionName, PageParam pageParam, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)
PageResult<Map<String,Object>>	page(String collectionName, Integer pageNum, Integer pageSize) 分页
PageResult<Map<String,Object>>	page(String collectionName, Integer pageNum, Integer pageSize, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)
PageResult<Map<String,Object>>	page(String collectionName, PageParam pageParam) 分页
PageResult<Map<String,Object>>	page(String collectionName, PageParam pageParam, QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)
Boolean	remove(com.mongodb.client.ClientSession clientSession, String collectionName, UpdateChainWrapper<Map<String,Object>,?> updateChainWrapper) 根据条件删除
Boolean	remove(String collectionName, UpdateChainWrapper<Map<String,Object>,?> updateChainWrapper) 根据条件删除
Boolean	removeBatchByIds(com.mongodb.client.ClientSession clientSession, String collectionName, Collection<Serializable> idList) 根据id批量删除
Boolean	removeBatchByIds(String collectionName, Collection<Serializable> idList) 根据id批量删除
Boolean	removeByColumn(com.mongodb.client.ClientSession clientSession, String collectionName, String column, String value) 根据字段删除
Boolean	removeByColumn(String collectionName, String column, String value) 根据字段删除
Boolean	removeById(com.mongodb.client.ClientSession clientSession, String collectionName, Serializable id) 根据id删除
Boolean	removeById(String collectionName, Serializable id) 根据id删除
Boolean	save(com.mongodb.client.ClientSession clientSession, String collectionName, Map<String,Object> entityMap) 添加
Boolean	save(String collectionName, Map<String,Object> entityMap) 添加
Boolean	saveBatch(com.mongodb.client.ClientSession clientSession, String collectionName, Collection<Map<String,Object>> entityMapList) 添加多个
Boolean	saveBatch(String collectionName, Collection<Map<String,Object>> entityMapList) 添加多个
Boolean	saveOrUpdate(com.mongodb.client.ClientSession clientSession, String collectionName, Map<String,Object> entityMap) 添加或修改
Boolean	saveOrUpdate(String collectionName, Map<String,Object> entityMap) 添加或修改
Boolean	saveOrUpdateBatch(com.mongodb.client.ClientSession clientSession, String collectionName, Collection<Map<String,Object>> entityMapList) 批量添加或修改
Boolean	saveOrUpdateBatch(String collectionName, Collection<Map<String,Object>> entityMapList) 批量添加或修改
List<Map<String,Object>>	sql(com.mongodb.client.ClientSession clientSession, String collectionName, String sql)
List<Map<String,Object>>	sql(String collectionName, String sql)
Boolean	update(com.mongodb.client.ClientSession clientSession, String collectionName, UpdateChainWrapper<Map<String,Object>,?> updateChainWrapper) 根据条件修改
Boolean	update(String collectionName, UpdateChainWrapper<Map<String,Object>,?> updateChainWrapper) 根据条件修改
Boolean	updateBatchByIds(com.mongodb.client.ClientSession clientSession, String collectionName, Collection<Map<String,Object>> entityMapList) 修改多个，根据id
Boolean	updateBatchByIds(String collectionName, Collection<Map<String,Object>> entityMapList) 修改多个，根据id
Boolean	updateByColumn(com.mongodb.client.ClientSession clientSession, String collectionName, Map<String,Object> entityMap, String column) 通过列进行修改
Boolean	updateByColumn(String collectionName, Map<String,Object> entityMap, String column) 通过列进行修改
Boolean	updateById(com.mongodb.client.ClientSession clientSession, String collectionName, Map<String,Object> entityMap) 修改根据id
Boolean	updateById(String collectionName, Map<String,Object> entityMap) 修改根据id

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

MongoPlusMapMapper

public MongoPlusMapMapper(SqlExecute sqlExecute)

方法详细资料

getMongoCollection

public com.mongodb.client.MongoCollection<org.bson.Document> getMongoCollection(String collectionName)

获取当前操作对象的连接，以便使用MongoDriver的语法

lambdaQuery

public LambdaQueryChainInjectWrapper lambdaQuery()

lambdaAggregate

public LambdaAggregateChainInjectWrapper lambdaAggregate()

lambdaUpdate

public LambdaUpdateChainInjectWrapper lambdaUpdate()

list

public List<Map<String,Object>> list(String collectionName)

从接口复制的说明: CommInjectQuery

获取列表 返回Map类型的List

指定者:

list 在接口中 CommInjectQuery

参数:

collectionName - 集合名

返回:

< Map >

list

public List<Map<String,Object>> list(com.mongodb.client.ClientSession clientSession,
                                     String collectionName)

从接口复制的说明: CommInjectQuery

获取列表 返回Map类型的List

指定者:

list 在接口中 CommInjectQuery

collectionName - 集合名

返回:

< Map >

list

public List<Map<String,Object>> list(String collectionName,
                                     QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

指定者:

list 在接口中 InjectQuery

list

public List<Map<String,Object>> list(com.mongodb.client.ClientSession clientSession,
                                     String collectionName,
                                     QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

指定者:

list 在接口中 InjectQuery

aggregateList

public List<Map<String,Object>> aggregateList(String collectionName,
                                              AggregateChainWrapper<Map<String,Object>,?> queryChainWrapper)

指定者:

aggregateList 在接口中 InjectQuery

aggregateList

public List<Map<String,Object>> aggregateList(com.mongodb.client.ClientSession clientSession,
                                              String collectionName,
                                              AggregateChainWrapper<Map<String,Object>,?> queryChainWrapper)

指定者:

aggregateList 在接口中 InjectQuery

one

public Map<String,Object> one(String collectionName,
                              QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

从接口复制的说明: InjectQuery

获取单个，返回T类型的对象

注：如果查询到大于一条数据，会抛出MongoQueryException异常

指定者:

one 在接口中 InjectQuery

参数:

collectionName - 集合名

返回:

Map

one

public Map<String,Object> one(com.mongodb.client.ClientSession clientSession,
                              String collectionName,
                              QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

从接口复制的说明: InjectQuery

获取单个，返回T类型的对象

注：如果查询到大于一条数据，会抛出MongoQueryException异常

指定者:

one 在接口中 InjectQuery

collectionName - 集合名

返回:

Map

limitOne

public Map<String,Object> limitOne(String collectionName,
                                   QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

从接口复制的说明: InjectQuery

获取单个，返回T类型的对象

注：如果查询到大于一条数据，会取第一条返回

指定者:

limitOne 在接口中 InjectQuery

参数:

collectionName - 集合名

返回:

Map< String, Object>

limitOne

public Map<String,Object> limitOne(com.mongodb.client.ClientSession clientSession,
                                   String collectionName,
                                   QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

从接口复制的说明: InjectQuery

获取单个，返回T类型的对象

注：如果查询到大于一条数据，会取第一条返回

指定者:

limitOne 在接口中 InjectQuery

collectionName - 集合名

返回:

Map< String, Object>

page

public PageResult<Map<String,Object>> page(String collectionName,
                                           PageParam pageParam)

从接口复制的说明: CommInjectQuery

分页

指定者:

page 在接口中 CommInjectQuery

参数:

collectionName - 集合名

pageParam - 分页参数对象

返回:

< Map< String, Object>>

page

public PageResult<Map<String,Object>> page(com.mongodb.client.ClientSession clientSession,
                                           String collectionName,
                                           PageParam pageParam)

从接口复制的说明: CommInjectQuery

分页

指定者:

page 在接口中 CommInjectQuery

collectionName - 集合名

pageParam - 分页参数对象

返回:

< Map< String, Object>>

page

public PageResult<Map<String,Object>> page(String collectionName,
                                           PageParam pageParam,
                                           QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

指定者:

page 在接口中 InjectQuery

page

public PageResult<Map<String,Object>> page(com.mongodb.client.ClientSession clientSession,
                                           String collectionName,
                                           PageParam pageParam,
                                           QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

指定者:

page 在接口中 InjectQuery

page

public PageResult<Map<String,Object>> page(String collectionName,
                                           Integer pageNum,
                                           Integer pageSize)

从接口复制的说明: CommInjectQuery

分页

指定者:

page 在接口中 CommInjectQuery

参数:

collectionName - 集合名

pageNum - 当前页

pageSize - 每页显示行数

返回:

Map< String, Object>>

page

public PageResult<Map<String,Object>> page(com.mongodb.client.ClientSession clientSession,
                                           String collectionName,
                                           Integer pageNum,
                                           Integer pageSize)

从接口复制的说明: CommInjectQuery

分页

指定者:

page 在接口中 CommInjectQuery

collectionName - 集合名

pageNum - 当前页

pageSize - 每页显示行数

返回:

Map< String, Object>>

page

public PageResult<Map<String,Object>> page(String collectionName,
                                           Integer pageNum,
                                           Integer pageSize,
                                           QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

指定者:

page 在接口中 InjectQuery

page

public PageResult<Map<String,Object>> page(com.mongodb.client.ClientSession clientSession,
                                           String collectionName,
                                           Integer pageNum,
                                           Integer pageSize,
                                           QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

指定者:

page 在接口中 InjectQuery

getById

public Map<String,Object> getById(String collectionName,
                                  Serializable id)

指定者:

getById 在接口中 InjectQuery

getById

public Map<String,Object> getById(com.mongodb.client.ClientSession clientSession,
                                  String collectionName,
                                  Serializable id)

指定者:

getById 在接口中 InjectQuery

getByIds

public List<Map<String,Object>> getByIds(String collectionName,
                                         Collection<Serializable> ids)

指定者:

getByIds 在接口中 InjectQuery

getByIds

public List<Map<String,Object>> getByIds(com.mongodb.client.ClientSession clientSession,
                                         String collectionName,
                                         Collection<Serializable> ids)

指定者:

getByIds 在接口中 InjectQuery

save

public Boolean save(String collectionName,
                    Map<String,Object> entityMap)

从接口复制的说明: InjectQuery

添加

指定者:

save 在接口中 InjectQuery

参数:

collectionName - 集合名

entityMap - 添加的Map

返回:

java.lang.Boolean

save

public Boolean save(com.mongodb.client.ClientSession clientSession,
                    String collectionName,
                    Map<String,Object> entityMap)

从接口复制的说明: InjectQuery

添加

指定者:

save 在接口中 InjectQuery

collectionName - 集合名

entityMap - 添加的Map

返回:

java.lang.Boolean

saveBatch

public Boolean saveBatch(String collectionName,
                         Collection<Map<String,Object>> entityMapList)

从接口复制的说明: InjectQuery

添加多个

指定者:

saveBatch 在接口中 InjectQuery

参数:

collectionName - 集合名

entityMapList - map对象集合

返回:

java.lang.Boolean

saveBatch

public Boolean saveBatch(com.mongodb.client.ClientSession clientSession,
                         String collectionName,
                         Collection<Map<String,Object>> entityMapList)

从接口复制的说明: InjectQuery

添加多个

指定者:

saveBatch 在接口中 InjectQuery

collectionName - 集合名

entityMapList - map对象集合

返回:

java.lang.Boolean

saveOrUpdate

public Boolean saveOrUpdate(String collectionName,
                            Map<String,Object> entityMap)

从接口复制的说明: InjectQuery

添加或修改

指定者:

saveOrUpdate 在接口中 InjectQuery

参数:

collectionName - 集合名

entityMap - map对象

返回:

java.lang.Boolean

saveOrUpdate

public Boolean saveOrUpdate(com.mongodb.client.ClientSession clientSession,
                            String collectionName,
                            Map<String,Object> entityMap)

从接口复制的说明: InjectQuery

添加或修改

指定者:

saveOrUpdate 在接口中 InjectQuery

collectionName - 集合名

entityMap - map对象

返回:

java.lang.Boolean

saveOrUpdateBatch

public Boolean saveOrUpdateBatch(String collectionName,
                                 Collection<Map<String,Object>> entityMapList)

从接口复制的说明: InjectQuery

批量添加或修改

指定者:

saveOrUpdateBatch 在接口中 InjectQuery

参数:

collectionName - 集合名

entityMapList - map对象集合

返回:

java.lang.Boolean

saveOrUpdateBatch

public Boolean saveOrUpdateBatch(com.mongodb.client.ClientSession clientSession,
                                 String collectionName,
                                 Collection<Map<String,Object>> entityMapList)

从接口复制的说明: InjectQuery

批量添加或修改

指定者:

saveOrUpdateBatch 在接口中 InjectQuery

collectionName - 集合名

entityMapList - map对象集合

返回:

java.lang.Boolean

updateById

public Boolean updateById(String collectionName,
                          Map<String,Object> entityMap)

从接口复制的说明: InjectQuery

修改根据id

指定者:

updateById 在接口中 InjectQuery

参数:

collectionName - 集合名

entityMap - 修改的对象，需要包含id

返回:

java.lang.Boolean

updateById

public Boolean updateById(com.mongodb.client.ClientSession clientSession,
                          String collectionName,
                          Map<String,Object> entityMap)

从接口复制的说明: InjectQuery

修改根据id

指定者:

updateById 在接口中 InjectQuery

collectionName - 集合名

entityMap - 修改的对象，需要包含id

返回:

java.lang.Boolean

updateBatchByIds

public Boolean updateBatchByIds(String collectionName,
                                Collection<Map<String,Object>> entityMapList)

从接口复制的说明: InjectQuery

修改多个，根据id

指定者:

updateBatchByIds 在接口中 InjectQuery

参数:

collectionName - 集合名

返回:

Boolean

updateBatchByIds

public Boolean updateBatchByIds(com.mongodb.client.ClientSession clientSession,
                                String collectionName,
                                Collection<Map<String,Object>> entityMapList)

从接口复制的说明: InjectQuery

修改多个，根据id

指定者:

updateBatchByIds 在接口中 InjectQuery

collectionName - 集合名

返回:

Boolean

updateByColumn

public Boolean updateByColumn(String collectionName,
                              Map<String,Object> entityMap,
                              String column)

从接口复制的说明: InjectQuery

通过列进行修改

指定者:

updateByColumn 在接口中 InjectQuery

参数:

collectionName - 集合名

entityMap - 修改的实体

column - 根据什么列修改

返回:

java.lang.Boolean

updateByColumn

public Boolean updateByColumn(com.mongodb.client.ClientSession clientSession,
                              String collectionName,
                              Map<String,Object> entityMap,
                              String column)

从接口复制的说明: InjectQuery

通过列进行修改

指定者:

updateByColumn 在接口中 InjectQuery

collectionName - 集合名

entityMap - 修改的实体

column - 根据什么列修改

返回:

java.lang.Boolean

removeById

public Boolean removeById(String collectionName,
                          Serializable id)

从接口复制的说明: InjectQuery

根据id删除

指定者:

removeById 在接口中 InjectQuery

参数:

collectionName - 集合名

id - 数据id

返回:

java.lang.Boolean

removeById

public Boolean removeById(com.mongodb.client.ClientSession clientSession,
                          String collectionName,
                          Serializable id)

从接口复制的说明: InjectQuery

根据id删除

指定者:

removeById 在接口中 InjectQuery

collectionName - 集合名

id - 数据id

返回:

java.lang.Boolean

removeByColumn

public Boolean removeByColumn(String collectionName,
                              String column,
                              String value)

从接口复制的说明: InjectQuery

根据字段删除

指定者:

removeByColumn 在接口中 InjectQuery

参数:

collectionName - 集合名

column - 字段

value - 值

返回:

java.lang.Boolean

removeByColumn

public Boolean removeByColumn(com.mongodb.client.ClientSession clientSession,
                              String collectionName,
                              String column,
                              String value)

从接口复制的说明: InjectQuery

根据字段删除

指定者:

removeByColumn 在接口中 InjectQuery

collectionName - 集合名

column - 字段

value - 值

返回:

java.lang.Boolean

removeBatchByIds

public Boolean removeBatchByIds(String collectionName,
                                Collection<Serializable> idList)

从接口复制的说明: InjectQuery

根据id批量删除

指定者:

removeBatchByIds 在接口中 InjectQuery

参数:

collectionName - 集合名

idList - id集合

返回:

java.lang.Boolean

removeBatchByIds

public Boolean removeBatchByIds(com.mongodb.client.ClientSession clientSession,
                                String collectionName,
                                Collection<Serializable> idList)

从接口复制的说明: InjectQuery

根据id批量删除

指定者:

removeBatchByIds 在接口中 InjectQuery

collectionName - 集合名

idList - id集合

返回:

java.lang.Boolean

count

public long count(String collectionName,
                  QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

从接口复制的说明: InjectQuery

获取总行数

指定者:

count 在接口中 InjectQuery

参数:

collectionName - 集合名

queryChainWrapper - 条件构造器

返回:

long

count

public long count(com.mongodb.client.ClientSession clientSession,
                  String collectionName,
                  QueryChainWrapper<Map<String,Object>,?> queryChainWrapper)

从接口复制的说明: InjectQuery

获取总行数

指定者:

count 在接口中 InjectQuery

collectionName - 集合名

queryChainWrapper - 条件构造器

返回:

long

getByColumn

public List<Map<String,Object>> getByColumn(String collectionName,
                                            String field,
                                            Object fieldValue)

从接口复制的说明: InjectQuery

根据某一列查询

指定者:

getByColumn 在接口中 InjectQuery

field - 字段

fieldValue - 字段值

返回:

T

getByColumn

public List<Map<String,Object>> getByColumn(com.mongodb.client.ClientSession clientSession,
                                            String collection,
                                            String field,
                                            Object fieldValue)

指定者:

getByColumn 在接口中 InjectQuery

remove

public Boolean remove(String collectionName,
                      UpdateChainWrapper<Map<String,Object>,?> updateChainWrapper)

从接口复制的说明: InjectQuery

根据条件删除

指定者:

remove 在接口中 InjectQuery

updateChainWrapper - 条件

返回:

java.lang.Boolean

remove

public Boolean remove(com.mongodb.client.ClientSession clientSession,
                      String collectionName,
                      UpdateChainWrapper<Map<String,Object>,?> updateChainWrapper)

从接口复制的说明: InjectQuery

根据条件删除

指定者:

remove 在接口中 InjectQuery

参数:

clientSession - 事务接口

updateChainWrapper - 条件

返回:

java.lang.Boolean

update

public Boolean update(String collectionName,
                      UpdateChainWrapper<Map<String,Object>,?> updateChainWrapper)

从接口复制的说明: InjectQuery

根据条件修改

指定者:

update 在接口中 InjectQuery

updateChainWrapper - 条件

返回:

java.lang.Boolean

update

public Boolean update(com.mongodb.client.ClientSession clientSession,
                      String collectionName,
                      UpdateChainWrapper<Map<String,Object>,?> updateChainWrapper)

从接口复制的说明: InjectQuery

根据条件修改

指定者:

update 在接口中 InjectQuery

参数:

clientSession - 事务接口

updateChainWrapper - 条件

返回:

java.lang.Boolean

sql

public List<Map<String,Object>> sql(String collectionName,
                                    String sql)

指定者:

sql 在接口中 InjectQuery

sql

public List<Map<String,Object>> sql(com.mongodb.client.ClientSession clientSession,
                                    String collectionName,
                                    String sql)

指定者:

sql 在接口中 InjectQuery

createIndex

public String createIndex(com.mongodb.client.ClientSession clientSession,
                          String collectionName,
                          org.bson.conversions.Bson bson)

从接口复制的说明: InjectQuery

创建索引，携带事务

指定者:

createIndex 在接口中 InjectQuery

bson - 描述索引键的对象，该对象不能为 null

返回:

java.lang.String

createIndex

public String createIndex(String collectionName,
                          org.bson.conversions.Bson bson)

从接口复制的说明: InjectQuery

创建索引

指定者:

createIndex 在接口中 InjectQuery

bson - 描述索引键的对象，该对象不能为 null

返回:

java.lang.String

createIndex

public String createIndex(com.mongodb.client.ClientSession clientSession,
                          String collectionName,
                          org.bson.conversions.Bson bson,
                          com.mongodb.client.model.IndexOptions indexOptions)

从接口复制的说明: InjectQuery

使用给定的键和选项创建索引。

指定者:

createIndex 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

bson - 描述索引键的对象，该对象不能为 null

indexOptions - 指数的选项

返回:

java.lang.String

createIndex

public String createIndex(String collectionName,
                          org.bson.conversions.Bson bson,
                          com.mongodb.client.model.IndexOptions indexOptions)

从接口复制的说明: InjectQuery

使用给定的键和选项创建索引。

指定者:

createIndex 在接口中 InjectQuery

bson - 描述索引键的对象，该对象不能为 null

indexOptions - 指数的选项

返回:

java.lang.String

createIndexes

public List<String> createIndexes(String collectionName,
                                  List<com.mongodb.client.model.IndexModel> indexes)

从接口复制的说明: InjectQuery

创建多个索引

指定者:

createIndexes 在接口中 InjectQuery

indexes - 索引列表

返回:

java.util.List

createIndexes

public List<String> createIndexes(String collectionName,
                                  List<com.mongodb.client.model.IndexModel> indexes,
                                  com.mongodb.client.model.CreateIndexOptions createIndexOptions)

从接口复制的说明: InjectQuery

创建多个索引

指定者:

createIndexes 在接口中 InjectQuery

indexes - 索引列表

createIndexOptions - 创建索引时要使用的选项

返回:

java.util.List 索引名称列表

createIndexes

public List<String> createIndexes(com.mongodb.client.ClientSession clientSession,
                                  String collectionName,
                                  List<com.mongodb.client.model.IndexModel> indexes)

从接口复制的说明: InjectQuery

创建多个索引

指定者:

createIndexes 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

indexes - 索引列表

返回:

java.util.List 索引名称列表

createIndexes

public List<String> createIndexes(com.mongodb.client.ClientSession clientSession,
                                  String collectionName,
                                  List<com.mongodb.client.model.IndexModel> indexes,
                                  com.mongodb.client.model.CreateIndexOptions createIndexOptions)

从接口复制的说明: InjectQuery

创建多个索引

指定者:

createIndexes 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

indexes - 索引列表

createIndexOptions - 创建索引时要使用的选项

返回:

java.util.List 索引名称列表

listIndexes

public List<org.bson.Document> listIndexes(String collectionName)

从接口复制的说明: InjectQuery

获取此集合中的所有索引。

指定者:

listIndexes 在接口中 InjectQuery

返回:

列表索引可迭代接口

listIndexes

public List<org.bson.Document> listIndexes(com.mongodb.client.ClientSession clientSession,
                                           String collectionName)

从接口复制的说明: InjectQuery

获取此集合中的所有索引。

指定者:

listIndexes 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

返回:

列表索引可迭代接口

dropIndex

public void dropIndex(String collectionName,
                      String indexName)

从接口复制的说明: InjectQuery

删除给定其名称的索引。

指定者:

dropIndex 在接口中 InjectQuery

indexName - 要删除的索引的名称

dropIndex

public void dropIndex(String collectionName,
                      String indexName,
                      com.mongodb.client.model.DropIndexOptions dropIndexOptions)

从接口复制的说明: InjectQuery

删除给定其名称的索引。

指定者:

dropIndex 在接口中 InjectQuery

indexName - 要删除的索引的名称

dropIndexOptions - 删除索引时要使用的选项

dropIndex

public void dropIndex(String collectionName,
                      org.bson.conversions.Bson keys)

从接口复制的说明: InjectQuery

在给定用于创建索引的键的情况下删除索引。

指定者:

dropIndex 在接口中 InjectQuery

keys - 要删除的索引的键

dropIndex

public void dropIndex(String collectionName,
                      org.bson.conversions.Bson keys,
                      com.mongodb.client.model.DropIndexOptions dropIndexOptions)

从接口复制的说明: InjectQuery

在给定用于创建索引的键的情况下删除索引。

指定者:

dropIndex 在接口中 InjectQuery

keys - 要删除的索引的键

dropIndexOptions - 删除索引时要使用的选项

dropIndex

public void dropIndex(com.mongodb.client.ClientSession clientSession,
                      String collectionName,
                      String indexName)

从接口复制的说明: InjectQuery

删除给定其名称的索引。

指定者:

dropIndex 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

indexName - 要删除的索引的名称

dropIndex

public void dropIndex(com.mongodb.client.ClientSession clientSession,
                      String collectionName,
                      org.bson.conversions.Bson keys)

从接口复制的说明: InjectQuery

在给定用于创建索引的键的情况下删除索引。

指定者:

dropIndex 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

keys - 要删除的索引的键

dropIndex

public void dropIndex(com.mongodb.client.ClientSession clientSession,
                      String collectionName,
                      String indexName,
                      com.mongodb.client.model.DropIndexOptions dropIndexOptions)

从接口复制的说明: InjectQuery

删除给定其名称的索引。

指定者:

dropIndex 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

indexName - 要删除的索引的名称

dropIndexOptions - 删除索引时要使用的选项

dropIndex

public void dropIndex(com.mongodb.client.ClientSession clientSession,
                      String collectionName,
                      org.bson.conversions.Bson keys,
                      com.mongodb.client.model.DropIndexOptions dropIndexOptions)

从接口复制的说明: InjectQuery

在给定用于创建索引的键的情况下删除索引。

指定者:

dropIndex 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

keys - 要删除的索引的键

dropIndexOptions - 删除索引时要使用的选项

dropIndexes

public void dropIndexes(String collectionName)

从接口复制的说明: InjectQuery

删除此集合上的所有索引，但 _id 上的默认值除外。

指定者:

dropIndexes 在接口中 InjectQuery

dropIndexes

public void dropIndexes(com.mongodb.client.ClientSession clientSession,
                        String collectionName)

从接口复制的说明: InjectQuery

删除此集合上的所有索引，但 _id 上的默认值除外。

指定者:

dropIndexes 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

dropIndexes

public void dropIndexes(String collectionName,
                        com.mongodb.client.model.DropIndexOptions dropIndexOptions)

从接口复制的说明: InjectQuery

删除此集合上的所有索引，但 _id 上的默认值除外。

指定者:

dropIndexes 在接口中 InjectQuery

dropIndexOptions - 删除索引时要使用的选项

dropIndexes

public void dropIndexes(com.mongodb.client.ClientSession clientSession,
                        String collectionName,
                        com.mongodb.client.model.DropIndexOptions dropIndexOptions)

从接口复制的说明: InjectQuery

删除此集合上的所有索引，但 _id 上的默认值除外。

指定者:

dropIndexes 在接口中 InjectQuery

参数:

clientSession - 要与此操作关联的客户端会话

dropIndexOptions - 删除索引时要使用的选项

count

public long count(String collectionName)

从接口复制的说明: CommInjectQuery

获取总行数

指定者:

count 在接口中 CommInjectQuery

参数:

collectionName - 集合名

返回:

long

count

public long count(com.mongodb.client.ClientSession clientSession,
                  String collectionName)

从接口复制的说明: CommInjectQuery

获取总行数

指定者:

count 在接口中 CommInjectQuery

collectionName - 集合名

返回:

long