Mailing-List: contact users-help@cocoon.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@cocoon.apache.org
Received-SPF: neutral (hermes.apache.org: local policy)
Message-ID: <4512CBFD.2010200@orcades.net>
Date: Thu, 21 Sep 2006 19:29:33 +0200
From: Olivier <olivier@orcades.net>
User-Agent: Thunderbird 1.5.0.5 (X11/20060719)
MIME-Version: 1.0
To: users@cocoon.apache.org
Subject: Re: Free for use: SaveFilesTransformer
References: <6DD7194CCE91BB44A41318EA7D06151070E007@pegasus.olympus.borgus.nl>
In-Reply-To: 
 <6DD7194CCE91BB44A41318EA7D06151070E007@pegasus.olympus.borgus.nl>
Content-Type: multipart/mixed;
 boundary="------------070300050906070604020005"

--------------070300050906070604020005
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit

Geert Josten wrote:
>> Really an intersting idea. But I'd not begin the transaction 
>> in setup(). 
>> What about startDocument()?
>>     
>
> And the rollback() at endDocument() as well (if necessary :). Though I
> guess I would like to manage the transactions independantly altogether.
> In actions fired with separate urls perhaps?
>
> ;-)
>    
>   
Hum ...
In fact the transaction id is the file url.
IMHO endDocument is not called if an exeption occure in pipeline.

See the transformer in attachment.

Comment are very welcome ...


--------------070300050906070604020005
Content-Type: text/x-java;
 name="TransactionalFileWriterTransformer.java"
Content-Transfer-Encoding: 7bit
Content-Disposition: inline;
 filename="TransactionalFileWriterTransformer.java"

/*
 * Created on 3 sept. 2005
 *
 */
package net.orcades.cocoon.transformation;

import java.io.File;
import java.io.IOException;
import java.io.OutputStream;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Map;

import net.orcades.cocoon.InvalidResourceException;
import net.orcades.cocoon.transaction.FileManagerPool;
import net.orcades.cocoon.transaction.ResourceManagerProcessingException;

import org.apache.avalon.framework.parameters.ParameterException;
import org.apache.avalon.framework.parameters.Parameters;
import org.apache.cocoon.ProcessingException;
import org.apache.cocoon.environment.SourceResolver;
import org.apache.cocoon.transformation.AbstractSAXTransformer;
import org.apache.commons.transaction.file.FileResourceManager;
import org.apache.commons.transaction.file.ResourceManagerException;
import org.apache.excalibur.source.Source;
import org.apache.xml.serialize.OutputFormat;
import org.apache.xml.serialize.XMLSerializer;
import org.xml.sax.Attributes;
import org.xml.sax.SAXException;

/**
 * @author olivier nouguier
 * 
 */
public class TransactionalFileWriterTransformer extends AbstractSAXTransformer {
	/*
	 * (non-Javadoc)
	 * 
	 * @see org.apache.cocoon.transformation.AbstractSAXTransformer#configure(org.apache.avalon.framework.configuration.Configuration)
	 */
	private FileResourceManager fileManager;

	private XMLSerializer serializer;

	private Object txId;

	/*
	 * (non-Javadoc)
	 * 
	 * @see org.apache.cocoon.transformation.AbstractSAXTransformer#setup(org.apache.cocoon.environment.SourceResolver,
	 *      java.util.Map, java.lang.String,
	 *      org.apache.avalon.framework.parameters.Parameters)
	 */
	public void setup(SourceResolver resolver, Map objectModel, String src, Parameters par) throws ProcessingException, SAXException, IOException {
		super.setup(resolver, objectModel, src, par);
		try {
			
			Source source = null;
			
			try {
				source = resolver.resolveURI(par.getParameter("dest-dir"));
				String destDir = new URI(source.getURI()).getPath();
				
				
				fileManager = FileManagerPool.getInstance().getFileResourceManager(destDir, getLogger(), par.getParameterAsBoolean("debug-fine", true));
				if(par.getParameterAsBoolean("reset", false)){
					fileManager.recover();
				}
				if(fileManager.resourceExists(src)){
					File file = new File(fileManager.getStoreDir() + File.separator + src);
					if(file.isDirectory()){
						fileManager=null;
						txId=null;
						
						throw new InvalidResourceException("IS_A_DIRECTORY");
					}
				}
				

				fileManager.startTransaction(src);

				txId = src;
				
				OutputStream outputStream = fileManager.writeResource(txId, src);

				serializer = new XMLSerializer();

				OutputFormat outputFormat = new OutputFormat();
				outputFormat.setMethod(par.getParameter("method", "xml"));
				outputFormat.setEncoding(par.getParameter("encoding", "ISO-8859-1"));
				outputFormat.setIndent(par.getParameterAsInteger("indenting", 1));
				serializer.setOutputFormat(outputFormat);

				serializer.setOutputByteStream(outputStream);
			} finally {
				if(source!=null)
					resolver.release(source);
			}

		} catch (ParameterException e) {
			throw new ProcessingException(e);
		} catch (ResourceManagerException e) {
			throw new ResourceManagerProcessingException(src, e);
		} catch (MalformedURLException e) {
			e.printStackTrace();
		} catch (URISyntaxException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}

	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see org.apache.cocoon.transformation.AbstractSAXTransformer#startDocument()
	 */
	public void startDocument() throws SAXException {
		super.startDocument();
		serializer.startDocument();
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see org.apache.cocoon.transformation.AbstractSAXTransformer#startElement(java.lang.String,
	 *      java.lang.String, java.lang.String, org.xml.sax.Attributes)
	 */
	public void startElement(String uri, String name, String raw, Attributes attr) throws SAXException {
		super.startElement(uri, name, raw, attr);
		serializer.startElement(uri, name, raw, attr);

	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see org.apache.cocoon.transformation.AbstractSAXTransformer#startCDATA()
	 */
	public void startCDATA() throws SAXException {
		super.startCDATA();
		serializer.startCDATA();
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see org.apache.cocoon.transformation.AbstractSAXTransformer#characters(char[],
	 *      int, int)
	 */
	public void characters(char[] buff, int start, int length) throws SAXException {
		super.characters(buff, start, length);
		serializer.characters(buff, start, length);
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see org.apache.cocoon.transformation.AbstractSAXTransformer#endCDATA()
	 */
	public void endCDATA() throws SAXException {
		super.endCDATA();
		serializer.endCDATA();
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see org.apache.cocoon.transformation.AbstractSAXTransformer#endElement(java.lang.String,
	 *      java.lang.String, java.lang.String)
	 */
	public void endElement(String uri, String name, String raw) throws SAXException {
		super.endElement(uri, name, raw);
		serializer.endElement(uri, name, raw);
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see org.apache.cocoon.transformation.AbstractSAXTransformer#endDocument()
	 */
	public void endDocument() throws SAXException {
		super.endDocument();
		serializer.endDocument();
		
		try {
			fileManager.commitTransaction(txId);
			fileManager = null;
			txId = null;
		} catch (ResourceManagerException e) {
			throw new SAXException(e);
		}

	}

	public void recycle() {
		serializer = null;
		if (fileManager != null) {
			Object sadTxId = txId;
			FileResourceManager sadFileManager = fileManager;
			txId = null;
			fileManager = null;
			if(sadTxId!=null)
			try {
				  sadFileManager.rollbackTransaction(sadTxId);
			} catch (ResourceManagerException e) {
				e.printStackTrace();
			}
		}
		
		super.recycle();
	}
	
	
}

--------------070300050906070604020005
Content-Type: text/plain; charset=us-ascii

---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@cocoon.apache.org
For additional commands, e-mail: users-help@cocoon.apache.org
--------------070300050906070604020005--