org.apache.hive.storage.jdbc.dao

Class JethroDatabaseAccessor

java.lang.Object

org.apache.hive.storage.jdbc.dao.GenericJdbcDatabaseAccessor

org.apache.hive.storage.jdbc.dao.JethroDatabaseAccessor

All Implemented Interfaces:

DatabaseAccessor

public class JethroDatabaseAccessor
extends GenericJdbcDatabaseAccessor

JethroData specific data accessor. This is needed because JethroData JDBC drivers do not support generic LIMIT and OFFSET escape functions, and has some special optimization for getting the query metadata using limit 0.

Field Summary

Fields inherited from class org.apache.hive.storage.jdbc.dao.GenericJdbcDatabaseAccessor

DBCP_CONFIG_PREFIX, DBCP_PWD, dbcpDataSource, DEFAULT_FETCH_SIZE, LOGGER

Constructor Summary

Constructors

Constructor and Description
JethroDatabaseAccessor()

Method Summary

Modifier and Type	Method and Description
protected String	addLimitAndOffsetToQuery(String sql, int limit, int offset) Uses generic JDBC escape functions to add a limit and offset clause to a query string
protected String	addLimitToQuery(String sql, int limit)
protected String	getMetaDataQuery(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.apache.hive.storage.jdbc.dao.GenericJdbcDatabaseAccessor

cleanupResources, getColumnNames, getConnectionPoolProperties, getDefaultDBCPProperties, getFetchSize, getRecordIterator, getTotalNumberOfRecords, initializeDatabaseConnection

Methods inherited from class java.lang.Object

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

Constructor Detail

JethroDatabaseAccessor

public JethroDatabaseAccessor()

Method Detail

addLimitAndOffsetToQuery

protected String addLimitAndOffsetToQuery(String sql,
                                          int limit,
                                          int offset)

Description copied from class: GenericJdbcDatabaseAccessor

Uses generic JDBC escape functions to add a limit and offset clause to a query string

Overrides:

addLimitAndOffsetToQuery in class GenericJdbcDatabaseAccessor

Returns:

addLimitToQuery

protected String addLimitToQuery(String sql,
                                 int limit)

Overrides:

addLimitToQuery in class GenericJdbcDatabaseAccessor

getMetaDataQuery

protected String getMetaDataQuery(org.apache.hadoop.conf.Configuration conf)

Overrides:

getMetaDataQuery in class GenericJdbcDatabaseAccessor