org.apache.hive.jdbc

Class Utils

java.lang.Object

org.apache.hive.jdbc.Utils

public class Utils
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Utils.JdbcConnectionParams

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_DATABASE Hive's default database name
static java.lang.String	DEFAULT_PORT If host is provided, without a port.
static java.lang.String	URL_PREFIX The required prefix for the connection URL.

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Modifier and Type	Method and Description
static int	hiveTypeToSqlType(java.lang.String type) Convert hive types to sql types.
static Utils.JdbcConnectionParams	parseURL(java.lang.String uri) Parse JDBC connection URL The new format of the URL is jdbc:hive2://:/dbName;sess_var_list?hive_conf_list#hive_var_list where the optional sess, conf and var lists are semicolon separated = pairs.
static void	verifySuccess(TStatus status)
static void	verifySuccess(TStatus status, boolean withInfo)
static void	verifySuccessWithInfo(TStatus status)

Methods inherited from class java.lang.Object

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

Field Detail

URL_PREFIX

public static final java.lang.String URL_PREFIX

The required prefix for the connection URL.

See Also:

Constant Field Values

DEFAULT_PORT

public static final java.lang.String DEFAULT_PORT

If host is provided, without a port.

See Also:

Constant Field Values

DEFAULT_DATABASE

public static final java.lang.String DEFAULT_DATABASE

Hive's default database name

See Also:

Constant Field Values

Constructor Detail

Utils

public Utils()

Method Detail

hiveTypeToSqlType

public static int hiveTypeToSqlType(java.lang.String type)
                             throws java.sql.SQLException

Convert hive types to sql types.

Parameters:

type -

Returns:

Integer java.sql.Types values

Throws:

java.sql.SQLException

verifySuccessWithInfo

public static void verifySuccessWithInfo(TStatus status)
                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

verifySuccess

public static void verifySuccess(TStatus status)
                          throws java.sql.SQLException

Throws:

java.sql.SQLException

verifySuccess

public static void verifySuccess(TStatus status,
                                 boolean withInfo)
                          throws java.sql.SQLException

Throws:

java.sql.SQLException

parseURL

public static Utils.JdbcConnectionParams parseURL(java.lang.String uri)
                                           throws java.lang.IllegalArgumentException

Parse JDBC connection URL The new format of the URL is jdbc:hive2://:/dbName;sess_var_list?hive_conf_list#hive_var_list where the optional sess, conf and var lists are semicolon separated = pairs. As before, if the host/port is not specified, it the driver runs an embedded hive. examples - jdbc:hive2://ubuntu:11000/db2?hive.cli.conf.printheader=true;hive.exec.mode.local.auto.inputbytes.max=9999#stab=salesTable;icol=customerID jdbc:hive2://?hive.cli.conf.printheader=true;hive.exec.mode.local.auto.inputbytes.max=9999#stab=salesTable;icol=customerID jdbc:hive2://ubuntu:11000/db2;user=foo;password=bar Connect to http://server:10001/hs2, with specified basicAuth credentials and initial database: jdbc:hive2://server:10001/db;user=foo;password=bar?hive.server2.transport.mode=http;hive.server2.thrift.http.path=hs2 Note that currently the session properties are not used.

Parameters:

uri -

Returns:

Throws:

java.lang.IllegalArgumentException