程序包 com.sie.mbm.mom.framework.db.executeDme.service

类 DmeExecuteImpl

java.lang.Object
com.sie.mbm.mom.framework.db.executeDme.service.DmeExecuteImpl
所有已实现的接口:
DmeExecute
@Component public class DmeExecuteImpl extends Object implements DmeExecute
DmeExecuteImpl 是 DmeExecute 接口的实现类，用于执行与数据库交互的各种操作。 该类通过委托服务（xdmDelegatorService）调用底层接口完成数据的增删改查等操作。

  • 字段详细资料

  • 构造器详细资料

    • DmeExecuteImpl

      public DmeExecuteImpl()

  • 方法详细资料

    • selectListByQuery

      public <T> List<T> selectListByQuery(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper)
      根据查询条件查询所有匹配的数据列表。
      指定者:
      selectListByQuery 在接口中 DmeExecute
      类型参数:
      T - 返回数据的类型
      参数:
      tableInfo - 表信息对象，包含表名、实体类等信息
      queryWrapper - 查询条件包装器
      返回:
      查询结果列表

    • selectCountByQuery

      public long selectCountByQuery(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper)
      根据查询条件统计记录数量。
      指定者:
      selectCountByQuery 在接口中 DmeExecute
      参数:
      tableInfo - 表信息对象
      queryWrapper - 查询条件包装器
      返回:
      记录总数

    • selectPageByQuery

      public <T> List<T> selectPageByQuery(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper, com.huawei.innovation.rdm.coresdk.basic.vo.RDMPageVO vo)
      分页查询数据。
      指定者:
      selectPageByQuery 在接口中 DmeExecute
      类型参数:
      T - 返回数据的类型
      参数:
      tableInfo - 表信息对象
      queryWrapper - 查询条件包装器
      vo - 分页参数对象
      返回:
      分页查询结果列表

    • selectOneById

      public Object selectOneById(ExpandTableInfo tableInfo, Serializable id)
      根据主键ID查询单条记录。
      指定者:
      selectOneById 在接口中 DmeExecute
      参数:
      tableInfo - 表信息对象
      id - 主键ID
      返回:
      查询到的对象，未找到则返回null

    • selectListByIds

      public <T> List<T> selectListByIds(ExpandTableInfo tableInfo, Collection<? extends Serializable> ids)
      根据多个主键ID批量查询记录。
      指定者:
      selectListByIds 在接口中 DmeExecute
      类型参数:
      T - 返回数据的类型
      参数:
      tableInfo - 表信息对象
      ids - 主键ID集合
      返回:
      查询结果列表

    • insert

      public Long insert(ExpandTableInfo tableInfo, Object param)
      插入一条记录。
      指定者:
      insert 在接口中 DmeExecute
      参数:
      tableInfo - 表信息对象
      param - 待插入的数据对象
      返回:
      插入记录的主键ID

    • insertBatch

      public int insertBatch(ExpandTableInfo tableInfo, List<?> entities)
      批量插入多条记录。
      指定者:
      insertBatch 在接口中 DmeExecute
      参数:
      tableInfo - 实体类对应的表信息
      entities - 待插入的实体列表
      返回:
      成功插入的记录数

    • insertBatchAndReturnId

      public List<?> insertBatchAndReturnId(ExpandTableInfo tableInfo, List<?> entities)
      批量插入并返回插入后的记录列表。
      指定者:
      insertBatchAndReturnId 在接口中 DmeExecute
      参数:
      tableInfo - 实体类对应的表信息
      entities - 待插入的实体列表
      返回:
      插入后的记录列表

    • update

      public int update(ExpandTableInfo tableInfo, Object entity, boolean ignoreNulls)
      更新单个实体对象。
      指定者:
      update 在接口中 DmeExecute
      参数:
      tableInfo - 实体类对应的表信息
      entity - 待更新的实体对象
      ignoreNulls - 是否忽略空值字段
      返回:
      更新影响的行数（固定为1）

    • updateBatch

      public int updateBatch(ExpandTableInfo tableInfo, List<?> entities, boolean ignoreNulls)
      批量更新多个实体对象。
      指定者:
      updateBatch 在接口中 DmeExecute
      参数:
      tableInfo - 实体类对应的表信息
      entities - 待更新的实体列表
      ignoreNulls - 是否忽略空值字段
      返回:
      更新影响的行数（等于实体列表大小）

    • updateByQuery

      public int updateByQuery(ExpandTableInfo tableInfo, Object dto, com.mybatisflex.core.query.QueryWrapper queryWrapper)
      根据查询条件更新记录。
      指定者:
      updateByQuery 在接口中 DmeExecute
      参数:
      tableInfo - 实体类对应的表信息
      dto - 更新内容对象
      queryWrapper - 查询条件包装器
      返回:
      更新影响的行数（固定为1）

    • deleteById

      public int deleteById(ExpandTableInfo tableInfo, Serializable id)
      根据主键ID删除记录。
      指定者:
      deleteById 在接口中 DmeExecute
      参数:
      tableInfo - 实体类对应的表信息
      id - 主键ID
      返回:
      删除影响的行数

    • deleteBatchByIds

      public int deleteBatchByIds(ExpandTableInfo tableInfo, Collection<? extends Serializable> ids)
      批量根据主键ID删除记录。
      指定者:
      deleteBatchByIds 在接口中 DmeExecute
      参数:
      tableInfo - 实体类对应的表信息
      ids - 主键ID集合
      返回:
      删除影响的行数

    • deleteByQuery

      public int deleteByQuery(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper)
      根据查询条件删除记录。
      指定者:
      deleteByQuery 在接口中 DmeExecute
      参数:
      tableInfo - 实体类对应的表信息
      queryWrapper - 查询条件包装器
      返回:
      删除影响的行数

    • executeList

      public <T> List<T> executeList(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper)
      执行自定义查询并返回结果列表。
      指定者:
      executeList 在接口中 DmeExecute
      类型参数:
      T - 返回数据的类型
      参数:
      tableInfo - 实体类对应的表信息
      queryWrapper - 查询条件包装器
      返回:
      查询结果列表

    • getExecuteListFilter

      private Object getExecuteListFilter(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper)
      获取执行列表查询所需的过滤参数。
      参数:
      tableInfo - 实体类对应的表信息
      queryWrapper - 查询条件包装器
      返回:
      过滤参数对象

    • executePage

      public <T> List<T> executePage(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper, com.huawei.innovation.rdm.coresdk.basic.vo.RDMPageVO vo)
      执行分页查询并返回结果列表。
      指定者:
      executePage 在接口中 DmeExecute
      类型参数:
      T - 返回数据的类型
      参数:
      tableInfo - 实体类对应的表信息
      queryWrapper - 查询条件包装器
      vo - 分页参数对象
      返回:
      查询结果列表

    • statics

      public Map<String,Object> statics(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper)
      统计查询结果中的聚合函数值。
      指定者:
      statics 在接口中 DmeExecute
      参数:
      tableInfo - 实体类对应的表信息
      queryWrapper - 查询条件包装器
      返回:
      聚合统计结果Map

    • getQueryFilter

      private com.huawei.innovation.rdm.coresdk.basic.vo.QueryRequestVo getQueryFilter(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper)
      获取查询参数。
      参数:
      tableInfo - 表信息对象
      queryWrapper - 查询条件包装器
      返回:
      查询请求参数对象

    • getExecuteFilter

      private Object getExecuteFilter(ExpandTableInfo tableInfo, com.mybatisflex.core.query.QueryWrapper queryWrapper)
      获取执行查询所需的过滤参数。
      参数:
      tableInfo - 表信息对象
      queryWrapper - 查询条件包装器
      返回:
      查询参数对象

    • resultToInt

      private int resultToInt(Object obj)
      将返回结果转换为整型。
      参数:
      obj - 返回结果对象
      返回:
      整型结果

    • getUserId

      private String getUserId()
      获取当前用户ID。
      返回:
      当前用户ID字符串

    • autoFillSite

      private void autoFillSite(ExpandTableInfo tableInfo, List<?> entities)
      自动填充siteID
      参数:
      entities -

    • getDmeTableName

      private String getDmeTableName(ExpandTableInfo tableInfo)