Commit 067fbd6b by WangJinfeng

fix RTDmpFetch

parent 746d6acf
package mobvista.dmp.util;
import mobvista.dmp.datasource.rtdmp.entity.KV;
import org.apache.commons.lang3.StringUtils;
import java.sql.*;
import java.text.SimpleDateFormat;
......@@ -81,15 +82,14 @@ public class MySQLUtil {
sql = "SELECT part,utime FROM dmp.table_info WHERE db_name = '" + dbName + "' AND tb_name = '" + tbName + "' AND flag = 1 ORDER BY part DESC LIMIT 1";
System.out.println("getPartitionTime,SQL --->>> " + sql);
ResultSet rs = stmt.executeQuery(sql);
if (!rs.next()) {
System.out.println("getPartitionTime Null,SQL --->>> " + sql);
}
while (rs.next()) {
partition = rs.getString("part");
utime = rs.getTimestamp("utime");
System.out.println("partition:" + partition + ",utime:" + utime);
}
if (StringUtils.isNotBlank(partition)) {
System.out.println("getPartitionTime Null,SQL --->>> " + sql);
}
System.out.println("getPartitionTime,SQL --->>> " + sql);
rs.close();
stmt.close();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment