From c70b92da60c0d00625da5fc2369b475e69e0b88e Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期四, 22 八月 2024 11:36:41 +0800
Subject: [PATCH] 1、完善代码和application.yml配置文件,去掉不用的引入文件; 2、init-config.xml配置中增加属性 enable,相应解析类也增加了解析与判断; 3、凡是有Server的应用,加载资源方式改为用springboot的工具类加载; 4、通信协议相关的扫描注解功能实现改为采用reflections-0.10.2,以实现可以在jar包情况下能够扫描类(.class)注解。

---
 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/multiDataSource/MultiDataSourceTransaction.java |   11 +++++++++--
 1 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/multiDataSource/MultiDataSourceTransaction.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/multiDataSource/MultiDataSourceTransaction.java
index fd87312..411999a 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/multiDataSource/MultiDataSourceTransaction.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/multiDataSource/MultiDataSourceTransaction.java
@@ -10,6 +10,12 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 
+/**
+ * 澶氭暟鎹簮鐨勪簨鍔$被锛屼簨鍔″璞$敱浜嬪姟宸ュ巶鍒涘缓锛屽畬鎴愭暟鎹簱浜嬪姟鎿嶄綔銆�
+ * 浜嬪姟瀵硅薄鍖呰9鐫�锛�
+ *   鏁版嵁搴撹繛鎺ャ�佷簨鍔℃彁浜ゃ�佷簨鍔″洖婊氱瓑瀵硅薄鍙婃搷浣�
+ * 鍦ㄤ簨鍔″璞′腑鍏蜂綋鍐冲畾閲囩敤鐨勫叿浣撴暟鎹簮
+ */
 public class MultiDataSourceTransaction implements Transaction {
 
     private final DataSource multidataSource;
@@ -19,9 +25,10 @@
     private boolean autoCommit;
 
 
-    public MultiDataSourceTransaction(DataSource dataSource) {
+    public MultiDataSourceTransaction(DataSource dataSource, boolean autoCommit) {
         //dataSource鏄疍ynamicDataSource绫荤殑瀹炰緥
         this.multidataSource = dataSource;
+        this.autoCommit = autoCommit;
         curConMap = new ConcurrentHashMap<>();
     }
 
@@ -38,7 +45,7 @@
         if (!this.curConMap.containsKey(nowDsName)) {
             try {
                 Connection conn = this.multidataSource.getConnection();
-                autoCommit=false;
+                this.autoCommit = false;
                 conn.setAutoCommit(false);
                 this.curConMap.put(nowDsName, conn);
             } catch (SQLException ex) {

--
Gitblit v1.8.0