couchdb/scripts/dbi-import.pl

#!/usr/bin/perl -w

use strict;
use DBI;
use CouchDB::Client;
use Data::Dump qw/dump/;

$|++;

my @tables;

my ( $dbi, $database ) = ( 'DBI:Pg:dbname=','carnetweb' );
( $dbi, $database ) = ( 'DBI:mysql:database=','reblog' );
@tables = ( 'items','items_userdata','feeds','feeds_userdata' );

my $dbh = DBI->connect($dbi . $database,"","") || die $DBI::errstr;

if ( ! @tables ) {

        my $sth = $dbh->prepare(qq{
                select table_name from information_schema.tables where table_schema = 'public'
        }) || die $dbh->errstr();
        $sth->execute() || die $sth->errstr();

        print "found ",$sth->rows," tables to import...\n";

        while (my ($table) = $sth->fetchrow_array ) {
                # anketa|changelog|banners|brand|faq|file|forum|galerija|grupe|kalendar
                next unless $table =~ m/(banners|brand|faq|file|forum|galerija|kalendar|kategorija|news|picture|rss|users)/;
                push @tables, $table;
        }
}

my $c = CouchDB::Client->new(uri => 'http://localhost:5984/');
$c->testConnection or die "The server cannot be reached";
print "CouchDB version " . $c->serverInfo->{version} . "\n";
my $db = $c->newDB( $database );
$db->delete if $c->dbExists( $database );
$db->create;

foreach my $table ( @tables ) {
        my $sth = $dbh->prepare(qq{ select * from $table }) || die $dbh->errstr();
        $sth->execute || die $sth->errstr();
        my @pk = $dbh->primary_key( undef, undef, $table );

        print "import ", $sth->rows, " rows from $table ",dump( @pk ),"...\n";

        while (my $row = $sth->fetchrow_hashref() ) {
                my $_id = $table . ':' . join(",", map { $row->{$_} } @pk);
                my $doc = $db->newDoc( $_id );
                $row->{table} = $table;
                $doc->{data} = $row;
                eval { $doc->create };
                print "$_id ", dump( $row ), $@ if $@;
        }
}

1	dpavlin	20	#!/usr/bin/perl -w
2
3			use strict;
4			use DBI;
5			use CouchDB::Client;
6			use Data::Dump qw/dump/;
7
8			$\|++;
9
10			my @tables;
11
12			my ( $dbi, $database ) = ( 'DBI:Pg:dbname=','carnetweb' );
13			( $dbi, $database ) = ( 'DBI:mysql:database=','reblog' );
14			@tables = ( 'items','items_userdata','feeds','feeds_userdata' );
15
16			my $dbh = DBI->connect($dbi . $database,"","") \|\| die $DBI::errstr;
17
18			if ( ! @tables ) {
19
20			my $sth = $dbh->prepare(qq{
21			select table_name from information_schema.tables where table_schema = 'public'
22			}) \|\| die $dbh->errstr();
23			$sth->execute() \|\| die $sth->errstr();
24
25			print "found ",$sth->rows," tables to import...\n";
26
27			while (my ($table) = $sth->fetchrow_array ) {
28			# anketa\|changelog\|banners\|brand\|faq\|file\|forum\|galerija\|grupe\|kalendar
29			next unless $table =~ m/(banners\|brand\|faq\|file\|forum\|galerija\|kalendar\|kategorija\|news\|picture\|rss\|users)/;
30			push @tables, $table;
31			}
32			}
33
34			my $c = CouchDB::Client->new(uri => 'http://localhost:5984/');
35			$c->testConnection or die "The server cannot be reached";
36			print "CouchDB version " . $c->serverInfo->{version} . "\n";
37			my $db = $c->newDB( $database );
38			$db->delete if $c->dbExists( $database );
39			$db->create;
40
41			foreach my $table ( @tables ) {
42			my $sth = $dbh->prepare(qq{ select * from $table }) \|\| die $dbh->errstr();
43			$sth->execute \|\| die $sth->errstr();
44			my @pk = $dbh->primary_key( undef, undef, $table );
45
46			print "import ", $sth->rows, " rows from $table ",dump( @pk ),"...\n";
47
48			while (my $row = $sth->fetchrow_hashref() ) {
49			my $_id = $table . ':' . join(",", map { $row->{$_} } @pk);
50			my $doc = $db->newDoc( $_id );
51			$row->{table} = $table;
52			$doc->{data} = $row;
53			eval { $doc->create };
54			print "$_id ", dump( $row ), $@ if $@;
55			}
56			}
57