oracle.jbo.pcoll.pmgr
Class SQLServerPersistManager

java.lang.Object
  oracle.jbo.pcoll.JDBCPersistManager
      oracle.jbo.pcoll.pmgr.SQLServerPersistManager

All Implemented Interfaces:

PersistManager

public class SQLServerPersistManager
extends JDBCPersistManager

Field Summary

Fields inherited from class oracle.jbo.pcoll.JDBCPersistManager

CONTSTAT_FIRST_AND_SECOND_PART, CONTSTAT_FIRST_PART, CONTSTAT_SECOND_PART, mDebugOn

Fields inherited from interface oracle.jbo.pcoll.PersistManager

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 Summary

SQLServerPersistManager()

Method Summary

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 boolean	canResetSequence()
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()
long	queryNextCollectionId()
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	sqlCreateSequence(java.lang.String seqName)
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)

Methods inherited from class oracle.jbo.pcoll.JDBCPersistManager

changeParent, close, close, closeResultSet, closeStmt, commit, createControlTable, createTable, delete, deleteAll, deleteControlRow, deleteOldChunksDataRow, dropOutdatedControlTable, getConnection, getContentLenDataRow, getTableSignature, handleControlRowLockConflict, handleControlTableExists, holdTableName, init, insert, insert, isPersistent, notifyPCollEvent, queryNextNodeId, queryNextObjId, retrieve, retrieveIdsWithKey, setCommitThreshhold, setPCollManager, setPersistent, setTableCreated, setTableName, update, update, updateControlRow, updateKeyInfo, waitForTableName

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLServerPersistManager

public SQLServerPersistManager()

Method Detail

getMaxTabNameLength

public int getMaxTabNameLength()

Specified by:

getMaxTabNameLength in interface PersistManager

Specified by:

getMaxTabNameLength in class JDBCPersistManager

sqlCreateControlTable

protected java.lang.String sqlCreateControlTable(java.lang.String controlTabName)

Specified by:

sqlCreateControlTable in class JDBCPersistManager

sqlTableExistsErrorCode

protected int sqlTableExistsErrorCode()

Specified by:

sqlTableExistsErrorCode in class JDBCPersistManager

dropTable

protected void dropTable(java.lang.String tabName)

Specified by:

dropTable in class JDBCPersistManager

sqlAddKeyContColumn

protected java.lang.String sqlAddKeyContColumn(java.lang.String tabName)

Specified by:

sqlAddKeyContColumn in class JDBCPersistManager

sqlDropKeyInfoTable

protected java.lang.String sqlDropKeyInfoTable(java.lang.String keyInfoTabName)

Specified by:

sqlDropKeyInfoTable in class JDBCPersistManager

sqlCreateKeyInfoTable

protected java.lang.String sqlCreateKeyInfoTable(java.lang.String keyInfoTabName)

Specified by:

sqlCreateKeyInfoTable in class JDBCPersistManager

sqlCreateKeyInfoKeyIndex

protected java.lang.String sqlCreateKeyInfoKeyIndex(java.lang.String keyInfoIndexName,
                                                    java.lang.String keyInfoTabName)

Specified by:

sqlCreateKeyInfoKeyIndex in class JDBCPersistManager

sqlCreateKeyInfoIdIndex

protected java.lang.String sqlCreateKeyInfoIdIndex(java.lang.String keyInfoIndexName,
                                                   java.lang.String keyInfoTabName)

Specified by:

sqlCreateKeyInfoIdIndex in class JDBCPersistManager

sqlCreateTable

protected java.lang.String sqlCreateTable(java.lang.String tabName)

Specified by:

sqlCreateTable in class JDBCPersistManager

sqlCreateIndex

protected java.lang.String sqlCreateIndex(java.lang.String tabName)

Specified by:

sqlCreateIndex in class JDBCPersistManager

sqlCreateSequence

protected java.lang.String sqlCreateSequence(java.lang.String seqName)

Overrides:

sqlCreateSequence in class JDBCPersistManager

canResetSequence

protected boolean canResetSequence()

Overrides:

canResetSequence in class JDBCPersistManager

queryNextCollectionId

public long queryNextCollectionId()

Specified by:

queryNextCollectionId in interface PersistManager

Overrides:

queryNextCollectionId in class JDBCPersistManager

sqlNextSequenceVal

protected long sqlNextSequenceVal(java.lang.String seqName)

Specified by:

sqlNextSequenceVal in class JDBCPersistManager

getCurrentTimeFromDb

protected java.util.Date getCurrentTimeFromDb()

Specified by:

getCurrentTimeFromDb in class JDBCPersistManager

sqlDeleteControlRow

protected java.lang.String sqlDeleteControlRow(java.lang.String controlTabName,
                                               java.lang.String tabName)

Specified by:

sqlDeleteControlRow in class JDBCPersistManager

sqlUpdateControlRow

protected java.lang.String sqlUpdateControlRow(java.lang.String controlTabName,
                                               java.lang.String tabName,
                                               java.lang.String dateColName)

Specified by:

sqlUpdateControlRow in class JDBCPersistManager

sqlLockControlRow

protected java.lang.String sqlLockControlRow(java.lang.String controlTabName,
                                             java.lang.String tabName)

Specified by:

sqlLockControlRow in class JDBCPersistManager

sqlInsertControlRow

protected java.lang.String sqlInsertControlRow(java.lang.String controlTabName,
                                               java.lang.String tabName)

Specified by:

sqlInsertControlRow in class JDBCPersistManager

sqlLockConflictErrorCode

protected int sqlLockConflictErrorCode()

Specified by:

sqlLockConflictErrorCode in class JDBCPersistManager

contentChunkLength

protected int contentChunkLength()

Specified by:

contentChunkLength in class JDBCPersistManager

sqlDeleteKeyInfo

protected java.lang.String sqlDeleteKeyInfo(java.lang.String keyInfoTabName,
                                            long id)

Specified by:

sqlDeleteKeyInfo in class JDBCPersistManager

bindDeleteKeyInfo

protected void bindDeleteKeyInfo(java.sql.PreparedStatement pStmt,
                                 long id,
                                 int collid)
                          throws java.sql.SQLException

Specified by:

bindDeleteKeyInfo in class JDBCPersistManager

Throws:

java.sql.SQLException

sqlInsertKeyInfo

protected java.lang.String sqlInsertKeyInfo(java.lang.String keyInfoTabName)

Specified by:

sqlInsertKeyInfo in class JDBCPersistManager

bindInsertKeyInfo

protected void bindInsertKeyInfo(java.sql.PreparedStatement pStmt,
                                 long id,
                                 int collid,
                                 int keyId,
                                 int keyHash)
                          throws java.sql.SQLException

Specified by:

bindInsertKeyInfo in class JDBCPersistManager

Throws:

java.sql.SQLException

sqlInsertDataRow

protected java.lang.String sqlInsertDataRow(java.lang.String tabName,
                                            long id,
                                            long parid,
                                            int collid)

Specified by:

sqlInsertDataRow in class JDBCPersistManager

bindInsertDataRow

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

Specified by:

bindInsertDataRow in class JDBCPersistManager

Throws:

java.sql.SQLException

sqlDeleteOldChunksDataRow

protected java.lang.String sqlDeleteOldChunksDataRow(java.lang.String tabName,
                                                     long id,
                                                     int collid,
                                                     int begIndx,
                                                     int endIndx)

Specified by:

sqlDeleteOldChunksDataRow in class JDBCPersistManager

bindDeleteOldChunksDataRow

protected void bindDeleteOldChunksDataRow(java.sql.PreparedStatement pStmt,
                                          long id,
                                          int collid,
                                          int begIndx,
                                          int endIndx)
                                   throws java.sql.SQLException

Specified by:

bindDeleteOldChunksDataRow in class JDBCPersistManager

Throws:

java.sql.SQLException

sqlUpdateDataRow

protected java.lang.String sqlUpdateDataRow(java.lang.String tabName,
                                            long id,
                                            long parid,
                                            int collid)

Specified by:

sqlUpdateDataRow in class JDBCPersistManager

bindUpdateDataRow

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

Specified by:

bindUpdateDataRow in class JDBCPersistManager

Throws:

java.sql.SQLException

sqlChangeParentDataRow

protected java.lang.String sqlChangeParentDataRow(java.lang.String tabName,
                                                  long id,
                                                  long parid,
                                                  int collid)

Specified by:

sqlChangeParentDataRow in class JDBCPersistManager

bindChangeParentDataRow

protected void bindChangeParentDataRow(java.sql.PreparedStatement pStmt,
                                       long id,
                                       long parid,
                                       int collid)
                                throws java.sql.SQLException

Specified by:

bindChangeParentDataRow in class JDBCPersistManager

Throws:

java.sql.SQLException

sqlDeleteDataRow

protected java.lang.String sqlDeleteDataRow(java.lang.String tabName,
                                            long id,
                                            int collid)

Specified by:

sqlDeleteDataRow in class JDBCPersistManager

bindDeleteDataRow

protected void bindDeleteDataRow(java.sql.PreparedStatement pStmt,
                                 long id,
                                 int collid)
                          throws java.sql.SQLException

Specified by:

bindDeleteDataRow in class JDBCPersistManager

Throws:

java.sql.SQLException

sqlDeleteAllDataRows

protected java.lang.String sqlDeleteAllDataRows(java.lang.String tabName,
                                                int collid)

Specified by:

sqlDeleteAllDataRows in class JDBCPersistManager

bindDeleteAllDataRows

protected void bindDeleteAllDataRows(java.sql.PreparedStatement pStmt,
                                     int collid)
                              throws java.sql.SQLException

Specified by:

bindDeleteAllDataRows in class JDBCPersistManager

Throws:

java.sql.SQLException

sqlRetrieveDataRow

protected java.lang.String sqlRetrieveDataRow(java.lang.String tabName,
                                              long id,
                                              int collid,
                                              boolean justLen,
                                              boolean keyonly)

Specified by:

sqlRetrieveDataRow in class JDBCPersistManager

bindRetrieveDataRow

protected void bindRetrieveDataRow(java.sql.PreparedStatement pStmt,
                                   long id,
                                   int collid,
                                   boolean justLen)
                            throws java.sql.SQLException

Specified by:

bindRetrieveDataRow in class JDBCPersistManager

Throws:

java.sql.SQLException

getContentDataRow

protected byte[] getContentDataRow(java.sql.ResultSet rslt,
                                   long[] idRet,
                                   long[] parentIdRet,
                                   int[] contentLenRet,
                                   boolean justLen)
                            throws java.sql.SQLException

Specified by:

getContentDataRow in class JDBCPersistManager

Throws:

java.sql.SQLException

sqlRetrieveIdsWithKey

protected java.lang.String sqlRetrieveIdsWithKey(java.lang.String tabName,
                                                 java.lang.String keyInfoTabName,
                                                 int keyId,
                                                 java.lang.Object keyval,
                                                 int collid)

Specified by:

sqlRetrieveIdsWithKey in class JDBCPersistManager

bindRetrieveIdsWithKey

protected void bindRetrieveIdsWithKey(java.sql.PreparedStatement pStmt,
                                      int keyId,
                                      java.lang.Object keyVal,
                                      int keyHash,
                                      int collid)
                               throws java.sql.SQLException

Specified by:

bindRetrieveIdsWithKey in class JDBCPersistManager

Throws:

java.sql.SQLException