Uploaded image for project: 'Jackrabbit Content Repository'
  1. Jackrabbit Content Repository
  2. JCR-1446

Local transactions support

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: 1.5
    • Fix Version/s: None
    • Component/s: jackrabbit-jca
    • Labels:
      None

      Description

      JCAManagedConnectionFactory doesn't currently support LocalTransaction. Wouldn't it be simple to provide a simple implemetation like the following (inspired of JR test suite):
      package com.weka.jackrabbit.jca;

      import javax.jcr.Session;
      import javax.resource.ResourceException;
      import javax.resource.spi.LocalTransaction;
      import javax.transaction.xa.XAException;
      import javax.transaction.xa.XAResource;
      import javax.transaction.xa.Xid;

      import org.apache.jackrabbit.api.XASession;

      /**

      • JackRabbit Local transaction (based on the XA Resource returned by
      • JackRabbit). <p/> Inspired from JackRabbit test suite.
      • Internal {@link javax.transaction.LocalTransaction}

        implementation.

      • */
        public class JackRabbitLocalTransaction implements LocalTransaction {

      /**

      • Global transaction id counter. TODO: remove the static attribute
        */
        private static byte counter = 0;

      /**

      • XASession
        */
        private XASession session;

      /**

      • XAResource
        */
        private final XAResource xares;

      /**

      • Xid
        */
        private Xid xid;

      /**

      • Create a new instance of this class. Takes a session as parameter.
      • @param session
      • session. If session is not of type {@link XASession}

        , an

      • <code>IllegalArgumentException</code> is thrown
        */
        public JackRabbitLocalTransaction(Session session)
        Unknown macro: { if (session instanceof XASession) { this.session = (XASession) session; xares = this.session.getXAResource(); } else { throw new IllegalArgumentException("Session not of type XASession"); } }

      /**

      • @see javax.transaction.LocalTransaction#begin
        */
        public void begin() throws ResourceException {

      try

      { xid = new XidImpl(counter++); xares.start(xid, XAResource.TMNOFLAGS); }

      catch (XAException e)

      { throw new ResourceException("Unable to begin transaction: " + "XA_ERR=" + e.errorCode); }

      }

      /**

      • @see javax.transaction.LocalTransaction#commit
        */
        public void commit() throws ResourceException {

      try

      { xares.end(xid, XAResource.TMSUCCESS); xares.prepare(xid); xares.commit(xid, false); session.logout(); }

      catch (XAException e) {

      if (e.errorCode >= XAException.XA_RBBASE && e.errorCode <= XAException.XA_RBEND)

      { throw new ResourceException(e.toString()); }

      throw new ResourceException("Unable to commit transaction: " + "XA_ERR=" + e.errorCode);
      }
      }

      /**

      • @see javax.transaction.LocalTransaction#rollback
        */
        public void rollback() throws ResourceException {

      try

      { xares.end(xid, XAResource.TMFAIL); xares.rollback(xid); session.logout(); }

      catch (XAException e)

      { throw new ResourceException("Unable to rollback transaction: " + "XA_ERR=" + e.errorCode); }

      }

      /**

      • Internal {@link Xid}

        implementation.
        */
        class XidImpl implements Xid {

      /** Global transaction id */
      private final byte[] globalTxId;

      /**

      • Create a new instance of this class. Takes a global transaction
      • number as parameter
      • @param globalTxNumber
      • global transaction number
        */
        public XidImpl(byte globalTxNumber)
        Unknown macro: { this.globalTxId = new byte[] { globalTxNumber }; }

      /**

      • @see javax.transaction.xa.Xid#getFormatId()
        */
        public int getFormatId() { return 0; }

      /**

      • @see javax.transaction.xa.Xid#getBranchQualifier()
        */
        public byte[] getBranchQualifier() { return new byte[0]; }

      /**

      • @see javax.transaction.xa.Xid#getGlobalTransactionId()
        */
        public byte[] getGlobalTransactionId() { return globalTxId; }

        }

      /**

      • @return Returns the counter.
        */
        public byte getCounter() { return counter; }

      /**

      • @param counter
      • The counter to set.
        */
        public void setCounter(byte counter) { JackRabbitLocalTransaction.counter = counter; }

        }

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                kalished Stephane Landelle
              • Votes:
                2 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - 0.5h
                  0.5h
                  Remaining:
                  Remaining Estimate - 0.5h
                  0.5h
                  Logged:
                  Time Spent - Not Specified
                  Not Specified