@@ -308,7 +308,7 @@ sub _build_bind_values {

         # Filter

         push @bind_values, 

-             $filter ? $filter->($value, $table, $column, $self->filters)

+             $filter ? $filter->($value, $table, $column, $self)

                      : $value;

     }

@@ -317,6 +317,62 @@ sub _build_bind_values {

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

+sub run_transaction {

+    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;

+    }

+}

+

 sub create_table {

     my ($self, $table, @column_definitions) = @_;

@@ -1139,6 +1195,10 @@ This method is same as DBI do method.

 See also L<DBI>

+=head2 run_transaction

+

+

+

 =head1 DBIx::Custom default configuration

 DBIx::Custom have DBI object.

@@ -1,71 +0,0 @@

-package DBIx::Custom::Column;

-

-use strict;

-use warnings;

-

-use base 'Object::Simple';

-

-__PACKAGE__->attr([qw/column id table/]);

-

-sub parse {

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

-    

-    $key ||= '';

-    

-    unless ($key =~ /\./) {

-        $self->column($key);

-        $self->table('');

-        return $self;

-    }

-    

-    my ($table, $column) = split /\./, $key;

-    

-    $self->column($column);

-    $self->table($table);

-    

-    return $self;

-}

-

-1;

-

-=head1 NAME

-

-DBIx::Custom::Column - DBIx::Custom column

-

-=head1 SYNOPSIS

-    

-    # New

-    my $column = DBIx::Custom::Column->new;

-    

-    # Parse

-    $column->parse('books.author@IDxxx');

-    

-    # Attributes

-    my $name  = $column->name;

-    my $table = $column->table;

-    my $id    = $column->id;

-

-=head1 ATTRIBUTES

-

-=head2 id

-

-    $column = $column->id($id);

-    $id     = $column->id

-

-=head2 name

-

-    $column = $column->name($name);

-    $name   = $column->name

-

-=head2 table

-

-    $column = $column->table($table);

-    $table  = $column->table

-

-=head1 METHODS

-

-=head2 parse

-

-    $column->parse('books.author@IDxxx');

-

-=cut

@@ -1,96 +0,0 @@

-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::Transaction - Transaction

-

-=head1 SYNOPSYS

-    

-    use DBIx::Custom::Transaction

-    my $txn = DBIx::Custom::Transaction->new(dbi => DBIx::Custom->new);

-    $txn->run(sub { ... });

-    

-=head1 ATTRIBUTES

-

-=head2 dbi

-

-    $self = $txn->dbi($dbi);

-    $dbi  = $txn->dbi;

-    

-=head1 METHODS

-

-=head2 run

-    

-    $txn->run(

-        sub {

-            # Transaction

-        }

-    );

-

-=cut

@@ -397,7 +397,7 @@ is_deeply($rows, [{key1 => 4, key2 => 4, key3 => 4, key4 => 4, key5 => 5},

 test 'transaction';

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

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

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

+$dbi->run_transaction(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});

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

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

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

 eval{

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

+    $dbi->run_transaction(sub {

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

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

         die "Fatal Error";

@@ -427,7 +427,7 @@ is_deeply($rows, [], "$test : rollback");

 test 'Error case';

 $dbi = DBIx::Custom->new;

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

+eval{$dbi->run_transaction};

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

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

@@ -437,7 +437,7 @@ ok($@, "$test : connect error");

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

 $dbi->connect;

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

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

+eval{$dbi->run_transaction};

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

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

@@ -1,69 +0,0 @@

-use Test::More;

-use strict;

-use warnings;

-use utf8;

-use Encode qw/decode encode/;

-

-BEGIN {

-    eval { require DBD::SQLite; 1 }

-        or plan skip_all => 'DBD::SQLite required';

-    eval { DBD::SQLite->VERSION >= 1 }

-        or plan skip_all => 'DBD::SQLite >= 1.00 required';

-

-    plan 'no_plan';

-    use_ok('DBIx::Custom');

-}

-

-# Function for test name

-my $test;

-sub test {

-    $test = shift;

-}

-

-# Constant varialbes for test

-my $CREATE_TABLE = {

-    0 => 'create table table1 (key1 char(255), key2 char(255));',

-    1 => 'create table table1 (key1 char(255), key2 char(255), key3 char(255), key4 char(255), key5 char(255));',

-    2 => 'create table table2 (key1 char(255), key3 char(255));'

-};

-

-my $SELECT_TMPL = {

-    0 => 'select * from table1;'

-};

-

-my $DROP_TABLE = {

-    0 => 'drop table table1'

-};

-

-my $NEW_ARGS = {

-    0 => {data_source => 'dbi:SQLite:dbname=:memory:'}

-};

-

-# Variables for test

-my $dbi;

-my $decoded_str;

-my $encoded_str;

-my $array;

-my $ret_val;

-

-use DBIx::Custom::Basic;

-

-test 'Filter';

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

-ok($dbi->filters->{encode_utf8}, "$test : exists default_bind_filter");

-ok($dbi->filters->{decode_utf8}, "$test : exists default_fetch_filter");

-

-$ret_val = $dbi->utf8_filter_on;

-is($dbi->bind_filter, $dbi->filters->{encode_utf8}, 'default bind filter');

-is($dbi->fetch_filter, $dbi->filters->{decode_utf8}, 'default fetch filter');

-is(ref $ret_val, 'DBIx::Custom::Basic', "$test : retern value");

-

-$decoded_str = 'あ';

-$encoded_str = $dbi->bind_filter->($decoded_str);

-is($encoded_str, encode('UTF-8', $decoded_str), "$test : encode utf8");

-is($decoded_str, $dbi->fetch_filter->($encoded_str), "$test : fetch_filter");

-

-$decoded_str = 'a';

-$encoded_str = $dbi->bind_filter->($decoded_str);

-is($encoded_str, encode('UTF-8', $decoded_str), "$test : upgrade and encode utf8");

-is($decoded_str, $dbi->fetch_filter->($encoded_str), "$test : fetch_filter");

@@ -1,67 +0,0 @@

-use Test::More;

-use strict;

-use warnings;

-

-BEGIN {

-    eval { require Time::Piece; 1 }

-        or plan skip_all => 'Time::Piece required';

-    

-    eval { Time::Piece->VERSION >= 1.15 }

-        or plan skip_all => 'Time::Piece >= 1.15 requred';

-        

-    plan 'no_plan';

-    use_ok('DBIx::Custom');

-}

-

-# Function for test name

-my $test;

-sub test {

-    $test = shift;

-}

-

-# Varialbe for tests

-

-my $format;

-my $data;

-my $timepiece;

-my $dbi;

-

-use DBIx::Custom::Basic;

-

-

-test 'SQL99 format';

-$dbi = DBIx::Custom::Basic->new;

-$data   = '2009-01-02 03:04:05';

-$format = $dbi->formats->{'SQL99_datetime'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : datetime date");

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : datetime time");

-

-$data   = '2009-01-02';

-$format = $dbi->formats->{'SQL99_date'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : date");

-

-$data   = '03:04:05';

-$format = $dbi->formats->{'SQL99_time'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : time");

-

-

-test 'ISO-8601 format';

-$data   = '2009-01-02T03:04:05';

-$format = $dbi->formats->{'ISO-8601_datetime'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : datetime date");

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : datetime time");

-

-$data   = '2009-01-02';

-$format = $dbi->formats->{'ISO-8601_date'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : date");

-

-$data   = '03:04:05';

-$format = $dbi->formats->{'ISO-8601_time'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : time");

-

@@ -1,36 +0,0 @@

-use Test::More;

-use strict;

-use warnings;

-

-# user password database

-our ($USER, $PASSWORD, $DATABASE) = connect_info();

-

-plan skip_all => 'private MySQL test' unless $USER;

-

-plan 'no_plan';

-

-use DBIx::Custom;

-use Scalar::Util 'blessed';

-{

-    my $dbi = DBIx::Custom->new(

-        user => $USER,

-        password => $PASSWORD,

-        data_source => "dbi:mysql:dbname=$DATABASE"

-    );

-    $dbi->connect;

-    

-    ok(blessed $dbi->dbh);

-    can_ok($dbi->dbh, qw/prepare/);

-}

-

-sub connect_info {

-    my $file = 'password.tmp';

-    open my $fh, '<', $file

-      or return;

-    

-    my ($user, $password, $database) = split(/\s/, (<$fh>)[0]);

-    

-    close $fh;

-    

-    return ($user, $password, $database);

-}

@@ -1,223 +0,0 @@

-use Test::More 'no_plan';

-use strict;

-use warnings;

-

-use DBIx::Custom;

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

-

-# Function for test name

-my $test;

-sub test {

-    $test = shift;

-}

-

-# Variables for test

-our $SQL_TMPL = {

-    0 => DBIx::Custom::SQL::Template->new->tag_start(0),

-    1 => DBIx::Custom::SQL::Template->new->tag_start(1),

-    2 => DBIx::Custom::SQL::Template->new->tag_start(2)

-};

-my $dbi;

-

-

-test 'Constructor';

-$dbi = DBIx::Custom->new(

-    user => 'a',

-    database => 'a',

-    password => 'b',

-    data_source => 'c',

-    options => {d => 1, e => 2},

-    filters => {

-        f => 3,

-    },

-    bind_filter => 'f',

-    fetch_filter => 'g',

-    result_class => 'g',

-    sql_tmpl => $SQL_TMPL->{0},

-);

-is_deeply($dbi,{user => 'a', database => 'a', password => 'b', data_source => 'c', 

-                options => {d => 1, e => 2}, filters => {f => 3}, bind_filter => 'f',

-                fetch_filter => 'g', result_class => 'g',

-                sql_tmpl => $SQL_TMPL->{0}}, $test);

-isa_ok($dbi, 'DBIx::Custom');

-

-

-test 'Sub class constructor';

-{

-    package DBIx::Custom::T1;

-    use base 'DBIx::Custom';

-    

-    __PACKAGE__

-      ->user('a')

-      ->database('a')

-      ->password('b')

-      ->data_source('c')

-      ->options({d => 1, e => 2})

-      ->filters({f => 3})

-      ->formats({f => 3})

-      ->bind_filter('f')

-      ->fetch_filter('g')

-      ->result_class('DBIx::Custom::Result')

-      ->sql_tmpl($SQL_TMPL->{0})

-    ;

-}

-$dbi = DBIx::Custom::T1->new(

-    user => 'ao',

-    database => 'ao',

-    password => 'bo',

-    data_source => 'co',

-    options => {do => 10, eo => 20},

-    filters => {

-        fo => 30,

-    },

-    formats => {

-        fo => 30,

-    },

-    bind_filter => 'fo',

-    fetch_filter => 'go',

-    result_class => 'ho',

-    sql_tmpl => $SQL_TMPL->{0},

-);

-is($dbi->user, 'ao', "$test : user");

-is($dbi->database, 'ao', "$test : database");

-is($dbi->password, 'bo', "$test : passowr");

-is($dbi->data_source, 'co', "$test : data_source");

-is_deeply($dbi->options, {do => 10, eo => 20}, "$test : options");

-is_deeply(scalar $dbi->filters, {fo => 30}, "$test : filters");

-is_deeply(scalar $dbi->formats, {fo => 30}, "$test : formats");

-is($dbi->bind_filter, 'fo', "$test : bind_filter");

-is($dbi->fetch_filter, 'go', "$test : fetch_filter");

-is($dbi->result_class, 'ho', "$test : result_class");

-is($dbi->sql_tmpl->tag_start, 0, "$test : sql_tmpl");

-isa_ok($dbi, 'DBIx::Custom::T1');

-

-test 'Sub class constructor default';

-$dbi = DBIx::Custom::T1->new;

-is($dbi->user, 'a', "$test : user");

-is($dbi->database, 'a', "$test : database");

-is($dbi->password, 'b', "$test : password");

-is($dbi->data_source, 'c', "$test : data_source");

-is_deeply($dbi->options, {d => 1, e => 2}, "$test : options");

-is_deeply($dbi->filters, {f => 3}, "$test : filters");

-is_deeply($dbi->formats, {f => 3}, "$test : formats");

-is($dbi->bind_filter, 'f', "$test : bind_filter");

-is($dbi->fetch_filter, 'g', "$test : fetch_filter");

-is($dbi->result_class, 'DBIx::Custom::Result', "$test : result_class");

-is($dbi->sql_tmpl->tag_start, 0, "$test : sql_tmpl");

-isa_ok($dbi, 'DBIx::Custom::T1');

-

-

-test 'Sub sub class constructor default';

-{

-    package DBIx::Custom::T1_2;

-    use base 'DBIx::Custom::T1';

-}

-$dbi = DBIx::Custom::T1_2->new;

-is($dbi->user, 'a', "$test : user");

-is($dbi->database, 'a', "$test : database");

-is($dbi->password, 'b', "$test : passowrd");

-is($dbi->data_source, 'c', "$test : data_source");

-is_deeply($dbi->options, {d => 1, e => 2}, "$test : options");

-is_deeply(scalar $dbi->filters, {f => 3}, "$test : filters");

-is_deeply(scalar $dbi->formats, {f => 3}, "$test : formats");

-is($dbi->bind_filter, 'f', "$test : bind_filter");

-is($dbi->fetch_filter, 'g', "$test : fetch_filter");

-is($dbi->result_class, 'DBIx::Custom::Result', "$test : result_class");

-is($dbi->sql_tmpl->tag_start, 0, "$test sql_tmpl");

-isa_ok($dbi, 'DBIx::Custom::T1_2');

-

-

-test 'Customized sub class constructor default';

-{

-    package DBIx::Custom::T1_3;

-    use base 'DBIx::Custom::T1';

-    

-    __PACKAGE__

-      ->user('ao')

-      ->database('ao')

-      ->password('bo')

-      ->data_source('co')

-      ->options({do => 10, eo => 20})

-      ->filters({fo => 30})

-      ->formats({fo => 30})

-      ->bind_filter('fo')

-      ->fetch_filter('go')

-      ->result_class('ho')

-      ->sql_tmpl($SQL_TMPL->{1})

-    ;

-}

-$dbi = DBIx::Custom::T1_3->new;

-is($dbi->user, 'ao', "$test : user");

-is($dbi->database, 'ao', "$test : database");

-is($dbi->password, 'bo', "$test : password");

-is($dbi->data_source, 'co', "$test : data_source");

-is_deeply($dbi->options, {do => 10, eo => 20}, "$test : options");

-is_deeply(scalar $dbi->filters, {fo => 30}, "$test : filters");

-is_deeply(scalar $dbi->formats, {fo => 30}, "$test : formats");

-is($dbi->bind_filter, 'fo', "$test : bind_filter");

-is($dbi->fetch_filter, 'go', "$test : fetch_filter");

-is($dbi->result_class, 'ho', "$test : result_class");

-is($dbi->sql_tmpl->tag_start, 1, "$test : sql_tmpl");

-isa_ok($dbi, 'DBIx::Custom::T1_3');

-

-

-test 'Customized sub class constructor';

-$dbi = DBIx::Custom::T1_3->new(

-    user => 'a',

-    database => 'a',

-    password => 'b',

-    data_source => 'c',

-    options => {d => 1, e => 2},

-    filters => {

-        f => 3,

-    },

-    formats => {

-        f => 3,

-    },

-    bind_filter => 'f',

-    fetch_filter => 'g',

-    result_class => 'h',

-    sql_tmpl => $SQL_TMPL->{2},

-);

-is($dbi->user, 'a', "$test : user");

-is($dbi->database, 'a', "$test : database");

-is($dbi->password, 'b', "$test : password");

-is($dbi->data_source, 'c', "$test : data_source");

-is_deeply($dbi->options, {d => 1, e => 2}, "$test : options");

-is_deeply($dbi->filters, {f => 3}, "$test : filters");

-is_deeply($dbi->formats, {f => 3}, "$test : formats");

-is($dbi->bind_filter, 'f', "$test : bind_filter");

-is($dbi->fetch_filter, 'g', "$test : fetch_filter");

-is($dbi->result_class, 'h', "$test : result_class");

-is($dbi->sql_tmpl->tag_start, 2, "$test : sql_tmpl");

-isa_ok($dbi, 'DBIx::Custom');

-

-

-test 'add_filters';

-$dbi = DBIx::Custom->new;

-$dbi->add_filter(a => sub {1});

-is($dbi->filters->{a}->(), 1, $test);

-

-test 'add_formats';

-$dbi = DBIx::Custom->new;

-$dbi->add_format(a => sub {1});

-is($dbi->formats->{a}->(), 1, $test);

-

-test 'filter_off';

-$dbi = DBIx::Custom->new;

-$dbi->bind_filter('a');

-$dbi->fetch_filter('b');

-$dbi->filter_off;

-ok(!$dbi->bind_filter,  "$test : bind_filter  off");

-ok(!$dbi->fetch_filter, "$test : fetch_filter off");

-

-test 'Accessor';

-$dbi = DBIx::Custom->new;

-$dbi->options({opt1 => 1, opt2 => 2});

-is_deeply(scalar $dbi->options, {opt1 => 1, opt2 => 2}, "$test : options");

-

-$dbi->no_bind_filters(['a', 'b']);

-is_deeply(scalar $dbi->no_bind_filters, ['a', 'b'], "$test: no_bind_filters");

-

-$dbi->no_fetch_filters(['a', 'b']);

-is_deeply(scalar $dbi->no_fetch_filters, ['a', 'b'], "$test: no_fetch_filters");

@@ -1,47 +0,0 @@

-use Test::More;

-use strict;

-use warnings;

-

-# user password database

-our ($USER, $PASSWORD, $DATABASE) = connect_info();

-

-plan skip_all => 'private MySQL test' unless $USER;

-

-plan 'no_plan';

-

-# Function for test name

-my $test;

-sub test {

-    $test = shift;

-}

-

-

-# Functions for tests

-sub connect_info {

-    my $file = 'password.tmp';

-    open my $fh, '<', $file

-      or return;

-    

-    my ($user, $password, $database) = split(/\s/, (<$fh>)[0]);

-    

-    close $fh;

-    

-    return ($user, $password, $database);

-}

-

-

-# Constat variables for tests

-my $CLASS = 'DBIx::Custom::MySQL';

-

-# Varialbes for tests

-my $dbi;

-

-use DBIx::Custom::MySQL;

-

-test 'connect';

-$dbi = $CLASS->new(user => $USER, password => $PASSWORD,

-                    database => $DATABASE);

-$dbi->connect;

-is(ref $dbi->dbh, 'DBI::db', $test);

-

-

@@ -1,85 +0,0 @@

-use Test::More;

-use strict;

-use warnings;

-

-BEGIN {

-    eval { require Time::Piece; 1 }

-        or plan skip_all => 'Time::Piece required';

-    

-    eval { Time::Piece->VERSION >= 1.15 }

-        or plan skip_all => 'Time::Piece >= 1.15 requred';

-        

-    plan 'no_plan';

-    use_ok('DBIx::Custom');

-}

-

-# Function for test name

-my $test;

-sub test {

-    $test = shift;

-}

-

-# Varialbe for tests

-

-my $format;

-my $data;

-my $timepiece;

-my $dbi;

-

-use DBIx::Custom::MySQL;

-

-

-test 'SQL99 format';

-$dbi = DBIx::Custom::MySQL->new;

-$data   = '2009-01-02 03:04:05';

-$format = $dbi->formats->{'SQL99_datetime'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : datetime date");

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : datetime time");

-

-$data   = '2009-01-02';

-$format = $dbi->formats->{'SQL99_date'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : date");

-

-$data   = '03:04:05';

-$format = $dbi->formats->{'SQL99_time'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : time");

-

-

-test 'ISO-8601 format';

-$data   = '2009-01-02T03:04:05';

-$format = $dbi->formats->{'ISO-8601_datetime'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : datetime date");

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : datetime time");

-

-$data   = '2009-01-02';

-$format = $dbi->formats->{'ISO-8601_date'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : date");

-

-$data   = '03:04:05';

-$format = $dbi->formats->{'ISO-8601_time'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : time");

-

-

-test 'default format';

-$data   = '2009-01-02 03:04:05';

-$format = $dbi->formats->{'datetime'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : datetime date");

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : datetime time");

-

-$data   = '2009-01-02';

-$format = $dbi->formats->{'date'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : date");

-

-$data   = '03:04:05';

-$format = $dbi->formats->{'time'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : time");

-

@@ -1,37 +0,0 @@

-use Test::More 'no_plan';

-

-use strict;

-use warnings;

-use DBIx::Custom::Query;

-

-# Function for test name

-my $test;

-sub test{

-    $test = shift;

-}

-

-# Variables for test

-my $query;

-

-test 'Accessors';

-$query = DBIx::Custom::Query->new(

-    sql              => 'a',

-    key_infos        => 'b',

-    bind_filter      => 'c',

-    no_bind_filters  => [qw/d e/],

-    sth              => 'e',

-    fetch_filter     => 'f',

-    no_fetch_filters => [qw/g h/],

-);

-

-is($query->sql, 'a', "$test : sql");

-is($query->key_infos, 'b', "$test : key_infos ");

-is($query->bind_filter, 'c', "$test : bind_filter");

-is_deeply($query->no_bind_filters, [qw/d e/], "$test : no_bind_filters");

-is_deeply($query->_no_bind_filters, {d => 1, e => 1}, "$test : _no_bind_filters");

-is_deeply($query->no_fetch_filters, [qw/g h/], "$test : no_fetch_filters");

-is($query->sth, 'e', "$test : sth");

-

-$query->no_bind_filters(undef);

-is_deeply(scalar $query->_no_bind_filters, {}, "$test _no_bind_filters undef value");

-

@@ -1,259 +0,0 @@

-use Test::More;

-use strict;

-use warnings;

-use DBI;

-

-BEGIN {

-    eval { require DBD::SQLite; 1 }

-        or plan skip_all => 'DBD::SQLite required';

-    eval { DBD::SQLite->VERSION >= 1 }

-        or plan skip_all => 'DBD::SQLite >= 1.00 required';

-

-    plan 'no_plan';

-    use_ok('DBIx::Custom::Result');

-}

-

-my $test;

-sub test {

-    $test = shift;

-}

-

-sub query {

-    my ($dbh, $sql) = @_;

-    my $sth = $dbh->prepare($sql);

-    $sth->execute;

-    return DBIx::Custom::Result->new(sth => $sth);

-}

-

-my $dbh;

-my $sql;

-my $sth;

-my @row;

-my $row;

-my @rows;

-my $rows;

-my $result;

-my $fetch_filter;

-my @error;

-my $error;

-

-$dbh = DBI->connect('dbi:SQLite:dbname=:memory:', undef, undef, {PrintError => 0, RaiseError => 1});

-$dbh->do("create table table1 (key1 char(255), key2 char(255));");

-$dbh->do("insert into table1 (key1, key2) values ('1', '2');");

-$dbh->do("insert into table1 (key1, key2) values ('3', '4');");

-

-$sql = "select key1, key2 from table1";

-

-test 'fetch scalar context';

-$result = query($dbh, $sql);

-@rows = ();

-while (my $row = $result->fetch) {

-    push @rows, [@$row];

-}

-is_deeply(\@rows, [[1, 2], [3, 4]], $test);

-

-

-test 'fetch list context';

-$result = query($dbh, $sql);

-@rows = ();

-while (my @row = $result->fetch) {

-    push @rows, [@row];

-}

-is_deeply(\@rows, [[1, 2], [3, 4]], $test);

-

-test 'fetch_hash scalar context';

-$result = query($dbh, $sql);

-@rows = ();

-while (my $row = $result->fetch_hash) {

-    push @rows, {%$row};

-}

-is_deeply(\@rows, [{key1 => 1, key2 => 2}, {key1 => 3, key2 => 4}], $test);

-

-

-test 'fetch hash list context';

-$result = query($dbh, $sql);

-@rows = ();

-while (my %row = $result->fetch_hash) {

-    push @rows, {%row};

-}

-is_deeply(\@rows, [{key1 => 1, key2 => 2}, {key1 => 3, key2 => 4}], $test);

-

-

-test 'fetch_single';

-$result = query($dbh, $sql);

-$row = $result->fetch_single;

-is_deeply($row, [1, 2], "$test : row");

-$row = $result->fetch;

-ok(!$row, "$test : finished");

-

-

-test 'fetch_single list context';

-$result = query($dbh, $sql);

-@row = $result->fetch_single;

-is_deeply([@row], [1, 2], "$test : row");

-@row = $result->fetch;

-ok(!@row, "$test : finished");

-

-

-test 'fetch_hash_single';

-$result = query($dbh, $sql);

-$row = $result->fetch_hash_single;

-is_deeply($row, {key1 => 1, key2 => 2}, "$test : row");

-$row = $result->fetch_hash;

-ok(!$row, "$test : finished");

-

-

-test 'fetch_hash_single list context';

-$result = query($dbh, $sql);

-@row = $result->fetch_hash_single;

-is_deeply({@row}, {key1 => 1, key2 => 2}, "$test : row");

-@row = $result->fetch_hash;

-ok(!@row, "$test : finished");

-

-

-test 'fetch_rows';

-$dbh->do("insert into table1 (key1, key2) values ('5', '6');");

-$dbh->do("insert into table1 (key1, key2) values ('7', '8');");

-$dbh->do("insert into table1 (key1, key2) values ('9', '10');");

-$result = query($dbh, $sql);

-$rows = $result->fetch_rows(2);

-is_deeply($rows, [[1, 2],

-                  [3, 4]], "$test : fetch_rows first");

-$rows = $result->fetch_rows(2);

-is_deeply($rows, [[5, 6],

-                  [7, 8]], "$test : fetch_rows secound");

-$rows = $result->fetch_rows(2);

-is_deeply($rows, [[9, 10]], "$test : fetch_rows third");

-$rows = $result->fetch_rows(2);

-ok(!$rows);

-

-

-test 'fetch_rows list context';

-$result = query($dbh, $sql);

-@rows = $result->fetch_rows(2);

-is_deeply([@rows], [[1, 2],

-                  [3, 4]], "$test : fetch_rows first");

-@rows = $result->fetch_rows(2);

-is_deeply([@rows], [[5, 6],

-                  [7, 8]], "$test : fetch_rows secound");

-@rows = $result->fetch_rows(2);

-is_deeply([@rows], [[9, 10]], "$test : fetch_rows third");

-@rows = $result->fetch_rows(2);

-ok(!@rows);

-

-

-test 'fetch_rows error';

-$result = query($dbh, $sql);

-eval {$result->fetch_rows};

-like($@, qr/Row count must be specified/, "$test : Not specified row count");

-

-

-test 'fetch_hash_rows';

-$result = query($dbh, $sql);

-$rows = $result->fetch_hash_rows(2);

-is_deeply($rows, [{key1 => 1, key2 => 2},

-                  {key1 => 3, key2 => 4}], "$test : fetch_rows first");

-$rows = $result->fetch_hash_rows(2);

-is_deeply($rows, [{key1 => 5, key2 => 6},

-                  {key1 => 7, key2 => 8}], "$test : fetch_rows secound");

-$rows = $result->fetch_hash_rows(2);

-is_deeply($rows, [{key1 => 9, key2 => 10}], "$test : fetch_rows third");

-$rows = $result->fetch_hash_rows(2);

-ok(!$rows);

-

-

-test 'fetch_rows list context';

-$result = query($dbh, $sql);

-@rows = $result->fetch_hash_rows(2);

-is_deeply([@rows], [{key1 => 1, key2 => 2},

-                    {key1 => 3, key2 => 4}], "$test : fetch_rows first");

-@rows = $result->fetch_hash_rows(2);

-is_deeply([@rows], [{key1 => 5, key2 => 6},

-                    {key1 => 7, key2 => 8}], "$test : fetch_rows secound");

-@rows = $result->fetch_hash_rows(2);

-is_deeply([@rows], [{key1 => 9, key2 => 10}], "$test : fetch_rows third");

-@rows = $result->fetch_hash_rows(2);

-ok(!@rows);

-$dbh->do("delete from table1 where key1 = 5 or key1 = 7 or key1 = 9");

-

-

-test 'fetch_rows error';

-$result = query($dbh, $sql);

-eval {$result->fetch_hash_rows};

-like($@, qr/Row count must be specified/, "$test : Not specified row count");

-

-

-test 'fetch_all';

-$result = query($dbh, $sql);

-$rows = $result->fetch_all;

-is_deeply($rows, [[1, 2], [3, 4]], $test);

-

-test 'fetch_all list context';

-$result = query($dbh, $sql);

-@rows = $result->fetch_all;

-is_deeply(\@rows, [[1, 2], [3, 4]], $test);

-

-

-test 'fetch_hash_all';

-$result = query($dbh, $sql);

-@rows = $result->fetch_hash_all;

-is_deeply($rows, [[1, 2], [3, 4]], $test);

-

-

-test 'fetch_hash_all list context';

-$result = query($dbh, $sql);

-@rows = $result->fetch_all;

-is_deeply(\@rows, [[1, 2], [3, 4]], $test);

-

-

-test 'fetch filter';

-$fetch_filter = sub {

-    my ($value, $key, $dbi, $infos) = @_;

-    my ($type, $sth, $i) = @{$infos}{qw/type sth index/};

-    

-    if ($key eq 'key1' && $value == 1 && $type =~ /char/i && $i == 0 && $sth->{TYPE}->[$i] eq $type) {

-        return $value * 3;

-    }

-    return $value;

-};

-

-$result = query($dbh, $sql);

-$result->fetch_filter($fetch_filter);

-$rows = $result->fetch_all;

-is_deeply($rows, [[3, 2], [3, 4]], "$test array");

-

-$result = query($dbh, $sql);

-$result->fetch_filter($fetch_filter);

-$rows = $result->fetch_hash_all;

-is_deeply($rows, [{key1 => 3, key2 => 2}, {key1 => 3, key2 => 4}], "$test hash");

-

-$result = query($dbh, $sql);

-$result->no_fetch_filters(['key1']);

-$rows = $result->fetch_all;

-is_deeply($rows, [[1, 2], [3, 4]], "$test array no filter keys");

-

-$result = query($dbh, $sql);

-$result->no_fetch_filters(['key1']);

-$rows = $result->fetch_hash_all;

-is_deeply($rows, [{key1 => 1, key2 => 2}, {key1 => 3, key2 => 4}], "$test hash no filter keys");

-

-

-test 'finish';

-$result = query($dbh, $sql);

-$result->fetch;

-$result->finish;

-ok(!$result->fetch, $test);

-

-test 'error'; # Cannot real test

-$result = query($dbh, $sql);

-$sth = $result->sth;

-

-@error = $result->error;

-is(scalar @error, 3, "$test list context count");

-is($error[0], $sth->errstr, "$test list context errstr");

-is($error[1], $sth->err, "$test list context err");

-is($error[2], $sth->state, "$test list context state");

-

-$error = $result->error;

-is($error, $sth->errstr, "$test scalar context");

-

@@ -1,198 +0,0 @@

-use strict;

-use warnings;

-

-use Test::More 'no_plan';

-

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

-

-# Function for test name

-my $test;

-sub test{

-    $test = shift;

-}

-

-# Variable for test

-my $datas;

-my $sql_tmpl;

-my $query;

-my $ret_val;

-my $clone;

-

-test "Various template pattern";

-$datas = [

-    # Basic tests

-    {   name            => 'placeholder basic',

-        tmpl            => "a {?  k1} b {=  k2} {<> k3} {>  k4} {<  k5} {>= k6} {<= k7} {like k8}", ,

-        sql_expected    => "a ? b k2 = ? k3 <> ? k4 > ? k5 < ? k6 >= ? k7 <= ? k8 like ?;",

-        key_infos_expected   => [

-            {original_key => 'k1', table => '', column => 'k1', access_keys => [['k1']]},

-            {original_key => 'k2', table => '', column => 'k2', access_keys => [['k2']]},

-            {original_key => 'k3', table => '', column => 'k3', access_keys => [['k3']]},

-            {original_key => 'k4', table => '', column => 'k4', access_keys => [['k4']]},

-            {original_key => 'k5', table => '', column => 'k5', access_keys => [['k5']]},

-            {original_key => 'k6', table => '', column => 'k6', access_keys => [['k6']]},

-            {original_key => 'k7', table => '', column => 'k7', access_keys => [['k7']]},

-            {original_key => 'k8', table => '', column => 'k8', access_keys => [['k8']]},

-        ],

-    },

-    {

-        name            => 'placeholder in',

-        tmpl            => "{in k1 3};",

-        sql_expected    => "k1 in (?, ?, ?);",

-        key_infos_expected   => [

-            {original_key => 'k1', table => '', column => 'k1', access_keys => [['k1', [0]]]},

-            {original_key => 'k1', table => '', column => 'k1', access_keys => [['k1', [1]]]},

-            {original_key => 'k1', table => '', column => 'k1', access_keys => [['k1', [2]]]},

-        ],

-    },

-    

-    # Table name

-    {

-        name            => 'placeholder with table name',

-        tmpl            => "{= a.k1} {= a.k2}",

-        sql_expected    => "a.k1 = ? a.k2 = ?;",

-        key_infos_expected  => [

-            {original_key => 'a.k1', table => 'a', column => 'k1', access_keys => [['a.k1'], ['a', 'k1']]},

-            {original_key => 'a.k2', table => 'a', column => 'k2', access_keys => [['a.k2'], ['a', 'k2']]},

-        ],

-    },

-    {   

-        name            => 'placeholder in with table name',

-        tmpl            => "{in a.k1 2} {in b.k2 2}",

-        sql_expected    => "a.k1 in (?, ?) b.k2 in (?, ?);",

-        key_infos_expected  => [

-            {original_key => 'a.k1', table => 'a', column => 'k1', access_keys => [['a.k1', [0]], ['a', 'k1', [0]]]},

-            {original_key => 'a.k1', table => 'a', column => 'k1', access_keys => [['a.k1', [1]], ['a', 'k1', [1]]]},

-            {original_key => 'b.k2', table => 'b', column => 'k2', access_keys => [['b.k2', [0]], ['b', 'k2', [0]]]},

-            {original_key => 'b.k2', table => 'b', column => 'k2', access_keys => [['b.k2', [1]], ['b', 'k2', [1]]]},

-        ],

-    },

-    {

-        name            => 'not contain tag',

-        tmpl            => "aaa",

-        sql_expected    => "aaa;",

-        key_infos_expected  => [],

-    }

-];

-

-for (my $i = 0; $i < @$datas; $i++) {

-    my $data = $datas->[$i];

-    my $sql_tmpl = DBIx::Custom::SQL::Template->new;

-    my $query = $sql_tmpl->create_query($data->{tmpl});

-    is($query->{sql}, $data->{sql_expected}, "$test : $data->{name} : sql");

-    is_deeply($query->{key_infos}, $data->{key_infos_expected}, "$test : $data->{name} : key_infos");

-}

-

-

-test 'Original tag processor';

-$sql_tmpl = DBIx::Custom::SQL::Template->new;

-

-$ret_val = $sql_tmpl->add_tag_processor(

-    p => sub {

-        my ($tag_name, $args) = @_;

-        

-        my $expand    = "$tag_name ? $args->[0] $args->[1]";

-        my $key_infos = [2];

-        return ($expand, $key_infos);

-    }

-);

-

-$query = $sql_tmpl->create_query("{p a b}");

-is($query->{sql}, "p ? a b;", "$test : add_tag_processor sql");

-is_deeply($query->{key_infos}, [2], "$test : add_tag_processor key_infos");

-isa_ok($ret_val, 'DBIx::Custom::SQL::Template');

-

-

-test "Tag processor error case";

-$sql_tmpl = DBIx::Custom::SQL::Template->new;

-

-

-eval{$sql_tmpl->create_query("{a }")};

-like($@, qr/Tag '{a }' in SQL template is not exist/, "$test : tag_processor not exist");

-

-$sql_tmpl->add_tag_processor({

-    q => 'string'

-});

-

-eval{$sql_tmpl->create_query("{q}", {})};

-like($@, qr/Tag processor 'q' must be code reference/, "$test : tag_processor not code ref");

-

-$sql_tmpl->add_tag_processor({

-   r => sub {} 

-});

-

-eval{$sql_tmpl->create_query("{r}")};

-like($@, qr/\QTag processor 'r' must return (\E\$expand\Q, \E\$key_infos\Q)/, "$test : tag processor return noting");

-

-$sql_tmpl->add_tag_processor({

-   s => sub { return ("a", "")} 

-});

-

-eval{$sql_tmpl->create_query("{s}")};

-like($@, qr/\QTag processor 's' must return (\E\$expand\Q, \E\$key_infos\Q)/, "$test : tag processor return not array key_infos");

-

-$sql_tmpl->add_tag_processor(

-    t => sub {return ("a", [])}

-);

-

-eval{$sql_tmpl->create_query("{t ???}")};

-like($@, qr/Tag '{t }' arguments cannot contain '?'/, "$test : cannot contain '?' in tag argument");

-

-

-test 'General error case';

-$sql_tmpl = DBIx::Custom::SQL::Template->new;

-$sql_tmpl->add_tag_processor(

-    a => sub {

-        return ("? ? ?", [[],[]]);

-    }

-);

-eval{$sql_tmpl->create_query("{a}")};

-like($@, qr/Placeholder count in SQL created by tag processor 'a' must be same as key informations count/, "$test placeholder count is invalid");

-

-

-test 'Default tag processor Error case';

-eval{$sql_tmpl->create_query("{= }")};

-like($@, qr/You must be pass key as argument to tag '{= }'/, "$test : basic '=' : key not exist");

-

-eval{$sql_tmpl->create_query("{in }")};

-like($@, qr/You must be pass key as first argument of tag '{in }'/, "$test : in : key not exist");

-

-eval{$sql_tmpl->create_query("{in a}")};

-like($@, qr/\QYou must be pass placeholder count as second argument of tag '{in }'\E\n\QUsage: {in \E\$key\Q \E\$placeholder_count\Q}/,

-     "$test : in : key not exist");

-

-eval{$sql_tmpl->create_query("{in a r}")};

-like($@, qr/\QYou must be pass placeholder count as second argument of tag '{in }'\E\n\QUsage: {in \E\$key\Q \E\$placeholder_count\Q}/,

-     "$test : in : key not exist");

-

-

-test 'Clone';

-$sql_tmpl = DBIx::Custom::SQL::Template->new;

-$sql_tmpl

-  ->tag_start('[')

-  ->tag_end(']')

-  ->tag_syntax('syntax')

-  ->tag_processors({a => 1, b => 2});

-

-$clone = $sql_tmpl->clone;

-is($clone->tag_start, $sql_tmpl->tag_start, "$test : tag_start");

-is($clone->tag_end, $sql_tmpl->tag_end, "$test : tag_end");

-is($clone->tag_syntax, $sql_tmpl->tag_syntax, "$test : tag_syntax");

-

-is_deeply( scalar $clone->tag_processors, scalar $sql_tmpl->tag_processors,

-          "$test : tag_processors deep clone");

-

-isnt($clone->tag_processors, $sql_tmpl->tag_processors, 

-     "$test : tag_processors reference not copy");

-

-$sql_tmpl->tag_processors(undef);

-

-$clone = $sql_tmpl->clone;

-is_deeply(scalar $clone->tag_processors, {}, "$test tag_processor undef copy");

-

-

-

-__END__

-

-

-

@@ -1,85 +0,0 @@

-use Test::More;

-use strict;

-use warnings;

-

-BEGIN {

-    eval { require Time::Piece; 1 }

-        or plan skip_all => 'Time::Piece required';

-    

-    eval { Time::Piece->VERSION >= 1.15 }

-        or plan skip_all => 'Time::Piece >= 1.15 requred';

-        

-    plan 'no_plan';

-    use_ok('DBIx::Custom');

-}

-

-# Function for test name

-my $test;

-sub test {

-    $test = shift;

-}

-

-# Varialbe for tests

-

-my $format;

-my $data;

-my $timepiece;

-my $dbi;

-

-use DBIx::Custom::SQLite;

-

-

-test 'SQL99 format';

-$dbi = DBIx::Custom::SQLite->new;

-$data   = '2009-01-02 03:04:05';

-$format = $dbi->formats->{'SQL99_datetime'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : datetime date");

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : datetime time");

-

-$data   = '2009-01-02';

-$format = $dbi->formats->{'SQL99_date'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : date");

-

-$data   = '03:04:05';

-$format = $dbi->formats->{'SQL99_time'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : time");

-

-

-test 'ISO-8601 format';

-$data   = '2009-01-02T03:04:05';

-$format = $dbi->formats->{'ISO-8601_datetime'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : datetime date");

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : datetime time");

-

-$data   = '2009-01-02';

-$format = $dbi->formats->{'ISO-8601_date'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : date");

-

-$data   = '03:04:05';

-$format = $dbi->formats->{'ISO-8601_time'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : time");

-

-

-test 'default format';

-$data   = '2009-01-02 03:04:05';

-$format = $dbi->formats->{'datetime'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : datetime date");

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : datetime time");

-

-$data   = '2009-01-02';

-$format = $dbi->formats->{'date'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%Y-%m-%d'), '2009-01-02', "$test : date");

-

-$data   = '03:04:05';

-$format = $dbi->formats->{'time'};

-$timepiece = Time::Piece->strptime($data, $format);

-is($timepiece->strftime('%H:%M:%S'), '03:04:05',  "$test : time");

-

@@ -1,79 +0,0 @@

-use Test::More;

-use strict;

-use warnings;

-use utf8;

-

-BEGIN {

-    eval { require DBD::SQLite; 1 }

-        or plan skip_all => 'DBD::SQLite required';

-    eval { DBD::SQLite->VERSION >= 1.25 }

-        or plan skip_all => 'DBD::SQLite >= 1.25 required';

-

-    plan 'no_plan';

-    use_ok('DBIx::Custom::SQLite');

-}

-

-# Function for test name

-my $test;

-sub test {

-    $test = shift;

-}

-

-# Constant varialbes for test

-my $CREATE_TABLE = {

-    0 => 'create table table1 (key1 char(255), key2 char(255));',

-    1 => 'create table table1 (key1 char(255), key2 char(255), key3 char(255), key4 char(255), key5 char(255));',

-    2 => 'create table table2 (key1 char(255), key3 char(255));'

-};

-

-

-# Variables for tests

-my $dbi;

-my $ret_val;

-my $rows;

-my $db_file;

-my $id;

-

-test 'connect_memory';

-$dbi = DBIx::Custom::SQLite->new;

-$dbi->connect_memory;

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

-ok(defined $ret_val, $test);

-$dbi->utf8_filter_on;

-$dbi->insert('table1', {key1 => 'あ', key2 => 2});

-$rows = $dbi->select('table1', {key1 => 'あ'})->fetch_hash_all;

-is_deeply($rows, [{key1 => 'あ', key2 => 2}], "$test : select rows");

-

-test 'connect_memory error';

-eval{$dbi->connect_memory};

-like($@, qr/Already connected/, "$test : already connected");

-

-test 'reconnect_memory';

-$dbi = DBIx::Custom::SQLite->new;

-$dbi->reconnect_memory;

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

-ok(defined $ret_val, "$test : connect first");

-$dbi->reconnect_memory;

-$ret_val = $dbi->do($CREATE_TABLE->{2});

-ok(defined $ret_val, "$test : connect first");

-

-test 'connect';

-$db_file  = 't/test.db';

-unlink $db_file if -f $db_file;

-$dbi = DBIx::Custom::SQLite->new(database => $db_file);

-$dbi->connect;

-ok(-f $db_file, "$test : database file");

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

-ok(defined $ret_val, "$test : database");

-$dbi->disconnect;

-unlink $db_file if -f $db_file;

-

-test 'last_insert_rowid';

-$dbi = DBIx::Custom::SQLite->new;

-$dbi->connect_memory;

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

-$dbi->insert('table1', {key1 => 1, key2 => 2});

-is($dbi->last_insert_rowid, 1, "$test: first");

-$dbi->insert('table1', {key1 => 1, key2 => 2});

-is($dbi->last_insert_rowid, 2, "$test: second");

-$dbi->disconnect;