@@ -49,6 +49,7 @@ my $where;

 my $update_param;

 my $insert_param;

 my $join;

+my $binary;

 # Drop table

 eval { $dbi->execute('drop table table1') };

@@ -60,6 +60,7 @@ my $where;

 my $update_param;

 my $insert_param;

 my $join;

+my $binary;

 # Prepare table

 $dbi = DBIx::Custom->connect;

@@ -1759,6 +1760,7 @@ is($dbi->select(table => 'table1')->one->{key3}, 3);

 test 'update_at';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $dbi->update_at(

@@ -1784,6 +1786,7 @@ is($dbi->select(table => 'table1')->one->{key2}, 2);

 is($dbi->select(table => 'table1')->one->{key3}, 4);

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $dbi->update_at(

@@ -1798,6 +1801,7 @@ is($dbi->select(table => 'table1')->one->{key3}, 4);

 test 'select_at';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $result = $dbi->select_at(

@@ -1892,6 +1896,9 @@ test 'model delete_at';

     }

 }

 $dbi = MyDBI6->connect;

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

+eval { $dbi->execute('drop table table3') };

 $dbi->execute($create_table1_2);

 $dbi->execute("create table table2 (key1, key2, key3)");

 $dbi->execute("create table table3 (key1, key2, key3)");

@@ -1907,6 +1914,7 @@ is_deeply($dbi->select(table => 'table1')->all, []);

 test 'model insert_at';

 $dbi = MyDBI6->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $dbi->model('table1')->insert_at(

     where => [1, 2],

@@ -1920,6 +1928,7 @@ is($row->{key3}, 3);

 test 'model update_at';

 $dbi = MyDBI6->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $dbi->model('table1')->update_at(

@@ -1934,6 +1943,7 @@ is($row->{key3}, 4);

 test 'model select_at';

 $dbi = MyDBI6->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $result = $dbi->model('table1')->select_at(where => [1, 2]);

@@ -1959,6 +1969,8 @@ test 'mycolumn and column';

     }

 }

 $dbi = MyDBI7->connect;

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

 $dbi->execute($create_table1);

 $dbi->execute('create table table2 (key1 char(255), key3 char(255));');

 $dbi->separator('__');

@@ -1975,6 +1987,7 @@ is_deeply($result->one,

 test 'update_param';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $dbi->insert(table => 'table1', param => {key1 => 1, key2 => 2, key3 => 3, key4 => 4, key5 => 5});

 $dbi->insert(table => 'table1', param => {key1 => 6, key2 => 7, key3 => 8, key4 => 9, key5 => 10});

@@ -1994,6 +2007,7 @@ is_deeply($rows, [{key1 => 1, key2 => 11, key3 => 3, key4 => 4, key5 => 5},

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $dbi->insert(table => 'table1', param => {key1 => 1, key2 => 2, key3 => 3, key4 => 4, key5 => 5});

 $dbi->insert(table => 'table1', param => {key1 => 6, key2 => 7, key3 => 8, key4 => 9, key5 => 10});

@@ -2012,6 +2026,7 @@ is_deeply($rows, [{key1 => 1, key2 => 11, key3 => 33, key4 => 4, key5 => 5},

                   "basic");

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $dbi->insert(table => 'table1', param => {key1 => 1, key2 => 2, key3 => 3, key4 => 4, key5 => 5});

 $dbi->insert(table => 'table1', param => {key1 => 6, key2 => 7, key3 => 8, key4 => 9, key5 => 10});

@@ -2036,6 +2051,7 @@ like($@, qr/not safety/);

 test 'update_param';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $dbi->insert(table => 'table1', param => {key1 => 1, key2 => 2, key3 => 3, key4 => 4, key5 => 5});

 $dbi->insert(table => 'table1', param => {key1 => 6, key2 => 7, key3 => 8, key4 => 9, key5 => 10});

@@ -2056,6 +2072,7 @@ is_deeply($rows, [{key1 => 1, key2 => 11, key3 => 3, key4 => 4, key5 => 5},

 test 'insert_param';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $param = {key1 => 1, key2 => 2};

 $insert_param = $dbi->insert_param($param);

@@ -2068,6 +2085,7 @@ is($dbi->select(table => 'table1')->one->{key2}, 2);

 $dbi = DBIx::Custom->connect;

 $dbi->quote('"');

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $param = {key1 => 1, key2 => 2};

 $insert_param = $dbi->insert_param($param);

@@ -2084,6 +2102,7 @@ like($@, qr/not safety/);

 test 'join';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

 $dbi->insert(table => 'table1', param => {key1 => 3, key2 => 4});

@@ -2144,6 +2163,7 @@ is_deeply($rows, [{table1__key1 => 1}]);

 $dbi = DBIx::Custom->connect;

 $dbi->quote('"');

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

 $dbi->execute('create table table2 (key1 char(255), key3 char(255));');

@@ -2172,6 +2192,7 @@ is_deeply($rows, [{table1_key1 => 1, table2_key1 => 1, key2 => 2, key3 => 5}],

 }

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

 $sql = <<"EOS";

@@ -2192,6 +2213,8 @@ $rows = $dbi->select(

 is_deeply($rows, [{latest_table1__key1 => 1}]);

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

 $dbi->execute($create_table1);

 $dbi->execute('create table table2 (key1 char(255), key3 char(255));');

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

@@ -2222,6 +2245,8 @@ $result = $dbi->select(

 is_deeply($result->all, [{'table2.key3' => 4}]);

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

 $dbi->execute($create_table1);

 $dbi->execute('create table table2 (key1 char(255), key3 char(255));');

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

@@ -2241,6 +2266,8 @@ is_deeply($result->all, [{'table2.key3' => 4}]);

 test 'mycolumn';

 $dbi = MyDBI8->connect;

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

 $dbi->execute($create_table1);

 $dbi->execute('create table table2 (key1 char(255), key3 char(255));');

 $dbi->setup_model;

@@ -2306,6 +2333,7 @@ test 'dbi method from model';

     }

 }

 $dbi = MyDBI9->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

 $model = $dbi->model('table1');

 eval{$model->execute('select * from table1')};

@@ -2313,6 +2341,7 @@ ok(!$@);

 test 'column table option';

 $dbi = MyDBI9->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

 $dbi->execute('create table table2 (key1 char(255), key3 char(255));');

 $dbi->setup_model;

@@ -2350,12 +2379,12 @@ is_deeply($result->one,

 test 'type option'; # DEPRECATED!

 $dbi = DBIx::Custom->connect(

-    data_source => 'dbi:SQLite:dbname=:memory:',

     dbi_option => {

         $DBD::SQLite::VERSION > 1.26 ? (sqlite_unicode => 1) : (unicode => 1)

     }

 );

-my $binary = pack("I3", 1, 2, 3);

+$binary = pack("I3", 1, 2, 3);

+eval { $dbi->execute('drop table table1') };

 $dbi->execute('create table table1(key1, key2)');

 $dbi->insert(table => 'table1', param => {key1 => $binary, key2 => 'あ'}, type => [key1 => DBI::SQL_BLOB]);

 $result = $dbi->select(table => 'table1');

@@ -2376,12 +2405,12 @@ is($row->{key1_length}, length $binary);

 test 'bind_type option';

 $dbi = DBIx::Custom->connect(

-    data_source => 'dbi:SQLite:dbname=:memory:',

     dbi_option => {

         $DBD::SQLite::VERSION > 1.26 ? (sqlite_unicode => 1) : (unicode => 1)

     }

 );

 $binary = pack("I3", 1, 2, 3);

+eval { $dbi->execute('drop table table1') };

 $dbi->execute('create table table1(key1, key2)');

 $dbi->insert(table => 'table1', param => {key1 => $binary, key2 => 'あ'}, bind_type => [key1 => DBI::SQL_BLOB]);

 $result = $dbi->select(table => 'table1');

@@ -2401,12 +2430,12 @@ is($row->{key1_length}, length $binary);

 test 'model type attribute';

 $dbi = DBIx::Custom->connect(

-    data_source => 'dbi:SQLite:dbname=:memory:',

     dbi_option => {

         $DBD::SQLite::VERSION > 1.26 ? (sqlite_unicode => 1) : (unicode => 1)

     }

 );

 $binary = pack("I3", 1, 2, 3);

+eval { $dbi->execute('drop table table1') };

 $dbi->execute('create table table1(key1, key2)');

 $model = $dbi->create_model(table => 'table1', bind_type => [key1 => DBI::SQL_BLOB]);

 $model->insert(param => {key1 => $binary, key2 => 'あ'});

@@ -2419,6 +2448,8 @@ is($row->{key1_length}, length $binary);

 test 'create_model';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

 $dbi->execute($create_table1);

 $dbi->execute('create table table2 (key1 char(255), key3 char(255));');

@@ -2453,6 +2484,7 @@ is_deeply($model2->select->one, {key1 => 1, key3 => 3});

 test 'model method';

 test 'create_model';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table2') };

 $dbi->execute('create table table2 (key1 char(255), key3 char(255));');

 $dbi->insert(table => 'table2', param => {key1 => 1, key3 => 3});

 $model = $dbi->create_model(

@@ -2480,6 +2512,7 @@ is_deeply($param, {key1 => [1, 2, 3, 4], key2 => [1, 2, 3], key3 => [1, 2, 3]});

 test 'select() param option';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

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

@@ -2499,6 +2532,7 @@ is_deeply($rows, [{table1_key1 => 2, key2 => 3, key3 => 5}]);

 test 'select() wrap option';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

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

@@ -2520,6 +2554,7 @@ like($@, qr/array/);

 test 'select() string where';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

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

@@ -2531,6 +2566,7 @@ $rows = $dbi->select(

 is_deeply($rows, [{key1 => 1, key2 => 2}]);

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

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

@@ -2545,6 +2581,7 @@ is_deeply($rows, [{key1 => 1, key2 => 2}]);

 test 'delete() string where';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

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

@@ -2557,6 +2594,7 @@ $rows = $dbi->select(table => 'table1')->all;

 is_deeply($rows, [{key1 => 2, key2 => 3}]);

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

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

@@ -2573,6 +2611,7 @@ is_deeply($rows, [{key1 => 2, key2 => 3}]);

 test 'update() string where';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

 $dbi->update(

@@ -2585,6 +2624,7 @@ $rows = $dbi->select(table => 'table1')->all;

 is_deeply($rows, [{key1 => 5, key2 => 2}]);

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

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

 $dbi->update(

@@ -2600,6 +2640,7 @@ is_deeply($rows, [{key1 => 5, key2 => 2}]);

 test 'insert id and primary_key option';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $dbi->insert(

     primary_key => ['key1', 'key2'], 

@@ -2624,6 +2665,7 @@ is($dbi->select(table => 'table1')->one->{key2}, 2);

 is($dbi->select(table => 'table1')->one->{key3}, 3);

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $dbi->insert(

     {key3 => 3},

@@ -2638,6 +2680,7 @@ is($dbi->select(table => 'table1')->one->{key3}, 3);

 test 'model insert id and primary_key option';

 $dbi = MyDBI6->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $dbi->model('table1')->insert(

     id => [1, 2],

@@ -2650,6 +2693,7 @@ is($row->{key2}, 2);

 is($row->{key3}, 3);

 $dbi = MyDBI6->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

 $dbi->model('table1')->insert(

     {key3 => 3},

@@ -2663,6 +2707,7 @@ is($row->{key3}, 3);

 test 'update and id option';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $dbi->update(

@@ -2688,6 +2733,7 @@ is($dbi->select(table => 'table1')->one->{key2}, 2);

 is($dbi->select(table => 'table1')->one->{key3}, 4);

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $dbi->update(

@@ -2703,6 +2749,7 @@ is($dbi->select(table => 'table1')->one->{key3}, 4);

 test 'model update and id option';

 $dbi = MyDBI6->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $dbi->model('table1')->update(

@@ -2718,6 +2765,7 @@ is($row->{key3}, 4);

 test 'delete and id option';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $dbi->delete(

@@ -2738,6 +2786,9 @@ is_deeply($dbi->select(table => 'table1')->all, []);

 test 'model delete and id option';

 $dbi = MyDBI6->connect;

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

+eval { $dbi->execute('drop table table3') };

 $dbi->execute($create_table1_2);

 $dbi->execute("create table table2 (key1, key2, key3)");

 $dbi->execute("create table table3 (key1, key2, key3)");

@@ -2754,6 +2805,7 @@ is_deeply($dbi->select(table => 'table1')->all, []);

 test 'select and id option';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $result = $dbi->select(

@@ -2793,6 +2845,7 @@ is($row->{key3}, 3);

 test 'model select_at';

 $dbi = MyDBI6->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1_2);

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

 $result = $dbi->model('table1')->select(id => [1, 2]);

@@ -2803,6 +2856,8 @@ is($row->{key3}, 3);

 test 'column separator is default .';

 $dbi = MyDBI7->connect;

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

 $dbi->execute($create_table1);

 $dbi->execute('create table table2 (key1 char(255), key3 char(255));');

 $dbi->setup_model;

@@ -2824,547 +2879,585 @@ is_deeply($result->one,

           {'table2.key1' => 1, 'table2.key3' => 3});

-test 'type_rule from';

+

+test 'separator';

 $dbi = DBIx::Custom->connect;

-$dbi->type_rule(

-    from1 => {

-        date => sub { uc $_[0] }

-    }

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

+$dbi->execute($create_table1);

+$dbi->execute('create table table2 (key1 char(255), key3 char(255));');

+

+$dbi->create_model(

+    table => 'table1',

+    join => [

+       'left outer join table2 on table1.key1 = table2.key1'

+    ],

+    primary_key => ['key1'],

 );

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->insert({key1 => 'a'}, table => 'table1');

-$result = $dbi->select(table => 'table1');

-is($result->fetch_first->[0], 'A');

+$model2 = $dbi->create_model(

+    table => 'table2',

+);

+$dbi->setup_model;

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

+$dbi->insert(table => 'table2', param => {key1 => 1, key3 => 3});

+$model = $dbi->model('table1');

+$result = $model->select(

+    column => [

+        $model->mycolumn,

+        {table2 => [qw/key1 key3/]}

+    ],

+    where => {'table1.key1' => 1}

+);

+is_deeply($result->one,

+          {key1 => 1, key2 => 2, 'table2.key1' => 1, 'table2.key3' => 3});

+is_deeply($model2->select->one, {key1 => 1, key3 => 3});

-$result = $dbi->select(table => 'table1');

-is($result->one->{key1}, 'A');

+$dbi->separator('__');

+$model = $dbi->model('table1');

+$result = $model->select(

+    column => [

+        $model->mycolumn,

+        {table2 => [qw/key1 key3/]}

+    ],

+    where => {'table1.key1' => 1}

+);

+is_deeply($result->one,

+          {key1 => 1, key2 => 2, 'table2__key1' => 1, 'table2__key3' => 3});

+is_deeply($model2->select->one, {key1 => 1, key3 => 3});

+$dbi->separator('-');

+$model = $dbi->model('table1');

+$result = $model->select(

+    column => [

+        $model->mycolumn,

+        {table2 => [qw/key1 key3/]}

+    ],

+    where => {'table1.key1' => 1}

+);

+is_deeply($result->one,

+          {key1 => 1, key2 => 2, 'table2-key1' => 1, 'table2-key3' => 3});

+is_deeply($model2->select->one, {key1 => 1, key3 => 3});

-test 'type_rule into';

+

+test 'filter_off';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    into1 => {

-        date => sub { uc $_[0] }

-    }

+eval { $dbi->execute('drop table table1') };

+eval { $dbi->execute('drop table table2') };

+$dbi->execute($create_table1);

+$dbi->execute('create table table2 (key1 char(255), key3 char(255));');

+

+$dbi->create_model(

+    table => 'table1',

+    join => [

+       'left outer join table2 on table1.key1 = table2.key1'

+    ],

+    primary_key => ['key1'],

 );

-$dbi->insert({key1 => 'a'}, table => 'table1');

-$result = $dbi->select(table => 'table1');

-is($result->one->{key1}, 'A');

+$dbi->setup_model;

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

+$model = $dbi->model('table1');

+$result = $model->select(column => 'key1');

+$result->filter(key1 => sub { $_[0] * 2 });

+is_deeply($result->one, {key1 => 2});

+test 'available_datetype';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 date, key2 datetime)");

-$dbi->type_rule(

-    into1 => [

-         [qw/date datetime/] => sub { uc $_[0] }

-    ]

-);

-$dbi->insert({key1 => 'a', key2 => 'b'}, table => 'table1');

-$result = $dbi->select(table => 'table1');

-$row = $result->one;

-is($row->{key1}, 'A');

-is($row->{key2}, 'B');

+ok($dbi->can('available_datatype'));

+

+test 'select prefix option';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->insert({key1 => 'a', key2 => 'B'}, table => 'table1');

-$dbi->type_rule(

-    into1 => [

-        [qw/date datetime/] => sub { uc $_[0] }

-    ]

+eval { $dbi->execute('drop table table1') };

+$dbi->execute($create_table1);

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

+$rows = $dbi->select(prefix => 'key1,', column => 'key2', table => 'table1')->all;

+is_deeply($rows, [{key1 => 1, key2 => 2}], "table");

+

+

+test 'separator';

+$dbi = DBIx::Custom->connect;

+is($dbi->separator, '.');

+$dbi->separator('-');

+is($dbi->separator, '-');

+$dbi->separator('__');

+is($dbi->separator, '__');

+eval { $dbi->separator('?') };

+like($@, qr/Separator/);

+

+

+test 'map_param';

+$dbi = DBIx::Custom->connect;

+$param = $dbi->map_param(

+    {id => 1, author => 'Ken', price => 1900},

+    id => 'book.id',

+    author => ['book.author', sub { '%' . $_[0] . '%' }],

+    price => ['book.price', {if => sub { $_[0] eq 1900 }}]

 );

-$result = $dbi->execute(

-    "select * from table1 where key1 = :key1 and key2 = :table1.key2;",

-    param => {key1 => 'a', 'table1.key2' => 'b'}

+is_deeply($param, {'book.id' => 1, 'book.author' => '%Ken%',

+  'book.price' => 1900});

+

+$param = $dbi->map_param(

+    {id => 0, author => 0, price => 0},

+    id => 'book.id',

+    author => ['book.author', sub { '%' . $_[0] . '%' }],

+    price => ['book.price', sub { '%' . $_[0] . '%' },

+      {if => sub { $_[0] eq 0 }}]

 );

-$row = $result->one;

-is($row->{key1}, 'a');

-is($row->{key2}, 'B');

+is_deeply($param, {'book.id' => 0, 'book.author' => '%0%', 'book.price' => '%0%'});

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->insert({key1 => 'A', key2 => 'B'}, table => 'table1');

-$dbi->type_rule(

-    into1 => [

-        [qw/date datetime/] => sub { uc $_[0] }

-    ]

+$param = $dbi->map_param(

+    {id => '', author => '', price => ''},

+    id => 'book.id',

+    author => ['book.author', sub { '%' . $_[0] . '%' }],

+    price => ['book.price', sub { '%' . $_[0] . '%' },

+      {if => sub { $_[0] eq 1 }}]

 );

-$result = $dbi->execute(

-    "select * from table1 where key1 = :key1 and key2 = :table1.key2;",

-    param => {key1 => 'a', 'table1.key2' => 'b'},

-    table => 'table1'

+is_deeply($param, {});

+

+$param = $dbi->map_param(

+    {id => undef, author => undef, price => undef},

+    id => 'book.id',

+    price => ['book.price', {if => 'exists'}]

 );

-$row = $result->one;

-is($row->{key1}, 'A');

-is($row->{key2}, 'B');

+is_deeply($param, {'book.price' => undef});

+

+$param = $dbi->map_param(

+    {price => 'a'},

+    id => ['book.id', {if => 'exists'}],

+    price => ['book.price', sub { '%' . $_[0] }, {if => 'exists'}]

+);

+is_deeply($param, {'book.price' => '%a'});

+

+test 'table_alias';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 date, key2 datetime)");

-$dbi->register_filter(twice => sub { $_[0] * 2 });

+eval { $dbi->execute('drop table table1') };

+$dbi->execute("create table table1 (key1 Date, key2 datetime)");

 $dbi->type_rule(

-    from1 => {

-        date => 'twice',

-    },

     into1 => {

-        date => 'twice',

+        date => sub { uc $_[0] }

     }

 );

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

+$dbi->execute("insert into table1 (key1) values (:table2.key1)", {'table2.key1' => 'a'},

+  table_alias => {table2 => 'table1'});

 $result = $dbi->select(table => 'table1');

-is($result->fetch->[0], 8);

+is($result->one->{key1}, 'A');

-test 'type_rule and filter order';

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    into1 => {

-        date => sub { $_[0] . 'b' }

-    },

-    into2 => {

-        date => sub { $_[0] . 'c' }

-    },

-    from1 => {

-        date => sub { $_[0] . 'd' }

-    },

-    from2 => {

-        date => sub { $_[0] . 'e' }

-    }

-);

-$dbi->insert({key1 => '1'}, table => 'table1', filter => {key1 => sub { $_[0] . 'a' }});

-$result = $dbi->select(table => 'table1');

-$result->filter(key1 => sub { $_[0] . 'f' });

-is($result->fetch_first->[0], '1abcdef');

+test 'order';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    from1 => {

-        date => sub { $_[0] . 'p' }

-    },

-    from2 => {

-        date => sub { $_[0] . 'q' }

-    },

-);

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

-$result = $dbi->select(table => 'table1');

-$result->type_rule(

-    from1 => {

-        date => sub { $_[0] . 'd' }

-    },

-    from2 => {

-        date => sub { $_[0] . 'e' }

-    }

-);

-$result->filter(key1 => sub { $_[0] . 'f' });

-is($result->fetch_first->[0], '1def');

+eval { $dbi->execute('drop table table1') };

+$dbi->execute("create table table1 (key1, key2)");

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

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

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

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

+my $order = $dbi->order;

+$order->prepend('key1', 'key2 desc');

+$result = $dbi->select(table => 'table1', append => "$order");

+is_deeply($result->all, [{key1 => 1, key2 => 3}, {key1 => 1, key2 => 1},

+  {key1 => 2, key2 => 4}, {key1 => 2, key2 => 2}]);

+$order->prepend('key1 desc');

+$result = $dbi->select(table => 'table1', append => "$order");

+is_deeply($result->all, [{key1 => 2, key2 => 4}, {key1 => 2, key2 => 2},

+  {key1 => 1, key2 => 3}, {key1 => 1, key2 => 1}]);

-test 'type_rule_off';

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    from1 => {

-        date => sub { $_[0] * 2 },

-    },

-    into1 => {

-        date => sub { $_[0] * 2 },

-    }

-);

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

-$result = $dbi->select(table => 'table1', type_rule_off => 1);

-is($result->type_rule_off->fetch->[0], 2);

+$order = $dbi->order;

+$order->prepend(['table1-key1'], [qw/table1-key2 desc/]);

+$result = $dbi->select(table => 'table1',

+  column => [[key1 => 'table1-key1'], [key2 => 'table1-key2']],

+  append => "$order");

+is_deeply($result->all, [{'table1-key1' => 1, 'table1-key2' => 3},

+  {'table1-key1' => 1, 'table1-key2' => 1},

+  {'table1-key1' => 2, 'table1-key2' => 4},

+  {'table1-key1' => 2, 'table1-key2' => 2}]);

+test 'tag_parse';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    from1 => {

-        date => sub { $_[0] * 2 },

-    },

-    into1 => {

-        date => sub { $_[0] * 3 },

-    }

-);

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

-$result = $dbi->select(table => 'table1', type_rule_off => 1);

-is($result->one->{key1}, 4);

+$dbi->tag_parse(0);

+eval { $dbi->execute('drop table table1') };

+$dbi->execute("create table table1 (key1, key2)");

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

+eval {$dbi->execute("select * from table1 where {= key1}", {key1 => 1})};

+ok($@);

+test 'last_sql';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    from1 => {

-        date => sub { $_[0] * 2 },

-    },

-    into1 => {

-        date => sub { $_[0] * 3 },

-    }

-);

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

-$result = $dbi->select(table => 'table1');

-is($result->one->{key1}, 12);

+eval { $dbi->execute('drop table table1') };

+$dbi->execute("create table table1 (key1, key2)");

+$dbi->execute('select * from table1');

+is($dbi->last_sql, 'select * from table1;');

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    from1 => {

-        date => sub { $_[0] * 2 },

-    },

-    into1 => {

-        date => sub { $_[0] * 3 },

-    }

-);

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

-$result = $dbi->select(table => 'table1');

-is($result->fetch->[0], 12);

+eval{$dbi->execute("aaa")};

+is($dbi->last_sql, 'aaa;');

+test 'DBIx::Custom header';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->register_filter(ppp => sub { uc $_[0] });

-$dbi->type_rule(

-    into1 => {

-        date => 'ppp'

-    }

-);

-$dbi->insert({key1 => 'a'}, table => 'table1');

-$result = $dbi->select(table => 'table1');

-is($result->one->{key1}, 'A');

+eval { $dbi->execute('drop table table1') };

+$dbi->execute("create table table1 (key1, key2)");

+$result = $dbi->execute('select key1 as h1, key2 as h2 from table1');

+is_deeply($result->header, [qw/h1 h2/]);

-eval{$dbi->type_rule(

-    into1 => {

-        date => 'pp'

-    }

-)};

-like($@, qr/not registered/);

+test 'Named placeholder :name(operater) syntax';

+$dbi->execute('drop table table1');

+$dbi->execute($create_table1_2);

+$dbi->insert(table => 'table1', param => {key1 => 1, key2 => 2, key3 => 3, key4 => 4, key5 => 5});

+$dbi->insert(table => 'table1', param => {key1 => 6, key2 => 7, key3 => 8, key4 => 9, key5 => 10});

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-eval {

-    $dbi->type_rule(

-        from1 => {

-            Date => sub { $_[0] * 2 },

-        }

-    );

-};

-like($@, qr/lower/);

+$source = "select * from table1 where :key1{=} and :key2{=}";

+$result = $dbi->execute($source, param => {key1 => 1, key2 => 2});

+$rows = $result->all;

+is_deeply($rows, [{key1 => 1, key2 => 2, key3 => 3, key4 => 4, key5 => 5}]);

-eval {

-    $dbi->type_rule(

-        into1 => {

-            Date => sub { $_[0] * 2 },

-        }

-    );

-};

-like($@, qr/lower/);

+$source = "select * from table1 where :key1{ = } and :key2{=}";

+$result = $dbi->execute($source, param => {key1 => 1, key2 => 2});

+$rows = $result->all;

+is_deeply($rows, [{key1 => 1, key2 => 2, key3 => 3, key4 => 4, key5 => 5}]);

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    from1 => {

-        date => sub { $_[0] * 2 },

-    },

-    into1 => {

-        date => sub { $_[0] * 3 },

-    }

-);

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

-$result = $dbi->select(table => 'table1');

-$result->type_rule_off;

-is($result->one->{key1}, 6);

+$source = "select * from table1 where :key1{<} and :key2{=}";

+$result = $dbi->execute($source, param => {key1 => 5, key2 => 2});

+$rows = $result->all;

+is_deeply($rows, [{key1 => 1, key2 => 2, key3 => 3, key4 => 4, key5 => 5}]);

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    from1 => {

-        date => sub { $_[0] * 2 },

-        datetime => sub { $_[0] * 4 },

-    },

-);

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

-$result = $dbi->select(table => 'table1');

-$result->type_rule(

-    from1 => {

-        date => sub { $_[0] * 3 }

-    }

+$source = "select * from table1 where :table1.key1{=} and :table1.key2{=}";

+$result = $dbi->execute(

+    $source,

+    param => {'table1.key1' => 1, 'table1.key2' => 1},

+    filter => {'table1.key2' => sub { $_[0] * 2 }}

 );

-$row = $result->one;

-is($row->{key1}, 6);

-is($row->{key2}, 2);

+$rows = $result->all;

+is_deeply($rows, [{key1 => 1, key2 => 2, key3 => 3, key4 => 4, key5 => 5}]);

-$result = $dbi->select(table => 'table1');

-$result->type_rule(

-    from1 => {

-        date => sub { $_[0] * 3 }

+test 'high perfomance way';

+$dbi->execute('drop table table1');

+$dbi->execute("create table table1 (ab, bc, ik, hi, ui, pq, dc);");

+$rows = [

+    {ab => 1, bc => 2, ik => 3, hi => 4, ui => 5, pq => 6, dc => 7},

+    {ab => 1, bc => 2, ik => 3, hi => 4, ui => 5, pq => 6, dc => 8},

+];

+{

+    my $query;

+    foreach my $row (@$rows) {

+      $query ||= $dbi->insert($row, table => 'table1', query => 1);

+      $dbi->execute($query, $row, filter => {ab => sub { $_[0] * 2 }});

     }

-);

-$row = $result->one;

-is($row->{key1}, 6);

-is($row->{key2}, 2);

-

-$result = $dbi->select(table => 'table1');

-$result->type_rule(

-    from1 => {

-        date => sub { $_[0] * 3 }

+    is_deeply($dbi->select(table => 'table1')->all,

+      [

+          {ab => 2, bc => 2, ik => 3, hi => 4, ui => 5, pq => 6, dc => 7},

+          {ab => 2, bc => 2, ik => 3, hi => 4, ui => 5, pq => 6, dc => 8},

+      ]

+    );

+}

+

+$dbi->execute('drop table table1');

+$dbi->execute("create table table1 (ab, bc, ik, hi, ui, pq, dc);");

+$rows = [

+    {ab => 1, bc => 2, ik => 3, hi => 4, ui => 5, pq => 6, dc => 7},

+    {ab => 1, bc => 2, ik => 3, hi => 4, ui => 5, pq => 6, dc => 8},

+];

+{

+    my $query;

+    my $sth;

+    foreach my $row (@$rows) {

+      $query ||= $dbi->insert($row, table => 'table1', query => 1);

+      $sth ||= $query->sth;

+      $sth->execute(map { $row->{$_} } sort keys %$row);

     }

-);

-$row = $result->one;

-is($row->{key1}, 6);

-is($row->{key2}, 2);

-$result = $dbi->select(table => 'table1');

-$result->type_rule(

-    from1 => [date => sub { $_[0] * 3 }]

-);

-$row = $result->one;

-is($row->{key1}, 6);

-is($row->{key2}, 2);

-$dbi->register_filter(fivetimes => sub { $_[0] * 5});

-$result = $dbi->select(table => 'table1');

-$result->type_rule(

-    from1 => [date => 'fivetimes']

-);

-$row = $result->one;

-is($row->{key1}, 10);

-is($row->{key2}, 2);

-$result = $dbi->select(table => 'table1');

-$result->type_rule(

-    from1 => [date => undef]

-);

-$row = $result->one;

-is($row->{key1}, 2);

-is($row->{key2}, 2);

+    is_deeply($dbi->select(table => 'table1')->all,

+      [

+          {ab => 1, bc => 2, ik => 3, hi => 4, ui => 5, pq => 6, dc => 7},

+          {ab => 1, bc => 2, ik => 3, hi => 4, ui => 5, pq => 6, dc => 8},

+      ]

+    );

+}

+test 'result';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    from1 => {

-        date => sub { $_[0] * 2 },

-    },

-);

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

+eval { $dbi->execute('drop table table1') };

+$dbi->execute($create_table1);

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

+$dbi->insert({key1 => 3, key2 => 4}, table => 'table1');

+

 $result = $dbi->select(table => 'table1');

-$result->filter(key1 => sub { $_[0] * 3 });

-is($result->one->{key1}, 12);

+@rows = ();

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

+    push @rows, [@$row];

+}

+is_deeply(\@rows, [[1, 2], [3, 4]]);

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    from1 => {

-        date => sub { $_[0] * 2 },

-    },

-);

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

 $result = $dbi->select(table => 'table1');

-$result->filter(key1 => sub { $_[0] * 3 });

-is($result->fetch->[0], 12);

+@rows = ();

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

+    push @rows, {%$row};

+}

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

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    into1 => {

-        date => sub { $_[0] . 'b' }

-    },

-    into2 => {

-        date => sub { $_[0] . 'c' }

-    },

-    from1 => {

-        date => sub { $_[0] . 'd' }

-    },

-    from2 => {

-        date => sub { $_[0] . 'e' }

-    }

-);

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

 $result = $dbi->select(table => 'table1');

-is($result->type_rule_off->fetch_first->[0], '1');

+$row = $result->fetch_first;

+is_deeply($row, [1, 2], "row");

+$row = $result->fetch;

+ok(!$row, "finished");

+

 $result = $dbi->select(table => 'table1');

-is($result->type_rule_on->fetch_first->[0], '1de');

+$row = $result->fetch_hash_first;

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

+$row = $result->fetch_hash;

+ok(!$row, "finished");

+

+$dbi->execute('create table table2 (key1, key2);');

+$result = $dbi->select(table => 'table2');

+$row = $result->fetch_hash_first;

+ok(!$row, "no row fetch");

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    into1 => {

-        date => sub { $_[0] . 'b' }

-    },

-    into2 => {

-        date => sub { $_[0] . 'c' }

-    },

-    from1 => {

-        date => sub { $_[0] . 'd' }

-    },

-    from2 => {

-        date => sub { $_[0] . 'e' }

-    }

-);

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

+eval { $dbi->execute('drop table table1') };

+$dbi->execute($create_table1);

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

+$dbi->insert({key1 => 3, key2 => 4}, table => 'table1');

+$dbi->insert({key1 => 5, key2 => 6}, table => 'table1');

+$dbi->insert({key1 => 7, key2 => 8}, table => 'table1');

+$dbi->insert({key1 => 9, key2 => 10}, table => 'table1');

 $result = $dbi->select(table => 'table1');

-is($result->type_rule1_off->fetch_first->[0], '1ce');

+$rows = $result->fetch_multi(2);

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

+                  [3, 4]], "fetch_multi first");

+$rows = $result->fetch_multi(2);

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

+                  [7, 8]], "fetch_multi secound");

+$rows = $result->fetch_multi(2);

+is_deeply($rows, [[9, 10]], "fetch_multi third");

+$rows = $result->fetch_multi(2);

+ok(!$rows);

+

 $result = $dbi->select(table => 'table1');

-is($result->type_rule1_on->fetch_first->[0], '1cde');

+eval {$result->fetch_multi};

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

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

-$dbi->execute("create table table1 (key1 Date, key2 datetime)");

-$dbi->type_rule(

-    into1 => {

-        date => sub { $_[0] . 'b' }

-    },

-    into2 => {

-        date => sub { $_[0] . 'c' }

-    },

-    from1 => {

-        date => sub { $_[0] . 'd' }

-    },

-    from2 => {

-        date => sub { $_[0] . 'e' }

-    }

-);

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

 $result = $dbi->select(table => 'table1');

-is($result->type_rule2_off->fetch_first->[0], '1bd');

+$rows = $result->fetch_hash_multi(2);

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

+                  {key1 => 3, key2 => 4}], "fetch_multi first");

+$rows = $result->fetch_hash_multi(2);

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

+                  {key1 => 7, key2 => 8}], "fetch_multi secound");

+$rows = $result->fetch_hash_multi(2);

+is_deeply($rows, [{key1 => 9, key2 => 10}], "fetch_multi third");

+$rows = $result->fetch_hash_multi(2);

+ok(!$rows);

+

 $result = $dbi->select(table => 'table1');

-is($result->type_rule2_on->fetch_first->[0], '1bde');

+eval {$result->fetch_hash_multi};

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

-test 'separator';

 $dbi = DBIx::Custom->connect;

+eval { $dbi->execute('drop table table1') };

 $dbi->execute($create_table1);

-$dbi->execute('create table table2 (key1 char(255), key3 char(255));');

-

-$dbi->create_model(

-    table => 'table1',

-    join => [

-       'left outer join table2 on table1.key1 = table2.key1'

-    ],

-    primary_key => ['key1'],

-);

-$model2 = $dbi->create_model(

-    table => 'table2',

-);

-$dbi->setup_model;

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

-$dbi->insert(table => 'table2', param => {key1 => 1, key3 => 3});

-$model = $dbi->model('table1');

-$result = $model->select(

-    column => [

-        $model->mycolumn,

-        {table2 => [qw/key1 key3/]}

-    ],

-    where => {'table1.key1' => 1}

-);

-is_deeply($result->one,

-          {key1 => 1, key2 => 2, 'table2.key1' => 1, 'table2.key3' => 3});

-is_deeply($model2->select->one, {key1 => 1, key3 => 3});

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

+$dbi->insert({key1 => 3, key2 => 4}, table => 'table1');

-$dbi->separator('__');

-$model = $dbi->model('table1');

-$result = $model->select(

-    column => [

-        $model->mycolumn,

-        {table2 => [qw/key1 key3/]}

-    ],

-    where => {'table1.key1' => 1}

-);

-is_deeply($result->one,

-          {key1 => 1, key2 => 2, 'table2__key1' => 1, 'table2__key3' => 3});

-is_deeply($model2->select->one, {key1 => 1, key3 => 3});

+test 'fetch_all';

+$result = $dbi->select(table => 'table1');

+$rows = $result->fetch_all;

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

-$dbi->separator('-');

-$model = $dbi->model('table1');

-$result = $model->select(

-    column => [

-        $model->mycolumn,

-        {table2 => [qw/key1 key3/]}

-    ],

-    where => {'table1.key1' => 1}

-);

-is_deeply($result->one,

-          {key1 => 1, key2 => 2, 'table2-key1' => 1, 'table2-key3' => 3});

-is_deeply($model2->select->one, {key1 => 1, key3 => 3});

+$result = $dbi->select(table => 'table1');

+$rows = $result->fetch_hash_all;

+is_deeply($rows, [{key1 => 1, key2 => 2}, {key1 => 3, key2 => 4}]);

+$result = $dbi->select(table => 'table1');

+$result->dbi->filters({three_times => sub { $_[0] * 3}});

+$result->filter({key1 => 'three_times'});

-test 'filter_off';

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

-$dbi->execute($create_table1);

-$dbi->execute('create table table2 (key1 char(255), key3 char(255));');

+$rows = $result->fetch_all;

+is_deeply($rows, [[3, 2], [9, 4]], "array");

-$dbi->create_model(

-    table => 'table1',

-    join => [

-       'left outer join table2 on table1.key1 = table2.key1'

-    ],

-    primary_key => ['key1'],

+$result = $dbi->select(table => 'table1');

+$result->dbi->filters({three_times => sub { $_[0] * 3}});

+$result->filter({key1 => 'three_times'});

+$rows = $result->fetch_hash_all;

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

+

+test "query_builder";

+$datas = [

+    # Basic tests

+    {   name            => 'placeholder basic',

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

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

+        columns_expected   => [qw/k1 k2 k3 k4 k5 k6 k7 k8/]

+    },

+    {

+        name            => 'placeholder in',

+        source            => "{in k1 3};",

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

+        columns_expected   => [qw/k1 k1 k1/]

+    },

+    

+    # Table name

+    {

+        name            => 'placeholder with table name',

+        source            => "{= a.k1} {= a.k2}",

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

+        columns_expected  => [qw/a.k1 a.k2/]

+    },

+    {   

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

+        source            => "{in a.k1 2} {in b.k2 2}",

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

+        columns_expected  => [qw/a.k1 a.k1 b.k2 b.k2/]

+    },

+    {

+        name            => 'not contain tag',

+        source            => "aaa",

+        sql_expected    => "aaa;",

+        columns_expected  => [],

+    }

+];

+

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

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

+    my $builder = DBIx::Custom->new->query_builder;

+    my $query = $builder->build_query($data->{source});

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

+    is_deeply($query->columns, $data->{columns_expected}, "$data->{name} : columns");

+}

+

+$builder = DBIx::Custom->new->query_builder;

+$ret_val = $builder->register_tag(

+    p => sub {

+        my @args = @_;

+        

+        my $expand    = "? $args[0] $args[1]";

+        my $columns = [2];

+        return [$expand, $columns];

+    }

 );

-$dbi->setup_model;

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

-$model = $dbi->model('table1');

-$result = $model->select(column => 'key1');

-$result->filter(key1 => sub { $_[0] * 2 });

-is_deeply($result->one, {key1 => 2});

-test 'available_datetype';

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

-ok($dbi->can('available_datatype'));

+$query = $builder->build_query("{p a b}");

+is($query->{sql}, "? a b;", "register_tag sql");

+is_deeply($query->{columns}, [2], "register_tag columns");

+isa_ok($ret_val, 'DBIx::Custom::QueryBuilder');

+$builder = DBIx::Custom->new->query_builder;

-test 'select prefix option';

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

-$dbi->execute($create_table1);

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

-$rows = $dbi->select(prefix => 'key1,', column => 'key2', table => 'table1')->all;

-is_deeply($rows, [{key1 => 1, key2 => 2}], "table");

+eval{$builder->build_query('{? }')};

+like($@, qr/\QColumn name must be specified in tag "{? }"/, "? not arguments");

+eval{$builder->build_query("{a }")};

+like($@, qr/\QTag "a" is not registered/, "tag not exist");

-test 'separator';

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

-is($dbi->separator, '.');

-$dbi->separator('-');

-is($dbi->separator, '-');

-$dbi->separator('__');

-is($dbi->separator, '__');

-eval { $dbi->separator('?') };

-like($@, qr/Separator/);

+$builder->register_tag({

+    q => 'string'

+});

+eval{$builder->build_query("{q}", {})};

+like($@, qr/Tag "q" must be sub reference/, "tag not code ref");

-test 'map_param';

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

-$param = $dbi->map_param(

-    {id => 1, author => 'Ken', price => 1900},

-    id => 'book.id',

-    author => ['book.author', sub { '%' . $_[0] . '%' }],

-    price => ['book.price', {if => sub { $_[0] eq 1900 }}]

-);

-is_deeply($param, {'book.id' => 1, 'book.author' => '%Ken%',

-  'book.price' => 1900});

+$builder->register_tag({

+   r => sub {} 

+});

-$param = $dbi->map_param(

-    {id => 0, author => 0, price => 0},

-    id => 'book.id',

-    author => ['book.author', sub { '%' . $_[0] . '%' }],

-    price => ['book.price', sub { '%' . $_[0] . '%' },

-      {if => sub { $_[0] eq 0 }}]

+eval{$builder->build_query("{r}")};

+like($@, qr/\QTag "r" must return [STRING, ARRAY_REFERENCE]/, "tag return noting");

+

+$builder->register_tag({

+   s => sub { return ["a", ""]} 

+});

+

+eval{$builder->build_query("{s}")};

+like($@, qr/\QTag "s" must return [STRING, ARRAY_REFERENCE]/, "tag return not array columns");

+

+$builder->register_tag(

+    t => sub {return ["a", []]}

 );

-is_deeply($param, {'book.id' => 0, 'book.author' => '%0%', 'book.price' => '%0%'});

-$param = $dbi->map_param(

-    {id => '', author => '', price => ''},

-    id => 'book.id',

-    author => ['book.author', sub { '%' . $_[0] . '%' }],

-    price => ['book.price', sub { '%' . $_[0] . '%' },

-      {if => sub { $_[0] eq 1 }}]

+

+test 'General error case';

+$builder = DBIx::Custom->new->query_builder;

+$builder->register_tag(

+    a => sub {

+        return ["? ? ?", ['']];

+    }

 );

-is_deeply($param, {});

+eval{$builder->build_query("{a}")};

+like($@, qr/\QPlaceholder count/, "placeholder count is invalid");

-$param = $dbi->map_param(

-    {id => undef, author => undef, price => undef},

-    id => 'book.id',

-    price => ['book.price', {if => 'exists'}]

+

+test 'Default tag Error case';

+eval{$builder->build_query("{= }")};

+like($@, qr/Column name must be specified in tag "{= }"/, "basic '=' : key not exist");

+

+eval{$builder->build_query("{in }")};

+like($@, qr/Column name and count of values must be specified in tag "{in }"/, "in : key not exist");

+

+eval{$builder->build_query("{in a}")};

+like($@, qr/\QColumn name and count of values must be specified in tag "{in }"/,

+     "in : key not exist");

+

+eval{$builder->build_query("{in a r}")};

+like($@, qr/\QColumn name and count of values must be specified in tag "{in }"/,

+     "in : key not exist");

+

+test 'variouse source';

+$source = "a {= b} c \\{ \\} {= \\{} {= \\}} d;";

+$query = $builder->build_query($source);

+is($query->sql, 'a b = ? c { } { = ? } = ? d;', "basic : 1");

+

+$source = "abc;";

+$query = $builder->build_query($source);

+is($query->sql, 'abc;', "basic : 2");

+

+$source = "{= a}";

+$query = $builder->build_query($source);

+is($query->sql, 'a = ?;', "only tag");

+

+$source = "000;";

+$query = $builder->build_query($source);

+is($query->sql, '000;', "contain 0 value");

+

+$source = "a {= b} }";

+eval{$builder->build_query($source)};

+like($@, qr/unexpected "}"/, "error : 1");

+

+$source = "a {= {}";

+eval{$builder->build_query($source)};

+like($@, qr/unexpected "{"/, "error : 2");

+

+### SQLite test

+test 'type option'; # DEPRECATED!

+$dbi = DBIx::Custom->connect(

+    data_source => 'dbi:SQLite:dbname=:memory:',

+    dbi_option => {

+        $DBD::SQLite::VERSION > 1.26 ? (sqlite_unicode => 1) : (unicode => 1)

+    }

 );

-is_deeply($param, {'book.price' => undef});

+$binary = pack("I3", 1, 2, 3);

+eval { $dbi->execute('drop table table1') };

+$dbi->execute('create table table1(key1, key2)');

+$dbi->insert(table => 'table1', param => {key1 => $binary, key2 => 'あ'}, type => [key1 => DBI::SQL_BLOB]);

+$result = $dbi->select(table => 'table1');

+$row   = $result->one;

+is_deeply($row, {key1 => $binary, key2 => 'あ'}, "basic");

+$result = $dbi->execute('select length(key1) as key1_length from table1');

+$row = $result->one;

+is($row->{key1_length}, length $binary);

-$param = $dbi->map_param(

-    {price => 'a'},

-    id => ['book.id', {if => 'exists'}],

-    price => ['book.price', sub { '%' . $_[0] }, {if => 'exists'}]

+test 'type_rule from';

+$dbi = DBIx::Custom->connect;

+$dbi->type_rule(

+    from1 => {

+        date => sub { uc $_[0] }

+    }

 );

-is_deeply($param, {'book.price' => '%a'});

+$dbi->execute("create table table1 (key1 Date, key2 datetime)");

+$dbi->insert({key1 => 'a'}, table => 'table1');

+$result = $dbi->select(table => 'table1');

+is($result->fetch_first->[0], 'A');

+$result = $dbi->select(table => 'table1');

+is($result->one->{key1}, 'A');

-test 'table_alias';

+

+test 'type_rule into';

 $dbi = DBIx::Custom->connect;

 $dbi->execute("create table table1 (key1 Date, key2 datetime)");

 $dbi->type_rule(

@@ -3372,380 +3465,374 @@ $dbi->type_rule(

         date => sub { uc $_[0] }

     }

 );

-$dbi->execute("insert into table1 (key1) values (:table2.key1)", {'table2.key1' => 'a'},

-  table_alias => {table2 => 'table1'});

+$dbi->insert({key1 => 'a'}, table => 'table1');

 $result = $dbi->select(table => 'table1');

 is($result->one->{key1}, 'A');

-

-test 'order';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1, key2)");

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

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

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

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

-my $order = $dbi->order;

-$order->prepend('key1', 'key2 desc');

-$result = $dbi->select(table => 'table1', append => "$order");

-is_deeply($result->all, [{key1 => 1, key2 => 3}, {key1 => 1, key2 => 1},

-  {key1 => 2, key2 => 4}, {key1 => 2, key2 => 2}]);

-$order->prepend('key1 desc');

-$result = $dbi->select(table => 'table1', append => "$order");

-is_deeply($result->all, [{key1 => 2, key2 => 4}, {key1 => 2, key2 => 2},

-  {key1 => 1, key2 => 3}, {key1 => 1, key2 => 1}]);

-

-$order = $dbi->order;

-$order->prepend(['table1-key1'], [qw/table1-key2 desc/]);

-$result = $dbi->select(table => 'table1',

-  column => [[key1 => 'table1-key1'], [key2 => 'table1-key2']],

-  append => "$order");

-is_deeply($result->all, [{'table1-key1' => 1, 'table1-key2' => 3},

-  {'table1-key1' => 1, 'table1-key2' => 1},

-  {'table1-key1' => 2, 'table1-key2' => 4},

-  {'table1-key1' => 2, 'table1-key2' => 2}]);

+$dbi->execute("create table table1 (key1 date, key2 datetime)");

+$dbi->type_rule(

+    into1 => [

+         [qw/date datetime/] => sub { uc $_[0] }

+    ]

+);

+$dbi->insert({key1 => 'a', key2 => 'b'}, table => 'table1');

+$result = $dbi->select(table => 'table1');

+$row = $result->one;

+is($row->{key1}, 'A');

+is($row->{key2}, 'B');

-test 'tag_parse';

 $dbi = DBIx::Custom->connect;

-$dbi->tag_parse(0);

-$dbi->execute("create table table1 (key1, key2)");

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

-eval {$dbi->execute("select * from table1 where {= key1}", {key1 => 1})};

-ok($@);

+$dbi->execute("create table table1 (key1 Date, key2 datetime)");

+$dbi->insert({key1 => 'a', key2 => 'B'}, table => 'table1');

+$dbi->type_rule(

+    into1 => [

+        [qw/date datetime/] => sub { uc $_[0] }

+    ]

+);

+$result = $dbi->execute(

+    "select * from table1 where key1 = :key1 and key2 = :table1.key2;",

+    param => {key1 => 'a', 'table1.key2' => 'b'}

+);

+$row = $result->one;

+is($row->{key1}, 'a');

+is($row->{key2}, 'B');

-test 'last_sql';

 $dbi = DBIx::Custom->connect;

-$dbi->execute("create table table1 (key1, key2)");

-$dbi->execute('select * from table1');

-is($dbi->last_sql, 'select * from table1;');

+$dbi->execute("create table table1 (key1 Date, key2 datetime)");

+$dbi->insert({key1 => 'A', key2 => 'B'}, table => 'table1');

+$dbi->type_rule(

+    into1 => [

+        [qw/date datetime/] => sub { uc $_[0] }

+    ]

+);

+$result = $dbi->execute(

+    "select * from table1 where key1 = :key1 and key2 = :table1.key2;",

+    param => {key1 => 'a', 'table1.key2' => 'b'},

+    table => 'table1'

+);

+$row = $result->one;

+is($row->{key1}, 'A');

+is($row->{key2}, 'B');

-eval{$dbi->execute("aaa")};

-is($dbi->last_sql, 'aaa;');

+$dbi = DBIx::Custom->connect;

+$dbi->execute("create table table1 (key1 date, key2 datetime)");

+$dbi->register_filter(twice => sub { $_[0] * 2 });

+$dbi->type_rule(

+    from1 => {

+        date => 'twice',

+    },

+    into1 => {

+        date => 'twice',

+    }

+);

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