Header Ads

ad

AspectJAOP Distributed Transaction Management Program using 100pCode | Atomikos API

100p Code AspectJAOP Distributed Transaction using 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. @EnableTransactionManagement
  12. public class AOPConfig {
  13. @Bean(name="txService")
  14. public UserTransactionImp createTxService() {
  15. return new UserTransactionImp();
  16. }
  17. @Bean(name="txMgmr")
  18. public UserTransactionManager createTxMgmr() {
  19. return new UserTransactionManager();
  20. }
  21. @Bean(name="jtaTxMgmr")
  22. public JtaTransactionManager createJtaTxMgmr() {
  23. JtaTransactionManager jta=new JtaTransactionManager();
  24. jta.setUserTransaction(createTxService());
  25. jta.setTransactionManager(createTxMgmr());
  26. return jta;
  27. }
  28. }

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:
  1. package com.nt.test;
  2. import org.springframework.context.ApplicationContext;
  3. import org.springframework.context.annotation.AnnotationConfigApplicationContext;
  4. import org.springframework.context.support.AbstractApplicationContext;
  5. import com.nt.config.AppConfig;
  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 AnnotationConfigApplicationContext(AppConfig.class);
  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. }

build.gradle:
  2. dependencies {
  3.      // https://mvnrepository.com/artifact/org.springframework/spring-context-support
  4. compile group: 'org.springframework', name: 'spring-context-support', version: '5.1.5.RELEASE'
  5.    // https://mvnrepository.com/artifact/org.springframework/spring-jdbc
  6. compile group: 'org.springframework', name: 'spring-jdbc', version: '5.1.5.RELEASE'
  7. // https://mvnrepository.com/artifact/org.aspectj/aspectjrt
  8. compile group: 'org.aspectj', name: 'aspectjrt', version: '1.9.2'
  9. // https://mvnrepository.com/artifact/org.aspectj/aspectjweaver
  10. compile group: 'org.aspectj', name: 'aspectjweaver', version: '1.9.2'
  11. // https://mvnrepository.com/artifact/com.atomikos/atomikos-util
  12. compile group: 'com.atomikos', name: 'atomikos-util', version: '4.0.6'
  13. // https://mvnrepository.com/artifact/com.atomikos/transactions-jta
  14. compile group: 'com.atomikos', name: 'transactions-jta', version: '4.0.6'
  15. // https://mvnrepository.com/artifact/com.atomikos/transactions-api
  16. compile group: 'com.atomikos', name: 'transactions-api', version: '4.0.6'
  17. // https://mvnrepository.com/artifact/com.atomikos/transactions
  18. compile group: 'com.atomikos', name: 'transactions', version: '4.0.6'
  19. // https://mvnrepository.com/artifact/com.atomikos/transactions-jdbc
  20. compile group: 'com.atomikos', name: 'transactions-jdbc', version: '4.0.6'
  21. // https://mvnrepository.com/artifact/javax.transaction/jta
  22. compile group: 'javax.transaction', name: 'jta', version: '1.1'
  23. // https://mvnrepository.com/artifact/mysql/mysql-connector-java
  24. compile group: 'mysql', name: 'mysql-connector-java', version: '8.0.15'
  25.  compile files('D:\\ojdbc6.jar')
  26. }






Post a Comment

No comments

Subscribe to: Post Comments ( Atom )