@@ -23,41 +23,41 @@ private TransactionManagerContext() {
2323
2424 public void setPlatformTransactionManager (PlatformTransactionManager platformTransactionManager ) {
2525 this .platformTransactionManager = platformTransactionManager ;
26- log .info ("platformTransactionManager:{} load success" , platformTransactionManager );
26+ if (platformTransactionManager != null ) {
27+ log .info ("platformTransactionManager:{} load success" , platformTransactionManager );
28+ }
2729 }
2830
2931
3032 public <T > T commit (Supplier <T > supplier ) {
31- PlatformTransactionManager transactionManager = TransactionManagerContext .getInstance ().getPlatformTransactionManager ();
32- if (transactionManager != null ) {
33+ if (platformTransactionManager != null ) {
3334 DefaultTransactionDefinition def = new DefaultTransactionDefinition ();
3435 def .setPropagationBehavior (TransactionDefinition .PROPAGATION_REQUIRES_NEW );
35- TransactionStatus transactionStatus = transactionManager .getTransaction (def );
36+ TransactionStatus transactionStatus = platformTransactionManager .getTransaction (def );
3637 try {
3738 T result = supplier .get ();
38- transactionManager .commit (transactionStatus );
39+ platformTransactionManager .commit (transactionStatus );
3940 return result ;
4041 } catch (Exception e ) {
41- transactionManager .rollback (transactionStatus );
42+ platformTransactionManager .rollback (transactionStatus );
4243 throw e ;
4344 }
4445 }
4546 return supplier .get ();
4647 }
4748
48- public <T > T readOnly (Supplier <T > supplier ){
49- PlatformTransactionManager transactionManager = TransactionManagerContext .getInstance ().getPlatformTransactionManager ();
50- if (transactionManager != null ) {
49+ public <T > T readOnly (Supplier <T > supplier ) {
50+ if (platformTransactionManager != null ) {
5151 DefaultTransactionDefinition def = new DefaultTransactionDefinition ();
5252 def .setPropagationBehavior (TransactionDefinition .PROPAGATION_REQUIRES_NEW );
5353 def .setReadOnly (true );
54- TransactionStatus transactionStatus = transactionManager .getTransaction (def );
54+ TransactionStatus transactionStatus = platformTransactionManager .getTransaction (def );
5555 try {
5656 T result = supplier .get ();
57- transactionManager .rollback (transactionStatus );
57+ platformTransactionManager .rollback (transactionStatus );
5858 return result ;
5959 } catch (Exception e ) {
60- transactionManager .rollback (transactionStatus );
60+ platformTransactionManager .rollback (transactionStatus );
6161 throw e ;
6262 }
6363 }
0 commit comments