/[couchdb]/scripts/reblog2couchdb.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 /scripts/reblog2couchdb.pl

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

revision 7 by dpavlin, Tue Aug 5 16:36:57 2008 UTC revision 10 by dpavlin, Fri Aug 8 19:19:12 2008 UTC
# Line 20  my $sql = qq{ Line 20  my $sql = qq{
20                  feeds.title as feed_title,                  feeds.title as feed_title,
21                  feeds.link as feed_link,                  feeds.link as feed_link,
22                  feeds.description as feed_description                  feeds.description as feed_description
23    --              t.value_long as tags
24          from items          from items
25          join items_userdata on items.id = item_id          join items_userdata on items.id = item_id
26          join feeds on items.feed_id = feeds.id          join feeds on items.feed_id = feeds.id
27          where items.id > ?  --      left outer join items_userdata as t on items.id = t.item_id and t.label='tags'
28            where items.id > ? and items_userdata.label = 'published' and items_userdata.value_numeric = 1
29          order by items.id asc          order by items.id asc
30          limit 5000          limit 1000
31  };  };
32    
   
33  my $c = CouchDB::Client->new(uri => 'http://localhost:5984/');  my $c = CouchDB::Client->new(uri => 'http://localhost:5984/');
34    
35  $c->testConnection or die "The server cannot be reached";  $c->testConnection or die "The server cannot be reached";
# Line 59  $sth->execute( $last_row ) || die $sth-> Line 60  $sth->execute( $last_row ) || die $sth->
60    
61  warn dump( $sth->{NAME} );  warn dump( $sth->{NAME} );
62    
63  print "found ",$sth->rows," items to process...";  print "found ",$sth->rows," items to process...\n";
64    
65  my $pk = 'id';  my $pk = 'id';
66    
# Line 86  while (my $row = $sth->fetchrow_hashref( Line 87  while (my $row = $sth->fetchrow_hashref(
87                  $doc->retrieve;                  $doc->retrieve;
88                  row2doc( $row, $doc )->update;                  row2doc( $row, $doc )->update;
89  #               eval { $doc->update };  #               eval { $doc->update };
90                  warn $@ ? "ERROR $_id $@\n" : "updated $_id\n";                  warn $@ ? "$count ERROR $_id $@\n" : "$count updated $_id\n";
91          } else {          } else {
92                  warn "created $_id\n";                  warn "$count created $_id\n";
93          }          }
94    
95          $last_row = $row->{id};          $last_row = $row->{id};
Legend:
Removed from v.7  
changed lines
  Added in v.10
  ViewVC Help
Powered by ViewVC 1.1.26