wyw/EdgeManager
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

fix(ENodeConfigure):dimension要后续一个个添加

Browse Source
This commit is contained in:
Yu Sun
2022-10-07 19:54:28 +08:00
parent 01bbe22143
commit d0af74e974
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
EdgeManager/EDataCapture/ENodeConfigure.php
View File

@@ -63,10 +63,14 @@ class ENodeConfigure {
)); ));
if (!in_array($table_name, pg_fetch_all_columns($table_exists, 1))) { if (!in_array($table_name, pg_fetch_all_columns($table_exists, 1))) {
$res[] = $node_count = pg_query($this -> dbconn, "SELECT COUNT(*) from timescaledb_information.data_nodes"); $res[] = $node_count = pg_query($this -> dbconn, "SELECT COUNT(*) from timescaledb_information.data_nodes");
if (intval(pg_fetch_assoc($node_count)['count']) === 0) { $node_count = intval(pg_fetch_assoc($node_count)['count']);
if ($node_count === 0) {
$res[] = pg_query($this -> dbconn, sprintf("SELECT create_hypertable('\"%s\"', 'capture_time')", $table_name)); $res[] = pg_query($this -> dbconn, sprintf("SELECT create_hypertable('\"%s\"', 'capture_time')", $table_name));
} else { } else {
$res[] = pg_query($this -> dbconn, sprintf("SELECT create_distributed_hypertable('\"%s\"', 'capture_time', 'code', 'device_code', 'parent_device_code', 'batch')", $table_name)); $res[] = pg_query($this -> dbconn, sprintf("SELECT create_distributed_hypertable('\"%s\"', 'capture_time', 'code')", $table_name));
$res[] = pg_query($this -> dbconn, sprintf("add_dimension('\"%s\"', 'device_code', number_partitions => %s)", $node_count));
$res[] = pg_query($this -> dbconn, sprintf("add_dimension('\"%s\"', 'parent_device_code', number_partitions => %s)", $node_count));
$res[] = pg_query($this -> dbconn, sprintf("add_dimension('\"%s\"', 'batch', number_partitions => %s)", $node_count));
} }
$res[] = pg_query($this -> dbconn, sprintf( $res[] = pg_query($this -> dbconn, sprintf(