gobblin.util

Class HiveJdbcConnector

java.lang.Object

gobblin.util.HiveJdbcConnector

All Implemented Interfaces:

Closeable, AutoCloseable

public class HiveJdbcConnector
extends Object
implements Closeable

A class for managing a Hive JDBC connection.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_HIVESERVER_VERSION
static String	HIVE_EXECUTION_SIMULATE
static String	HIVESERVER_CONNECTION_STRING
static String	HIVESERVER_PASSWORD
static String	HIVESERVER_URL
static String	HIVESERVER_USER
static String	HIVESERVER_VERSION
static String	HIVESITE_DIR

Method Summary

Modifier and Type	Method and Description
void	close()
void	executeStatements(String... statements) Executes the given SQL statements.
Connection	getConnection()
static HiveJdbcConnector	newConnectorWithProps(Properties compactRunProps) Create a new HiveJdbcConnector based on the configs in a Properties object
static HiveJdbcConnector	newEmbeddedConnector(int hiveServerVersion) Create a new HiveJdbcConnector using the specified Hive server version.

Methods inherited from class java.lang.Object

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

Field Detail

HIVESERVER_VERSION

public static final String HIVESERVER_VERSION

See Also:

Constant Field Values

DEFAULT_HIVESERVER_VERSION

public static final String DEFAULT_HIVESERVER_VERSION

See Also:

Constant Field Values

HIVESERVER_CONNECTION_STRING

public static final String HIVESERVER_CONNECTION_STRING

See Also:

Constant Field Values

HIVESERVER_URL

public static final String HIVESERVER_URL

See Also:

Constant Field Values

HIVESERVER_USER

public static final String HIVESERVER_USER

See Also:

Constant Field Values

HIVESERVER_PASSWORD

public static final String HIVESERVER_PASSWORD

See Also:

Constant Field Values

HIVESITE_DIR

public static final String HIVESITE_DIR

See Also:

Constant Field Values

HIVE_EXECUTION_SIMULATE

public static final String HIVE_EXECUTION_SIMULATE

See Also:

Constant Field Values

Method Detail

newEmbeddedConnector

public static HiveJdbcConnector newEmbeddedConnector(int hiveServerVersion)
                                              throws SQLException

Create a new HiveJdbcConnector using the specified Hive server version.

Parameters:

hiveServerVersion - is the Hive server version to use

Returns:

a HiveJdbcConnector with the specified hiveServerVersion

Throws:

SQLException

newConnectorWithProps

public static HiveJdbcConnector newConnectorWithProps(Properties compactRunProps)
                                               throws SQLException

Create a new HiveJdbcConnector based on the configs in a Properties object

Parameters:

compactRunProps - contains the configuration keys to construct the HiveJdbcConnector

Returns:

Throws:

SQLException - if there is a problem setting up the JDBC connection

executeStatements

public void executeStatements(String... statements)
                       throws SQLException

Executes the given SQL statements.

Parameters:

statements - SQL statements to be executed.

Throws:

SQLException - if any issue in executing any statement.

getConnection

public Connection getConnection()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException