com.actian.vw.connector.common

Class SqlManager

java.lang.Object

com.actian.vw.connector.common.ConnManager

com.actian.vw.connector.common.SqlManager

Direct Known Subclasses:

VectorwiseManager

public abstract class SqlManager
extends ConnManager

ConnManager implementation for generic SQL-compliant database. This is an abstract class; it requires a database-specific ConnManager implementation to actually create the connection.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_FETCH_SIZE
static org.apache.commons.logging.Log	LOG

Constructor Summary

Constructors

Constructor and Description
SqlManager() Constructs the SqlManager.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Perform any shutdown operations on the connection.
protected ResultSet	execute(String stmt, Integer fetchSize, Object... args) Executes an arbitrary SQL statement.
protected ResultSet	execute(String stmt, Object... args)
protected String	getColNamesQuery(String tableName)
protected String	getColTypesQuery(String tableName)
String[]	getColumnDataForRawQuery(String stmt) Get column names for a query statement that we do not modify further.
Map<String,DatabaseMetaData.Column>	getColumnTypeNamesForQuery(String query) Return an unordered mapping from colname to sql type name for all columns in a query.
protected Map<String,DatabaseMetaData.Column>	getColumnTypeNamesForRawQuery(String stmt)
Map<String,DatabaseMetaData.Column>	getColumnTypeNamesForTable(String tableName) Return an unordered mapping from colname to sql type name for all columns in a table.
abstract Connection	getConnection() Retrieve the actual connection from the outer ConnManager.
protected abstract String	getConnectionString()
protected int	getMetadataIsolationLevel()
protected abstract String	getPassword()
String[]	getPrimaryKeyColDetails(String stmt)
String[]	getPrimaryKeyColumnNames(String tableName)
protected abstract String	getPrimaryKeyQuery(String tableName)
protected abstract String	getUserName()
protected Connection	makeConnection() Create a connection to the database; usually used only from within getConnection(), which enforces a singleton guarantee around the Connection object.
void	release() If a method of this ConnManager has returned a ResultSet to you, you are responsible for calling release() after you close the ResultSet object, to free internal resources.

Methods inherited from class com.actian.vw.connector.common.ConnManager

escapeTableName, getColumnTypeNames, getColumnTypesForQuery, getDriverClass, timestampToQueryString

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

DEFAULT_FETCH_SIZE

protected static final int DEFAULT_FETCH_SIZE

See Also:

Constant Field Values

Constructor Detail

SqlManager

public SqlManager()

Constructs the SqlManager.

Parameters:

opts - the SqoopOptions describing the user's requested action.

Method Detail

getColNamesQuery

protected String getColNamesQuery(String tableName)

Returns:

the SQL query to use in getColumnNames() in case this logic must be tuned per-database, but the main extraction loop is still inheritable.

getPrimaryKeyColumnNames

public String[] getPrimaryKeyColumnNames(String tableName)

getPrimaryKeyQuery

protected abstract String getPrimaryKeyQuery(String tableName)

getPrimaryKeyColDetails

public String[] getPrimaryKeyColDetails(String stmt)

getColumnDataForRawQuery

public String[] getColumnDataForRawQuery(String stmt)
                                  throws SQLException

Get column names for a query statement that we do not modify further.

Throws:

SQLException

getColTypesQuery

protected String getColTypesQuery(String tableName)

Returns:

the SQL query to use in getColumnTypes() in case this logic must be tuned per-database, but the main extraction loop is still inheritable.

getColumnTypeNamesForTable

public Map<String,DatabaseMetaData.Column> getColumnTypeNamesForTable(String tableName)

Description copied from class: ConnManager

Return an unordered mapping from colname to sql type name for all columns in a table.

Overrides:

getColumnTypeNamesForTable in class ConnManager

getColumnTypeNamesForQuery

public Map<String,DatabaseMetaData.Column> getColumnTypeNamesForQuery(String query)

Description copied from class: ConnManager

Return an unordered mapping from colname to sql type name for all columns in a query.

Overrides:

getColumnTypeNamesForQuery in class ConnManager

getColumnTypeNamesForRawQuery

protected Map<String,DatabaseMetaData.Column> getColumnTypeNamesForRawQuery(String stmt)

execute

protected ResultSet execute(String stmt,
                Object... args)
                     throws SQLException

Throws:

SQLException

getConnection

public abstract Connection getConnection()
                                  throws SQLException

Retrieve the actual connection from the outer ConnManager.

Specified by:

getConnection in class ConnManager

Returns:

the actual database connection.

Throws:

SQLException

makeConnection

protected Connection makeConnection()
                             throws SQLException

Create a connection to the database; usually used only from within getConnection(), which enforces a singleton guarantee around the Connection object.

Throws:

SQLException

getConnectionString

protected abstract String getConnectionString()

getPassword

protected abstract String getPassword()

getUserName

protected abstract String getUserName()

execute

protected ResultSet execute(String stmt,
                Integer fetchSize,
                Object... args)
                     throws SQLException

Executes an arbitrary SQL statement.

Parameters:

stmt - The SQL statement to execute

fetchSize - Overrides default or parameterized fetch size

Returns:

A ResultSet encapsulating the results or null on error

Throws:

SQLException

close

public void close()
           throws SQLException

Description copied from class: ConnManager

Perform any shutdown operations on the connection.

Specified by:

close in class ConnManager

Throws:

SQLException

getMetadataIsolationLevel

protected int getMetadataIsolationLevel()

Returns:

the transaction isolation level to use for metadata queries (queries executed by the ConnManager itself).

release

public void release()

Description copied from class: ConnManager

If a method of this ConnManager has returned a ResultSet to you, you are responsible for calling release() after you close the ResultSet object, to free internal resources. ConnManager implementations do not guarantee the ability to have multiple returned ResultSets available concurrently. Requesting a new ResultSet from a ConnManager may cause other open ResulSets to close.

Specified by:

release in class ConnManager