Header Ads

ad

Spring AspectJAOP Distributed Transaction Management Program using Annotations | Atomikos API

 Distributed Transaction Management Program using Annotations  | Atomikos API
Deposite.java:
  2. package com.nt.dao;
  3. public interface Deposite {
  4. public int deposite(int acno,int amount);
  5. }


DepositeImpl.java:
  1. package com.nt.dao;

  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.beans.factory.annotation.Qualifier;
  5. import org.springframework.jdbc.core.JdbcTemplate;
  6. import org.springframework.stereotype.Repository;

  8. @Repository("depositeDAO")
  9. public class DepositeImpl implements Deposite {
  10. private static final String DEPOSITE_QUERY="UPDATE DTX_ACCOUNT SET BALANCE=BALANCE+? WHERE ACNO=?";
  11. @Autowired
  12. @Qualifier(value="mysqlJt")
  13. private JdbcTemplate jt;
  14. @Override
  15. public int deposite(int acno, int amount) {
  16. int count=0;
  17. count=jt.update(DEPOSITE_QUERY, amount,acno);
  18. return count;
  19. }
  20. }
Withdraw.java:
  1. package com.nt.dao;
  2. public class Withdraw {
  3.     public int withdraw(int acno,int amount);
  4. }

WithdrawImpl.java:
  1. package com.nt.dao;

  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.beans.factory.annotation.Qualifier;
  5. import org.springframework.jdbc.core.JdbcTemplate;
  6. import org.springframework.stereotype.Repository;

  8. @Repository("withdrawDAO")
  9. public class WithdrawImpl implements Withdraw {
  10. private static final String WITHDRAW_QUERY="UPDATE  DTX_ACCOUNT SET BALANCE=BALANCE-? WHERE ACNO=?";
  11. @Autowired
  12. @Qualifier(value="oracleJt")
  13. private JdbcTemplate jt;
  14. @Override
  15. public int withdraw(int acno, int amount) {
  16. int count=0;
  17. count=jt.update(WITHDRAW_QUERY, amount,acno);
  18. return count;
  19. }
  20. }

BankService.java:
  1. package com.nt.service;
  2. public interface BankService {
  3.      public boolean transferMoney(int srcAcno, int destAcno, int amt)throws Exception;
  4. }

BankServiceImpl.java:
  1. package com.nt.service;

  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.stereotype.Service;
  5. import org.springframework.transaction.annotation.Propagation;
  6. import org.springframework.transaction.annotation.Transactional;
  7. import com.nt.dao.Deposite;
  8. import com.nt.dao.Withdraw;

  10. @Service("bankService")
  11. public class BankServiceImpl implements BankService {
  12. @Autowired
  13. private Withdraw withDAO;
  14. @Autowired
  15. private Deposite depoDAO;
  17. @Transactional(propagation=Propagation.REQUIRED,rollbackFor=Throwable.class)
  18. public boolean transferMoney(int srcAcno, int destAcno, int amt)throws Exception {
  19. int wFlag=0,dFlag=0;
  20. boolean status=false;
  21. wFlag=withDAO.withdraw(srcAcno, amt);
  22. dFlag=depoDAO.deposite(destAcno, amt);
  23. if(wFlag==0 || dFlag==0) {
  24. status=false;
  25. throw new Exception("Transaction Failed....");
  26. }
  27. else {
  28. status=true;
  29. }
  30. return status;
  31. }
  32. }

persistence-beans.xml:
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
  6. http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd">

  8. <!-- DataSource properties for Oracle -->
  9. <bean id="oracleXADS" class="com.atomikos.jdbc.AtomikosDataSourceBean">
  10. <property name="uniqueResourceName" value="oracleXA"/>
  11. <property name="xaDataSourceClassName" value="oracle.jdbc.xa.client.OracleXADataSource"/>
  12. <property name="xaProperties">
  13. <props>
  14. <prop key="databaseName">xe</prop>
  15. <prop key="user">system</prop>
  16. <prop key="password">manager</prop>
  17. <prop key="URL">jdbc:oracle:thin:@localhost:1521:xe</prop>
  18. </props>
  19. </property>
  20. <property name="poolSize" value="10"/>
  21. </bean>
  23. <!-- DataSource properties for MySQL -->
  24. <bean id="mysqlXADS" class="com.atomikos.jdbc.AtomikosDataSourceBean">
  25. <property name="uniqueResourceName" value="mysqlXA"/>
  26. <property name="xaDataSourceClassName" value="com.mysql.cj.jdbc.MysqlXADataSource"/>
  27. <property name="xaProperties">
  28. <props>
  29. <prop key="databaseName">skydatabase</prop>
  30. <prop key="user">root</prop>
  31. <prop key="password">root</prop>
  32. <prop key="URL">jdbc:mysql:///skydatabase</prop> 
  33. </props>
  34. </property>
  35. <property name="poolSize" value="10"/>
  36. </bean>
  38. <!-- JdbcTemplate cfg -->
  39. <bean id="oracleJt" class="org.springframework.jdbc.core.JdbcTemplate">
  40. <constructor-arg ref="oracleXADS"/>
  41. </bean>
  42. <bean id="mysqlJt" class="org.springframework.jdbc.core.JdbcTemplate">
  43. <constructor-arg ref="mysqlXADS"/>
  44. </bean>
  45. <!-- combine class with cfg -->
  46. <context:component-scan base-package="com.nt.dao"/>
  47. </beans>
service-beans.xml
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
  6. http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd">

  8. <context:component-scan base-package="com.nt.service"/>
  9. </beans>
aop-beans.xml:
  2. <?xml version="1.0" encoding="UTF-8"?>
  3. <beans xmlns="http://www.springframework.org/schema/beans"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5. xmlns:tx="http://www.springframework.org/schema/tx"
  6. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
  7. http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd">
  8. <!-- Cfg Tx Service -->
  9. <bean id="txService" class="com.atomikos.icatch.jta.UserTransactionImp"/>
  10. <!-- Cfg Tx Mgmr -->
  11. <bean id="txMgmr" class="com.atomikos.icatch.jta.UserTransactionManager"/>
  12. <!-- Cfg JtaTransactionManager -->
  13. <bean id="jtaTxMgmr" class="org.springframework.transaction.jta.JtaTransactionManager">
  14. <property name="userTransaction" ref="txService"/>
  15. <property name="transactionManager" ref="txMgmr"/>
  16. </bean>
  17. <!-- Activate TxMgmr -->
  18. <tx:annotation-driven transaction-manager="jtaTxMgmr"/>
  19. </beans>

applicationContext.xml:
  2. <?xml version="1.0" encoding="UTF-8"?>
  3. <beans xmlns="http://www.springframework.org/schema/beans"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

  7. <import resource="persistence-beans.xml"/>
  8. <import resource="service-beans.xml"/>
  9. <import resource="aop-beans.xml"/>
  10. </beans>

DTxTest.java:
  1. package com.nt.test;

  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.support.AbstractApplicationContext;
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;
  6. import com.nt.service.BankService;

  8. public class DTxTest {
  9. public static void main(String[] args) {
  10. ApplicationContext ctx=null;
  11. BankService service=null;
  12. ctx=new ClassPathXmlApplicationContext("com/nt/cfgs/applicationContext.xml");
  13. service=ctx.getBean("bankService",BankService.class);
  14. try {
  15.     System.out.println(service.transferMoney(101, 102, 2000));
  16. }
  17. catch(Exception e) {
  18. System.out.println("Transaction failed....Internal Problems.....");
  19. e.printStackTrace();
  20. }
  21. ((AbstractApplicationContext) ctx).close();
  22. }
  23. }

Post a Comment

No comments

Subscribe to: Post Comments ( Atom )