程序包 com.sh.javax.datastore

类 DsUpdateDBBuilder

java.lang.Object
com.sh.javax.datastore.DsUpdateDBBuilder
所有已实现的接口:
Serializable, Cloneable
public class DsUpdateDBBuilder extends Object implements Serializable, Cloneable

Description:

Title:首亨软件 - 聚天平台

另请参阅:

  • 字段详细资料

    • log4j

      protected static final org.apache.logging.log4j.Logger log4j

  • 构造器详细资料

  • 方法详细资料

    • processData

      public DsUpdateDBBuilder processData(DsUpdateDBBuilderCol_I process)

    • setUpdateCheckFilter

      public DsUpdateDBBuilder setUpdateCheckFilter(Predicate<RowInfo> updateFilterFunc)

    • setTableName

      public DsUpdateDBBuilder setTableName(String tableName)

    • setPkCol

      public DsUpdateDBBuilder setPkCol(String... cols)
      设置主键
      参数:
      cols - 修改后的列名
      返回:

    • autoCreateTable

      public DsUpdateDBBuilder autoCreateTable(boolean autoCreate)
      自动创建表
      参数:
      autoCreate -
      返回:

    • clearTableData

      public DsUpdateDBBuilder clearTableData(boolean clearData)
      操作前清空表一次，只有一次生效
      参数:
      clearData -
      返回:

    • changeColName

      public DsUpdateDBBuilder changeColName(String oldName, String newName)
      修改列名
      参数:
      oldName -
      newName -
      返回:

    • refreshEveryCount

      public DsUpdateDBBuilder refreshEveryCount(int count)

    • ignoreCols

      public DsUpdateDBBuilder ignoreCols(String... cols)
      设置忽略的列
      参数:
      cols -
      返回:

    • asInsert

      public DsUpdateDBBuilder asInsert()

    • asInsertIgnore

      public DsUpdateDBBuilder asInsertIgnore()

    • asUpdate

      public DsUpdateDBBuilder asUpdate()

    • asInsertOrUpdate

      public DsUpdateDBBuilder asInsertOrUpdate()

    • onlyInsert

      public DsUpdateDBBuilder onlyInsert()

    • onlyUpdate

      public DsUpdateDBBuilder onlyUpdate()

    • ifExistsQueryFromDBColValue

      public DsUpdateDBBuilder ifExistsQueryFromDBColValue(String... colName)
      如果表里的数据已经存在，则从数据库更新非条件列
      参数:
      colName -
      返回:

    • setNoChangeIgnore

      public DsUpdateDBBuilder setNoChangeIgnore(boolean flag)
      数据没有改变时，不进行数据库更新，注意，只有asInsertOrUpdate()时有效
      参数:
      flag -
      返回:

    • getSQLBatchBuilder

      public SQLBatchBuilder getSQLBatchBuilder()

    • setDebug

      public DsUpdateDBBuilder setDebug(boolean flag)

    • nextDs

      public DsUpdateDBBuilder nextDs(Datastore ds)
      执行另一个相同结构的ds
      参数:
      ds - 相求表结构与上次一样，且主键、修改列名都已经完成，一般用于流式转换时使用，相同对象，只是数据变更
      返回:

    • reset

      public DsUpdateDBBuilder reset()
      重置临时数据
      返回:

    • updateCommit

      public String[] updateCommit()

    • update

      public String[] update(boolean commit)
      入库操作
      返回:

    • checkColExists

      protected void checkColExists(List<DsUpdateDBBuilder.DsUpdateDBBuilderCol> colList)
      检查列是否存在，不存在自动添加

    • getDs

      public Datastore getDs()

    • getInsertRow

      public int getInsertRow()

    • getUpdateRow

      public int getUpdateRow()

    • getTableName

      public String getTableName()

    • getDc

      public DataCenter getDc()