couchdb/scripts/svn2couch.pl

#!/usr/bin/perl

# st2couch.pl
#
# 09/30/08 20:07:10 CEST Dobrica Pavlinusic <dpavlin@rot13.org>

use warnings;
use strict;

my $path = shift @ARGV || '/home/dpavlin/private/svn/couchdb/';
my $repository = $path;
$repository =~ s{/+$}{};
$repository =~ s{^.+/([^/]+)}{$1};
my $database = 'subversion';

warn "# $path -> $repository @ $database";

use SVN::Dump;
use CouchDB::Client;
use Data::Structure::Util qw(unbless);
use Data::Dump qw/dump/;

open(my $svn_fh, "svnadmin dump $path |") || die "can't open svnadmin dump $path: $!";
my $dump = SVN::Dump->new({ fh => $svn_fh });

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 unless $c->dbExists( $database );

my $r = 0;

while ( my $record = $dump->next_record() ) {
        warn "## record ",dump( $record );
        my $_id = $repository . '-r' . $r++;
        my $doc = $db->newDoc( $_id );
        my $data = {
                repository => $repository,
                type => $record->type,
                text => $record->get_text,
        };

        $data->{$_} = $record->{headers_block}->{$_}
                foreach ( keys %{ $record->{headers_block} } );

        warn "## data ",dump( $data );
        $doc->{data} = $data;
        $doc->create;
        warn "<< $record\n";
}
1	dpavlin	24	#!/usr/bin/perl
2
3			# st2couch.pl
4			#
5			# 09/30/08 20:07:10 CEST Dobrica Pavlinusic <dpavlin@rot13.org>
6
7			use warnings;
8			use strict;
9
10			my $path = shift @ARGV \|\| '/home/dpavlin/private/svn/couchdb/';
11			my $repository = $path;
12			$repository =~ s{/+$}{};
13			$repository =~ s{^.+/([^/]+)}{$1};
14			my $database = 'subversion';
15
16			warn "# $path -> $repository @ $database";
17
18			use SVN::Dump;
19			use CouchDB::Client;
20			use Data::Structure::Util qw(unbless);
21			use Data::Dump qw/dump/;
22
23			open(my $svn_fh, "svnadmin dump $path \|") \|\| die "can't open svnadmin dump $path: $!";
24			my $dump = SVN::Dump->new({ fh => $svn_fh });
25
26			my $c = CouchDB::Client->new(uri => 'http://localhost:5984/');
27			$c->testConnection or die "The server cannot be reached";
28			print "CouchDB version " . $c->serverInfo->{version} . "\n";
29			my $db = $c->newDB( $database );
30			#$db->delete if $c->dbExists( $database );
31			$db->create unless $c->dbExists( $database );
32
33			my $r = 0;
34
35			while ( my $record = $dump->next_record() ) {
36			warn "## record ",dump( $record );
37			my $_id = $repository . '-r' . $r++;
38			my $doc = $db->newDoc( $_id );
39			my $data = {
40			repository => $repository,
41			type => $record->type,
42			text => $record->get_text,
43			};
44
45			$data->{$_} = $record->{headers_block}->{$_}
46			foreach ( keys %{ $record->{headers_block} } );
47
48			warn "## data ",dump( $data );
49			$doc->{data} = $data;
50			$doc->create;
51			warn "<< $record\n";
52			}