Changeset 35368 for lang/perl

Timestamp:

09/14/09 14:58:39 (4 years ago)

Author:

fujiwara

Message:

added (post|put)_view_views()

Location:

lang/perl/DBIx-CouchLike/trunk

Files:

• Changes (modified) (1 diff)
• META.yml (modified) (1 diff)
• lib/DBIx/CouchLike.pm (modified) (10 diffs)
• t/16_view_with.t (added)

lang/perl/DBIx-CouchLike/trunk/Changes

@@ -1 +1 @@
 Revision history for Perl extension DBIx::CouchLike
+
+0.12    Mon Sep 14 14:57:37 2009
+        - added post_with_views(), put_with_views().
 
 0.10    Fri Sep 11 15:35:59 2009

lang/perl/DBIx-CouchLike/trunk/META.yml

@@ -1 +1 @@
 ---
-abstract: ~
+abstract: 'DBI based CouchDB like document database library'
 author:
   - 'FUJIWARA <fujiwara.shunichiro gmail.com>'

lang/perl/DBIx-CouchLike/trunk/lib/DBIx/CouchLike.pm

@@ -9 +9 @@
 use DBIx::CouchLike::Iterator;
 
-our $VERSION = '0.10';
+our $VERSION = '0.12';
 our $RD;
 __PACKAGE__->mk_accessors(qw/ dbh table utf8 _json /);
@@ -138 +138 @@
 
 sub post_multi {
+    my $self = shift;
+    $self->_post_multi([], @_);
+}
+
+sub _post_multi {
     my $self      = shift;
+    my $views     = shift;
     my @value_ref = @_;
     my $sth = $self->prepare_sql(q{INSERT INTO _DATA_ (id, value) VALUES(?, ?)});
@@ -149 +155 @@
         push @id, $id;
     }
-    $self->update_views( @value_ref );
+    $self->update_views( $views, @value_ref );
     return wantarray ? @id : $id[0];
 }
@@ -164 +170 @@
 sub put_multi {
     my $self = shift;
+    $self->_put_multi([], @_);
+}
+
+sub put_with_views {
+    my $self  = shift;
+    my @views = map { "_design/$_" } @_;
+    sub {
+        $self->_put_multi(\@views, @_);
+    };
+}
+
+sub _put_multi {
+    my $self      = shift;
+    my $views     = shift;
     my @value_ref = @_;
-    my $sth  = $self->prepare_sql(q{UPDATE _DATA_ SET value=? WHERE id=?});
+    my $sth       = $self->prepare_sql(q{UPDATE _DATA_ SET value=? WHERE id=?});
 
     my @post;
@@ -186 +206 @@
     my @new_id;
     @new_id = $self->post_multi(@post) if @post;
-    $self->update_views(@put);
+    $self->update_views( $views, @put );
     return wantarray ? (@id, @new_id) : $id[0] || $new_id[0];
 }
@@ -351 +371 @@
 }
 
+sub post_with_views {
+    my $self  = shift;
+    my @views = map { "_design/$_" } @_;
+    sub {
+        $self->_post_multi(\@views, @_);
+    };
+}
+
 sub _start_with {
     my $self  = shift;
@@ -439 +467 @@
 
 sub update_views {
-    my $self     = shift;
-    my $dbh      = $self->dbh;
+    my $self  = shift;
+    my $dbh   = $self->dbh;
+    my $views = shift || [];
+    my @views = @$views;
 
     my @data_val;
@@ -456 +486 @@
 
     my $pf = join(",", map {"?"} @id);
-    my $del_sth = $self->prepare_sql(
-        qq{DELETE FROM _MAP_ WHERE id IN ($pf)}
-    );
-    $del_sth->execute(@id);
+    my $df = @views ? join(",", map {"?"} @views) : "";
+
+    if (@views) {
+        my $del_sql = qq{DELETE FROM _MAP_ WHERE id IN ($pf)};
+        my @value;
+        my @cond;
+        for my $v (@views) {
+            my ($part, @v) = $self->_start_with( design_id => $v );
+            push @cond,  $part;
+            push @value, @v;
+        }
+        $del_sql .= " AND (" . join(" OR ", @cond). ")";
+        $self->prepare_sql($del_sql)
+            ->execute(@id, @value);
+    }
+    else {
+        $self->prepare_sql(qq{DELETE FROM _MAP_ WHERE id IN ($pf)})
+            ->execute(@id);
+    }
 
     my $index_sth = $self->prepare_sql(
@@ -465 +510 @@
     );
 
-    my ($part, @value) = $self->_start_with( id => '_design/' );
-    my $sth = $self->prepare_sql(
-        q{SELECT id, value FROM _DATA_ WHERE } . $part
-    );
-    $sth->execute(@value);
+    my $sth;
+    if (@views) {
+        $sth = $self->prepare_sql(
+            qq{SELECT id, value FROM _DATA_ WHERE id IN($df)}
+        );
+        $sth->execute(@views);
+    }
+    else {
+        my ($part, @value) = $self->_start_with( id => '_design/' );
+        $sth = $self->prepare_sql(
+            q{SELECT id, value FROM _DATA_ WHERE } . $part
+        );
+        $sth->execute(@value);
+    }
 
  DESIGN:
@@ -613 +667 @@
   $result_2 = $itr->next;
 
+  # post / put with specified views
+  $couch->put_with_views("find")->($obj);
+  $couch->post_with_views("foo", "bar")->($obj1, $obj2);
+
 =head1 DESCRIPTION