diff --git a/storage/src/main/java/com/njcn/gather/storage/service/impl/TableGenServiceImpl.java b/storage/src/main/java/com/njcn/gather/storage/service/impl/TableGenServiceImpl.java index 140c1185..21bd7d29 100644 --- a/storage/src/main/java/com/njcn/gather/storage/service/impl/TableGenServiceImpl.java +++ b/storage/src/main/java/com/njcn/gather/storage/service/impl/TableGenServiceImpl.java @@ -17,7 +17,11 @@ public class TableGenServiceImpl implements TableGenService { @Override public void genTable(String code, boolean isContrast) { tableGenMapper.genNonHarmonicTable(code, isContrast); + // 添加索引 + tableGenMapper.genAdHarmonicTable("CREATE INDEX idx_ad_non_harmonic_" + code + "_dev_monitor_id" + " ON ad_non_harmonic_" + code + " (Dev_Monitor_Id);"); tableGenMapper.genNonHarmonicResultTable(code, isContrast); + // 添加索引 + tableGenMapper.genAdHarmonicTable("CREATE INDEX idx_ad_non_harmonic_result_" + code + "_dev_monitor_id" + " ON ad_non_harmonic_result_" + code + " (Dev_Monitor_Id);"); StringBuilder A = new StringBuilder(); StringBuilder B = new StringBuilder(); @@ -57,6 +61,8 @@ public class TableGenServiceImpl implements TableGenService { " PRIMARY KEY (Dev_Monitor_Id, Time_Id, Script_Id, Sort, AD_Type)\n" ) + ") COMMENT='谐波类原始数据表';"; tableGenMapper.genAdHarmonicTable(sql); + // 添加索引 + tableGenMapper.genAdHarmonicTable("CREATE INDEX idx_ad_harmonic_" + code + "_dev_monitor_id" + " ON ad_harmonic_" + code + " (Dev_Monitor_Id);"); String a = A.toString().replaceAll("float", "json"); String b = B.toString().replaceAll("float", "json"); @@ -84,6 +90,8 @@ public class TableGenServiceImpl implements TableGenService { " PRIMARY KEY (Dev_Monitor_Id,Script_Id, Sort, AD_Type)\n" ) + ") COMMENT='谐波类检测结果表';"; tableGenMapper.genAdHarmonicTable(sql2); + // 添加索引 + tableGenMapper.genAdHarmonicTable("CREATE INDEX idx_ad_harmonic_result_" + code + "_dev_monitor_id" + " ON ad_harmonic_result_" + code + " (Dev_Monitor_Id);"); } @Override