@@ -1,5 +1,6 @@

 0.1663

-    - added bind_param_option can set bind_param option

+    - added EXPERIMENTAL type() attribute to DBIx::Custom::Model

+    - added EXPERIMENTAL bind_param_option can set bind_param option

       to insert(), update(), delete(), select(), insert_at(),

       update_at(), delete_at(), select_at(), delete_all(), update_all()

 0.1662

@@ -19,7 +19,7 @@ use DBIx::Custom::Tag;

 use DBIx::Custom::Util;

 use Encode qw/encode_utf8 decode_utf8/;

-our @COMMON_ARGS = qw/table query filter bind_param_option/;

+our @COMMON_ARGS = qw/table query filter type/;

 __PACKAGE__->attr(

     [qw/data_source password pid user/],

@@ -433,15 +433,23 @@ sub execute{

     }

     $filter = {%$filter, %$f};

+    # Type

+    my $type = DBIx::Custom::Util::array_to_hash($args{type});

+    

     # Bind

-    my $bind = $self->_bind($params, $query->columns, $filter);

+    my $bind = $self->_bind($params, $query->columns, $filter, $type);

     # Execute

     my $sth = $query->sth;

     my $affected;

     eval {

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

-            $sth->bind_param($i + 1, $bind->[$i]);

+            if (my $type = $bind->[$i]->{type}) {

+                $sth->bind_param($i + 1, $bind->[$i]->{value}, $type);

+            }

+            else {

+                $sth->bind_param($i + 1, $bind->[$i]->{value});

+            }

         }

         $affected = $sth->execute;

     };

@@ -678,6 +686,8 @@ sub include_model {

         $table_alias = {%$table_alias, %{$model->table_alias}};

         # Table - Model

+        croak "Table name is duplicated"

+          if exists $self->{_model_from}->{$model->table};

         $self->{_model_from}->{$model->table} = $model->name;

     }

@@ -1163,10 +1173,10 @@ sub where {

 }

 sub _bind {

-    my ($self, $params, $columns, $filter) = @_;

+    my ($self, $params, $columns, $filter, $type) = @_;

     # bind values

-    my @bind;

+    my $bind = [];

     # Build bind values

     my $count = {};

@@ -1196,13 +1206,17 @@ sub _bind {

         # Filter

         my $f = $filter->{$column} || $self->{default_out_filter} || '';

-        push @bind, $f ? $f->($value) : $value;

+        # Type

+        push @$bind, {

+            value => $f ? $f->($value) : $value,

+            type => $type->{$column}

+        };

         # Count up 

         $count->{$column}++;

     }

-    return \@bind;

+    return $bind;

 }

 sub _connect {

@@ -2403,6 +2417,17 @@ You can check SQL.

     my $sql = $query->sql;

+=item C<type> EXPERIMENTAL

+

+Specify database data type.

+

+    $dbi->select(type => [image => DBI::SQL_BLOB]);

+    $dbi->select(type => [[qw/image audio/] => DBI::SQL_BLOB]);

+

+This is used to bind paramter by C<bind_param()> of statment handle.

+

+    $sth->bind_param($pos, $value, DBI::SQL_BLOB);

+

 =back

 =head2 C<select_at()> EXPERIMENTAL

@@ -16,6 +16,7 @@ __PACKAGE__->attr(

     columns => sub { [] },

     filter => sub { [] },

     join => sub { [] },

+    type => sub { [] },

     primary_key => sub { [] }

 );

@@ -39,6 +40,25 @@ sub AUTOLOAD {

     }

 }

+my @methods = qw/insert insert_at update update_at update_all

+                 delete delete_at delete_all select select_at/;

+foreach my $method (@methods) {

+

+    my $code = sub {

+        my $self = shift;

+        

+        my @args = (table => $self->table, type => $self->type);

+        push @args, (primary_key => $self->primary_key) if $method =~ /_at$/;

+        push @args, (join => $self->join) if $method =~ /^select/;

+        

+        $self->dbi->$method(@args, @_);

+    };

+    

+    no strict 'refs';

+    my $class = __PACKAGE__;

+    *{"${class}::$method"} = $code;

+}

+

 sub column {

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

@@ -56,43 +76,8 @@ sub column {

     return $self->dbi->column($table, $columns);

 }

-sub delete {

-    my $self = shift;

-    $self->dbi->delete(table => $self->table, @_);

-}

-

-sub delete_all {

-    my $self = shift;

-    $self->dbi->delete_all(table => $self->table, @_);

-}

-

-sub delete_at {

-    my $self = shift;

-    

-    return $self->dbi->delete_at(

-        table => $self->table,

-        primary_key => $self->primary_key,

-        @_

-    );

-}

-

 sub DESTROY { }

-sub insert {

-    my $self = shift;

-    $self->dbi->insert(table => $self->table, @_);

-}

-

-sub insert_at {

-    my $self = shift;

-    

-    return $self->dbi->insert_at(

-        table => $self->table,

-        primary_key => $self->primary_key,

-        @_

-    );

-}

-

 sub mycolumn {

     my $self = shift;

     my $table = shift unless ref $_[0];

@@ -104,46 +89,6 @@ sub mycolumn {

     return $self->dbi->mycolumn($table, $columns);

 }

-sub select {

-    my $self = shift;

-    $self->dbi->select(

-        table => $self->table,

-        join => $self->join,

-        @_

-    );

-}

-

-sub select_at {

-    my $self = shift;

-    

-    return $self->dbi->select_at(

-        table => $self->table,

-        primary_key => $self->primary_key,

-        join => $self->join,

-        @_

-    );

-}

-

-sub update {

-    my $self = shift;

-    $self->dbi->update(table => $self->table, @_)

-}

-

-sub update_all {

-    my $self = shift;

-    $self->dbi->update_all(table => $self->table, @_);

-}

-

-sub update_at {

-    my $self = shift;

-    

-    return $self->dbi->update_at(

-        table => $self->table,

-        primary_key => $self->primary_key,

-        @_

-    );

-}

-

 1;

 =head1 NAME

@@ -204,6 +149,15 @@ Generally, this is automatically set from class name.

 Foreign key, this is used as C<primary_key> of C<insert_at>,C<update_at()>,

 C<delete_at()>,C<select_at()>.

+=head2 C<type>

+

+    my $type = $model->type;

+    $model   = $model->type(['image' => DBI::SQL_BLOB]);

+    

+Database data type, this is used as type optioon of C<insert()>, C<insert_at()>,

+C<update()>, C<update_at()>, C<update_all>, C<delete()>, C<delete_all()>,

+C<select(), C<select_at()>

+

 =head2 C<view>

     my $view = $model->view;

@@ -265,7 +219,7 @@ you don't have to specify C<table> option.

 Same as C<insert_at()> of L<DBIx::Custom> except that

 you don't have to specify C<table> and C<primary_key> option.

-=head2 C<mycolumn> EXPERIMENTAL

+=head2 C<mycolumn>

     my $column = $self->mycolumn;

     my $column = $self->mycolumn(book => ['author', 'title']);

@@ -1403,11 +1403,13 @@ is_deeply($model->list->fetch_hash_all, [{name => 'a'}], 'basic');

 }

 $dbi = MyDBI5->connect($NEW_ARGS->{0});

 $dbi->execute("create table company (name)");

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

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

 $model->insert({name => 'a'});

 is_deeply($model->list->fetch_hash_all, [{name => 'a'}], 'include all model');

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

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

-is_deeply($model->list->fetch_hash_all, [{name => 'a'}], 'include all model');

+is_deeply($model->list->fetch_hash_all, [{key1 => 1}], 'include all model');

 test 'primary_key';

 use MyDBI1;

@@ -1602,13 +1604,15 @@ test 'model delete_at';

 }

 $dbi = MyDBI6->connect($NEW_ARGS->{0});

 $dbi->execute($CREATE_TABLE->{1});

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

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

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

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

 is_deeply($dbi->select(table => 'table1')->fetch_hash_all, []);

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

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

 $dbi->model('table1_1')->delete_at(where => [1, 2]);

 is_deeply($dbi->select(table => 'table1')->fetch_hash_all, []);

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

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

 $dbi->model('table1_3')->delete_at(where => [1, 2]);

 is_deeply($dbi->select(table => 'table1')->fetch_hash_all, []);

@@ -1873,3 +1877,28 @@ $result = $model->select(

 is_deeply($result->fetch_hash_first, 

           {table2_alias__key1 => 1, table2_alias__key3 => 48});

+test 'type() option';

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

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

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

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

+$row = $result->fetch_hash_first;

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

+

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

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

+$row   = $result->fetch_hash_first;

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

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

+$row = $result->fetch_hash_first;

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

+

@@ -2,7 +2,7 @@ package MyModel4::book;

 use base 'MyModel4';

-sub table { 'company' }

+sub table { 'table1' }

 sub list { shift->select }

@@ -5,7 +5,7 @@ use warnings;

 use base 'MyModel5';

-__PACKAGE__->attr(table => 'table1');

+__PACKAGE__->attr(table => 'table2');

 __PACKAGE__->attr('primary_key' => sub { ['key1', 'key2'] });

@@ -6,8 +6,8 @@ use warnings;

 use base 'MyModel5';

 __PACKAGE__->attr(name => 'table1_3');

-__PACKAGE__->attr(table => 'table1');

+__PACKAGE__->attr(table => 'table3');

 __PACKAGE__->attr('primary_key' => sub { ['key1', 'key2'] });

-1;

+1;