From caae1e3562f083c175a877a56dae275b4a65aa3e Mon Sep 17 00:00:00 2001
From: ruan4261 <i@4261.ink>
Date: Fri, 16 Jul 2021 17:28:37 +0800
Subject: [PATCH] =?UTF-8?q?:sparkles:=20feature(1.1.14):=20=E6=96=B0?=
 =?UTF-8?q?=E5=A2=9E=20StrictRecordSet,=20=E5=8F=91=E7=94=9F=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF=E6=97=B6=E4=B8=8D=E8=BF=9B=E8=A1=8C=E6=8A=91=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../devkit/DatabaseRuntimeException.java      | 21 ++++++++
 .../micro/devkit/handler/StrictRecordSet.java | 51 +++++++++++++++++++
 2 files changed, 72 insertions(+)
 create mode 100644 src/main/java/weaver/micro/devkit/DatabaseRuntimeException.java
 create mode 100644 src/main/java/weaver/micro/devkit/handler/StrictRecordSet.java

diff --git a/src/main/java/weaver/micro/devkit/DatabaseRuntimeException.java b/src/main/java/weaver/micro/devkit/DatabaseRuntimeException.java
new file mode 100644
index 0000000..e7076ec
--- /dev/null
+++ b/src/main/java/weaver/micro/devkit/DatabaseRuntimeException.java
@@ -0,0 +1,21 @@
+package weaver.micro.devkit;
+
+public class DatabaseRuntimeException extends RuntimeException {
+
+    public DatabaseRuntimeException() {
+        super();
+    }
+
+    public DatabaseRuntimeException(String message) {
+        super(message);
+    }
+
+    public DatabaseRuntimeException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public DatabaseRuntimeException(Throwable cause) {
+        super(cause);
+    }
+
+}
diff --git a/src/main/java/weaver/micro/devkit/handler/StrictRecordSet.java b/src/main/java/weaver/micro/devkit/handler/StrictRecordSet.java
new file mode 100644
index 0000000..74ab071
--- /dev/null
+++ b/src/main/java/weaver/micro/devkit/handler/StrictRecordSet.java
@@ -0,0 +1,51 @@
+package weaver.micro.devkit.handler;
+
+import com.api.integration.util.ProcBean;
+import weaver.conn.RecordSet;
+import weaver.micro.devkit.DatabaseRuntimeException;
+
+import java.util.List;
+
+public class StrictRecordSet extends RecordSet {
+
+    @Override
+    public boolean executeProc(String s, String s1, String s2) {
+        return $(super.executeProc(s, s1, s2));
+    }
+
+    @Override
+    public boolean executeProc2(String s, String s1, String s2) {
+        return $(super.executeProc2(s, s1, s2));
+    }
+
+//    public boolean executeProcNew(String s, String s1, List<ProcBean> list) {
+//        return $(super.executeProcNew(s, s1, list));
+//    }
+
+    @Override
+    public boolean executeSql(String s, boolean b, String s1, boolean b1, Object... objects) {
+        return $(super.executeSql(s, b, s1, b1, objects));
+    }
+
+//    public boolean executeBatchSql(String s, List<?> list, String s1) {
+//        return $(super.executeBatchSql(s, list, s1));
+//    }
+
+    @Override
+    public boolean executeSql(String s, String s1) {
+        return $(super.executeSql(s, s1));
+    }
+
+    @Override
+    public boolean executeSqlWithDataSource(String s, String s1) {
+        return $(super.executeSqlWithDataSource(s, s1));
+    }
+
+    boolean $(boolean result) {
+        if (!result)
+            throw new DatabaseRuntimeException(this.getExceptionMsg());
+
+        return true;
+    }
+
+}