From 6e86509e278c90c8a5af406daf322b5dbd8e26dd Mon Sep 17 00:00:00 2001 From: Yu Sun Date: Thu, 4 Aug 2022 15:26:47 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E6=97=A9=E4=BA=8B=E5=8A=A1=E5=BC=80?= =?UTF-8?q?=E5=A7=8B=E7=9A=84=E4=BD=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- EdgeManager/EDataCapture/ENodeConfigure.php | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/EdgeManager/EDataCapture/ENodeConfigure.php b/EdgeManager/EDataCapture/ENodeConfigure.php index ba6de1f..687d7d6 100644 --- a/EdgeManager/EDataCapture/ENodeConfigure.php +++ b/EdgeManager/EDataCapture/ENodeConfigure.php @@ -9,6 +9,7 @@ class ENodeConfigure { ) {} function add_node() { + pg_query($this -> dbconn, "BEGIN"); $exists = pg_query($this -> dbconn, sprintf( "SELECT EXISTS( SELECT 1 FROM hf_mes_scada_data_capture_node_configure @@ -16,12 +17,13 @@ class ENodeConfigure { AND working_subclass = '%s' )", $this -> post -> code, $this -> post -> working_subclass )); - if (pg_fetch_assoc($exists)['exists'] == 't') { + if (pg_fetch_assoc($exists)['exists'] === 't') { + pg_query($this -> dbconn, "ROLLBACK"); return "REPLICATED"; } $table_name = 'hf_mes_scada_data_capture_node_data_' . $this -> post -> working_subclass; - pg_query($this -> dbconn, "BEGIN"); + // https://www.postgresql.org/docs/current/when-can-parallel-query-be-used.html $res[] = pg_query($this -> dbconn, sprintf( 'CREATE TABLE IF NOT EXISTS "%s" ( id serial8,