亚马逊广告

data-base/base-sync-amazon-ad/src/main/java/com/bailuntec/job/AmazonAdDownloadReportJob.java

@@ -42,7 +42,9 @@ public class AmazonAdDownloadReportJob implements SimpleJob {
     @Override
     public void execute(ShardingContext shardingContext) {
 
-        try (SqlSession sqlSession = SessionUtil.getFactory().openSession(true)) {
+        SqlSession sqlSession = SessionUtil.getFactory().openSession(true);
+
+        try {
 
             JobAmazonAdLogMapper jobAmazonAdLogMapper = sqlSession.getMapper(JobAmazonAdLogMapper.class);
             DcBaseCompanyAccountMapper dcBaseCompanyAccountMapper = sqlSession.getMapper(DcBaseCompanyAccountMapper.class);
@@ -125,6 +127,8 @@ public class AmazonAdDownloadReportJob implements SimpleJob {
                 }
             });
 
+        } finally {
+            sqlSession.close();
         }
     }
 

data-common/src/main/java/com/bailuntec/utils/SessionUtil.java

@@ -66,7 +66,7 @@ public class SessionUtil {
             threadLocalTransction.set(null);
         } catch (Exception e) {
             e.printStackTrace();
-            throw new RuntimeException("MYSQL关闭Session异常",e);
+            throw new RuntimeException("MYSQL关闭Session异常", e);
         }
     }
 
@@ -80,7 +80,7 @@ public class SessionUtil {
             threadLocal.set(null);
         } catch (Exception e) {
             e.printStackTrace();
-            throw new RuntimeException("MYSQL关闭Session异常",e);
+            throw new RuntimeException("MYSQL关闭Session异常", e);
         }
     }