Changeset 559

Timestamp:

01/24/09 00:30:59 (10 months ago)

Author:

ykerherve

Message:

- Added a new (experimental) GearmanDBI Driver that transports sql to a worker

using Gearman

- Refactored ObjectDriver::Driver::DBI a bit to allow the above

Location:

trunk/lib/Data/ObjectDriver/Driver

Files:

• DBI.pm (modified) (6 diffs)
• GearmanDBI.pm (added)

trunk/lib/Data/ObjectDriver/Driver/DBI.pm

@@ -119 +119 @@
 }
 
-sub fetch {
-    my $driver = shift;
-    my($rec, $class, $orig_terms, $orig_args) = @_;
+sub prepare_fetch {
+    my $driver = shift;
+    my($class, $orig_terms, $orig_args) = @_;
 
     ## Use (shallow) duplicates so the pre_search trigger can modify them.
@@ -130 +130 @@
     my $stmt = $driver->prepare_statement($class, $terms, $args);
 
+    my $sql = $stmt->as_sql;
+    $sql .= "\nFOR UPDATE" if $orig_args->{for_update};
+    return ($sql, $stmt->{bind}, $stmt)
+}
+
+sub fetch {
+    my $driver = shift;
+    my($rec, $class, $orig_terms, $orig_args) = @_;
+
+    my ($sql, $bind, $stmt) = $driver->prepare_fetch($class, $orig_terms, $orig_args);
+
     my @bind;
     my $map = $stmt->select_map;
@@ -136 +147 @@
     }
 
-    my $sql = $stmt->as_sql;
-    $sql .= "\nFOR UPDATE" if $orig_args->{for_update};
     my $dbh = $driver->r_handle($class->properties->{db});
     $driver->start_query($sql, $stmt->{bind});
+
     my $sth = $orig_args->{no_cached_prepare} ? $dbh->prepare($sql) : $driver->_prepare_cached($dbh, $sql);
     $sth->execute(@{ $stmt->{bind} });
@@ -145 +155 @@
 
     # need to slurp 'offset' rows for DBs that cannot do it themselves
-    if (!$driver->dbd->offset_implemented && $args->{offset}) {
-        for (1..$args->{offset}) {
+    if (!$driver->dbd->offset_implemented && $orig_args->{offset}) {
+        for (1..$orig_args->{offset}) {
             $sth->fetch;
         }
@@ -152 +162 @@
 
     return $sth;
+}
+
+sub load_object_from_rec {
+    my $driver = shift;
+    my ($class, $rec, $no_triggers) = @_;
+
+    my $obj = $class->new;
+    $obj->set_values_internal($rec);
+    ## Don't need a duplicate as there's no previous version in memory
+    ## to preserve.
+    $obj->{__is_stored} = 1;
+    $obj->call_trigger('post_load') unless $no_triggers;
+    return $obj;
 }
 
@@ -172 +195 @@
             return;
         }
-        my $obj;
-        $obj = $class->new;
-        $obj->set_values_internal($rec);
-        ## Don't need a duplicate as there's no previous version in memory
-        ## to preserve.
-        $obj->{__is_stored} = 1;
-        $obj->call_trigger('post_load') unless $args->{no_triggers};
-        $obj;
+        return $driver->load_object_from_rec($class, $rec, $args->{no_triggers});
     };