Transaction Management in Spring with SERVICE and DAO layers?

[Rao Potla]

How to apply different PROPAGATION transaction attributes for methods in SERVICE and DAO layers using Classic Spring AOP(i.e using TransactionProxyFactoryBean)?

Below Example is using @Transactional annotation. I would like know How to apply the same using TransactionProxyFactoryBean(Spring 1.x) (or) Transaction Advices (Spring 2.x i.e <tx:advice> and <aop:config>)

//Service Interface

package com.apress.springrecipes.bookshop;

import java.util.List;

public interface Cashier {

    public void checkout(List<String> isbns, String username);
}

//Service Implementation

package com.apress.springrecipes.bookshop;

import java.util.List;

import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

public class BookShopCashier implements Cashier {

    private BookShop bookShop;

    public void setBookShop(BookShop bookShop) {
        this.bookShop = bookShop;
    }

    @Transactional(propagation = Propagation.REQUIRED)
    public void checkout(List<String> isbns, String username) {
        for (String isbn : isbns) {
            bookShop.purchase(isbn, username);
        }
    }
}

//DAO Interface

package com.apress.springrecipes.bookshop;

public interface BookShop {

    public void purchase(String isbn, String username);
    public void increaseStock(String isbn, int stock);
    public int checkStock(String isbn);
}

//DAO Implementation

package com.apress.springrecipes.bookshop;

import java.io.IOException;

import org.springframework.jdbc.core.support.JdbcDaoSupport;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

public class JdbcBookShop extends JdbcDaoSupport implements BookShop {

    @Transactional(
            propagation = Propagation.REQUIRES_NEW,
            rollbackFor = IOException.class,
            noRollbackFor = ArithmeticException.class)
    public void purchase(String isbn, String username) {
        int price = getJdbcTemplate().queryForInt(
                "SELECT PRICE FROM BOOK WHERE ISBN = ?", new Object[] { isbn });

        getJdbcTemplate().update(
                "UPDATE BOOK_STOCK SET STOCK = STOCK - 1 " +
                "WHERE ISBN = ?",
                new Object[] { isbn });

        getJdbcTemplate().update(
                "UPDATE ACCOUNT SET BALANCE = BALANCE - ? " +
                "WHERE USERNAME = ?",
                new Object[] { price, username });
    }

    @Transactional
    public void increaseStock(String isbn, int stock) {
        String threadName = Thread.currentThread().getName();
        System.out.println(threadName + " - Prepare to increase book stock");

        getJdbcTemplate().update(
                "UPDATE BOOK_STOCK SET STOCK = STOCK + ? " +
                "WHERE ISBN = ?",
                new Object[] { stock, isbn });

        System.out.println(threadName + " - Book stock increased by " + stock);
        sleep(threadName);

        System.out.println(threadName + " - Book stock rolled back");
        throw new RuntimeException("Increased by mistake");
    }

    @Transactional(
            isolation = Isolation.REPEATABLE_READ,
            timeout = 30,
            readOnly = true)
    public int checkStock(String isbn) {
        String threadName = Thread.currentThread().getName();
        System.out.println(threadName + " - Prepare to check book stock");

        int stock = getJdbcTemplate().queryForInt(
                "SELECT STOCK FROM BOOK_STOCK WHERE ISBN = ?",
                new Object[] { isbn });

        System.out.println(threadName + " - Book stock is " + stock);
        sleep(threadName);

        return stock;
    }

    private void sleep(String threadName) {
        System.out.println(threadName + " - Sleeping");
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {}
        System.out.println(threadName + " - Wake up");
    }
}

//beans.xml

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop-2.5.xsd">

    <tx:annotation-driven />

    <bean id="dataSource"
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName"
            value="org.apache.derby.jdbc.ClientDriver" />
        <property name="url"
            value="jdbc:derby://localhost:1527/bookshop;create=true" />
        <property name="username" value="app" />
        <property name="password" value="app" />
    </bean>

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

    <bean id="bookShop"
        class="com.apress.springrecipes.bookshop.JdbcBookShop">
        <property name="dataSource" ref="dataSource" />
    </bean>

    <bean id="cashier"
        class="com.apress.springrecipes.bookshop.BookShopCashier">
        <property name="bookShop" ref="bookShop" />
    </bean>
</beans>

// example beans.xml with TransactionProxyFactoryBean .
Here I could able to configure "transactionAttributes" for only Service(i.e Cashier) methods . How to apply "transactionAttributes" differently for DAO(i.e BookShop) methods like we did using @Transactional Annotation ? and the same with <tx:advice> ,<aop:config> ?

<bean id="bookShop"
        class="com.apress.springrecipes.bookshop.JdbcBookShop">
        <property name="dataSource" ref="dataSource" />
    </bean>

    <bean id="cashier"
        class="com.apress.springrecipes.bookshop.BookShopCashier">
        <property name="bookShop" ref="bookShop" />
    </bean>
<bean id="cashierProxy" class="org.springframework.transaction.å
interceptor.TransactionProxyFactoryBean">
<property name="target" ref="cashier" />
<property name="transactionManager" ref="transactionManager" />
<property name="transactionAttributes">
<props>
<prop key="checkout">PROPAGATION_REQUIRED</prop>
</props>
</property>
</bean>

// example beans.xml using Trasaction Advices(Spring 2.x way)

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-2.5.xsd">

<tx:advice id="cashierTxAdvice" transaction-manager="transactionManager">
  <tx:attributes>
          <tx:method name="checkOut" />
  </tx:attributes>
</tx:advice>
<aop:config>
  <aop:pointcut id="cashierOperation" expression="execution(* com.apress.springrecipes.bookshop.Cashier.*(..))" />
  <aop:advisor advice-ref="cashierTxAdvice" pointcut-ref="cashierOperation" />
</aop:config>
...
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
  <bean id="cashier"
        class="com.apress.springrecipes.bookshop.BookShopCashier">
        <property name="bookShop" ref="bookShop" />
    </bean>

<bean id="bookShop"
class="com.apress.springrecipes.bookshop.JdbcBookShop">
<property name="dataSource" ref="dataSource" />
</bean>
</beans>

[Mark Spritzler]

<tx:advice id="cashierTxAdvice" transaction-manager="transactionManager">  
  <tx:attributes>  
          <tx:method name="cashier" />  
  </tx:attributes>  
</tx:advice>  

look at the attributes of tx:method. It includes all the attributes of the @Transactional annotation.

Mark

[Rao Potla]

Mark Spritzler wrote:

<tx:advice id="cashierTxAdvice" transaction-manager="transactionManager">  
  <tx:attributes>  
          <tx:method name="cashier" />  
  </tx:attributes>  
</tx:advice>  

look at the attributes of tx:method. It includes all the attributes of the @Transactional annotation.

Mark

<tx:method name="cashier" />

sorry Mark, I have placed "cashier" instead of "chechout" in <tx:method>

<tx:method name="checkout" />

moreover in <tx:method> "checkout" is the name of the method in Cashier interface(i.e Service layer) & for that "checkout" method we are applying default transaction attributes. Now I would like to apply like <tx:method name="purchase" propagation="REQUIRES_NEW"/> <-- "purchase" is BookShop (DAO layer) interface method.

can I configure like the below? please help me in this.

<tx:advice id="cashierTxAdvice" transaction-manager="transactionManager">
   <tx:attibutes>
      <tx:method name="checkout" /><!-- Service METHOD -->
      <tx:method name="purshase" propagation="REQUIRES_NEW" /><!-- DAO METHOD -->
  </tx:attibutes>
</tx:advice>

<aop:config>  
  <aop:pointcut id="cashierOperation" expression="execution(* com.apress.springrecipes.bookshop.*.*(..))" />  
 <!--execution(* com.apress.springrecipes.bookshop.*.*(..)) instead of execution(*com.apress.springrecipes.bookshop.BookShop.*(..))  -->

  <aop:advisor advice-ref="cashierTxAdvice" pointcut-ref="cashierOperation" />  
</aop:config>  

even I tried the above one, but it is not working correctly.

Initial data in the tables

SQL> select * from BOOK;

ISBN BOOK_NAME PRICE
---------- ------------------------- ----------
0001 The First Book 30
0002 The Second Book 50

SQL> SELECT * FROM BOOK_STOCK;

ISBN STOCK
---------- ----------
0001 10
0002 10

SQL> SELECT * FROM ACCOUNT;

USERNAME BALANCE
-------------------------------------------------- ----------
user1 40

After the below operation execution

Cashier cashier = (Cashier) context.getBean("cashier");
     List<String> isbnList =Arrays.asList(new String[] { "0001", "0002" });
     cashier.checkout(isbnList, "user1");

The data in the tables should be like

SQL> select * from BOOK;

ISBN BOOK_NAME PRICE
---------- ------------------------- ----------
0001 The First Book 30
0002 The Second Book 50

SQL> SELECT * FROM BOOK_STOCK;

ISBN STOCK
---------- ----------
0001 9
0002 10

SQL> SELECT * FROM ACCOUNT;

USERNAME BALANCE
-------------------------------------------------- ----------
user1 10


because, there should be one successful Transaction of First time purchase("0001","user1") method execution. But when run the above code with that configuration (<tx:advice>) in beans.xml I am not getting the first purchase()'s transaction successfully to get the data in DataBase as show above.


Please help me in this?

Thanks
RaoPotla

[Mark Spritzler]

Just what I said, the tx:method tag has attributes for propagation.

If you haven't used tx:method before, then check it out in the SpringFramework.org Spring Framework Documentation under the transactions section.

here shows the settings
http://static.springsource.org/spring/docs/3.0.x/spring-framework-reference/html/transaction.html#transaction-declarative-txadvice-settings

and here is an example
http://static.springsource.org/spring/docs/3.0.x/spring-framework-reference/html/transaction.html#transaction-declarative-first-example

and here is another example
http://static.springsource.org/spring/docs/3.0.x/spring-framework-reference/html/transaction.html#transaction-declarative-diff-tx

Mark

[Rao Potla]

Thank you very much Mark, the following URL is very helpful for me & this is what I am looking for.

http://static.springsource.org/spring/docs/3.0.x/spring-framework-reference/html/transaction.html#transaction-declarative-diff-tx