Package cdc.rdb

Class RdbHelper

java.lang.Object

cdc.rdb.RdbHelper

public class RdbHelper
extends Object

Helper class for DB handling.

Author:

Damien Carbonne

Constructor Summary

Constructors

Constructor	Description
RdbHelper(Connection connection)
RdbHelper(DatabaseMetaData metadata)

Method Summary

Modifier and Type	Method	Description
String	getCatalogSeparator()
String	getDeleteFromTableQuery(String schemaName, String tableName, List<String> whereColumnsNames)
String	getIdentifierQuoteString()
String	getInsertIntoTableQuery(String schemaName, String tableName, int columns)
String	getInsertIntoTableQuery(String schemaName, String tableName, List<String> columnsNames)
String	getOrderClause(List<RdbColumnSorting> sortings)
String	getQueryTableName(String schemaName, String tableName)
String	getSelectClause(String schemaName, String tableName)
long	getTableSize(Connection connection, String schemaName, String tableName)
String	getTableSizeQuery(String schemaName, String tableName)
String	getUpdateTableQuery(String schemaName, String tableName, List<String> setColumnsNames, List<String> whereColumnsNames)
static void	print(ResultSet rs, PrintStream out)
String	wrapIdentifier(String id)

Methods inherited from class java.lang.Object

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

Constructor Detail

RdbHelper

public RdbHelper(DatabaseMetaData metadata)
          throws SQLException

Throws:

SQLException

RdbHelper

public RdbHelper(Connection connection)
          throws SQLException

Throws:

SQLException

Method Detail

getCatalogSeparator

public String getCatalogSeparator()

Returns:

The catalog separator.

getIdentifierQuoteString

public String getIdentifierQuoteString()

Returns:

The identifier quote string.

wrapIdentifier

public String wrapIdentifier(String id)

Parameters:

id - The naked identifier.

Returns:

id wrapped with identifier quote string.

getQueryTableName

public String getQueryTableName(String schemaName,
                                String tableName)

Parameters:

schemaName - The schema name.

tableName - The table name.

Returns:

The String designating the table identified by schemaName and tableName.

getSelectClause

public String getSelectClause(String schemaName,
                              String tableName)

Parameters:

schemaName - The schema name.

tableName - The table name.

Returns:

SELECT * FROM TTT
where TTT is the table name.

getTableSizeQuery

public String getTableSizeQuery(String schemaName,
                                String tableName)

Parameters:

schemaName - The schema name.

tableName - The table name.

Returns:

SELECT COUNT (*) FROM TTT
where TTT is the table name.

getInsertIntoTableQuery

public String getInsertIntoTableQuery(String schemaName,
                                      String tableName,
                                      int columns)

Parameters:

schemaName - The schema name.

tableName - The table name.

columns - The number of columns.

Returns:

INSERT INTO TTT VALUES(?,?,...)
where TTT is the table name.

getInsertIntoTableQuery

public String getInsertIntoTableQuery(String schemaName,
                                      String tableName,
                                      List<String> columnsNames)

Parameters:

schemaName - The schema name.

tableName - The table name.

columnsNames - The columns names.

Returns:

INSERT INTO TTT (N1, N2, ...) VALUES (?,?,...)
where TTT is the table name
and Ni is the i-th column name.

getDeleteFromTableQuery

public String getDeleteFromTableQuery(String schemaName,
                                      String tableName,
                                      List<String> whereColumnsNames)

getUpdateTableQuery

public String getUpdateTableQuery(String schemaName,
                                  String tableName,
                                  List<String> setColumnsNames,
                                  List<String> whereColumnsNames)

getTableSize

public long getTableSize(Connection connection,
                         String schemaName,
                         String tableName)
                  throws SQLException

Parameters:

connection - The connection.

schemaName - The schema name.

tableName - The table name.

Returns:

The size of the table designated by schemaName and .

Throws:

SQLException - When an SQL error occurs.

getOrderClause

public String getOrderClause(List<RdbColumnSorting> sortings)

Parameters:

sortings - The columns sortings.

Returns:

A String defining an order clause based on sortings.

print

public static void print(ResultSet rs,
                         PrintStream out)