org.jboss.mq.pm.jdbc2: public class: MSSQLPersistenceManager

org.jboss.mq.pm.jdbc2
public class: MSSQLPersistenceManager [javadoc | source]

java.lang.Object
   org.jboss.mx.util.JBossNotificationBroadcasterSupport
      org.jboss.system.ServiceMBeanSupport
         org.jboss.mq.pm.jdbc2.PersistenceManager
            org.jboss.mq.pm.jdbc2.MSSQLPersistenceManager

All Implemented Interfaces:
PersistenceManagerExt, PersistenceManagerMBean, PersistenceManager, CacheStore, org.jboss.kernel.spi.dependency.KernelControllerContextAware, ServiceMBean, MBeanRegistration, NotificationEmitter

MSSQLPersistenceManager.

Based on http://jira.jboss.com/jira/browse/JBAS-2369

author: < - a href="luc.texier@jboss.com">Luc Texier

version: $ - Revision: 42605 $

Field Summary
protected String	CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION

Fields inherited from org.jboss.mq.pm.jdbc2.PersistenceManager:
nextTransactionId, txManager, datasource, tm, UPDATE_MARKED_MESSAGES, UPDATE_MARKED_MESSAGES_XARECOVERY, UPDATE_MARKED_MESSAGES_WITH_TX, DELETE_MARKED_MESSAGES_WITH_TX, DELETE_MARKED_MESSAGES_WITH_TX_XARECOVERY, DELETE_TX, DELETE_MARKED_MESSAGES, DELETE_TEMPORARY_MESSAGES, INSERT_TX, INSERT_TX_XARECOVERY, DELETE_ALL_TX, DELETE_ALL_TX_XARECOVERY, SELECT_MAX_TX, SELECT_ALL_TX_XARECOVERY, SELECT_MESSAGES_IN_DEST, SELECT_MESSAGES_IN_DEST_XARECOVERY, SELECT_MESSAGE_KEYS_IN_DEST, SELECT_MESSAGE, SELECT_MESSAGE_XARECOVERY, INSERT_MESSAGE, MARK_MESSAGE, DELETE_MESSAGE, UPDATE_MESSAGE, CREATE_MESSAGE_TABLE, CREATE_IDX_MESSAGE_TXOP_TXID, CREATE_IDX_MESSAGE_DESTINATION, CREATE_TX_TABLE, CREATE_TX_TABLE_XARECOVERY, OBJECT_BLOB, BYTES_BLOB, BINARYSTREAM_BLOB, BLOB_BLOB, blobType, createTables, connectionRetryAttempts, xaRecovery, connectionManagerName, sqlProperties

Fields inherited from org.jboss.mq.pm.jdbc2.PersistenceManager:

nextTransactionId, txManager, datasource, tm, UPDATE_MARKED_MESSAGES, UPDATE_MARKED_MESSAGES_XARECOVERY, UPDATE_MARKED_MESSAGES_WITH_TX, DELETE_MARKED_MESSAGES_WITH_TX, DELETE_MARKED_MESSAGES_WITH_TX_XARECOVERY, DELETE_TX, DELETE_MARKED_MESSAGES, DELETE_TEMPORARY_MESSAGES, INSERT_TX, INSERT_TX_XARECOVERY, DELETE_ALL_TX, DELETE_ALL_TX_XARECOVERY, SELECT_MAX_TX, SELECT_ALL_TX_XARECOVERY, SELECT_MESSAGES_IN_DEST, SELECT_MESSAGES_IN_DEST_XARECOVERY, SELECT_MESSAGE_KEYS_IN_DEST, SELECT_MESSAGE, SELECT_MESSAGE_XARECOVERY, INSERT_MESSAGE, MARK_MESSAGE, DELETE_MESSAGE, UPDATE_MESSAGE, CREATE_MESSAGE_TABLE, CREATE_IDX_MESSAGE_TXOP_TXID, CREATE_IDX_MESSAGE_DESTINATION, CREATE_TX_TABLE, CREATE_TX_TABLE_XARECOVERY, OBJECT_BLOB, BYTES_BLOB, BINARYSTREAM_BLOB, BLOB_BLOB, blobType, createTables, connectionRetryAttempts, xaRecovery, connectionManagerName, sqlProperties

Fields inherited from org.jboss.system.ServiceMBeanSupport:
SERVICE_CONTROLLER_SIG, log, server, serviceName

Constructor:

Constructor:
public MSSQLPersistenceManager() throws JMSException { } Create a new MSSQLPersistenceManager. Throws: `JMSException` - for any error

 public MSSQLPersistenceManager() throws JMSException {

}

Create a new MSSQLPersistenceManager.

Throws:

JMSException - for any error

Method from org.jboss.mq.pm.jdbc2.MSSQLPersistenceManager Summary:
createSchema, innerCreateSchema, startService

Methods from org.jboss.mq.pm.jdbc2.PersistenceManager:
add, add, addTXRecord, closeQueue, commitPersistentTx, createPersistentTx, createSchema, extractMessage, extractXid, forcePersistentTx, getConnection, getConnectionManager, getConnectionRetryAttempts, getInstance, getMessageCache, getMessageCacheInstance, getRecoverMessagesChunk, getRecoveryRetries, getRecoveryTimeout, getSqlProperties, getStatementRetries, getTxManager, initializeFields, insertPersistentTx, internalRestoreQueue, isXARecovery, loadFromStorage, markMessage, remove, removeFromStorage, removeMarkedMessages, removeTXRecord, resolveAllUncommitedTXs, restoreQueue, rollbackPersistentTx, saveToStorage, setBlob, setBlob, setConnectionManager, setConnectionRetryAttempts, setMessageCache, setRecoverMessagesChunk, setRecoveryRetries, setRecoveryTimeout, setSqlProperties, setStatementRetries, setXARecovery, startService, update

Methods from org.jboss.mq.pm.jdbc2.PersistenceManager:

add, add, addTXRecord, closeQueue, commitPersistentTx, createPersistentTx, createSchema, extractMessage, extractXid, forcePersistentTx, getConnection, getConnectionManager, getConnectionRetryAttempts, getInstance, getMessageCache, getMessageCacheInstance, getRecoverMessagesChunk, getRecoveryRetries, getRecoveryTimeout, getSqlProperties, getStatementRetries, getTxManager, initializeFields, insertPersistentTx, internalRestoreQueue, isXARecovery, loadFromStorage, markMessage, remove, removeFromStorage, removeMarkedMessages, removeTXRecord, resolveAllUncommitedTXs, restoreQueue, rollbackPersistentTx, saveToStorage, setBlob, setBlob, setConnectionManager, setConnectionRetryAttempts, setMessageCache, setRecoverMessagesChunk, setRecoveryRetries, setRecoveryTimeout, setSqlProperties, setStatementRetries, setXARecovery, startService, update

Methods from org.jboss.system.ServiceMBeanSupport:
create, createService, destroy, destroyService, getDeploymentInfo, getLog, getName, getNextNotificationSequenceNumber, getObjectName, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, pojoChange, pojoCreate, pojoDestroy, pojoStart, pojoStop, postDeregister, postRegister, preDeregister, preRegister, setKernelControllerContext, start, startService, stop, stopService, unsetKernelControllerContext

Methods from org.jboss.system.ServiceMBeanSupport:

create, createService, destroy, destroyService, getDeploymentInfo, getLog, getName, getNextNotificationSequenceNumber, getObjectName, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, pojoChange, pojoCreate, pojoDestroy, pojoStart, pojoStop, postDeregister, postRegister, preDeregister, preRegister, setKernelControllerContext, start, startService, stop, stopService, unsetKernelControllerContext

Methods from org.jboss.mx.util.JBossNotificationBroadcasterSupport:
addNotificationListener, getNotificationInfo, handleNotification, nextNotificationSequenceNumber, removeNotificationListener, removeNotificationListener, sendNotification

Methods from java.lang.Object:
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.jboss.mq.pm.jdbc2.MSSQLPersistenceManager Detail:
protected synchronized void createSchema() throws JMSException { TransactionManagerStrategy tms = new TransactionManagerStrategy(); tms.startTX(); Connection c = null; PreparedStatement stmt = null; boolean threadWasInterrupted = Thread.interrupted(); try { innerCreateSchema(c, stmt); } catch (SQLException e) { tms.setRollbackOnly(); throw new SpyJMSException("Could not get a connection for jdbc2 table construction ", e); } finally { try { if (stmt != null) stmt.close(); } catch (Throwable ignore) { } stmt = null; try { if (c != null) c.close(); } catch (Throwable ignore) { } c = null; tms.endTX(); // Restore the interrupted state of the thread if (threadWasInterrupted) Thread.currentThread().interrupt(); } }
protected void innerCreateSchema(Connection c, PreparedStatement stmt) throws SQLException { if (createTables) { c = this.getConnection(); boolean createdMessageTable = false; try { stmt = c.prepareStatement(CREATE_MESSAGE_TABLE); stmt.executeUpdate(); createdMessageTable = true; } catch (SQLException e) { log.debug("Could not create table with SQL: " + CREATE_MESSAGE_TABLE, e); } finally { try { if (stmt != null) stmt.close(); } catch (Throwable ignored) { log.trace("Ignored: " + ignored); } stmt = null; } if (createdMessageTable) { try { stmt = c.prepareStatement(CREATE_IDX_MESSAGE_TXOP_TXID); stmt.executeUpdate(); } catch (SQLException e) { log.debug("Could not create index with SQL: " + CREATE_IDX_MESSAGE_TXOP_TXID, e); } finally { try { if (stmt != null) stmt.close(); } catch (Throwable ignored) { log.trace("Ignored: " + ignored); } stmt = null; } try { stmt = c.prepareStatement(CREATE_IDX_MESSAGE_DESTINATION); stmt.executeUpdate(); } catch (SQLException e) { log.debug("Could not create index with SQL: " + CREATE_IDX_MESSAGE_DESTINATION, e); } finally { try { if (stmt != null) stmt.close(); } catch (Throwable ignored) { log.trace("Ignored: " + ignored); } stmt = null; } try { stmt = c.prepareStatement(CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION); stmt.executeUpdate(); } catch (SQLException e) { log.debug("Could not create index with SQL: " + CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION, e); } finally { try { if (stmt != null) stmt.close(); } catch (Throwable ignored) { log.trace("Ignored: " + ignored); } stmt = null; } } try { stmt = c.prepareStatement(CREATE_TX_TABLE); stmt.executeUpdate(); } catch (SQLException e) { log.debug("Could not create table with SQL: " + CREATE_TX_TABLE, e); } finally { try { if (stmt != null) stmt.close(); } catch (Throwable ignored) { log.trace("Ignored: " + ignored); } stmt = null; } } }
public void startService() throws Exception { CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION = sqlProperties.getProperty("CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION", CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION); super.startService(); }

Method from org.jboss.mq.pm.jdbc2.MSSQLPersistenceManager Detail:

 protected synchronized  void createSchema() throws JMSException {
      TransactionManagerStrategy tms = new TransactionManagerStrategy();
      tms.startTX();
      Connection c = null;
      PreparedStatement stmt = null;
      boolean threadWasInterrupted = Thread.interrupted();
      try
      {
          innerCreateSchema(c, stmt);
      }
      catch (SQLException e)
      {
         tms.setRollbackOnly();
         throw new SpyJMSException("Could not get a connection for jdbc2 table construction ", e);
      }
      finally
      {
         try
         {
            if (stmt != null)
               stmt.close();
         }
         catch (Throwable ignore)
         {
         }
         stmt = null;
         try
         {
            if (c != null)
               c.close();
         }
         catch (Throwable ignore)
         {
         }
         c = null;
         tms.endTX();
         // Restore the interrupted state of the thread
         if (threadWasInterrupted)
            Thread.currentThread().interrupt();
      }
}

 protected  void innerCreateSchema(Connection c,
    PreparedStatement stmt) throws SQLException {
       if (createTables)
       {
          c = this.getConnection();
          boolean createdMessageTable = false;
          try
          {
             stmt = c.prepareStatement(CREATE_MESSAGE_TABLE);
             stmt.executeUpdate();
             createdMessageTable = true;
          }
          catch (SQLException e)
          {
             log.debug("Could not create table with SQL: " + CREATE_MESSAGE_TABLE, e);
          }
          finally
          {
             try
             {
                if (stmt != null)
                   stmt.close();
             }
             catch (Throwable ignored)
             {
                log.trace("Ignored: " + ignored);
             }
             stmt = null;
          }
          if (createdMessageTable)
          {
             try
             {
                stmt = c.prepareStatement(CREATE_IDX_MESSAGE_TXOP_TXID);
                stmt.executeUpdate();
             }
             catch (SQLException e)
             {
                log.debug("Could not create index with SQL: " + CREATE_IDX_MESSAGE_TXOP_TXID, e);
             }
             finally
             {
                try
                {
                   if (stmt != null)
                      stmt.close();
                }
                catch (Throwable ignored)
                {
                   log.trace("Ignored: " + ignored);
                }
                stmt = null;
             }
             try
             {
                stmt = c.prepareStatement(CREATE_IDX_MESSAGE_DESTINATION);
                stmt.executeUpdate();
             }
             catch (SQLException e)
             {
                log.debug("Could not create index with SQL: " + CREATE_IDX_MESSAGE_DESTINATION, e);
             }
             finally
             {
                try
                {
                   if (stmt != null)
                      stmt.close();
                }
                catch (Throwable ignored)
                {
                   log.trace("Ignored: " + ignored);
                }
                stmt = null;
             }
              try
              {
                 stmt = c.prepareStatement(CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION);
                 stmt.executeUpdate();
              }
              catch (SQLException e)
              {
                 log.debug("Could not create index with SQL: " + CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION, e);
              }
              finally
              {
                 try
                 {
                    if (stmt != null)
                       stmt.close();
                 }
                 catch (Throwable ignored)
                 {
                    log.trace("Ignored: " + ignored);
                 }
                 stmt = null;
              }
          }
          try
          {
             stmt = c.prepareStatement(CREATE_TX_TABLE);
             stmt.executeUpdate();
          }
          catch (SQLException e)
          {
             log.debug("Could not create table with SQL: " + CREATE_TX_TABLE, e);
          }
          finally
          {
             try
             {
                if (stmt != null)
                   stmt.close();
             }
             catch (Throwable ignored)
             {
                log.trace("Ignored: " + ignored);
             }
             stmt = null;
          }
       }
}

 public  void startService() throws Exception {
      CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION = sqlProperties.getProperty("CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION", CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION);
      super.startService();
}