I have a simple BPEL that uses just one DataBase BC to insert/update records, it purpouse is just testing rollbacks inside a BPEL. The BPEL first make an insertion and after that tries to update a record, then finishes.
I need the BPEL's to rollback the inserted records in my real application if an error occurs, so I make this project to test and I produce an error intentionally in the update sql to see if the inserted record is rollbacked.
SCENARIO
----------
GlassFishESB v2.1
DataBase: MySQL 5.1
JDBC lib: mysql-connector-java-5.1.7-bin.jar
Pool definition in glasshFish:
Datasource Classname: com.mysql.jdbc.jdbc2.optional.MysqlXADataSource
Resource Type: javax.sql.XADataSource
Database BC: all 'Transation' properties to XATransaction
The BPEL has the property atomic = 'true'
PROBLEM
---------
I execute a test, then the BPEL invokes the DB BC and inserts the record. Then the BPEL invokes the update (I put an error in the sql to make it fail) and fails, BUT THE INSERTED RECORD IS NOT ROLLBACKED and after the BPEL ends is still in the database!!
Is there any way to rollback the DB BC operations if something produces an error inside the BPEL??
Any ideas will be appreciated!!
Thanks in advance!!
BTW, I attach some files of my project, maybe it helps (I can upload full project if necessary):
---------------
The BEPEL FILE:
---------------
<?xml version="1.0" encoding="UTF-8"?>
<process
name="textRollBack"
targetNamespace="
http://enterprise.netbeans.org/bpel/textRollBack/textRollBack"
xmlns="
http://docs.oasis-open.org/wsbpel/2.0/process/executable"
xmlns:xsd="
http://www.w3.org/2001/XMLSchema"
xmlns:sxt="
http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Trace"
xmlns:sxed="
http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Editor"
xmlns:sxat="
http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Attachment"
xmlns:sxeh="
http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/ErrorHandling"
xmlns:tns="
http://enterprise.netbeans.org/bpel/textRollBack/textRollBack" xmlns:sxed2="
http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Editor2" xmlns:ns0="
http://j2ee.netbeans.org/xsd/tableSchema" xmlns:sxtx="
http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Transaction" sxtx:atomic="yes">
<import namespace="
http://j2ee.netbeans.org/wsdl/textRollBack/textRollBack" location="textRollBack.wsdl" importType="
http://schemas.xmlsoap.org/wsdl/"/>
<import namespace="
http://j2ee.netbeans.org/wsdl/text" location="text.wsdl" importType="
http://schemas.xmlsoap.org/wsdl/"/>
<partnerLinks>
<partnerLink name="PartnerLink1" xmlns:tns="
http://j2ee.netbeans.org/wsdl/text" partnerLinkType="tns:jdbcpartner" partnerRole="jdbcPortTypeRole"/>
<partnerLink name="rollback" xmlns:tns="
http://j2ee.netbeans.org/wsdl/textRollBack/textRollBack" partnerLinkType="tns:textRollBack" myRole="textRollBackPortTypeRole"/>
</partnerLinks>
<variables>
<variable name="InsertOut" xmlns:tns="
http://j2ee.netbeans.org/wsdl/text" messageType="tns:insertRetMsg"/>
<variable name="InsertIn" xmlns:tns="
http://j2ee.netbeans.org/wsdl/text" messageType="tns:inputMsg"/>
<variable name="TextRollBackOperationOut" xmlns:tns="
http://j2ee.netbeans.org/wsdl/textRollBack/textRollBack" messageType="tns:textRollBackOperationResponse"/>
<variable name="TextRollBackOperationIn" xmlns:tns="
http://j2ee.netbeans.org/wsdl/textRollBack/textRollBack" messageType="tns:textRollBackOperationRequest"/>
</variables>
<sequence>
<receive name="Receive1" createInstance="yes" partnerLink="rollback" operation="textRollBackOperation" xmlns:tns="
http://j2ee.netbeans.org/wsdl/textRollBack/textRollBack" portType="tns:textRollBackPortType" variable="TextRollBackOperationIn"/>
<assign name="Assign1">
<copy>
<from variable="TextRollBackOperationIn" part="id"/>
<to>$InsertIn.part/ns0:text_Record/ns0:id</to>
</copy>
<copy>
<from variable="TextRollBackOperationIn" part="dato"/>
<to>$InsertIn.part/ns0:text_Record/ns0:texto</to>
</copy>
<copy>
<from variable="TextRollBackOperationIn" part="dato"/>
<to variable="TextRollBackOperationOut" part="part1"/>
</copy>
</assign>
<invoke name="Invoke1" partnerLink="PartnerLink1" operation="insert" xmlns:tns="
http://j2ee.netbeans.org/wsdl/text" portType="tns:jdbcPortType" inputVariable="InsertIn" outputVariable="InsertOut"/>
<invoke name="Invoke2" partnerLink="PartnerLink1" operation="update" xmlns:tns="
http://j2ee.netbeans.org/wsdl/text" portType="tns:jdbcPortType" inputVariable="InsertIn"/>
<reply name="Reply1" partnerLink="rollback" operation="textRollBackOperation" xmlns:tns="
http://j2ee.netbeans.org/wsdl/textRollBack/textRollBack" portType="tns:textRollBackPortType" variable="TextRollBackOperationOut"/>
</sequence>
</process>
--------------
The DB BC File
--------------
<?xml version="1.0" encoding="UTF-8"?>
<definitions name="text" targetNamespace="
http://j2ee.netbeans.org/wsdl/text" xmlns="
http://schemas.xmlsoap.org/wsdl/" xmlns:ns="
http://j2ee.netbeans.org/xsd/tableSchema" xmlns:wsdl="
http://schemas.xmlsoap.org/wsdl/" xmlns:tns="
http://j2ee.netbeans.org/wsdl/text" xmlns:plink="
http://docs.oasis-open.org/wsbpel/2.0/plnktype" xmlns:xsd="
http://www.w3.org/2001/XMLSchema" xmlns:soap="
http://schemas.xmlsoap.org/wsdl/soap/" xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/">
<types>
<xsd:schema xmlns:xsd="
http://www.w3.org/2001/XMLSchema" targetNamespace="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/">
<xsd:import namespace="
http://j2ee.netbeans.org/xsd/tableSchema" schemaLocation="text.xsd"/>
</xsd:schema>
</types>
<message name="insertRetMsg">
<part name="part" type="xsd:int"/>
</message>
<message name="inputMsg">
<part name="part" element="ns:text"/>
</message>
<message name="outputMsg">
<part name="part" element="ns:text"/>
</message>
<portType name="jdbcPortType">
<operation name="insert">
<input name="inputInsert" message="tns:inputMsg"/>
<output name="outputInsert" message="tns:insertRetMsg"/>
</operation>
<operation name="update">
<input name="inputUpdate" message="tns:inputMsg"/>
</operation>
<operation name="delete">
<input name="inputDelete" message="tns:inputMsg"/>
</operation>
</portType>
<binding name="binding" type="tns:jdbcPortType">
<jdbc:binding xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/"/>
<operation name="insert">
<jdbc:operation xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/"/>
<input name="inputInsert">
<jdbc:input xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/" MarkColumnName="" MoveRowToTableName="" PKName="id" PollMilliSeconds="36000000" TableName="text" Transaction="XATransaction" numberOfRecords="" operationType="insert" paramOrder="id,texto" sql="insert into text (id,texto) values (?,?)"/>
</input>
<output name="outputInsert">
<jdbc:output xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/" returnPartName="part"/>
</output>
</operation>
<operation name="update">
<jdbc:operation xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/"/>
<input name="inputUpdate">
<jdbc:input xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/" MarkColumnName="" MarkColumnValue="" MoveRowToTableName="" PKName="id" PollMilliSeconds="36000000" TableName="text" Transaction="XATransaction" numberOfRecords="" operationType="update" paramOrder="id,texto" sql="update text set id = ?,texto2 = ?"/>
</input>
</operation>
<operation name="delete">
<jdbc:operation xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/"/>
<input name="inputDelete">
<jdbc:input xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/" MarkColumnName="" MarkColumnValue="" MoveRowToTableName="" PKName="id" PollMilliSeconds="36000000" TableName="text" Transaction="XATransaction" numberOfRecords="" operationType="delete" paramOrder="" sql="delete from text"/>
</input>
</operation>
</binding>
<service name="service">
<port name="port" binding="tns:binding">
<jdbc:address xmlns:jdbc="
http://schemas.sun.com/jbi/wsdl-extensions/jdbc/" jndiName="jdbc/snacks"/>
</port>
</service>
<plink:partnerLinkType xmlns:plink="
http://docs.oasis-open.org/wsbpel/2.0/plnktype" name="jdbcpartner">
<plink:role name="jdbcPortTypeRole" portType="tns:jdbcPortType"/>
</plink:partnerLinkType>
</definitions>
--------------
TABLE in MySql
--------------
CREATE TABLE `text` (
`id` int(10) unsigned NOT NULL AUTO_INCREMENT,
`texto` varchar(45) NOT NULL,
PRIMARY KEY (`id`)
)
