org.apache.paimon.flink.action.cdc.schema

Class JdbcSchemaUtils

java.lang.Object

org.apache.paimon.flink.action.cdc.schema.JdbcSchemaUtils

public class JdbcSchemaUtils
extends Object

Utility class to load table schema with JDBC.

Constructor Summary

Constructors

Constructor and Description
JdbcSchemaUtils()

Method Summary

Modifier and Type	Method and Description
static Schema	buildSchema(DatabaseMetaData metaData, String databaseName, String schemaName, String tableName, String tableComment, TypeMapping typeMapping, JdbcToPaimonTypeVisitor jdbcToPaimonTypeVisitor)
static Schema	buildSchema(DatabaseMetaData metaData, String databaseName, String tableName, String tableComment, TypeMapping typeMapping, JdbcToPaimonTypeVisitor jdbcToPaimonTypeVisitor)
static Schema	mergeSchema(String currentTable, Schema current, String otherTable, Schema other)

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcSchemaUtils

public JdbcSchemaUtils()

Method Detail

buildSchema

public static Schema buildSchema(DatabaseMetaData metaData,
                                 String databaseName,
                                 String tableName,
                                 String tableComment,
                                 TypeMapping typeMapping,
                                 JdbcToPaimonTypeVisitor jdbcToPaimonTypeVisitor)
                          throws SQLException

Throws:

SQLException

buildSchema

public static Schema buildSchema(DatabaseMetaData metaData,
                                 String databaseName,
                                 String schemaName,
                                 String tableName,
                                 String tableComment,
                                 TypeMapping typeMapping,
                                 JdbcToPaimonTypeVisitor jdbcToPaimonTypeVisitor)
                          throws SQLException

Throws:

SQLException

mergeSchema

public static Schema mergeSchema(String currentTable,
                                 Schema current,
                                 String otherTable,
                                 Schema other)