diff --git a/EdgeManager/EDataCapture/ENodeConfigure.php b/EdgeManager/EDataCapture/ENodeConfigure.php
index 7c7c68b..eadd182 100644
--- a/EdgeManager/EDataCapture/ENodeConfigure.php
+++ b/EdgeManager/EDataCapture/ENodeConfigure.php
@@ -9,7 +9,7 @@ class ENodeConfigure {
     ) {}
 
     function add_node() {
-        $exists = pg_query(sprintf(
+        $exists = pg_query($this -> dbconn, sprintf(
             "SELECT EXISTS(
                 SELECT 1 FROM hf_mes_scada_data_capture_node_configure WHERE code='%s'
             )", $this -> post -> code
@@ -39,7 +39,7 @@ class ENodeConfigure {
             (array) $this -> post
         );
         // 检查一下，如果超表已经有了就不要尝试重复创建了
-        $table_exists = pg_query(sprintf(
+        $table_exists = pg_query($this -> dbconn, sprintf(
             "SELECT *
             FROM timescaledb_information.hypertables
             WHERE hypertable_name = '%s'
@@ -70,13 +70,13 @@ class ENodeConfigure {
             'hf_mes_scada_data_capture_node_configure',
             (array) $this -> post,
         );
-        $exists = pg_query(sprintf(
+        $exists = pg_query($this -> dbconn, sprintf(
             "SELECT EXISTS(
                 SELECT 1 FROM hf_mes_scada_data_capture_node_configure WHERE working_subclass = '%s'
             )", $this -> post -> working_subclass
         ));
         if (pg_fetch_assoc($exists)['exists'] == 'f') {
-            $res[] = pg_query(sprintf(
+            $res[] = pg_query($this -> dbconn, sprintf(
                 'DROP TABLE "hf_mes_scada_data_capture_node_data_%s"',
                 $this -> post -> working_subclass
             ));
diff --git a/EdgeManager/Init.php b/EdgeManager/Init.php
index ea4c2dd..a1f6bf2 100644
--- a/EdgeManager/Init.php
+++ b/EdgeManager/Init.php
@@ -1,14 +1,14 @@
 <?php
 function init_db($server_name, $user, $password) {
     $dbconn = pg_connect(sprintf("host=%s user=%s password=%s", $server_name, $user, $password));
-    $res = pg_query("select datname from pg_database");
+    $res = pg_query($dbconn, "select datname from pg_database");
     
     if (!in_array('scada', pg_fetch_all_columns($res, 0)))
-        pg_query("CREATE DATABASE scada");
+        pg_query($dbconn, "CREATE DATABASE scada");
     pg_close($dbconn);
 
     $dbconn = pg_connect(sprintf("host=%s dbname=scada user=%s password=%s", $server_name, $user, $password));
-    pg_query("CREATE TABLE IF NOT EXISTS hf_mes_scada_data_capture_node_configure (
+    pg_query($dbconn, "CREATE TABLE IF NOT EXISTS hf_mes_scada_data_capture_node_configure (
         id serial2,
         code text primary key NOT NULL,
         name text NOT NULL,