/[pgdiff]/pgdiff
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /pgdiff

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.7 by dpavlin, Fri Aug 15 22:06:19 2003 UTC revision 1.9 by dpavlin, Thu Oct 16 09:36:43 2003 UTC
# Line 119  sub debug { Line 119  sub debug {
119  $verbose = 1 if ($debug);  $verbose = 1 if ($debug);
120    
121  # init object for scheme in master database  # init object for scheme in master database
122  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";
123    my $sscheme = new Pg::Scheme( 'dbh' => $sdbh, 'DEBUG' => 0 ) || die "can't query slave schema";
124    
125  # which tables to compare?  # which tables to compare?
126    
# Line 127  my @tables = $mscheme->list_tables($tabl Line 128  my @tables = $mscheme->list_tables($tabl
128    
129  debug "Comparing tables: ".join(", ",@tables)."\n";  debug "Comparing tables: ".join(", ",@tables)."\n";
130    
131    # start transaction
132    print "begin work;\n";
133    
134    # disable active triggers on slave database
135    my @triggers = $sscheme->get_triggers();
136    
137    foreach my $tr (@triggers) {
138            print "update pg_trigger set tgenabled = false where tgname='$tr';\n";
139    }
140    
141  my $cols;  my $cols;
142  my $diff_total = 0;  my $diff_total = 0;
143    
# Line 219  foreach my $table (@tables) { Line 230  foreach my $table (@tables) {
230    
231          debug_sql($msql);          debug_sql($msql);
232    
233          my $msth = $mdbh->prepare($msql) || die;          my $msth = $mdbh->prepare($msql) || die $mdbh->errstr;
234          $msth->execute() || die;          $msth->execute() || die $msth->errstr;
235    
236          my $ssth = $sdbh->prepare($ssql) || die;          my $ssth = $sdbh->prepare($ssql) || die $sdbh->errstr;
237          $ssth->execute() || die;          $ssth->execute() || die $ssth->errstr;
238    
239          my $diff_row = 0;          my $diff_row = 0;
240    
# Line 389  if ($verbose) { Line 400  if ($verbose) {
400          }          }
401  }  }
402    
403    # enable triggers again on slave
404    foreach my $tr (@triggers) {
405            print "update pg_trigger set tgenabled = true where tgname='$tr';\n";
406    }
407    # end transaction
408    print "commit;\n";
409    
410  $mdbh->disconnect();  $mdbh->disconnect();
411  $sdbh->disconnect();  $sdbh->disconnect();

Legend:
Removed from v.1.7  
changed lines
  Added in v.1.9

  ViewVC Help
Powered by ViewVC 1.1.26