/[Sack]/trunk/bin/mongodb2shards.pl
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 /trunk/bin/mongodb2shards.pl

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

revision 260 by dpavlin, Tue Jan 26 17:34:19 2010 UTC revision 261 by dpavlin, Sun Jan 31 16:44:33 2010 UTC
# Line 4  use lib 'lib'; Line 4  use lib 'lib';
4  use Sack::Shard;  use Sack::Shard;
5    
6  use Data::Dump qw(dump);  use Data::Dump qw(dump);
 use Data::Structure::Util qw(unbless);  
7  use autodie;  use autodie;
8    
9  use MongoDB;  use MongoDB;
10    
11  my $name = 'dns';  my $name = 'pxelator';
12  my $shard_size = 5000;  my $shard_size = 5000;
13    
14    
# Line 17  my $connection = MongoDB::Connection->ne Line 16  my $connection = MongoDB::Connection->ne
16  my $database   = $connection->get_database('pxelator');  my $database   = $connection->get_database('pxelator');
17  my $collection = $database->get_collection('audit');  my $collection = $database->get_collection('audit');
18    
19  my $q = {"package.name" => "dnsd", "source" => "upstream"};  my $q;
20    #$q = {"package.name" => "dnsd", "source" => "upstream"};
21    
22  warn "# mongodb query: ", dump($q), $/;  warn "# mongodb query: ", dump($q), $/;
23    
# Line 26  my $cursor = $collection->query($q); Line 26  my $cursor = $collection->query($q);
26  Sack::Shard::create( $name, $cursor->count, $shard_size );  Sack::Shard::create( $name, $cursor->count, $shard_size );
27    
28  while( my $o = $cursor->next ) {  while( my $o = $cursor->next ) {
29          $o->{_id} .= '';          $o->{_id} .= ''; # convert _id to scalar
30          Sack::Shard::add( $o );          Sack::Shard::add( $o );
31  }  }
32  Sack::Shard::finish;  Sack::Shard::finish;
Legend:
Removed from v.260  
changed lines
  Added in v.261
  ViewVC Help
Powered by ViewVC 1.1.26