程序包 com.sh.javax

接口 DataCenter

所有已知实现类:
AutoCloseableExDataCenter, AutoCloseableJDBCDataCenter, AutoCloseableMainDataCenter, AutoCloseableReportDataCenter, DataCenterBase, DecorateDataCenter, ESDataCenter, ExDataCenter, JDBCDataCenter, MainDataCenter, ReportDataCenter, SDBDataCenter, SQueryDataCenter

public interface DataCenter
Description: 数据中心接口 Title:首亨软件 - CRM、TSS、ERP等信息化管理软件
  • 字段详细资料

    • QUERY_TIMEOUT_FOREVER

      static final int QUERY_TIMEOUT_FOREVER
      另请参阅:
    • PROC_PARAM_TYPE_IN

      static final int PROC_PARAM_TYPE_IN
      另请参阅:
    • PROC_PARAM_TYPE_OUT

      static final int PROC_PARAM_TYPE_OUT
      另请参阅:
    • PROC_PARAM_TYPE_OUT_CURSOR

      static final int PROC_PARAM_TYPE_OUT_CURSOR
      另请参阅:
    • KEY_External_MainDataCenter

      static final String KEY_External_MainDataCenter
      另请参阅:
    • KEY_External_ReportDataCenter

      static final String KEY_External_ReportDataCenter
      另请参阅:
    • KEY_External_ExDataCenter

      static final String KEY_External_ExDataCenter
      另请参阅:
  • 方法详细资料

    • printLog

      String printLog()
    • printLog

      String printLog(org.slf4j.Logger log)
    • printLog

      String printLog(org.apache.logging.log4j.Logger log4j)
    • printLog

      String printLog(org.apache.logging.log4j.Logger log4j, String prefix)
    • getErrorMsg

      String getErrorMsg()
    • getDriverName

      String getDriverName()
    • getJDBCUrl

      String getJDBCUrl()
    • getJDBCUserId

      String getJDBCUserId()
    • getJDBCPassword

      String getJDBCPassword()
    • getLastException

      Exception getLastException()
    • getDBType

      String getDBType()
      获取当前连接的数据类型
      返回:
      String
    • getCacheDcType

      String getCacheDcType()
      获取缓存使用的连接类型
      返回:
      String
    • hasConnected

      boolean hasConnected()
      是否已经建立连接
      返回:
      boolean
    • isMainDataCenter

      boolean isMainDataCenter()
      是否主数据库连接
      返回:
      boolean
    • isReportDataCenter

      boolean isReportDataCenter()
      是否主数据库连接
      返回:
      boolean
    • isExDataCenter

      boolean isExDataCenter()
      是否主数据库连接
      返回:
      boolean
    • setQueryTimeout

      void setQueryTimeout(int queryTimeout)
      设置查询超时时间,QUERY_TIMEOUT_FOREVER表示无限制
      参数:
      queryTimeout - 超时时长 单位:秒
    • setConnection

      boolean setConnection(Connection conn)
      对于外部传入Connection连接的情况,必须设置
      参数:
      conn - JDBC连接 注意:1)如果已经获取连接再次调用时,必须disconnect后再设置,否则无效 2)通过setConnection设置连接时,不需要调用connect方法
      返回:
      boolean
    • getQueryTimeout

      int getQueryTimeout()
      获取查询超时时长
      返回:
      超时时长,0表示无限制 单位:秒
    • setWriteEnable

      void setWriteEnable(boolean enable)
      设置是否记录DC日志,为全局开关
      参数:
      enable - true|false
    • getWriteEnable

      boolean getWriteEnable()
      查询是否在记录DC日志
      返回:
      boolean
    • setInitClassInfo

      void setInitClassInfo(String initClassInfo)
      初始化该实例类的信息 该方法主要用在记录DC日志时对DataCenter实例进行跟踪
      参数:
      initClassInfo - 实例类信息,如:com.sh.javax.DataCenter.setInitClassInfo
    • connect

      Connection connect()
      连接默认数据库
      返回:
      数据库连接
    • isClosed

      boolean isClosed()
      判断连接是否关闭,只在连接调用close方法后才会返回true
      返回:
      true 已关闭 false 未关闭
    • isValid

      boolean isValid(int timeout)
      判断连接是否有效
      参数:
      timeout - 指定等待验证连接的秒数
      返回:
      true 有效 false 无效
    • isValid

      boolean isValid()
      判断连接是否有效
      返回:
      true 有效 false 无效
    • checkValidAndReset

      boolean checkValidAndReset()
      检查连接,如果连接无效了,则自动重新连接
      返回:
      boolean
    • connect

      @Deprecated Connection connect(String sector)
      已过时。
      连接配置文件中指定的段,这个只对connType=config有效
      参数:
      sector - 段名称
      返回:
      数据库连接
    • getNewConnection

      Connection getNewConnection()
      获取新的连接,不从连接池中取,一般不允许使用
      返回:
      连接对象
    • setConfig

      void setConfig(String JDBCDriver, String JDBCConnectionURL, String userID, String password)
      设置数据连接属性
      参数:
      JDBCDriver - JDBC驱动
      JDBCConnectionURL - 连接URL
      userID - 用户名
      password - 密码
    • setConfig

      void setConfig(String JDBCDriver, String JDBCConnectionURL, String userID, String password, int maxActive, int maxIdle, int maxWait)
      设置数据连接属性
      参数:
      JDBCDriver - JDBC驱动
      JDBCConnectionURL - 连接URL
      userID - 用户名
      password - 密码
      maxActive - 最大活动数
      maxIdle - 最大空闲数
      maxWait - 最大等待时长
    • disconnect

      void disconnect(Connection con)
      断开指定的连接
      参数:
      con - 数据库连接
    • disconnect

      void disconnect()
      断开默认的数据库连接
    • retrieve

      Datastore retrieve(Connection con, String sql)
      从指定的数据中检索数据
      参数:
      con - 数据库连接
      sql - 查询语句
      返回:
      Datastore数据集
    • retrieve

      Datastore retrieve(Connection con, String sql, boolean cacheFlag)
      从指定的数据库中检索数据
      参数:
      con - 数据库连接
      sql - 查询语句
      cacheFlag - true使用缓存,false 不使用缓存
      返回:
      Datastore数据集
    • retrieve

      Datastore retrieve(String sql)
      从默认的数据库中获取数据
      参数:
      sql - 查询SQL
      返回:
      查询结果集
    • retrieve

      Datastore retrieve(String sql, boolean cacheFlag)
      从默认的数据库中获取数据
      参数:
      sql - 查询SQL
      cacheFlag - 是否使用缓存 true|false
      返回:
      查询结果集
    • retrieveObj

      Object retrieveObj(String sql, Class queryObj)
      通过对象查找
      参数:
      sql - 查询SQL
      queryObj - 查询对象
      返回:
      queryObj对应的实例
    • retrieveObj

      Object retrieveObj(String sql, Class queryObj, boolean cacheFlag)
      通过对象查找
      参数:
      sql - 查询SQL
      queryObj - 查询对象
      cacheFlag - 是否使用缓存
      返回:
      queryObj对应的实例
    • retrieveObjByParams2

      Object retrieveObjByParams2(String sql, List<String> colsTypeList, List<Object> colsValueList, Class queryObj)
      查询对象
      参数:
      sql - SQL语句
      colsTypeList - 参数类型
      colsValueList - 参数值
      queryObj - 带注释的PO对象
      返回:
      查询对象
    • retrieveObjByParams

      Object retrieveObjByParams(String sql, String[] colsType, Object[] colsValue, Class queryObj)
      查询对象
      参数:
      sql - SQL语句
      colsType - 参数类型
      colsValue - 参数值
      queryObj - 带注释的PO对象
      返回:
      查询对象
    • retrieveObjByParams

      Object retrieveObjByParams(String sql, Object[] colsValue, Class queryObj)
      查询对象
      参数:
      sql - SQL语句
      colsValue - 参数值
      queryObj - 带注释的PO对象
      返回:
      查询对象
    • retrieveObjByParams

      Object retrieveObjByParams(String sql, String[] colsType, Object[] colsValue, Class queryObj, boolean cacheFlag)
      查询对象
      参数:
      sql - SQL语句
      queryObj - 带注释的PO对象
      colsType - String数据,记录参数对应的类型
      colsValue - String数据
      queryObj - Object数据,记录参数值
      cacheFlag - 是否使用缓存
      返回:
      查询对象
    • retrieveObjList

      List retrieveObjList(String sql, Class queryObj)
      不带参数的多数据集查询,不带缓存
      参数:
      sql - 查询SQL
      queryObj - 查询对象
      返回:
      queryObj对应的实例集
    • retrieveObjList

      List retrieveObjList(String sql, Class queryObj, boolean cacheFlag)
      不带参数的多数据集查询
      参数:
      sql - 查询SQL
      queryObj - 查询对象
      cacheFlag - 是否使用缓存
      返回:
      queryObj对应的实例集
    • retrieveObjList

      List retrieveObjList(String sql, String[] colsType, Object[] colsValue, Class queryObj)
      查询多个对象的列表数据
      参数:
      sql - 查询SQL
      colsType - 参数类型
      colsValue - 参数值
      queryObj - 查询对象
      返回:
      queryObj对应的实例集
    • retrieveObjList

      List retrieveObjList(String sql, Object[] colsValue, Class queryObj)
      查询多个对象的列表数据
      参数:
      sql - 查询SQL
      colsValue - 参数值
      queryObj - 查询对象
      返回:
      queryObj对应的实例集
    • retrieveObjList

      List retrieveObjList(String sql, String[] colsType, Object[] colsValue, Class queryObj, boolean cacheFlag)
      查询多个对象的列表数据
      参数:
      sql - 查询SQL
      colsType - 参数类型
      colsValue - 参数值
      queryObj - 查询对象
      cacheFlag - 是否使用缓存
      返回:
      queryObj对应的List集
    • retrieveByParams

      Datastore retrieveByParams(String sql, String[] colsType, Object[] obj, boolean cacheFlag)
      带参数查询数据集
      参数:
      sql - 查询SQL
      colsType - 参数类型数组
      obj - 参数值数组
      cacheFlag - 是否使用缓存
      返回:
      查询数据集
    • retrieveByParams

      Datastore retrieveByParams(String sql, Object[] obj, boolean cacheFlag)
      带参数查询数据集
      参数:
      sql - 查询SQL
      obj - 参数值数组
      cacheFlag - 是否使用缓存
      返回:
      查询数据集
    • retrieveByParams

      Datastore retrieveByParams(String sql, String[] colsType, Object[] obj)
      带参数查询数据集
      参数:
      sql - 查询SQL
      colsType - 参数类型数组
      obj - 参数值数组
      返回:
      查询数据集
    • retrieveByParams

      Datastore retrieveByParams(String sql, Object[] obj)
      带参数查询数据集
      参数:
      sql - 查询SQL
      obj - 参数值数组
      返回:
      查询数据集
    • retrieveByParams2

      Datastore retrieveByParams2(String sql, List<String> colsTypeList, List<Object> objList)
      带参数查询数据集
      参数:
      sql - 查询SQL
      colsTypeList - 参数类型数组
      objList - 参数值数组
      返回:
      查询数据集
    • retrieveByParams2

      Datastore retrieveByParams2(String sql, List<Object> objList)
    • retrieveByParams2

      Datastore retrieveByParams2(String sql, List<Object> objList, boolean cacheFlag)
    • retrieveByParams2

      Datastore retrieveByParams2(String sql, List<String> colsTypeList, List<Object> objList, boolean cacheFlag)
      带参数查询数据集
      参数:
      sql - 查询SQL
      colsTypeList - 参数类型数组
      objList - 参数值数组
      cacheFlag - 是否使用缓存
      返回:
      查询数据集
    • retrieveByStoreProc

      Datastore retrieveByStoreProc(String procName)
      通过存储过程的方式检索数据
      参数:
      procName - 存储过程名称
      返回:
      数据集Datastore 注意:目前只支持ORACLE
    • retrieveByStoreProc

      Datastore retrieveByStoreProc(String procName, String[] colsType, Object[] obj)
      通过存储过程的方式检索数据
      参数:
      procName - 存储过程名称
      colsType - 参数类型数组
      obj - 参数值数组,多行数据
      返回:
      数据集Datastore 注意:目前只支持ORACLE
    • retrieveListByStoreProc

      List<Datastore> retrieveListByStoreProc(String procName, String[] colsType, Object[] obj, int[] paramType)
      通过存储过程的方式检索数据,能返回多个游标
      参数:
      procName - 存储过程名称,存储过程需要可以任意定义返回游标
      colsType - 参数类型数组
      obj - 参数值数组,多行数据
      paramType - 输入、输出参数类型、DataCenter.PROC_PARAM_TYPE_IN,DataCenter.PROC_PARAM_TYPE_OUT
      返回:
      多数据集Datastore 注意:目前只支持ORACLE
    • update

      String[] update(Connection con, String sql, boolean commit)
      修改指定的数据库中的数据
      参数:
      con - 数据库连接
      sql - 更新语句
      commit - 是否提交,true提交,false不提交,可手动调用dc.commit()提交或dc.rollback()回滚
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • update

      String[] update(String sql)
      执行SQL并按默认方式处理事务
      参数:
      sql - 修改数据库的语句
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateObject

      String[] updateObject(Object obj, boolean commit, boolean showSql)
      更新表数据
      参数:
      obj - 实例对象
      commit - 是否自动提交事务
      showSql - 是否打印出sql 默认为false
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateObject

      String[] updateObject(Object obj, boolean commit)
      更新表数据
      参数:
      obj - 实例对象
      commit - 是否自动提交事务
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • addObject

      String[] addObject(Object obj, boolean commit, boolean showSql)
      添加表数据
      参数:
      obj - 实例对象
      commit - 是否自动提交事务
      showSql - 是否打印出sql 默认为false
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • replaceObject

      String[] replaceObject(Object obj, boolean commit, boolean showSql)
      添加或修改表数据,只有mysql支持
      参数:
      obj - 实例对象
      commit - 是否自动提交事务
      showSql - 是否打印出sql 默认为false
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • replaceObject

      String[] replaceObject(Object obj, boolean commit)
    • addObject

      String[] addObject(Object obj, boolean commit)
      添加表数据
      参数:
      obj - 实例对象
      commit - 是否自动提交事务
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • update

      String[] update(String sql, boolean commit)
      修改默认的数据库中的数据
      参数:
      sql - 更新语句
      commit - 是否提交,true提交,false取消数据更新
      返回:
      string[0] "true"成功;"false"失败 string[1] 出错信息
    • updateByParams

      String[] updateByParams(String sql, String[] colsType, Object[] obj)
      用参数的方式更新数据库
      参数:
      sql - 更改数据库数据的语句
      colsType - 参数类型
      obj - 参数值数组
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByParams

      String[] updateByParams(String sql, Object[] obj)
      用参数的方式更新数据库
      参数:
      sql - 更改数据库数据的语句
      obj - 参数值数组
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByParams

      String[] updateByParams(String sql, String[] colsType, Object[] obj, boolean commit)
      用参数的方式更新数据库
      参数:
      sql - 更改数据库数据的语句
      colsType - 参数类型
      obj - 参数值数组
      commit - 是否提交
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByParams

      String[] updateByParams(String sql, Object[] obj, boolean commit)
      用参数的方式更新数据库
      参数:
      sql - 更改数据库数据的语句
      obj - 参数值数组
      commit - 是否提交
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByParams2

      String[] updateByParams2(String sql, List<String> colsTypeList, List<Object> objList, boolean commit)
      用参数的方式更新数据库
      参数:
      sql - 更改数据库数据的语句
      colsTypeList - 参数类型
      objList - 参数值数组
      commit - 是否提交
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByParams

      String[] updateByParams(String sql, String[] colsType, Object[] obj, int start, int end, boolean commit)
      用参数的方式更新数据库
      参数:
      sql - 更改数据库数据的语句
      colsType - 参数类型
      obj - 参数值数组
      start - 参数起始位置
      end - 参数结束位置
      commit - 是否提交
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByParams

      String[] updateByParams(String sql, String[] colsType, Object[][] obj, boolean commit)
      用参数的方式更新数据库
      参数:
      sql - 更改数据库数据的语句
      colsType - 参数类型
      obj - 参数值数组,同时更改多条数据
      commit - 是否提交
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByStoreProc

      String[] updateByStoreProc(String procName)
    • updateByStoreProc

      String[] updateByStoreProc(String procName, String[] colsType, Object[][] obj, int start, int end, boolean commit)
      通过存储过程的方式修改数据
      参数:
      procName - 存储过程名称
      colsType - 参数类型数组
      obj - 参数值数组,多行数据
      start - 参数起始序号
      end - 参数结束序号
      commit - 是否提交
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByStoreProc

      String[] updateByStoreProc(String procName, String[] colsType, Object[] obj)
      通过存储过程的方式修改数据
      参数:
      procName - 存储过程名称
      colsType - 参数类型数组
      obj - 参数值数组,一行数据
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByStoreProc

      String[] updateByStoreProc(String procName, String[] colsType, Object[] obj, boolean commit)
      通过存储过程的方式修改数据
      参数:
      procName - 存储过程名称
      colsType - 参数类型数组
      obj - 参数值数组,一行数据
      commit - 是否提交
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByStoreProc

      String[] updateByStoreProc(String procName, String[] colsType, Object[] obj, int[] paramType)
      通过存储过程的方式修改数据
      参数:
      procName - 存储过程名称,需要带上参数
      colsType - 参数类型数组
      obj - 参数值数组,一行数据,如果为OUT型参数,可以为空或null
      paramType - 参数类型,DataCenter.PROC_PARAM_TYPE_OUT或DataCenter.PROC_PARAM_TYPE_IN
      返回:
      {true,ret1,ret2....}为果[0]为true时,后台参数依次返回指定参数类型的OUT的值 Note:要求colsType/obj/paramType三个数组长度一致
    • updateByStoreProc

      String[] updateByStoreProc(String procName, String[] colsType, Object[] obj, int start, int end, boolean commit)
      通过存储过程的方式修改数据
      参数:
      procName - 存储过程名称
      colsType - 参数类型数组
      obj - 参数值数组,一行数据
      start - 参数起始序号
      end - 参数结束序号
      commit - 是否提交
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • updateByStoreProc

      String[] updateByStoreProc(String procName, String[] colsType, Object[][] obj, boolean commit)
      通过存储过程的方式修改数据
      参数:
      procName - 存储过程名称
      colsType - 参数类型数组
      obj - 参数值数组,多行数据
      commit - 是否提交
      返回:
      string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
    • beginBatchUpdateByParams

      String[] beginBatchUpdateByParams(String sql, String[] colsType, int refreshCount)
      开始进行批量更新,必需与endBatchUpdateByParams一一配对使用
      参数:
      sql - 执行SQL
      colsType - SQL参数类型
      refreshCount - 批量队列到达该值时自动刷新,0表示取消自动刷新,设置此值后在自动刷新时操作成功会提交事务,即执行commit()方法
      返回:
      {true|false,操作关键字(后续操作会用到)|错误信息}
    • beginBatchUpdateByParams

      String[] beginBatchUpdateByParams(String sql, String[] colsType)
      开始进行批量更新,必需与endBatchUpdateByParams一一配对使用
      参数:
      sql - 执行SQL
      colsType - SQL参数类型
      返回:
      {true|false,操作关键字(后续操作会用到)|错误信息}
    • addBatch

      String[] addBatch(String key, Object[] obj)
      添加批量操作
      参数:
      key - 操作序列号,通过beginBatchUpdateByParams获取
      obj - 参数值
      返回:
      {true|false,操作序列号|错误信息}
    • getBatchUpdate

      BatchUpdate getBatchUpdate(String key)
    • refreshBatchUpdate

      String[] refreshBatchUpdate(String key)
      刷新批量更新,如果批量执行太多时,可以用这个函数来刷新队列,也可以在beginBatchUpdateByParams中设置refreshCount参数
      参数:
      key - 操作序列号,通过beginBatchUpdateByParams获取
      返回:
      {true|false,当前操作号|错误信息}
    • endBatchUpdateByParams

      String[] endBatchUpdateByParams(String key)
      结束批量更新操作,执行后如果要重新执行批量更新,则需要再次调用beginBatchUpdateByParams函数
      参数:
      key - 操作序列号,通过beginBatchUpdateByParams获取
      返回:
      {true|false,更新记录条数|错误信息}
    • endBatchUpdateByParams

      String[] endBatchUpdateByParams(String key, boolean commit)
      结束批量更新操作,执行后如果要重新执行批量更新,则需要再次调用beginBatchUpdateByParams函数
      参数:
      key - 操作序列号,通过beginBatchUpdateByParams获取
      commit - 自动提交事务,true|false,默认:false
      返回:
      {true|false,更新记录条数|错误信息}
    • setAutoCommit

      void setAutoCommit(boolean commit)
      设置DataCenter是否自动提交
      参数:
      commit - true自动提交,false手工提交
    • getConnection

      Connection getConnection()
      获取连接
      返回:
      Connection 连接对象
    • getExecutionLen

      long getExecutionLen()
      获取最后一次执行时长
      返回:
      执行时长,单位:ms
    • commit

      void commit()
      提交事务
    • rollback

      void rollback()
      事务回滚
    • setAutoGetGeneratedKey

      void setAutoGetGeneratedKey(boolean getGeneratedKeys)
      设置自获取序列号
      参数:
      getGeneratedKeys - boolean
    • getAutoGeneratedKey

      int getAutoGeneratedKey()
      获取自增长列 在执行查询前,需要做的操作有: setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) int key == getAutoGeneratedKey() ;
      返回:
      自增长值
    • getAutoGeneratedKey2

      long getAutoGeneratedKey2()
    • getAutoGeneratedKeyStr

      String getAutoGeneratedKeyStr()
      获取自增长列并转化为String类型 在执行查询前,需要做的操作有: setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) String key == getAutoGeneratedKeyStr() ;
      返回:
      自增长键值
    • setUpdateSilence

      void setUpdateSilence(boolean isUpdateSilence)
      设置此连接是否为安静模式,即执行update时不会通知缓存等事件
      参数:
      isUpdateSilence - 开头
    • getLastExecuteSql

      String getLastExecuteSql()
      获取最近一次执行的SQL语句
      返回:
      String
    • getDsCacheRedis

      DSCacheRedis getDsCacheRedis()
      获取redis
      返回:
      DSCacheRedis
    • isExecute

      boolean isExecute()
      就否正在执行SQL
      返回:
      true|false
    • setCheckTimerSchedule

      void setCheckTimerSchedule(long delay, String flag)
      设置定时检查的间隔时间参数
      参数:
      delay - 间隔时间,单独产:毫秒
      flag - 状态标识,用于业务判断
    • setCheckTimerSchedule

      void setCheckTimerSchedule(long delay, boolean forceDisconnect)
      设置定时检查的间隔时间参数
      参数:
      delay - 间隔时间,单独产:毫秒
      forceClose - 到达时间后是否强制关闭
    • setCheckTimerSchedule

      void setCheckTimerSchedule(long delay, String flag, boolean forceClose)
      设置定时检查的间隔时间参数
      参数:
      delay - 间隔时间,单独产:毫秒
      flag - 状态标识,用于业务判断
      forceClose - 到达时间后是否强制关闭,默认:false
    • isTooLongIdle

      boolean isTooLongIdle(long idleTimeout)
      判断是否空闲太久
      参数:
      idleTimeout - 空闲超时时长
      返回:
      boolean true|false
    • getIdleTime

      long getIdleTime()
      获取空闲时间
      返回:
      空闲时长,单位:毫秒
    • createUpdateBuilder

      SqlUpdateBuilder createUpdateBuilder()
      创建添加、修改、删除的SQL生成工具对象为
      返回:
    • createQueryBuilder

      SqlBuilder createQueryBuilder()
      创建查询的SQL生成工具对象为
      返回:
    • createSelectBuilder

      SqlSelectBuilder createSelectBuilder()
    • setParam

      void setParam(String key, String value)
    • getParam

      String getParam(String key, String defaultValue)
    • createColsTypeByValue

      String[] createColsTypeByValue(Object[] value)
      通过参数值自动生成参数类型
      参数:
      value -
      返回:
    • getLastRowCount

      int getLastRowCount()
      获取最后一次影响行数
      返回: