com.actian.vw.connector.common

Class VectorwiseManager

java.lang.Object

com.actian.vw.connector.common.ConnManager

com.actian.vw.connector.common.SqlManager

com.actian.vw.connector.common.VectorwiseManager

public class VectorwiseManager
extends SqlManager

Manages connections to Vectorwise databases.

Field Summary

Fields

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

Fields inherited from class com.actian.vw.connector.common.SqlManager

DEFAULT_FETCH_SIZE

Constructor Summary

Constructors

Constructor and Description
VectorwiseManager(String jdbcUrl, String username, String password)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Perform any shutdown operations on the connection.
protected void	discardConnection(boolean doClose) Any reference to the connection managed by this manager is nulled.
String	escapeTableName(String tableName) When using a table name in a generated SQL query, how (if at all) should we escape that column name? e.g., a table named "table" may need to be quoted with double-quotes: "table".
protected String	getColNamesQuery(String tableName)
Connection	getConnection() Retrieve the actual connection from the outer ConnManager.
protected String	getConnectionString()
String	getCurTimestampQuery() Vectorwsie does not support the CURRENT_TIMESTAMP() function.
String	getDriverClass()
protected String	getListColumnsQuery(String tableName)
protected String	getListDatabasesQuery()
protected String	getPassword()
String[]	getPrimaryKeyColNames(String tableName)
protected String	getPrimaryKeyQuery(String tableName)
protected String	getSchemaQuery()
protected String	getUserName()
String	getVwAdmin()
String	getVwConnectString()
String	getVwPort()
String	getVwVersionString()
protected boolean	hasOpenConnection()
protected static void	markWarningPrinted() Set a flag to prevent printing the --direct warning twice.
boolean	supportsStagingForExport()

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

execute, execute, getColTypesQuery, getColumnDataForRawQuery, getColumnTypeNamesForQuery, getColumnTypeNamesForRawQuery, getColumnTypeNamesForTable, getMetadataIsolationLevel, getPrimaryKeyColDetails, getPrimaryKeyColumnNames, makeConnection, release

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

getColumnTypeNames, getColumnTypesForQuery, 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

Constructor Detail

VectorwiseManager

public VectorwiseManager(String jdbcUrl,
                 String username,
                 String password)

Method Detail

getConnection

public Connection getConnection()
                         throws SQLException

Description copied from class: SqlManager

Retrieve the actual connection from the outer ConnManager.

Specified by:

getConnection in class SqlManager

Returns:

the actual database connection.

Throws:

SQLException

hasOpenConnection

protected boolean hasOpenConnection()

discardConnection

protected void discardConnection(boolean doClose)
                          throws SQLException

Any reference to the connection managed by this manager is nulled. If doClose is true, then this method will attempt to close the connection first.

Parameters:

doClose - if true, try to close the connection before forgetting it.

Throws:

SQLException

close

public void close()
           throws SQLException

Description copied from class: ConnManager

Perform any shutdown operations on the connection.

Overrides:

close in class SqlManager

Throws:

SQLException

getColNamesQuery

protected String getColNamesQuery(String tableName)

Overrides:

getColNamesQuery in class SqlManager

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.

getCurTimestampQuery

public String getCurTimestampQuery()

Vectorwsie does not support the CURRENT_TIMESTAMP() function. Instead it has the notion of keyword CURRENT_TIMESTAMP that resolves to the current time stamp for the database system.

markWarningPrinted

protected static void markWarningPrinted()

Set a flag to prevent printing the --direct warning twice.

escapeTableName

public String escapeTableName(String tableName)

When using a table name in a generated SQL query, how (if at all) should we escape that column name? e.g., a table named "table" may need to be quoted with double-quotes: "table".

Overrides:

escapeTableName in class ConnManager

Parameters:

tableName - the table name as provided by the user, etc.

Returns:

how the table name should be rendered in the sql text.

supportsStagingForExport

public boolean supportsStagingForExport()

getListDatabasesQuery

protected String getListDatabasesQuery()

getSchemaQuery

protected String getSchemaQuery()

getVwPort

public String getVwPort()
                 throws SQLException

Throws:

SQLException

getVwConnectString

public String getVwConnectString()
                          throws SQLException

Throws:

SQLException

getVwAdmin

public String getVwAdmin()
                  throws SQLException

Throws:

SQLException

getVwVersionString

public String getVwVersionString()
                          throws SQLException

Throws:

SQLException

getListColumnsQuery

protected String getListColumnsQuery(String tableName)

getPrimaryKeyQuery

protected String getPrimaryKeyQuery(String tableName)

Specified by:

getPrimaryKeyQuery in class SqlManager

getDriverClass

public String getDriverClass()

Specified by:

getDriverClass in class ConnManager

Returns:

a string identifying the driver class to load for this JDBC connection type.

getConnectionString

protected String getConnectionString()

Specified by:

getConnectionString in class SqlManager

getPassword

protected String getPassword()

Specified by:

getPassword in class SqlManager

getUserName

protected String getUserName()

Specified by:

getUserName in class SqlManager

getPrimaryKeyColNames

public String[] getPrimaryKeyColNames(String tableName)