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.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	buildInsertSQL(String schemaName, DataRecord dataRecord, Map<LogicTableName,Set<String>> shardingColumnsMap)
String	buildInventoryDumpSQL(String schemaName, String tableName, String uniqueKey, int uniqueKeyDataType, boolean firstQuery)
String	buildSplitByPrimaryKeyRangeSQL(String schemaName, String tableName, String primaryKey)
String	buildTruncateSQL(String schemaName, String tableName)
String	buildUpdateSQL(String schemaName, DataRecord dataRecord, Collection<Column> conditionColumns, Map<LogicTableName,Set<String>> shardingColumnsMap)
protected String	decorate(String schemaName, String tableName)
List<Column>	extractUpdatedColumns(DataRecord record, Map<LogicTableName,Set<String>> shardingColumnsMap)
protected abstract String	getLeftIdentifierQuoteString() Get left identifier quote string.
protected abstract String	getRightIdentifierQuoteString() Get right identifier quote string.
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

构造器详细资料

AbstractPipelineSQLBuilder

public AbstractPipelineSQLBuilder()

方法详细资料

getLeftIdentifierQuoteString

protected abstract String getLeftIdentifierQuoteString()

Get left identifier quote string.

返回:

string

getRightIdentifierQuoteString

protected abstract String getRightIdentifierQuoteString()

Get right identifier quote string.

返回:

string

quote

public String quote(String item)

Add left and right identifier quote string.

参数:

item - to add quote item

返回:

add quote string

buildInventoryDumpSQL

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

指定者:

buildInventoryDumpSQL 在接口中 PipelineSQLBuilder

decorate

protected String decorate(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

buildTruncateSQL

public String buildTruncateSQL(String schemaName,
                               String tableName)

指定者:

buildTruncateSQL 在接口中 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