org.apache.shardingsphere.data.pipeline.core.sqlbuilder

类 AbstractPipelineSQLBuilder

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

所有已实现的接口:

PipelineSQLBuilder, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI, org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

直接已知子类:

DefaultPipelineSQLBuilder, OraclePipelineSQLBuilder

public abstract class AbstractPipelineSQLBuilder
extends Object
implements PipelineSQLBuilder

Abstract pipeline SQL builder.

构造器概要

构造器

构造器和说明
AbstractPipelineSQLBuilder()

方法概要

限定符和类型	方法和说明
String	buildCheckEmptySQL(String schemaName, String tableName)
String	buildChunkedQuerySQL(String schemaName, @NonNull String tableName, @NonNull String uniqueKey, boolean firstQuery)
String	buildCountSQL(String schemaName, String tableName)
String	buildDeleteSQL(String schemaName, DataRecord dataRecord, Collection<Column> conditionColumns)
String	buildDivisibleInventoryDumpSQL(String schemaName, String tableName, String uniqueKey, int uniqueKeyDataType, boolean firstQuery)
String	buildDropSQL(String schemaName, String tableName)
String	buildIndivisibleInventoryDumpSQL(String schemaName, String tableName, String uniqueKey, int uniqueKeyDataType, boolean firstQuery)
String	buildInsertSQL(String schemaName, DataRecord dataRecord, Map<LogicTableName,Set<String>> shardingColumnsMap)
String	buildSplitByPrimaryKeyRangeSQL(String schemaName, String tableName, String primaryKey)
String	buildUpdateSQL(String schemaName, DataRecord dataRecord, Collection<Column> conditionColumns, Map<LogicTableName,Set<String>> shardingColumnsMap)
List<Column>	extractUpdatedColumns(DataRecord record, Map<LogicTableName,Set<String>> shardingColumnsMap)
protected String	getQualifiedTableName(String schemaName, String tableName)
protected boolean	isShardingColumn(Map<LogicTableName,Set<String>> shardingColumnsMap, String tableName, String columnName)
String	quote(String item) Add left and right identifier quote string.

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

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

从接口继承的方法 org.apache.shardingsphere.data.pipeline.spi.sqlbuilder.PipelineSQLBuilder

buildCRC32SQL, buildCreateSchemaSQL

从接口继承的方法 org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

getType, getTypeAliases

从接口继承的方法 org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI

isDefault

构造器详细资料

AbstractPipelineSQLBuilder

public AbstractPipelineSQLBuilder()

方法详细资料

quote

public String quote(String item)

Add left and right identifier quote string.

参数:

item - to add quote item

返回:

add quote string

buildDivisibleInventoryDumpSQL

public String buildDivisibleInventoryDumpSQL(String schemaName,
                                             String tableName,
                                             String uniqueKey,
                                             int uniqueKeyDataType,
                                             boolean firstQuery)

指定者:

buildDivisibleInventoryDumpSQL 在接口中 PipelineSQLBuilder

buildIndivisibleInventoryDumpSQL

public String buildIndivisibleInventoryDumpSQL(String schemaName,
                                               String tableName,
                                               String uniqueKey,
                                               int uniqueKeyDataType,
                                               boolean firstQuery)

指定者:

buildIndivisibleInventoryDumpSQL 在接口中 PipelineSQLBuilder

getQualifiedTableName

protected final String getQualifiedTableName(String schemaName,
                                             String tableName)

buildInsertSQL

public String buildInsertSQL(String schemaName,
                             DataRecord dataRecord,
                             Map<LogicTableName,Set<String>> shardingColumnsMap)

指定者:

buildInsertSQL 在接口中 PipelineSQLBuilder

isShardingColumn

protected final boolean isShardingColumn(Map<LogicTableName,Set<String>> shardingColumnsMap,
                                         String tableName,
                                         String columnName)

buildUpdateSQL

public String buildUpdateSQL(String schemaName,
                             DataRecord dataRecord,
                             Collection<Column> conditionColumns,
                             Map<LogicTableName,Set<String>> shardingColumnsMap)

指定者:

buildUpdateSQL 在接口中 PipelineSQLBuilder

extractUpdatedColumns

public List<Column> extractUpdatedColumns(DataRecord record,
                                          Map<LogicTableName,Set<String>> shardingColumnsMap)

指定者:

extractUpdatedColumns 在接口中 PipelineSQLBuilder

buildDeleteSQL

public String buildDeleteSQL(String schemaName,
                             DataRecord dataRecord,
                             Collection<Column> conditionColumns)

指定者:

buildDeleteSQL 在接口中 PipelineSQLBuilder

buildDropSQL

public String buildDropSQL(String schemaName,
                           String tableName)

指定者:

buildDropSQL 在接口中 PipelineSQLBuilder

buildCountSQL

public String buildCountSQL(String schemaName,
                            String tableName)

指定者:

buildCountSQL 在接口中 PipelineSQLBuilder

buildChunkedQuerySQL

public String buildChunkedQuerySQL(String schemaName,
                                   @NonNull
                                   @NonNull String tableName,
                                   @NonNull
                                   @NonNull String uniqueKey,
                                   boolean firstQuery)

指定者:

buildChunkedQuerySQL 在接口中 PipelineSQLBuilder

buildCheckEmptySQL

public String buildCheckEmptySQL(String schemaName,
                                 String tableName)

指定者:

buildCheckEmptySQL 在接口中 PipelineSQLBuilder

buildSplitByPrimaryKeyRangeSQL

public String buildSplitByPrimaryKeyRangeSQL(String schemaName,
                                             String tableName,
                                             String primaryKey)

指定者:

buildSplitByPrimaryKeyRangeSQL 在接口中 PipelineSQLBuilder