--- pgdiff	2003/08/15 22:06:19	1.7
+++ pgdiff	2003/10/16 09:36:43	1.9
@@ -119,7 +119,8 @@
 $verbose = 1 if ($debug);
 
 # init object for scheme in master database
-my $mscheme = new Pg::Scheme( 'dbh' => $mdbh, 'DEBUG' => 0 ) || die "can't query schema";
+my $mscheme = new Pg::Scheme( 'dbh' => $mdbh, 'DEBUG' => 0 ) || die "can't query master schema";
+my $sscheme = new Pg::Scheme( 'dbh' => $sdbh, 'DEBUG' => 0 ) || die "can't query slave schema";
 
 # which tables to compare?
 
@@ -127,6 +128,16 @@
 
 debug "Comparing tables: ".join(", ",@tables)."\n";
 
+# start transaction
+print "begin work;\n";
+
+# disable active triggers on slave database
+my @triggers = $sscheme->get_triggers();
+
+foreach my $tr (@triggers) {
+	print "update pg_trigger set tgenabled = false where tgname='$tr';\n";
+}
+
 my $cols;
 my $diff_total = 0;
 
@@ -219,11 +230,11 @@
 
 	debug_sql($msql);
 
-	my $msth = $mdbh->prepare($msql) || die;
-	$msth->execute() || die;
+	my $msth = $mdbh->prepare($msql) || die $mdbh->errstr;
+	$msth->execute() || die $msth->errstr;
 
-	my $ssth = $sdbh->prepare($ssql) || die;
-	$ssth->execute() || die;
+	my $ssth = $sdbh->prepare($ssql) || die $sdbh->errstr;
+	$ssth->execute() || die $ssth->errstr;
 
 	my $diff_row = 0;
 
@@ -389,5 +400,12 @@
 	}
 }
 
+# enable triggers again on slave
+foreach my $tr (@triggers) {
+	print "update pg_trigger set tgenabled = true where tgname='$tr';\n";
+}
+# end transaction
+print "commit;\n";
+
 $mdbh->disconnect();
 $sdbh->disconnect();