'commit'

src/main/java/com/dsideal/QingLong/DataShare/Controller/DataShareController.java

@@ -135,6 +135,12 @@ public class DataShareController extends Controller {
     @IsNumericInterface({"system_id"})
     @EmptyInterface({"table_names"})
     public void share(int system_id, String table_names) {
+        if (!dm.isExistTable(table_names)) {
+            Kv kv = Kv.by("success", false);
+            kv.set("message", "检查到数据表在数据库中不存在的情况，请检查后重新录入！");
+            renderJson(kv);
+            return;
+        }
         dm.share(system_id, table_names);
         Kv kv = Kv.by("success", true);
         kv.set("message", "保存成功！");

src/main/java/com/dsideal/QingLong/DataShare/Model/DataShareModel.java

@@ -112,6 +112,18 @@ public class DataShareModel {
         String sql = "select * from t_datashare_table where system_id=?";
         return Db.find(sql, system_id);
     }
+
+    /**
+     * 功能：判断指定的一组表是不是有不存在的
+     * @param table_names
+     * @return
+     */
+    public boolean isExistTable(String table_names) {
+        for (String s : table_names.split(",")) {
+            if (!PgUtil.isExistTable(s)) return false;
+        }
+        return true;
+    }
 }
 
 

src/main/java/com/dsideal/QingLong/Util/PgUtil.java

@@ -88,6 +88,17 @@ public class PgUtil {
         Db.update(sql);
     }
 
+    /**
+     * 功能：判断一个表是不是存在
+     * @param table_name
+     * @return
+     */
+    public static boolean isExistTable(String table_name) {
+        String sql = "SELECT * FROM pg_tables WHERE tablename = ?";
+        List<Record> list = Db.find(sql, table_name);
+        return !list.isEmpty();
+    }
+
     //写权限
     public static String WRITE = "INSERT,UPDATE,DELETE,SELECT";
     //读权限
@@ -133,6 +144,5 @@ public class PgUtil {
         for (Record record : list) {
             System.out.println(record);
         }
-
     }
 }