'commit'

src/main/java/UnitTest/TestPgRole.java

@@ -11,69 +11,7 @@ import java.util.List;
 
 public class TestPgRole {
 
-    /**
-     * 功能：删除用户
-     *
-     * @param user_name
-     */
-    public static void delUser(String user_name) {
-        String sql = "DROP USER " + user_name;
-        Db.update(sql);
-    }
-
-    /**
-     * 功能：创建用户
-     *
-     * @param user_name
-     * @param pwd
-     */
-    public static void createUser(String user_name, String pwd) {
-        String sql = "CREATE USER " + user_name + " WITH PASSWORD '" + pwd + "'";
-        Db.update(sql);
-    }
-
-    /**
-     * 功能：判断用户是否存在
-     *
-     * @param user_name
-     * @return
-     */
-    public static boolean isExistUser(String user_name) {
-        String sql = "SELECT * FROM pg_user WHERE usename = ?";
-        List<Record> list = Db.find(sql, user_name);
-        return !list.isEmpty();
-    }
 
-    /**
-     * 功能：判断角色是否存在
-     *
-     * @param role_name
-     * @return
-     */
-    public static boolean isExistRole(String role_name) {
-        String sql = "select * from pg_roles where rolname=?";
-        List<Record> list = Db.find(sql, role_name);
-        return !list.isEmpty();
-    }
-
-    /**
-     * 功能：创建一个角色
-     *
-     * @param role_name
-     */
-    public static void createRole(String role_name) {
-        String sql = "CREATE ROLE " + role_name;
-        Db.update(sql);
-    }
-
-    /**
-     * 功能：删除一个角色
-     * @param role_name
-     */
-    public static void delRole(String role_name) {
-        String sql = "DROP ROLE " + role_name;
-        Db.update(sql);
-    }
 
     public static void main(String[] args) {
         //初始化

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

@@ -0,0 +1,72 @@
+package com.dsideal.QingLong.Util;
+
+import com.jfinal.plugin.activerecord.Db;
+import com.jfinal.plugin.activerecord.Record;
+
+import java.util.List;
+
+public class PgUtil {
+     /**
+     * 功能：删除用户
+     *
+     * @param user_name
+     */
+    public static void delUser(String user_name) {
+        String sql = "DROP USER " + user_name;
+        Db.update(sql);
+    }
+
+    /**
+     * 功能：创建用户
+     *
+     * @param user_name
+     * @param pwd
+     */
+    public static void createUser(String user_name, String pwd) {
+        String sql = "CREATE USER " + user_name + " WITH PASSWORD '" + pwd + "'";
+        Db.update(sql);
+    }
+
+    /**
+     * 功能：判断用户是否存在
+     *
+     * @param user_name
+     * @return
+     */
+    public static boolean isExistUser(String user_name) {
+        String sql = "SELECT * FROM pg_user WHERE usename = ?";
+        List<Record> list = Db.find(sql, user_name);
+        return !list.isEmpty();
+    }
+
+    /**
+     * 功能：判断角色是否存在
+     *
+     * @param role_name
+     * @return
+     */
+    public static boolean isExistRole(String role_name) {
+        String sql = "select * from pg_roles where rolname=?";
+        List<Record> list = Db.find(sql, role_name);
+        return !list.isEmpty();
+    }
+
+    /**
+     * 功能：创建一个角色
+     *
+     * @param role_name
+     */
+    public static void createRole(String role_name) {
+        String sql = "CREATE ROLE " + role_name;
+        Db.update(sql);
+    }
+
+    /**
+     * 功能：删除一个角色
+     * @param role_name
+     */
+    public static void delRole(String role_name) {
+        String sql = "DROP ROLE " + role_name;
+        Db.update(sql);
+    }
+}