org.tikv.common

Class TiDBJDBCClient

java.lang.Object

org.tikv.common.TiDBJDBCClient

All Implemented Interfaces:

AutoCloseable

public class TiDBJDBCClient
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor and Description
TiDBJDBCClient(Connection connection)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	dropTable(String databaseName, String tableName)
int	getDelayCleanTableLock() get enable-table-lock config from tidb
int	getRowFormatVersion() get row format version from tidb
boolean	isClosed()
boolean	isEnableTableLock()
boolean	lockTableWriteLocal(String databaseName, String tableName)
boolean	unlockTables()

Methods inherited from class java.lang.Object

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

Constructor Detail

TiDBJDBCClient

public TiDBJDBCClient(Connection connection)

Method Detail

isEnableTableLock

public boolean isEnableTableLock()
                          throws IOException,
                                 SQLException

Throws:

IOException

SQLException

getDelayCleanTableLock

public int getDelayCleanTableLock()
                           throws IOException,
                                  SQLException

get enable-table-lock config from tidb

Returns:

Milliseconds

Throws:

IOException

SQLException

getRowFormatVersion

public int getRowFormatVersion()

get row format version from tidb

Returns:

1 if should not encode and write with new row format.(default) 2 if encode and write with new row format.(default on v4.0.0 cluster)

lockTableWriteLocal

public boolean lockTableWriteLocal(String databaseName,
                                   String tableName)
                            throws SQLException

Throws:

SQLException

unlockTables

public boolean unlockTables()
                     throws SQLException

Throws:

SQLException

dropTable

public boolean dropTable(String databaseName,
                         String tableName)
                  throws SQLException

Throws:

SQLException

isClosed

public boolean isClosed()
                 throws SQLException

Throws:

SQLException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception