nsinnovations/fusionpbx
2
0
Fork 0
mirror of https://github.com/fusionpbx/fusionpbx.git synced 2025-12-30 09:03:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refresh Publication

Browse Source 
Needed to prevent issues with logical replication
This commit is contained in:
FusionPBX
2024-03-01 12:49:16 -07:00
committed by GitHub
parent b9ce1d2edf
commit d7ac495b7e
1 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
resources/classes/schema.php
View File

@@ -894,6 +894,21 @@ if (!class_exists('schema')) {
unset ($sql_update, $sql);
}
//refresh each postgresql subscription with its publication
if ($db_type == "pgsql") {
//get the list of postgresql subscriptions
$sql = "select subname from pg_subscription; ";
$pg_subscriptions = $this->database->select($sql, null, 'all');
unset($sql, $parameters);
//refresh each subscription publication
foreach ($pg_subscriptions as $row) {
$sql = "ALTER SUBSCRIPTION ".$row['subname']." REFRESH PUBLICATION;";
$response .= $sql;
$this->database->execute($sql);
}
}
//handle response
//if ($output == "echo") {
// echo $response;
@@ -914,4 +929,3 @@ if (!class_exists('schema')) {
//print_r($result_array);
?>