mirror of
https://github.com/postgres/postgres.git
synced 2025-10-31 10:30:33 +03:00
87438cb90e
-It fixes up some bugs with handling setval calls -Adds upgrade instructions from prior versions -Improved the sample config file -Fixed some things in the clean_pending script
107 lines
3.2 KiB
Perl
Executable File
107 lines
3.2 KiB
Perl
Executable File
#!/usr/bin/perl
|
|
# clean_pending.pl
|
|
# This perl script removes entries from the pending,pendingKeys,
|
|
# pendingDeleteData tables that have already been mirrored to all hosts.
|
|
#
|
|
#
|
|
#
|
|
# Written by Steven Singer (ssinger@navtechinc.com)
|
|
# (c) 2001-2002 Navtech Systems Support Inc.
|
|
# Released under the GNU Public License version 2. See COPYING.
|
|
#
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
##############################################################################
|
|
# $PostgreSQL: pgsql/contrib/dbmirror/clean_pending.pl,v 1.5 2004/09/10 04:31:06 neilc Exp $
|
|
##############################################################################
|
|
|
|
|
|
|
|
=head1 NAME
|
|
|
|
clean_pending.pl - A Perl script to remove old entries from the
|
|
pending, pendingKeys, and pendingDeleteData tables.
|
|
|
|
|
|
=head1 SYNPOSIS
|
|
|
|
|
|
clean_pending.pl databasename
|
|
|
|
|
|
=head1 DESCRIPTION
|
|
|
|
|
|
This Perl script connects to the database specified as a command line argument
|
|
on the local system. It uses a hard-coded username and password.
|
|
It then removes any entries from the pending, pendingDeleteData, and
|
|
pendingKeys tables that have already been sent to all hosts in mirrorHosts.
|
|
|
|
|
|
=cut
|
|
|
|
BEGIN {
|
|
# add in a global path to files
|
|
#Ensure that Pg is in the path.
|
|
}
|
|
|
|
|
|
use strict;
|
|
use Pg;
|
|
if ($#ARGV != 0) {
|
|
die "usage: clean_pending.pl configFile\n";
|
|
}
|
|
|
|
if( ! defined do $ARGV[0]) {
|
|
die("Invalid Configuration file $ARGV[0]");
|
|
}
|
|
|
|
#connect to the database.
|
|
|
|
my $connectString = "host=$::masterHost dbname=$::masterDb user=$::masterUser password=$::masterPassword";
|
|
|
|
my $dbConn = Pg::connectdb($connectString);
|
|
unless($dbConn->status == PGRES_CONNECTION_OK) {
|
|
printf("Can't connect to database\n");
|
|
die;
|
|
}
|
|
my $result = $dbConn->exec("BEGIN");
|
|
unless($result->resultStatus == PGRES_COMMAND_OK) {
|
|
die $dbConn->errorMessage;
|
|
}
|
|
|
|
|
|
#delete all transactions that have been sent to all mirrorhosts
|
|
#or delete everything if no mirror hosts are defined.
|
|
# Postgres takes the "SELECT COUNT(*) FROM dbmirror_MirrorHost and makes it into
|
|
# an InitPlan. EXPLAIN show's this.
|
|
my $deletePendingQuery = 'DELETE FROM dbmirror_Pending WHERE (SELECT ';
|
|
$deletePendingQuery .= ' COUNT(*) FROM dbmirror_MirroredTransaction WHERE ';
|
|
$deletePendingQuery .= ' XID=dbmirror_Pending.XID) = (SELECT COUNT(*) FROM ';
|
|
$deletePendingQuery .= ' dbmirror_MirrorHost) OR (SELECT COUNT(*) FROM ';
|
|
$deletePendingQuery .= ' dbmirror_MirrorHost) = 0';
|
|
|
|
my $result = $dbConn->exec($deletePendingQuery);
|
|
unless ($result->resultStatus == PGRES_COMMAND_OK ) {
|
|
printf($dbConn->errorMessage);
|
|
die;
|
|
}
|
|
$dbConn->exec("COMMIT");
|
|
$result = $dbConn->exec('VACUUM dbmirror_Pending');
|
|
unless ($result->resultStatus == PGRES_COMMAND_OK) {
|
|
printf($dbConn->errorMessage);
|
|
}
|
|
$result = $dbConn->exec('VACUUM dbmirror_PendingData');
|
|
unless($result->resultStatus == PGRES_COMMAND_OK) {
|
|
printf($dbConn->errorMessage);
|
|
}
|
|
$result = $dbConn->exec('VACUUM dbmirror_MirroredTransaction');
|
|
unless($result->resultStatus == PGRES_COMMAND_OK) {
|
|
printf($dbConn->errorMessage);
|
|
}
|
|
|