charles 1 year ago
parent
commit
82f5ff8cc0

+ 5 - 5
hz-business/src/main/java/com/hz/business/service/impl/BatteryServiceImpl.java

@@ -2346,7 +2346,7 @@ public class BatteryServiceImpl extends ServiceImpl<BatteryMapper, Battery> impl
 
         // CellMaxVol,CellMinVol,CellMaxTemp,CellMinTemp,BmsCellVoltDiff,VehSpd
         builder.append("select SN,Time,PackVoltage,PackCrnt,PackSoc,CellVoltage,CellTemp,InsulationRss,Info from ")
-                .append(database + "." + tableName).append(" where ");
+                .append(tableName).append(" where ");
 
 
         if (param.getStartTime() == null && param.getEndTime() == null) {
@@ -2378,10 +2378,10 @@ public class BatteryServiceImpl extends ServiceImpl<BatteryMapper, Battery> impl
         PreparedStatement psSelect = null;
         try {
             conn = PhoenixUtils.getConnection();
-            //psSelect = conn.prepareStatement(" use " + database + " ");
-            //psSelect.setFetchSize(1000);
-            //psSelect.execute();
-            //psSelect.close();
+            psSelect = conn.prepareStatement(" use " + database + " ");
+            psSelect.setFetchSize(1000);
+            psSelect.execute();
+            psSelect.close();
             psSelect = conn.prepareStatement(builder.toString());
             ResultSet resultSet = psSelect.executeQuery();
             flinkDataList = convertList(resultSet);