org.apache.paimon.jdbc

Class JdbcUtils

java.lang.Object

org.apache.paimon.jdbc.JdbcUtils

public class JdbcUtils
extends Object

Util for jdbc catalog.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CATALOG_KEY
static String	CATALOG_TABLE_NAME
static String	TABLE_DATABASE
static String	TABLE_NAME

Constructor Summary

Constructors

Constructor and Description
JdbcUtils()

Method Summary

Modifier and Type	Method and Description
static boolean	acquire(JdbcClientPool connections, String lockId, long timeoutMillSeconds)
static void	createDistributedLockTable(JdbcClientPool connections, Options options)
static boolean	databaseExists(JdbcClientPool connections, String storeKey, String databaseName)
static int	execute(java.util.function.Consumer<SQLException> sqlErrorHandler, JdbcClientPool connections, String sql, String... args)
static int	execute(JdbcClientPool connections, String sql, String... args)
static Properties	extractJdbcConfiguration(Map<String,String> properties, String prefix)
static Map<String,String>	getTable(JdbcClientPool connections, String storeKey, String databaseName, String tableName) Get paimon table metadata.
static boolean	insertProperties(JdbcClientPool connections, String storeKey, String databaseName, Map<String,String> properties)
static void	release(JdbcClientPool connections, String lockId)
static boolean	tableExists(JdbcClientPool connections, String storeKey, String databaseName, String tableName)
static void	updateTable(JdbcClientPool connections, String storeKey, Identifier fromTable, Identifier toTable)

Methods inherited from class java.lang.Object

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

Field Detail

CATALOG_TABLE_NAME

public static final String CATALOG_TABLE_NAME

See Also:

Constant Field Values

CATALOG_KEY

public static final String CATALOG_KEY

See Also:

Constant Field Values

TABLE_DATABASE

public static final String TABLE_DATABASE

See Also:

Constant Field Values

TABLE_NAME

public static final String TABLE_NAME

See Also:

Constant Field Values

Constructor Detail

JdbcUtils

public JdbcUtils()

Method Detail

extractJdbcConfiguration

public static Properties extractJdbcConfiguration(Map<String,String> properties,
                                                  String prefix)

getTable

public static Map<String,String> getTable(JdbcClientPool connections,
                                          String storeKey,
                                          String databaseName,
                                          String tableName)
                                   throws SQLException,
                                          InterruptedException

Get paimon table metadata.

Throws:

SQLException

InterruptedException

updateTable

public static void updateTable(JdbcClientPool connections,
                               String storeKey,
                               Identifier fromTable,
                               Identifier toTable)

databaseExists

public static boolean databaseExists(JdbcClientPool connections,
                                     String storeKey,
                                     String databaseName)

tableExists

public static boolean tableExists(JdbcClientPool connections,
                                  String storeKey,
                                  String databaseName,
                                  String tableName)

execute

public static int execute(JdbcClientPool connections,
                          String sql,
                          String... args)

execute

public static int execute(java.util.function.Consumer<SQLException> sqlErrorHandler,
                          JdbcClientPool connections,
                          String sql,
                          String... args)

insertProperties

public static boolean insertProperties(JdbcClientPool connections,
                                       String storeKey,
                                       String databaseName,
                                       Map<String,String> properties)

createDistributedLockTable

public static void createDistributedLockTable(JdbcClientPool connections,
                                              Options options)
                                       throws SQLException,
                                              InterruptedException

Throws:

SQLException

InterruptedException

acquire

public static boolean acquire(JdbcClientPool connections,
                              String lockId,
                              long timeoutMillSeconds)
                       throws SQLException,
                              InterruptedException

Throws:

SQLException

InterruptedException

release

public static void release(JdbcClientPool connections,
                           String lockId)
                    throws SQLException,
                           InterruptedException

Throws:

SQLException

InterruptedException