From 44967ccf72125724af57d4d5f4e1c89da0629ceb Mon Sep 17 00:00:00 2001
From: chengjie <chengjie>
Date: Tue, 23 Jul 2024 00:21:11 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/CustFeatureCalcBatchServiceImpl.java       | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/irbs.feature/src/main/java/irbs/feature/service/impl/CustFeatureCalcBatchServiceImpl.java b/irbs.feature/src/main/java/irbs/feature/service/impl/CustFeatureCalcBatchServiceImpl.java
index 9d7312d..4f10e14 100644
--- a/irbs.feature/src/main/java/irbs/feature/service/impl/CustFeatureCalcBatchServiceImpl.java
+++ b/irbs.feature/src/main/java/irbs/feature/service/impl/CustFeatureCalcBatchServiceImpl.java
@@ -121,6 +121,15 @@ public class CustFeatureCalcBatchServiceImpl implements CustFeatureCalcBatchServ
         }
     }
 
+    private void executeCommentSql(String commentSql){
+        if(commentSql != null && !commentSql.equals("")){
+            String[] sql = commentSql.split(";");
+            for(String s : sql){
+                jdbcTemplate.execute(s);
+            }
+        }
+    }
+
     /**
      * 创建上农内评POC项目的客户特征库计算结果表
      * @param custFeatureParams
@@ -175,7 +184,7 @@ public class CustFeatureCalcBatchServiceImpl implements CustFeatureCalcBatchServ
             //创建表
             jdbcTemplate.execute(createSql.toString());
             //添加注释
-            jdbcTemplate.execute(commentSql.toString());
+            executeCommentSql(commentSql.toString());
         }
         //判断表字段是否有变化
         try{
@@ -187,7 +196,7 @@ public class CustFeatureCalcBatchServiceImpl implements CustFeatureCalcBatchServ
             jdbcTemplate.execute("drop table P_IRS_SHRCB_CORP_FEATURE_RET");
             jdbcTemplate.execute(createSql.toString());
             //添加注释
-            jdbcTemplate.execute(commentSql.toString());
+            executeCommentSql(commentSql.toString());
         }
         //判断相同数据日期是否已存在数据
         String querySql = "select count(1) as CNT from P_IRS_SHRCB_CORP_FEATURE_RET where data_dt = '" + custFeatureParams.getDataDt() + "'";