org.apache.shardingsphere.data.pipeline.core.util

类 PipelineSchemaTableUtil

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.util.PipelineSchemaTableUtil

public final class PipelineSchemaTableUtil
extends Object

Pipeline schema table util.

方法概要

限定符和类型	方法和说明
static String	getDefaultSchema(PipelineDataSourceConfiguration dataSourceConfig) Get default schema by connection.getSchema().
static Map<String,List<String>>	getSchemaTablesMapFromActual(PipelineDataSourceConfiguration pipelineDataSourceConfig, String schemaName, String tableName) Get schema tables map from actual data source.

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

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

方法详细资料

getSchemaTablesMapFromActual

public static Map<String,List<String>> getSchemaTablesMapFromActual(PipelineDataSourceConfiguration pipelineDataSourceConfig,
                                                                    String schemaName,
                                                                    String tableName)

Get schema tables map from actual data source.

参数:

pipelineDataSourceConfig - pipeline data source config

schemaName - schema name,

tableName - table name

返回:

schema tables map

getDefaultSchema

public static String getDefaultSchema(PipelineDataSourceConfiguration dataSourceConfig)

Get default schema by connection.getSchema().

参数:

dataSourceConfig - pipeline data source config

返回:

schema