16 $x =~ s/([\\\r\n\t])/\\$1/g;
21 my ($mdbh, $sdbh, $table) = @_;
22 my $start = [ Time::HiRes::gettimeofday ];
23 my $data = $mdbh->selectall_arrayref("SELECT * FROM $table");
24 my $elapsed = Time::HiRes::tv_interval($start);
25 #printf "MySQL $table time used: $elapsed\n";
27 $start = [ Time::HiRes::gettimeofday ];
28 $sdbh->do("DELETE FROM $table");
29 $sdbh->do("COPY $table FROM STDIN");
31 for my $row (@$data) {
32 $sdbh->pg_putcopydata(join("\t", map { copy_escape($_) } (@$row)) . "\n");
34 $sdbh->pg_putcopyend();
35 $elapsed = Time::HiRes::tv_interval($start);
36 #printf "PostgreSQL $table time used: $elapsed\n";
39 my $mdbh = DBI->connect($config::master_connstr, $config::master_username, $config::master_password)
40 or die "PostgreSQL connect: " . $DBI::errstr;
41 $mdbh->{AutoCommit} = 0;
42 $mdbh->{RaiseError} = 1;
44 my $sdbh = DBI->connect($config::local_connstr, $config::local_username, $config::local_password)
45 or die "PostgreSQL connect: " . $DBI::errstr;
46 $sdbh->{AutoCommit} = 0;
47 $sdbh->{RaiseError} = 1;
48 $sdbh->do("SET client_encoding TO 'iso8859-1';");
50 # For our own enjoyment.
51 sync_table($mdbh, $sdbh, "Fotballbrukere");
52 sync_table($mdbh, $sdbh, "Fotballdeltagere");
53 sync_table($mdbh, $sdbh, "Fotballresultater");
54 sync_table($mdbh, $sdbh, "Fotballresultater_2123");
55 sync_table($mdbh, $sdbh, "Fotballserier");
58 sync_table($mdbh, $sdbh, 'Fotballjuks');
59 sync_table($mdbh, $sdbh, 'FotballKaffeklubb');
60 sync_table($mdbh, $sdbh, 'Fotballkommentarer');
61 sync_table($mdbh, $sdbh, 'Fotballkommentartema');
62 sync_table($mdbh, $sdbh, 'FotballLogin');
63 sync_table($mdbh, $sdbh, 'Fotballspraak');
64 sync_table($mdbh, $sdbh, 'Fotballtoppti');
65 sync_table($mdbh, $sdbh, 'Fotballvariabler');
67 $sdbh->do('DELETE FROM last_sync');
68 $sdbh->do('INSERT INTO last_sync VALUES ( CURRENT_TIMESTAMP );');