conn = ds.getConnection();
conn = getConnection();
   protected void createSchema() throws Exception   {      Connection conn = null;      TransactionWrapper tx = new TransactionWrapper();            log.info("creating tables");            try      {         conn = ds.getConnection();                  try         {            conn.createStatement().executeUpdate(createTransaction);            if (trace)            {               log.trace(createTransaction + " succeeded");            }         }         catch (SQLException e)         {            log.debug(createTransaction + " failed!", e);         }                  try         {            conn.createStatement().executeUpdate(createMessageReference);            if (trace)            {               log.trace(createMessageReference + " succeeded");            }         }         catch (SQLException e)         {            log.debug(createMessageReference + " failed!", e);         }                  try         {            conn.createStatement().executeUpdate(createIdxMessageRefTx);            if (trace)            {               log.trace(createIdxMessageRefTx + " succeeded");            }         }         catch (SQLException e)         {            log.debug(createIdxMessageRefTx + " failed!", e);         }                  try         {            conn.createStatement().executeUpdate(createIdxMessageRefOrd);            if (trace)            {               log.trace(createIdxMessageRefOrd + " succeeded");            }         }         catch (SQLException e)         {            log.debug(createIdxMessageRefOrd + " failed!", e);         }                  try         {            conn.createStatement().executeUpdate(createIdxMessageRefMessageId);            if (trace)            {               log.trace(createIdxMessageRefMessageId + " succeeded");            }         }         catch (SQLException e)         {            log.debug(createIdxMessageRefOrd + " failed!", e);         }                  try         {            conn.createStatement().executeUpdate(createMessage);            if (trace)            {               log.trace(createMessage + " succeeded");            }         }         catch (SQLException e)         {            log.debug(createMessage + " failed!", e);         }                  try         {            conn.createStatement().executeUpdate(createCounter);            if (trace)            {               log.trace(createCounter + " succeeded");            }         }         catch (SQLException e)         {            log.debug(createCounter + " failed!", e);         }      }      finally      {         if (conn != null)         {            try            {               conn.close();            }            catch (Throwable t)            {            }         }         tx.end();      }   }