Header Ads

ad

AspectJAOP Distributed Transaction Management Program using Spring Boot | Atomikos API

Deposite.java:
  1. package com.nt.dao;
  2. public interface Deposite {
  3. public int deposite(int acno,int amount);
  4. }


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. }

AOPConfig.java:
  1. package com.nt.config;

  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.transaction.annotation.EnableTransactionManagement;
  6. import org.springframework.transaction.jta.JtaTransactionManager;
  7. import com.atomikos.icatch.jta.UserTransactionImp;
  8. import com.atomikos.icatch.jta.UserTransactionManager;

  10. @Configuration
  11. public class AOPConfig {
  12. @Bean(name="txService")
  13. public UserTransactionImp createTxService() {
  14. return new UserTransactionImp();
  15. }
  16. @Bean(name="txMgmr")
  17. public UserTransactionManager createTxMgmr() {
  18. return new UserTransactionManager();
  19. }
  20. @Bean(name="jtaTxMgmr")
  21. public JtaTransactionManager createJtaTxMgmr() {
  22. JtaTransactionManager jta=new JtaTransactionManager();
  23. jta.setUserTransaction(createTxService());
  24. jta.setTransactionManager(createTxMgmr());
  25. return jta;
  26. }
  27. }

ServiceConfig.java:
  1. package com.nt.config;

  3. import org.springframework.context.annotation.ComponentScan;
  4. import org.springframework.context.annotation.Configuration;

  6. @Configuration
  7. @ComponentScan(basePackages="com.nt.service")
  8. public class ServiceConfig {
  10. }


PersistenceConfig.java:
  1. package com.nt.config;

  3. import java.util.Properties;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.ComponentScan;
  6. import org.springframework.context.annotation.Configuration;
  7. import org.springframework.jdbc.core.JdbcTemplate;
  8. import com.atomikos.jdbc.AtomikosDataSourceBean;

  10. @Configuration
  11. @ComponentScan(basePackages="com.nt.dao")
  12. public class PersistenceConfig {
  13. @Bean(name="oracleXADS")
  14. public AtomikosDataSourceBean createAtomikosOracleDs() {
  15. AtomikosDataSourceBean ads=null;
  16. Properties props=null;
  17. ads=new AtomikosDataSourceBean();
  18. ads.setUniqueResourceName("oracleXA");
  19. ads.setXaDataSourceClassName("oracle.jdbc.xa.client.OracleXADataSource");
  20. props=new Properties();
  21. props.setProperty("databaseName", "xe");
  22. props.setProperty("user", "system");
  23. props.setProperty("password", "manager");
  24. props.setProperty("URL", "jdbc:oracle:thin:@localhost:1521:xe");
  25. ads.setXaProperties(props);
  26. ads.setMaxPoolSize(10);
  27. return ads;
  28. }
  29. @Bean(name="mysqlXADS")
  30. public AtomikosDataSourceBean createAtomikosMysqlDs() {
  31. AtomikosDataSourceBean ads=null;
  32. Properties props=null;
  33. ads=new AtomikosDataSourceBean();
  34. ads.setUniqueResourceName("mysqlXA");
  35. ads.setXaDataSourceClassName("com.mysql.cj.jdbc.MysqlXADataSource");
  36. props=new Properties();
  37. props.setProperty("databaseName", "skydatabase");
  38. props.setProperty("user", "root");
  39. props.setProperty("password", "root");
  40. props.setProperty("URL", "jdbc:mysql://localhost:3306/skydatabase");
  41. ads.setXaProperties(props);
  42. ads.setMaxPoolSize(10);
  43. return ads;
  44. }
  45. @Bean(name="oracleJt")
  46. public JdbcTemplate createJtForOracle() {
  47. return new JdbcTemplate(createAtomikosOracleDs());
  48. }
  49. @Bean(name="mysqlJt")
  50. public JdbcTemplate createJtForMysql() {
  51. return new JdbcTemplate(createAtomikosMysqlDs());
  52. }
  53. }

AppConfig.java:
  1. package com.nt.config;

  3. import org.springframework.context.annotation.ComponentScan;
  4. import org.springframework.context.annotation.Configuration;

  6. @Configuration
  7. @ComponentScan(basePackageClasses={PersistenceConfig.class,ServiceConfig.class,AOPConfig.class})
  8. public class AppConfig {
  9. }

DtxTest.java:
  2. package com.nt.test;

  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
  7. import org.springframework.context.ApplicationContext;
  8. import org.springframework.context.annotation.Import;
  9. import org.springframework.context.support.AbstractApplicationContext;
  10. import com.nt.config.AppConfig;
  11. import com.nt.service.BankService;

  13. @SpringBootApplication(exclude=DataSourceAutoConfiguration.class)
  14. @Import(AppConfig.class)
  15. public class DtxTest {
  16. public static void main(String[] args) {
  17. ApplicationContext ctx=null;
  18. BankService service=null;
  19. ctx=SpringApplication.run(DtxTest.class, args);
  20. service=ctx.getBean("bankService",BankService.class);
  21. try {
  22. System.out.println(service.transferMoney(101, 102, 2000));
  23. }
  24. catch(Exception e) {
  25. System.out.println("Transaction failed,,Internal Problems.....");
  26. e.printStackTrace();
  27. }
  28. ((AbstractApplicationContext) ctx).close();
  29. }
  30. }



Post a Comment

No comments

Subscribe to: Post Comments ( Atom )