[jira] Updated: (JCR-1446) Local transactions support

["Jukka Zitting (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/JCR-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jukka Zitting updated JCR-1446:
-------------------------------

    Status: Patch Available  (was: Open)

> Local transactions support
> --------------------------
>
>                 Key: JCR-1446
>                 URL: https://issues.apache.org/jira/browse/JCR-1446
>             Project: Jackrabbit Content Repository
>          Issue Type: Improvement
>          Components: jackrabbit-jca
>    Affects Versions: 1.5.0
>            Reporter: Stephane Landelle
>   Original Estimate: 0.5h
>  Remaining Estimate: 0.5h
>
> 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) {
> 		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) {
> 			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;
> 	}
> }

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.