Changeset 33533

Timestamp:

05/23/09 22:18:26 (4 years ago)

Author:

kazuho

Message:

switch to rwlock

Files:

• lang/perl/DBIx-Distributed/trunk/lib/DBIx/Distributed/Driver/Direct.pm (modified) (1 diff)

lang/perl/DBIx-Distributed/trunk/lib/DBIx/Distributed/Driver/Direct.pm

@@ -238 +238 @@
 
 sub _exec_sql {
-    my ($self, $params, $cb, $sql, @values) = @_;
-    # obtain database handle (and lock)
-    $self->_dbh($self->driver->find_dbh_cb->($self->_dtable, $self->key))
-        unless $self->_dbh;
+    my ($self, $params, $is_read, $sql, @values) = @_;
     # record sql
     $self->driver->_record_sql($sql, @values);
     my $attr = $params->{attr} || {};
-    $cb ||= sub {
-        $self->_dbh->do(@_);
-    };
-    $cb->($sql, $attr, @values);
+    # obtain database handle (and lock)
+    $self->_dbh(
+        $self->driver->find_dbh_cb->($self->_dtable, $self->key, $is_read),
+    ) unless $self->_dbh;
+    # execute
+    if ($is_read) {
+        return $self->_dbh->selectall_arrayref($sql, $attr, @values);
+    } else {
+        return $self->_dbh->do($sql, $attr, @values);
+    }
 }