|
@@ -198,7 +198,7 @@ public class FlatTagHandler {
|
|
private void _checkAndDealColumn(String month) {
|
|
private void _checkAndDealColumn(String month) {
|
|
List<JSONObject> checkTableDiffList = _getDiffColumnList(month);
|
|
List<JSONObject> checkTableDiffList = _getDiffColumnList(month);
|
|
List<String> addColumns = new ArrayList<>();
|
|
List<String> addColumns = new ArrayList<>();
|
|
-// List<String> delColumns = new ArrayList<>();
|
|
|
|
|
|
+ List<String> delColumns = new ArrayList<>();
|
|
for(JSONObject dataObj : checkTableDiffList) {
|
|
for(JSONObject dataObj : checkTableDiffList) {
|
|
String tempName = dataObj.getString("temp_name"),
|
|
String tempName = dataObj.getString("temp_name"),
|
|
cluName = dataObj.getString("clu_name"),
|
|
cluName = dataObj.getString("clu_name"),
|
|
@@ -206,9 +206,9 @@ public class FlatTagHandler {
|
|
if(StringUtils.isEmpty(cluName)) { //需要添加的列
|
|
if(StringUtils.isEmpty(cluName)) { //需要添加的列
|
|
addColumns.add("add column `" + tempName + "` " + type);
|
|
addColumns.add("add column `" + tempName + "` " + type);
|
|
}
|
|
}
|
|
-// if(StringUtils.isEmpty(tempName)) {//需要删除的列
|
|
|
|
-// delColumns.add("drop column `"+cluName+"`");
|
|
|
|
-// }
|
|
|
|
|
|
+ if(StringUtils.isEmpty(tempName)) {//需要删除的列
|
|
|
|
+ delColumns.add("drop column `"+cluName+"`");
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
try {
|
|
try {
|
|
@@ -223,7 +223,7 @@ public class FlatTagHandler {
|
|
|
|
|
|
//2.处理增删列
|
|
//2.处理增删列
|
|
_dealColumn(addColumns);
|
|
_dealColumn(addColumns);
|
|
-// _dealColumn(delColumns);
|
|
|
|
|
|
+ _dealColumn(delColumns);
|
|
|
|
|
|
//3.创建视图
|
|
//3.创建视图
|
|
String createViewSql = String.format("CREATE TABLE %s ON cluster %s AS ads.%s ENGINE = Distributed(%s, ads, %s, rand())",
|
|
String createViewSql = String.format("CREATE TABLE %s ON cluster %s AS ads.%s ENGINE = Distributed(%s, ads, %s, rand())",
|