/[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 26 by dpavlin, Fri Mar 27 19:33:12 2009 UTC revision 28 by dpavlin, Sat Apr 25 00:11:51 2009 UTC
# Line 14  my $database = 'reblog'; Line 14  my $database = 'reblog';
14  my $dbi = "DBI:mysql:database=$database";  my $dbi = "DBI:mysql:database=$database";
15  $dbi .= ";host=127.0.0.1;port=13306";   # XXX over ssh  $dbi .= ";host=127.0.0.1;port=13306";   # XXX over ssh
16    
17    my $dbh = DBI->connect($dbi,"","",{ RaiseError => 1 });
18    
19    $dbh->do(qq{
20            create temporary table published_items as
21            select
22                    item_id
23            from
24                    items_userdata
25            where
26                    label = 'published' and
27                    value_numeric = 1
28    });
29    
30  my $sql = qq{  my $sql = qq{
31          select          select
32                  items.id as _id,                  items.id as _id,
# Line 23  my $sql = qq{ Line 36  my $sql = qq{
36                  feeds.link as feed_link,                  feeds.link as feed_link,
37                  feeds.description as feed_description                  feeds.description as feed_description
38          from items          from items
39          join items_userdata on items.id = item_id          join published_items on items.id = item_id
40          join feeds on items.feed_id = feeds.id          join feeds on items.feed_id = feeds.id
41          where items.id > ? and items_userdata.label = 'published' and items_userdata.value_numeric = 1          where items.id > ?
42          order by items.id asc          order by items.id asc
43          limit 1000          limit 1000
44  };  };
# Line 33  my $sql = qq{ Line 46  my $sql = qq{
46  my $sql_tags = qq{  my $sql_tags = qq{
47  select  select
48          items_userdata.item_id,          items_userdata.item_id,
49          t.value_long as tags,          value_long as tags,
50          items_userdata.timestamp          timestamp
51  from items_userdata  from items_userdata
52  join items_userdata as t  join published_items p
53          on items_userdata.item_id = t.item_id and t.label='tags'          on items_userdata.item_id = p.item_id and label='tags'
54  where  where
55          items_userdata.item_id > ? and          items_userdata.item_id > ?
         items_userdata.label = 'published' and  
         items_userdata.value_numeric = 1  
56  order by items_userdata.item_id asc  order by items_userdata.item_id asc
57  };  };
58    
# Line 52  print "CouchDB version " . $c->serverInf Line 63  print "CouchDB version " . $c->serverInf
63  my $db = $c->newDB( $database );  my $db = $c->newDB( $database );
64  $db->create unless $c->dbExists( $database );  $db->create unless $c->dbExists( $database );
65    
66  my $status = $db->newDoc( '_sync' );  my $status = $db->newDoc( 'last_sync' );
67  eval { $status->retrieve };  eval { $status->retrieve };
68  eval { $status->create } if $@;  $status->create if $@;
69    
70  print "status ",dump( $status->{data} ), "\n";  print "status ",dump( $status->{data} ), "\n";
71    
# Line 67  sub commit_last_row { Line 78  sub commit_last_row {
78          $status->update;          $status->update;
79  }  }
80    
 my $dbh = DBI->connect($dbi,"","",{ RaiseError => 1 });  
   
81  print "Fetching items from $dbi id > $last_row\n";  print "Fetching items from $dbi id > $last_row\n";
82    
83  my $sth = $dbh->prepare($sql);  my $sth = $dbh->prepare($sql);
Legend:
Removed from v.26  
changed lines
  Added in v.28
  ViewVC Help
Powered by ViewVC 1.1.26