org.apache.shardingsphere.data.pipeline.core.prepare

类 PipelineJobPreparerUtils

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.prepare.PipelineJobPreparerUtils

public final class PipelineJobPreparerUtils
extends Object

Pipeline job preparer utils.

构造器概要

构造器

构造器和说明
PipelineJobPreparerUtils()

方法概要

限定符和类型	方法和说明
static void	checkSourceDataSource(String databaseType, Collection<? extends DataSource> dataSources) Check data source.
static void	checkTargetDataSource(String databaseType, ImporterConfiguration importerConfig, Collection<? extends DataSource> targetDataSources) Check target data source.
static void	destroyPosition(String jobId, PipelineDataSourceConfiguration pipelineDataSourceConfig) Cleanup job preparer.
static IngestPosition<?>	getIncrementalPosition(JobItemIncrementalTasksProgress initIncremental, DumperConfiguration dumperConfig, PipelineDataSourceManager dataSourceManager) Get incremental position.
static org.apache.shardingsphere.infra.parser.ShardingSphereSQLParserEngine	getSQLParserEngine(String targetDatabaseName) Get SQL parser engine.
static boolean	isIncrementalSupported(String databaseType) Is incremental supported.
static void	prepareTargetSchema(String databaseType, PrepareTargetSchemasParameter prepareTargetSchemasParameter) Prepare target schema.
static void	prepareTargetTables(String databaseType, PrepareTargetTablesParameter prepareTargetTablesParameter) Prepare target tables.

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

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

构造器详细资料

PipelineJobPreparerUtils

public PipelineJobPreparerUtils()

方法详细资料

isIncrementalSupported

public static boolean isIncrementalSupported(String databaseType)

Is incremental supported.

参数:

databaseType - database type

返回:

true if supported, otherwise false

prepareTargetSchema

public static void prepareTargetSchema(String databaseType,
                                       PrepareTargetSchemasParameter prepareTargetSchemasParameter)
                                throws SQLException

Prepare target schema.

参数:

databaseType - database type

prepareTargetSchemasParameter - prepare target schemas parameter

抛出:

SQLException - if prepare target schema fail

getSQLParserEngine

public static org.apache.shardingsphere.infra.parser.ShardingSphereSQLParserEngine getSQLParserEngine(String targetDatabaseName)

Get SQL parser engine.

参数:

targetDatabaseName - target database name

返回:

SQL parser engine

prepareTargetTables

public static void prepareTargetTables(String databaseType,
                                       PrepareTargetTablesParameter prepareTargetTablesParameter)
                                throws SQLException

Prepare target tables.

参数:

databaseType - database type

prepareTargetTablesParameter - prepare target tables parameter

抛出:

SQLException - SQL exception

getIncrementalPosition

public static IngestPosition<?> getIncrementalPosition(JobItemIncrementalTasksProgress initIncremental,
                                                       DumperConfiguration dumperConfig,
                                                       PipelineDataSourceManager dataSourceManager)
                                                throws SQLException

Get incremental position.

参数:

initIncremental - init incremental

dumperConfig - dumper config

dataSourceManager - data source manager

返回:

ingest position

抛出:

SQLException - sql exception

checkSourceDataSource

public static void checkSourceDataSource(String databaseType,
                                         Collection<? extends DataSource> dataSources)

Check data source.

参数:

databaseType - database type

dataSources - data source

checkTargetDataSource

public static void checkTargetDataSource(String databaseType,
                                         ImporterConfiguration importerConfig,
                                         Collection<? extends DataSource> targetDataSources)

Check target data source.

参数:

databaseType - database type

importerConfig - importer config

targetDataSources - target data sources

destroyPosition

public static void destroyPosition(String jobId,
                                   PipelineDataSourceConfiguration pipelineDataSourceConfig)
                            throws SQLException

Cleanup job preparer.

参数:

jobId - job id

pipelineDataSourceConfig - pipeline data source config

抛出:

SQLException - sql exception