cleanup last insert id handling

[dbsrgits/DBIx-Data-Store-old.git] / lib / DBIx / Data / Store.pm

diff --git a/lib/DBIx/Data/Store.pm b/lib/DBIx/Data/Store.pm
index 2713c2c..b956b85 100644 (file)
--- a/lib/DBIx/Data/Store.pm
+++ b/lib/DBIx/Data/Store.pm
@@ -6,6 +6,7 @@ use DBIx::Connector;
 use DBIx::Data::Store::Command::Call;
 use DBIx::Data::Store::Command::Row;
 use DBIx::Data::Store::Command::Stream;
+use DBIx::Data::Store::Command::Closure;
 
 has 'connection' => (is => 'ro', lazy_build => 1); # , isa => 'DBIx::Connector'
 
@@ -41,6 +42,12 @@ method new_stream_command ($sql, $args, $column_order) {
   );
 }
 
+method new_closure_command ($code) {
+  return DBIx::Data::Store::Command::Closure->new(
+    run => $code, against => $self->connection
+  );
+}
+
 __PACKAGE__->meta->make_immutable;
 
 1;