org.apache.hive.storage.jdbc.dao

Class MySqlDatabaseAccessor

java.lang.Object

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

org.apache.hive.storage.jdbc.dao.MySqlDatabaseAccessor

All Implemented Interfaces:

DatabaseAccessor

public class MySqlDatabaseAccessor
extends GenericJdbcDatabaseAccessor

MySQL specific data accessor. This is needed because MySQL JDBC drivers do not support generic LIMIT and OFFSET escape functions

Field Summary

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

DBCP_CONFIG_PREFIX, dbcpDataSource, DEFAULT_FETCH_SIZE, LOGGER

Constructor Summary

Constructors

Constructor and Description
MySqlDatabaseAccessor()

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)

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

MySqlDatabaseAccessor

public MySqlDatabaseAccessor()

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