Skip to content

D
dlink
Unverified Commit 63c37db0 authored by aiwenmo's avatar aiwenmo Committed by GitHub
Browse files
Options

[Optimization-367][core] Optimization explainSql return all error 

[Optimization-367][core] Optimization explainSql return all error
parents 99a3a129 56e1bf4c
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 8 deletions
dlink-core/src/main/java/com/dlink/explainer/Explainer.java
View file @ 63c37db0
...@@ -17,6 +17,7 @@ import com.dlink.result.ExplainResult; ...@@ -17,6 +17,7 @@ import com.dlink.result.ExplainResult;
import com.dlink.result.SqlExplainResult; import com.dlink.result.SqlExplainResult;
import com.dlink.trans.Operations; import com.dlink.trans.Operations;
import com.dlink.utils.FlinkUtil; import com.dlink.utils.FlinkUtil;
import com.dlink.utils.LogUtil;
import com.dlink.utils.SqlUtil; import com.dlink.utils.SqlUtil;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode; import com.fasterxml.jackson.databind.node.ObjectNode;
...@@ -154,8 +155,7 @@ public class Explainer { ...@@ -154,8 +155,7 @@ public class Explainer {
} }
executor.executeSql(item.getValue()); executor.executeSql(item.getValue());
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); record.setError(LogUtil.getError(e));
record.setError(e.getMessage());
record.setExplainTrue(false); record.setExplainTrue(false);
record.setExplainTime(LocalDateTime.now()); record.setExplainTime(LocalDateTime.now());
record.setSql(item.getValue()); record.setSql(item.getValue());
...@@ -186,8 +186,7 @@ public class Explainer { ...@@ -186,8 +186,7 @@ public class Explainer {
record.setParseTrue(true); record.setParseTrue(true);
record.setExplainTrue(true); record.setExplainTrue(true);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); record.setError(LogUtil.getError(e));
record.setError(e.getMessage());
record.setParseTrue(false); record.setParseTrue(false);
record.setExplainTrue(false); record.setExplainTrue(false);
correct = false; correct = false;
...@@ -207,8 +206,7 @@ public class Explainer { ...@@ -207,8 +206,7 @@ public class Explainer {
record.setParseTrue(true); record.setParseTrue(true);
record.setExplainTrue(true); record.setExplainTrue(true);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); record.setError(LogUtil.getError(e));
record.setError(e.getMessage());
record.setParseTrue(false); record.setParseTrue(false);
record.setExplainTrue(false); record.setExplainTrue(false);
correct = false; correct = false;
...@@ -235,8 +233,7 @@ public class Explainer { ...@@ -235,8 +233,7 @@ public class Explainer {
record.setType("DATASTREAM"); record.setType("DATASTREAM");
record.setParseTrue(true); record.setParseTrue(true);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); record.setError(LogUtil.getError(e));
record.setError(e.getMessage());
record.setExplainTrue(false); record.setExplainTrue(false);
record.setExplainTime(LocalDateTime.now()); record.setExplainTime(LocalDateTime.now());
record.setSql(item.getValue()); record.setSql(item.getValue());
......
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