|
@ -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项目的客户特征库计算结果表 |
|
|
* 创建上农内评POC项目的客户特征库计算结果表 |
|
|
* @param custFeatureParams |
|
|
* @param custFeatureParams |
|
@ -175,7 +184,7 @@ public class CustFeatureCalcBatchServiceImpl implements CustFeatureCalcBatchServ |
|
|
//创建表
|
|
|
//创建表
|
|
|
jdbcTemplate.execute(createSql.toString()); |
|
|
jdbcTemplate.execute(createSql.toString()); |
|
|
//添加注释
|
|
|
//添加注释
|
|
|
jdbcTemplate.execute(commentSql.toString()); |
|
|
executeCommentSql(commentSql.toString()); |
|
|
} |
|
|
} |
|
|
//判断表字段是否有变化
|
|
|
//判断表字段是否有变化
|
|
|
try{ |
|
|
try{ |
|
@ -187,7 +196,7 @@ public class CustFeatureCalcBatchServiceImpl implements CustFeatureCalcBatchServ |
|
|
jdbcTemplate.execute("drop table P_IRS_SHRCB_CORP_FEATURE_RET"); |
|
|
jdbcTemplate.execute("drop table P_IRS_SHRCB_CORP_FEATURE_RET"); |
|
|
jdbcTemplate.execute(createSql.toString()); |
|
|
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() + "'"; |
|
|
String querySql = "select count(1) as CNT from P_IRS_SHRCB_CORP_FEATURE_RET where data_dt = '" + custFeatureParams.getDataDt() + "'"; |
|
|