public class DB2PersistManager extends JDBCPersistManager
CONTSTAT_FIRST_AND_SECOND_PART, CONTSTAT_FIRST_PART, CONTSTAT_SECOND_PART, mDebugOn
CLOSE_RETAIN_TABLE, INIT_TABLE_EXISTS, PCEVT_CANT_BE_PERSISTED, PCEVT_NO_PASSIVATE_NON_ZERO_LOCK, PCEVT_NO_PASSIVATE_NOT_ALL_ELEM_PERS, PCEVT_NODE_RECENTLY_USED
Constructor and Description |
---|
DB2PersistManager() |
Modifier and Type | Method and Description |
---|---|
protected void |
bindChangeParentDataRow(java.sql.PreparedStatement pStmt,
long id,
long parid,
int collid) |
protected void |
bindDeleteAllDataRows(java.sql.PreparedStatement pStmt,
int collid) |
protected void |
bindDeleteDataRow(java.sql.PreparedStatement pStmt,
long id,
int collid) |
protected void |
bindDeleteKeyInfo(java.sql.PreparedStatement pStmt,
long id,
int collid) |
protected void |
bindDeleteOldChunksDataRow(java.sql.PreparedStatement pStmt,
long id,
int collid,
int begIndx,
int endIndx) |
protected void |
bindInsertDataRow(java.sql.PreparedStatement pStmt,
long id,
long parid,
int collid,
int keyContLen,
int contentLen,
int contentIdx,
byte[] chunk,
int contentStatus) |
protected void |
bindInsertKeyInfo(java.sql.PreparedStatement pStmt,
long id,
int collid,
int keyId,
int keyHash) |
protected void |
bindRetrieveDataRow(java.sql.PreparedStatement pStmt,
long id,
int collid,
boolean justLen) |
protected void |
bindRetrieveIdsWithKey(java.sql.PreparedStatement pStmt,
int keyId,
java.lang.Object keyVal,
int keyHash,
int collid) |
protected void |
bindUpdateDataRow(java.sql.PreparedStatement pStmt,
long id,
long parid,
int collid,
int keyContLen,
int contentLen,
int contentIdx,
byte[] chunk,
int contentStatus) |
protected int |
contentChunkLength() |
protected void |
dropTable(java.lang.String tabName) |
protected byte[] |
getContentDataRow(java.sql.ResultSet rslt,
long[] idRet,
long[] parentIdRet,
int[] contentLenRet,
boolean justLen) |
protected java.util.Date |
getCurrentTimeFromDb() |
int |
getMaxTabNameLength() |
protected java.lang.String |
sqlAddKeyContColumn(java.lang.String tabName) |
protected java.lang.String |
sqlChangeParentDataRow(java.lang.String tabName,
long id,
long parid,
int collid) |
protected java.lang.String |
sqlCreateControlTable(java.lang.String controlTabName) |
protected java.lang.String |
sqlCreateIndex(java.lang.String tabName) |
protected java.lang.String |
sqlCreateKeyInfoIdIndex(java.lang.String keyInfoIndexName,
java.lang.String keyInfoTabName) |
protected java.lang.String |
sqlCreateKeyInfoKeyIndex(java.lang.String keyInfoIndexName,
java.lang.String keyInfoTabName) |
protected java.lang.String |
sqlCreateKeyInfoTable(java.lang.String keyInfoTabName) |
protected java.lang.String |
sqlCreateTable(java.lang.String tabName) |
protected java.lang.String |
sqlDeleteAllDataRows(java.lang.String tabName,
int collid) |
protected java.lang.String |
sqlDeleteControlRow(java.lang.String controlTabName,
java.lang.String tabName) |
protected java.lang.String |
sqlDeleteDataRow(java.lang.String tabName,
long id,
int collid) |
protected java.lang.String |
sqlDeleteKeyInfo(java.lang.String keyInfoTabName,
long id) |
protected java.lang.String |
sqlDeleteOldChunksDataRow(java.lang.String tabName,
long id,
int collid,
int begIndx,
int endIndx) |
protected java.lang.String |
sqlDropKeyInfoTable(java.lang.String keyInfoTabName) |
protected java.lang.String |
sqlInsertControlRow(java.lang.String controlTabName,
java.lang.String tabName) |
protected java.lang.String |
sqlInsertDataRow(java.lang.String tabName,
long id,
long parid,
int collid) |
protected java.lang.String |
sqlInsertKeyInfo(java.lang.String keyInfoTabName) |
protected int |
sqlLockConflictErrorCode() |
protected java.lang.String |
sqlLockControlRow(java.lang.String controlTabName,
java.lang.String tabName) |
protected long |
sqlNextSequenceVal(java.lang.String seqName) |
protected java.lang.String |
sqlRetrieveDataRow(java.lang.String tabName,
long id,
int collid,
boolean justLen,
boolean keyonly) |
protected java.lang.String |
sqlRetrieveIdsWithKey(java.lang.String tabName,
java.lang.String keyInfoTabName,
int keyId,
java.lang.Object keyval,
int collid) |
protected int |
sqlTableExistsErrorCode() |
protected java.lang.String |
sqlUpdateControlRow(java.lang.String controlTabName,
java.lang.String tabName,
java.lang.String dateColName) |
protected java.lang.String |
sqlUpdateDataRow(java.lang.String tabName,
long id,
long parid,
int collid) |
canResetSequence, changeParent, close, close, closeResultSet, closeStmt, commit, createControlTable, createTable, delete, deleteAll, deleteControlRow, deleteOldChunksDataRow, dropOutdatedControlTable, getConnection, getContentLenDataRow, getTableSignature, handleControlRowLockConflict, handleControlTableExists, holdTableName, init, insert, insert, isPersistent, notifyPCollEvent, queryNextCollectionId, queryNextNodeId, queryNextObjId, retrieve, retrieveIdsWithKey, setCommitThreshhold, setPCollManager, setPersistent, setTableCreated, setTableName, sqlCreateSequence, update, update, updateControlRow, updateKeyInfo, waitForTableName
public int getMaxTabNameLength()
getMaxTabNameLength
in interface PersistManager
getMaxTabNameLength
in class JDBCPersistManager
protected java.lang.String sqlCreateControlTable(java.lang.String controlTabName)
sqlCreateControlTable
in class JDBCPersistManager
protected int sqlTableExistsErrorCode()
sqlTableExistsErrorCode
in class JDBCPersistManager
protected void dropTable(java.lang.String tabName)
dropTable
in class JDBCPersistManager
protected java.lang.String sqlAddKeyContColumn(java.lang.String tabName)
sqlAddKeyContColumn
in class JDBCPersistManager
protected java.lang.String sqlDropKeyInfoTable(java.lang.String keyInfoTabName)
sqlDropKeyInfoTable
in class JDBCPersistManager
protected java.lang.String sqlCreateKeyInfoTable(java.lang.String keyInfoTabName)
sqlCreateKeyInfoTable
in class JDBCPersistManager
protected java.lang.String sqlCreateKeyInfoKeyIndex(java.lang.String keyInfoIndexName, java.lang.String keyInfoTabName)
sqlCreateKeyInfoKeyIndex
in class JDBCPersistManager
protected java.lang.String sqlCreateKeyInfoIdIndex(java.lang.String keyInfoIndexName, java.lang.String keyInfoTabName)
sqlCreateKeyInfoIdIndex
in class JDBCPersistManager
protected java.lang.String sqlCreateTable(java.lang.String tabName)
sqlCreateTable
in class JDBCPersistManager
protected java.lang.String sqlCreateIndex(java.lang.String tabName)
sqlCreateIndex
in class JDBCPersistManager
protected long sqlNextSequenceVal(java.lang.String seqName)
sqlNextSequenceVal
in class JDBCPersistManager
protected java.util.Date getCurrentTimeFromDb()
getCurrentTimeFromDb
in class JDBCPersistManager
protected java.lang.String sqlDeleteControlRow(java.lang.String controlTabName, java.lang.String tabName)
sqlDeleteControlRow
in class JDBCPersistManager
protected java.lang.String sqlUpdateControlRow(java.lang.String controlTabName, java.lang.String tabName, java.lang.String dateColName)
sqlUpdateControlRow
in class JDBCPersistManager
protected java.lang.String sqlLockControlRow(java.lang.String controlTabName, java.lang.String tabName)
sqlLockControlRow
in class JDBCPersistManager
protected java.lang.String sqlInsertControlRow(java.lang.String controlTabName, java.lang.String tabName)
sqlInsertControlRow
in class JDBCPersistManager
protected int sqlLockConflictErrorCode()
sqlLockConflictErrorCode
in class JDBCPersistManager
protected int contentChunkLength()
contentChunkLength
in class JDBCPersistManager
protected java.lang.String sqlDeleteKeyInfo(java.lang.String keyInfoTabName, long id)
sqlDeleteKeyInfo
in class JDBCPersistManager
protected void bindDeleteKeyInfo(java.sql.PreparedStatement pStmt, long id, int collid) throws java.sql.SQLException
bindDeleteKeyInfo
in class JDBCPersistManager
java.sql.SQLException
protected java.lang.String sqlInsertKeyInfo(java.lang.String keyInfoTabName)
sqlInsertKeyInfo
in class JDBCPersistManager
protected void bindInsertKeyInfo(java.sql.PreparedStatement pStmt, long id, int collid, int keyId, int keyHash) throws java.sql.SQLException
bindInsertKeyInfo
in class JDBCPersistManager
java.sql.SQLException
protected java.lang.String sqlInsertDataRow(java.lang.String tabName, long id, long parid, int collid)
sqlInsertDataRow
in class JDBCPersistManager
protected void bindInsertDataRow(java.sql.PreparedStatement pStmt, long id, long parid, int collid, int keyContLen, int contentLen, int contentIdx, byte[] chunk, int contentStatus) throws java.sql.SQLException
bindInsertDataRow
in class JDBCPersistManager
java.sql.SQLException
protected java.lang.String sqlDeleteOldChunksDataRow(java.lang.String tabName, long id, int collid, int begIndx, int endIndx)
sqlDeleteOldChunksDataRow
in class JDBCPersistManager
protected void bindDeleteOldChunksDataRow(java.sql.PreparedStatement pStmt, long id, int collid, int begIndx, int endIndx) throws java.sql.SQLException
bindDeleteOldChunksDataRow
in class JDBCPersistManager
java.sql.SQLException
protected java.lang.String sqlUpdateDataRow(java.lang.String tabName, long id, long parid, int collid)
sqlUpdateDataRow
in class JDBCPersistManager
protected void bindUpdateDataRow(java.sql.PreparedStatement pStmt, long id, long parid, int collid, int keyContLen, int contentLen, int contentIdx, byte[] chunk, int contentStatus) throws java.sql.SQLException
bindUpdateDataRow
in class JDBCPersistManager
java.sql.SQLException
protected java.lang.String sqlChangeParentDataRow(java.lang.String tabName, long id, long parid, int collid)
sqlChangeParentDataRow
in class JDBCPersistManager
protected void bindChangeParentDataRow(java.sql.PreparedStatement pStmt, long id, long parid, int collid) throws java.sql.SQLException
bindChangeParentDataRow
in class JDBCPersistManager
java.sql.SQLException
protected java.lang.String sqlDeleteDataRow(java.lang.String tabName, long id, int collid)
sqlDeleteDataRow
in class JDBCPersistManager
protected void bindDeleteDataRow(java.sql.PreparedStatement pStmt, long id, int collid) throws java.sql.SQLException
bindDeleteDataRow
in class JDBCPersistManager
java.sql.SQLException
protected java.lang.String sqlDeleteAllDataRows(java.lang.String tabName, int collid)
sqlDeleteAllDataRows
in class JDBCPersistManager
protected void bindDeleteAllDataRows(java.sql.PreparedStatement pStmt, int collid) throws java.sql.SQLException
bindDeleteAllDataRows
in class JDBCPersistManager
java.sql.SQLException
protected java.lang.String sqlRetrieveDataRow(java.lang.String tabName, long id, int collid, boolean justLen, boolean keyonly)
sqlRetrieveDataRow
in class JDBCPersistManager
protected void bindRetrieveDataRow(java.sql.PreparedStatement pStmt, long id, int collid, boolean justLen) throws java.sql.SQLException
bindRetrieveDataRow
in class JDBCPersistManager
java.sql.SQLException
protected byte[] getContentDataRow(java.sql.ResultSet rslt, long[] idRet, long[] parentIdRet, int[] contentLenRet, boolean justLen) throws java.sql.SQLException
getContentDataRow
in class JDBCPersistManager
java.sql.SQLException
protected java.lang.String sqlRetrieveIdsWithKey(java.lang.String tabName, java.lang.String keyInfoTabName, int keyId, java.lang.Object keyval, int collid)
sqlRetrieveIdsWithKey
in class JDBCPersistManager
protected void bindRetrieveIdsWithKey(java.sql.PreparedStatement pStmt, int keyId, java.lang.Object keyVal, int keyHash, int collid) throws java.sql.SQLException
bindRetrieveIdsWithKey
in class JDBCPersistManager
java.sql.SQLException