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() + "'";