Package org.jumpmind.symmetric.db.derby

Class DerbyFunctions

java.lang.Object

org.jumpmind.symmetric.db.derby.DerbyFunctions

public class DerbyFunctions
extends Object

Constructor Summary

Constructors

Constructor	Description
DerbyFunctions()

Method Summary

Modifier and Type	Method	Description
protected static void	appendCsvString(String tableName, String[] columnNames, String[] pkColumnNames, ResultSet rs, StringBuilder builder)
static String	blobToString(String columnName, String tableName, String whereClause)
static String	clobToString(String columnName, String tableName, String whereClause)
static String	escape(String str)
protected static int	findColumnIndex(ResultSetMetaData metaData, String columnName)
static String	getPrimaryKeyWhereString(String[] pkColumnNames, ResultSet rs)
static String	getSessionId()
static String	getSyncNodeDisabled()
static String	getTransactionId()
static void	insertData(int enabled, String schemaName, String prefixName, String tableName, String channelName, String dmlType, int triggerHistId, String transactionId, String externalData, String columnNames, String pkColumnNames)
static void	insertData(String schemaName, String prefixName, String tableName, String channelName, String dmlType, int triggerHistId, String transactionId, String externalData, String pkData, String rowData, String oldRowData)	Deprecated.
static int	isSyncDisabled()
static int	setSyncDisabled(int disabledIndicator)
static String	setSyncNodeDisabled(String nodeId)

Methods inherited from class java.lang.Object

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

Constructor Details

DerbyFunctions

public DerbyFunctions()

Method Details

getTransactionId

public static String getTransactionId()
                               throws SQLException

Throws:

SQLException

getSessionId

public static String getSessionId()
                           throws SQLException

Throws:

SQLException

isSyncDisabled

public static int isSyncDisabled()
                          throws SQLException

Throws:

SQLException

getSyncNodeDisabled

public static String getSyncNodeDisabled()
                                  throws SQLException

Throws:

SQLException

setSyncNodeDisabled

public static String setSyncNodeDisabled(String nodeId)
                                  throws SQLException

Throws:

SQLException

setSyncDisabled

public static int setSyncDisabled(int disabledIndicator)
                           throws SQLException

Throws:

SQLException

findColumnIndex

protected static int findColumnIndex(ResultSetMetaData metaData,
 String columnName)
                              throws SQLException

Throws:

SQLException

appendCsvString

protected static void appendCsvString(String tableName,
 String[] columnNames,
 String[] pkColumnNames,
 ResultSet rs,
 StringBuilder builder)
                               throws SQLException

Throws:

SQLException

insertData

public static void insertData(int enabled,
 String schemaName,
 String prefixName,
 String tableName,
 String channelName,
 String dmlType,
 int triggerHistId,
 String transactionId,
 String externalData,
 String columnNames,
 String pkColumnNames)
                       throws SQLException

Throws:

SQLException

insertData

@Deprecated
public static void insertData(String schemaName,
 String prefixName,
 String tableName,
 String channelName,
 String dmlType,
 int triggerHistId,
 String transactionId,
 String externalData,
 String pkData,
 String rowData,
 String oldRowData)
                       throws SQLException

Deprecated.

Throws:

SQLException

escape

public static String escape(String str)

blobToString

public static String blobToString(String columnName,
 String tableName,
 String whereClause)
                           throws SQLException

Throws:

SQLException

clobToString

public static String clobToString(String columnName,
 String tableName,
 String whereClause)
                           throws SQLException

Throws:

SQLException

getPrimaryKeyWhereString

public static String getPrimaryKeyWhereString(String[] pkColumnNames,
 ResultSet rs)
                                       throws SQLException

Throws:

SQLException