camel-ibatis

[Arvydas <ar...@gmail.com>]

Hi all.
As a newcomer to camel I would be very grateful if you helped me. 

The problem is with camel IBATIS component. 

I am making the simple camel ibatis component which selects information from
database table, deletes it from same database table and sends the
information to http provider. All is working but now i need to implement
additional feature - I need to lock the mysql table before selection and
release the lock after removal. I have tried to write four sql statements:

<statement id="lock"> LOCK TABLE vacation WRITE <statement/> - locks the
table
<select id="selectAll" resultMap="VacationResult"/> - selects the data
<delete id="deleteAll" parameterClass="Vacation">  - deletes the data
<statement id="unlock"> UNLOCK TABLES </statement> - unlocks the table

And use them in camel dsl:
         <from uri="timer://pollTheDatabase?period=120000" />
        <to uri="ibatis:lock?statementType=Update"/>
	<to uri="ibatis:selectAll?statementType=QueryForList" />
	<to uri="ibatis:deleteAll?statementType=Delete" />
	<to uri="ibatis:unlock?statementType=Update" />
         ...
        <inOut
uri="jbi:service:http://org.apache.servicemix/VacationNotification" />

(I use statementType=Update, because statementType is required in DSL)

But first statement locks the table and doesn't unlock it till servicemix
shutdown.

I tried to do it other way - with <transacted/>, but the bad thing is that
then i have two transactionManagers with two dataSources and transaction
isn't working.
One in sqlMapConfig.xml:
<sqlMapConfig>
	<transactionManager type="JDBC">
		<dataSource type="DBCP">
			<property name="JDBC.Driver" value="com.mysql.jdbc.Driver"></property>
			<property name="JDBC.ConnectionURL"
value="jdbc:mysql://localhost:3306/simple"/>
			<property name="JDBC.Username" value="root"></property>
			<property name="JDBC.Password" value="ura"/>
		</dataSource>
	</transactionManager>
	<sqlMap resource="Query.xml"/>
</sqlMapConfig>

And the other in camel-context:

	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
		<property name="driverClassName" value="com.mysql.jdbc.Driver" />
		<property name="url" value="jdbc:mysql://localhost:3306/simple" />
		<property name="username" value="root" />
		<property name="password" value="ura" />
	</bean>

	<bean id="txManager"
		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource" />
	</bean>

I tried to do it in third way - write four sql statements:
<statement id="transaction"> begin <statement/> - locks the table
<select id="selectAll" resultMap="VacationResult">
SELECT * vacation FOR UPDATE;
</select>                                                        - selects
the data
<delete id="deleteAll" parameterClass="Vacation">  - deletes the data
<statement id="commit"> commit </statement> - unlocks the table

But it doesn't lock the table between select and delete.


By the way I tested locking by adding a delay in DSL between select and
delete statements and tried to insert into table. No lock was able to
prevent me from doing it :)

Any ideas how implement the locking? 

sorry for my english :) 
-- 
View this message in context: http://old.nabble.com/camel-ibatis-tp28831029p28831029.html
Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.