@@ -1,13 +1,14 @@

 package DBIx::Custom;

-use base 'Object::Simple';

 use strict;

 use warnings;

+use base 'Object::Simple';

 use Carp 'croak';

 use DBI;

 use DBIx::Custom::Result;

 use DBIx::Custom::SQL::Template;

+use DBIx::Custom::Transaction;

 __PACKAGE__->attr('dbh');

@@ -356,55 +357,7 @@ sub _build_bind_values {

     return \@bind_values;

 }

-sub run_transaction {

-    my ($self, $transaction) = @_;

-    

-    # Check auto commit

-    croak("AutoCommit must be true before transaction start")

-      unless $self->_auto_commit;

-    

-    # Auto commit off

-    $self->_auto_commit(0);

-    

-    # Run transaction

-    eval {$transaction->($self)};

-    

-    # Tranzaction error

-    my $transaction_error = $@;

-    

-    # Tranzaction is failed.

-    if ($transaction_error) {

-        # Rollback

-        eval{$self->dbh->rollback};

-        

-        # Rollback error

-        my $rollback_error = $@;

-        

-        # Auto commit on

-        $self->_auto_commit(1);

-        

-        if ($rollback_error) {

-            # Rollback is failed

-            croak("${transaction_error}Rollback is failed : $rollback_error");

-        }

-        else {

-            # Rollback is success

-            croak("${transaction_error}Rollback is success");

-        }

-    }

-    # Tranzaction is success

-    else {

-        # Commit

-        eval{$self->dbh->commit};

-        my $commit_error = $@;

-        

-        # Auto commit on

-        $self->_auto_commit(1);

-        

-        # Commit is failed

-        croak($commit_error) if $commit_error;

-    }

-}

+sub transaction { DBIx::Custom::Transaction->new(dbi => shift) }

 sub last_insert_id {

     my $self = shift;

@@ -726,11 +679,11 @@ DBIx::Custom - Customizable DBI

 =head1 VERSION

-Version 0.0906

+Version 0.1001

 =cut

-our $VERSION = '0.0906';

+our $VERSION = '0.1001';

 =head1 SYNOPSYS

@@ -1038,11 +991,11 @@ Return value of query method is L<DBIx::Custom::Result> object

 See also L<DBIx::Custom::Result>.

-=head2 run_transaction

+=head2 transaction

-Run transaction

+Get L<DBIx::Custom::Transaction> object, and you run a transaction.

-    $dbi->run_transaction(sub {

+    $dbi->transaction->run(sub {

         my $dbi = shift;

         # do something

@@ -0,0 +1,106 @@

+package DBIx::Custom::Transaction;

+

+use strict;

+use warnings;

+

+use base 'Object::Simple';

+use Carp 'croak';

+

+__PACKAGE__->attr('dbi');

+

+sub run {

+    my ($self, $transaction) = @_;

+    

+    # DBIx::Custom object

+    my $dbi = $self->dbi;

+    

+    # Shorcut

+    return unless $dbi;

+    

+    # Check auto commit

+    croak("AutoCommit must be true before transaction start")

+      unless $dbi->_auto_commit;

+    

+    # Auto commit off

+    $dbi->_auto_commit(0);

+    

+    # Run transaction

+    eval {$transaction->()};

+    

+    # Tranzaction error

+    my $transaction_error = $@;

+    

+    # Tranzaction is failed.

+    if ($transaction_error) {

+        # Rollback

+        eval{$dbi->dbh->rollback};

+        

+        # Rollback error

+        my $rollback_error = $@;

+        

+        # Auto commit on

+        $dbi->_auto_commit(1);

+        

+        if ($rollback_error) {

+            # Rollback is failed

+            croak("${transaction_error}Rollback is failed : $rollback_error");

+        }

+        else {

+            # Rollback is success

+            croak("${transaction_error}Rollback is success");

+        }

+    }

+    # Tranzaction is success

+    else {

+        # Commit

+        eval{$dbi->dbh->commit};

+        my $commit_error = $@;

+        

+        # Auto commit on

+        $dbi->_auto_commit(1);

+        

+        # Commit is failed

+        croak($commit_error) if $commit_error;

+    }

+}

+

+1;

+

+=head1 NAME

+

+DBIx::Custom::TransactionScope - Transaction scope

+

+=head1 SYNOPSYS

+

+    use DBIx::Custom::SQLite;

+    

+    # New

+    my $dbi = DBIx::Custom::SQLite->new(user => 'taro', $password => 'kliej&@K',

+                                        database => 'sample');

+    

+    # Connect memory database

+    my $dbi->connect_memory;

+

+=head1 ATTRIBUTES

+

+=head2 dbi

+

+=head1 METHODS

+

+=head2 run

+

+=head1 AUTHOR

+

+Yuki Kimoto, C<< <kimoto.yuki at gmail.com> >>

+

+Github L<http://github.com/yuki-kimoto>

+

+I develope this module L<http://github.com/yuki-kimoto/DBIx-Custom>

+

+=head1 Copyright & lisence

+

+Copyright 2009 Yuki Kimoto, all rights reserved.

+

+This program is free software; you can redistribute it and/or modify it

+under the same terms as Perl itself.

+

@@ -432,11 +432,10 @@ is_deeply($rows, [{key1 => 6, key2 => 6, key3 => 6, key4 => 6, key5 => 5},

                   {key1 => 6, key2 => 7, key3 => 8, key4 => 9, key5 => 10}], "$test : update tag #update with table name dot");

-test 'run_tansaction';

+test 'transaction';

 $dbi->do($DROP_TABLE->{0});

 $dbi->do($CREATE_TABLE->{0});

-$dbi->run_transaction(sub {

-    my $dbi = shift;

+$dbi->transaction->run(sub {

     $insert_tmpl = 'insert into table1 {insert key1 key2}';

     $dbi->query($insert_tmpl, {key1 => 1, key2 => 2});

     $dbi->query($insert_tmpl, {key1 => 3, key2 => 4});

@@ -449,8 +448,7 @@ $dbi->do($DROP_TABLE->{0});

 $dbi->do($CREATE_TABLE->{0});

 $dbi->dbh->{RaiseError} = 0;

 eval{

-    $dbi->run_transaction(sub {

-        my $dbi = shift;

+    $dbi->transaction->run(sub {

         $insert_tmpl = 'insert into table1 {insert key1 key2}';

         $dbi->query($insert_tmpl, {key1 => 1, key2 => 2});

         die "Fatal Error";

@@ -464,9 +462,10 @@ $rows   = $result->fetch_hash_all;

 is_deeply($rows, [], "$test : rollback");

+

 test 'Error case';

 $dbi = DBIx::Custom->new;

-eval{$dbi->run_transaction};

+eval{$dbi->transaction->run};

 like($@, qr/Not yet connect to database/, "$test : Yet Connected");

 $dbi = DBIx::Custom->new(data_source => 'dbi:SQLit');

@@ -476,9 +475,9 @@ ok($@, "$test : connect error");

 $dbi = DBIx::Custom->new($NEW_ARGS->{0});

 $dbi->connect;

 $dbi->dbh->{AutoCommit} = 0;

-eval{$dbi->run_transaction()};

+eval{$dbi->transaction->run};

 like($@, qr/AutoCommit must be true before transaction start/,

-         "$test : run_transaction auto commit is false");

+         "$test : transaction auto commit is false");

 $dbi = DBIx::Custom->new($NEW_ARGS->{0});

 $sql = 'laksjdf';