HiveServer2 JDBC

HiveServer2 JDBC

Using JDBC

You can use JDBC to access data stored in a relational database or other tabular format.

Load the HiveServer2 JDBC driver.

For example:

Class.forName("org.apache.hive.jdbc.HiveDriver");
Connect to the database by creating a Connection object with the JDBC driver.

For example:

Connection cnct = DriverManager.getConnection("jdbc:hive2://<host>:<port>", "<user>", "<password>");

The default <port> is 10000. In non-secure configurations, specify a <user> for the query to run as. The <password> field value is ignored in non-secure mode.

Connection cnct = DriverManager.getConnection("jdbc:hive2://<host>:<port>", "<user>", "");

In Kerberos secure mode, the user information is based on the Kerberos credentials.
Submit SQL to the database by creating a Statement object and using its executeQuery() method.

For example:

Statement stmt = cnct.createStatement(); ResultSet rset = stmt.executeQuery("SELECT foo FROM bar");
Process the result set, if necessary.

JDBC Data Types

The following table lists the data types implemented for HiveServer2 JDBC.

Hive Type	Java Type	Specification
TINYINT	byte	signed or unsigned 1-byte integer
SMALLINT	short	signed 2-byte integer
INT	int	signed 4-byte integer
BIGINT	long	signed 8-byte integer
FLOAT	double	single-precision number (approximately 7 digits)
DOUBLE	double	double-precision number (approximately 15 digits)
DECIMAL	java.math.BigDecimal	fixed-precision decimal value
BOOLEAN	boolean	a single bit (0 or 1)
STRING	String	character string or variable-length character string
TIMESTAMP	java.sql.Timestamp	date and time value
BINARY	String	binary data
Complex Types
ARRAY	String -- json encoded	values of one data type
MAP	String -- json encoded	key-value pairs
STRUCT	String -- json encoded	structured values

The next table shows which data types are currently implemented in methods of the classes PreparedStatement, ResultSet, ResultSetMetaData, and JdbcColumn.

	PreparedStatement	ResultSet	ResultSetMetaData	JdbcColumn
boolean	execute()	X	X	X
byte	X	X
tinyint			X	X
smallint			X	X
int	executeUpdate()	X	X	X
bigint			X	X
float	X	X	X	X
double	X	X	X	X
decimal		X	X	X
timestamp	X	X	X	X
binary				X
string	updateSql() -- no, private method	X	X	X
Complex Types
array<>			X	X
map<>			X	X
struct<>			X	X

Supported `Connection` methods in HiveServer2	Comments
`clearWarnings()`
`close()`
`createStatement()`
`getAutoCommit()`	hard coded to true
`getCatalog()`	hard coded to empty string
`getMetaData()`
`getTransactionIsolation()`	hard coded to TRANSACTION_NONE
`getWarnings()`
`isClosed()`
`isReadOnly()`	hard coded to false
`prepareStatement(String sql)`
`prepareStatement(String sql, int autoGeneratedKeys)`	second argument is ignored
`prepareStatement(String sql, int resultSetType, int resultSetConcurrency)`	arguments 2 and 3 are ignored
`setAutoCommit(boolean autoCommit)`	throws exception if auto-commit is turned on
`setTransactionIsolation(int level)`	empty implementation

Supported `DatabaseMetaData` methods in HiveServer2	Comments
`allTablesAreSelectable()`	hard coded to true
`getCatalogs()`
`getCatalogSeparator()`	hard coded to CATALOG_SEPARATOR
`getCatalogTerm()`	hard coded to instance
`getColumns(String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern)`
`getDatabaseProductName()`	hard coded to Hive
`getDatabaseProductVersion()`	hard coded to 0.10.0
`getDefaultTransactionIsolation()`	hard coded to TRANSACTION_NONE
`getDriverMajorVersion()`
`getDriverMinorVersion()`
`getDriverName()`
`getDriverVersion()`
`getExtraNameCharacters()`	returns empty string
`getFunctions(String catalog, String schemaPattern, String functionNamePattern)`
`getImportedKeys(String catalog, String schema, String table)`
`getJDBCMajorVersion()`	returns 3
`getJDBCMinorVersion()`	returns 0
`getMaxColumnNameLength()`
`getNumericFunctions()`	hard coded to the empty string
`getPrimaryKeys(String catalog, String schema, String table)`	returns empty
`getProcedureColumns(String catalog, String schemaPattern, String procedureNamePattern, String columnNamePattern)`	returns empty
`getProcedureTerm()`	returns "UDF" string
`getProcedures()`	returns empty
`getSchemas()`
`getSchemas(String catalog, String schemaPattern)`
`getSchemaTerm()`	returns "database"
`getSearchStringEscape()`	returns $SEARCH_STRING_ESCAPE
`getSQLStateType()`	returns sqlStateSQL99
`getStringFunctions()`	hard coded to the empty string
`getSystemFunctions()`	hard coded to the empty string
`getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types)`
`getTableTypes()`
`getTimeDateFunctions()`	hard coded to the empty string
`getTypeInfo()`
`getUDTs(String catalog, String schemaPattern, String typeNamePattern, int[] types)`	returns empty
`supportsAlterTableWithAddColumn()`
`supportsAlterTableWithDropColumn()`
`supportsBatchUpdates()`
`supportsCatalogsInDataManipulation()`
`supportsCatalogsInIndexDefinitions()`
`supportsCatalogsInPrivilegeDefinitions()`
`supportsCatalogsInProcedureCalls()`
`supportsCatalogsInTableDefinitions()`
`supportsColumnAliasing()`
`supportsGroupBy()`
`supportsMultipleResultSets()`
`supportsNonNullableColumns()`
`supportsOuterJoins()`
`supportsPositionedDelete()`
`supportsPositionedUpdate()`
`supportsResultSetHoldability(int holdability)`
`supportsResultSetType(int type)`
`supportsSavepoints()`
`supportsSchemasInDataManipulation()`
`supportsSchemasInIndexDefinitions()`
`supportsSchemasInPrivilegeDefinitions()`
`supportsSchemasInProcedureCalls()`
`supportsSchemasInTableDefinitions()`
`supportsSelectForUpdate()`
`supportsStoredProcedures()`
`supportsTransactions()`

Supported `ResultSetMetaData` methods in HiveServer2	Comments
`getColumnCount()`
`getColumnDisplaySize(int column)`
`getColumnLabel(int column)`
`getColumnName(int column)`
`getColumnType(int column)`
`getColumnTypeName(int column)`
`getPrecision(int column)`
`getScale(int column)`
`isAutoIncrement(int column)`	hard coded to false
`isCurrency(int column)`	hard coded to false
`isNullable(int column)`