couchdb/scripts/reblog2couchdb.pl

#!/usr/bin/perl -w

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

$|++;

my $database = 'reblog';

my $connect = "DBI:mysql:database=$database";
#$connect = "DBI:mysql:database=$database;host=localhost;port=13306";

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

# select all posts which have been read or unread
my $sql = qq{
        select
                *
        from items
--      join items_userdata on id=item_id
--      where label = 'read' and value_numeric = ?
--      limit 3
        order by id asc
};

my $sth = $dbh->prepare($sql) || die $dbh->errstr();
$sth->execute( 1 ) || die $sth->errstr();

print "found ",$sth->rows," items to process...";

my $c = CouchDB::Client->new(uri => 'http://localhost:5984/');

$c->testConnection or die "The server cannot be reached";
print "Running version " . $c->serverInfo->{version} . "\n";
my $db = $c->newDB( $database );
$db->create unless $c->dbExists( $database );

my @docs = $db->listDocs;
my $row_id = shift @docs || 0;

my $pk = 'id';

while (my $row = $sth->fetchrow_hashref() ) {
        my $_id = $row->{$pk};
        my $doc = $db->newDoc( $_id );
        $doc->{data} = $row;
        eval { $doc->create };
        if ( $@ ) {
                warn "can't create $_id $@";
                eval { $doc->update };
                warn $@ ? "can't update $_id $@" : "updated $_id";
        } else {
                warn "created ",dump( $row );
        }
}

__END__

$sql = qq{
        update items_userdata
        set value_numeric = 1
        where label = 'read' and item_id in ($ids)
};

$dbh->do( $sql );

1	dpavlin	2	#!/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 $database = 'reblog';
11
12			my $connect = "DBI:mysql:database=$database";
13			#$connect = "DBI:mysql:database=$database;host=localhost;port=13306";
14
15			my $dbh = DBI->connect($connect,"","") \|\| die $DBI::errstr;
16
17			# select all posts which have been read or unread
18			my $sql = qq{
19			select
20			*
21			from items
22			-- join items_userdata on id=item_id
23			-- where label = 'read' and value_numeric = ?
24			-- limit 3
25			order by id asc
26			};
27
28			my $sth = $dbh->prepare($sql) \|\| die $dbh->errstr();
29			$sth->execute( 1 ) \|\| die $sth->errstr();
30
31			print "found ",$sth->rows," items to process...";
32
33			my $c = CouchDB::Client->new(uri => 'http://localhost:5984/');
34
35			$c->testConnection or die "The server cannot be reached";
36			print "Running version " . $c->serverInfo->{version} . "\n";
37			my $db = $c->newDB( $database );
38			$db->create unless $c->dbExists( $database );
39
40			my @docs = $db->listDocs;
41			my $row_id = shift @docs \|\| 0;
42
43			my $pk = 'id';
44
45			while (my $row = $sth->fetchrow_hashref() ) {
46			my $_id = $row->{$pk};
47			my $doc = $db->newDoc( $_id );
48			$doc->{data} = $row;
49			eval { $doc->create };
50			if ( $@ ) {
51			warn "can't create $_id $@";
52			eval { $doc->update };
53			warn $@ ? "can't update $_id $@" : "updated $_id";
54			} else {
55			warn "created ",dump( $row );
56			}
57			}
58
59			__END__
60
61			$sql = qq{
62			update items_userdata
63			set value_numeric = 1
64			where label = 'read' and item_id in ($ids)
65			};
66
67			$dbh->do( $sql );
68