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

类 OraclePipelineSQLBuilder

java.lang.Object

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

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

所有已实现的接口:

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

public final class OraclePipelineSQLBuilder
extends AbstractPipelineSQLBuilder

Oracle pipeline SQL builder.

构造器概要

构造器

构造器和说明
OraclePipelineSQLBuilder()

方法概要

限定符和类型	方法和说明
String	buildCheckEmptySQL(String schemaName, String tableName)
String	buildChunkedQuerySQL(String schemaName, @NonNull String tableName, @NonNull String uniqueKey, boolean firstQuery)
String	buildDivisibleInventoryDumpSQL(String schemaName, String tableName, String uniqueKey, int uniqueKeyDataType, boolean firstQuery)
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	getType()

从类继承的方法 org.apache.shardingsphere.data.pipeline.core.sqlbuilder.AbstractPipelineSQLBuilder

buildCountSQL, buildDeleteSQL, buildDropSQL, buildUpdateSQL, extractUpdatedColumns, getQualifiedTableName, isShardingColumn, quote

从类继承的方法 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

getTypeAliases

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

isDefault

构造器详细资料

OraclePipelineSQLBuilder

public OraclePipelineSQLBuilder()

方法详细资料

buildDivisibleInventoryDumpSQL

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

指定者:

buildDivisibleInventoryDumpSQL 在接口中 PipelineSQLBuilder

覆盖:

buildDivisibleInventoryDumpSQL 在类中 AbstractPipelineSQLBuilder

buildIndivisibleInventoryDumpSQL

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

指定者:

buildIndivisibleInventoryDumpSQL 在接口中 PipelineSQLBuilder

覆盖:

buildIndivisibleInventoryDumpSQL 在类中 AbstractPipelineSQLBuilder

buildInsertSQL

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

指定者:

buildInsertSQL 在接口中 PipelineSQLBuilder

覆盖:

buildInsertSQL 在类中 AbstractPipelineSQLBuilder

buildChunkedQuerySQL

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

指定者:

buildChunkedQuerySQL 在接口中 PipelineSQLBuilder

覆盖:

buildChunkedQuerySQL 在类中 AbstractPipelineSQLBuilder

buildCheckEmptySQL

public String buildCheckEmptySQL(String schemaName,
                                 String tableName)

指定者:

buildCheckEmptySQL 在接口中 PipelineSQLBuilder

覆盖:

buildCheckEmptySQL 在类中 AbstractPipelineSQLBuilder

buildSplitByPrimaryKeyRangeSQL

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

指定者:

buildSplitByPrimaryKeyRangeSQL 在接口中 PipelineSQLBuilder

覆盖:

buildSplitByPrimaryKeyRangeSQL 在类中 AbstractPipelineSQLBuilder

getType

public String getType()