@@ -361,7 +361,8 @@ sub execute {

     $param ||= $opt{param} || {};

     my $tables = $opt{table} || [];

     $tables = [$tables] unless ref $tables eq 'ARRAY';

-    my $filter = _array_to_hash($opt{filter});

+    my $filter = ref $opt{filter} eq 'ARRAY' ?

+      _array_to_hash($opt{filter}) : $opt{filter};

     # Append

     $sql .= $opt{append} if defined $opt{append} && !ref $sql;

@@ -377,7 +378,7 @@ sub execute {

     }

     # Save query

-    $self->last_sql($query->sql);

+    $self->{last_sql} = $query->{sql};

     # Return query

     return $query if $opt{query};

@@ -401,24 +402,26 @@ sub execute {

     # Type rule

     my $type_filters = {};

-    unless ($opt{type_rule_off}) {

-        my $type_rule_off_parts = {

-            1 => $opt{type_rule1_off},

-            2 => $opt{type_rule2_off}

-        };

-        for my $i (1, 2) {

-            unless ($type_rule_off_parts->{$i}) {

-                $type_filters->{$i} = {};

-                my $table_alias = $opt{table_alias} || {};

-                for my $alias (keys %$table_alias) {

-                    my $table = $table_alias->{$alias};

-                    

-                    for my $column (keys %{$self->{"_into$i"}{key}{$table} || {}}) {

-                        $type_filters->{$i}->{"$alias.$column"} = $self->{"_into$i"}{key}{$table}{$column};

+    if ($self->{_type_rule_is_called}) {

+        unless ($opt{type_rule_off}) {

+            my $type_rule_off_parts = {

+                1 => $opt{type_rule1_off},

+                2 => $opt{type_rule2_off}

+            };

+            for my $i (1, 2) {

+                unless ($type_rule_off_parts->{$i}) {

+                    $type_filters->{$i} = {};

+                    my $table_alias = $opt{table_alias} || {};

+                    for my $alias (keys %$table_alias) {

+                        my $table = $table_alias->{$alias};

+                        

+                        for my $column (keys %{$self->{"_into$i"}{key}{$table} || {}}) {

+                            $type_filters->{$i}->{"$alias.$column"} = $self->{"_into$i"}{key}{$table}{$column};

+                        }

                     }

+                    $type_filters->{$i} = {%{$type_filters->{$i}}, %{$self->{"_into$i"}{key}{$main_table} || {}}}

+                      if $main_table;

                 }

-                $type_filters->{$i} = {%{$type_filters->{$i}}, %{$self->{"_into$i"}{key}{$main_table} || {}}}

-                  if $main_table;

             }

         }

     }

@@ -449,17 +452,22 @@ sub execute {

     }

     # Create bind values

-    my $bind = $self->_create_bind_values($param, $query->columns,

-      $filter, $type_filters, _array_to_hash($opt{bind_type} || $opt{type}));

+    my ($bind, $bind_types) = $self->_create_bind_values($param, $query->columns,

+      $filter, $type_filters, $opt{bind_type} || $opt{type} || {});

     # Execute

-    my $sth = $query->sth;

+    my $sth = $query->{sth};

     my $affected;

     eval {

-        $sth->bind_param($_ + 1, $bind->[$_]->{value},

-            $bind->[$_]->{bind_type} ? $bind->[$_]->{bind_type} : ())

-          for (0 .. @$bind - 1);

-        $affected = $sth->execute;

+        if ($opt{bind_type} || $opt{type}) {

+            $sth->bind_param($_ + 1, $bind->[$_],

+                $bind_types->[$_] ? $bind_types->[$_] : ())

+              for (0 .. @$bind - 1);

+            $affected = $sth->execute;

+        }

+        else {

+            $affected = $sth->execute(@$bind);

+        }

     };

     $self->_croak($@, qq{. Following SQL is executed.\n}

@@ -479,39 +487,36 @@ sub execute {

         print STDERR "Bind values: " . join(', ', @output) . "\n\n";

     }

-    # Select statement

-    if ($sth->{NUM_OF_FIELDS}) {

-        

-        # Filter(DEPRECATED!)

-        my $filter = {};

-        if ($self->{filter}{on}) {

-            $filter->{in}  = {};

-            $filter->{end} = {};

-            push @$tables, $main_table if $main_table;

-            for my $table (@$tables) {

-                for my $way (qw/in end/) {

-                    $filter->{$way} = {%{$filter->{$way}},

-                      %{$self->{filter}{$way}{$table} || {}}};

-                }

+    # Not select statement

+    return $affected unless $sth->{NUM_OF_FIELDS};

+

+    # Filter(DEPRECATED!)

+    my $infilter = {};

+    if ($self->{filter}{on}) {

+        $infilter->{in}  = {};

+        $infilter->{end} = {};

+        push @$tables, $main_table if $main_table;

+        for my $table (@$tables) {

+            for my $way (qw/in end/) {

+                $infilter->{$way} = {%{$infilter->{$way}},

+                  %{$self->{filter}{$way}{$table} || {}}};

             }

         }

-        

-        # Result

-        my $result = $self->result_class->new(

-            sth => $sth,

-            dbi => $self,

-            default_filter => $self->{default_in_filter},

-            filter => $filter->{in} || {},

-            end_filter => $filter->{end} || {},

-            type_rule => {

-                from1 => $self->type_rule->{from1},

-                from2 => $self->type_rule->{from2}

-            },

-        );

-        return $result;

     }

-    # Not select statement

-    else { return $affected }

+    

+    # Result

+    my $result = $self->result_class->new(

+        sth => $sth,

+        dbi => $self,

+        default_filter => $self->{default_in_filter},

+        filter => $infilter->{in} || {},

+        end_filter => $infilter->{end} || {},

+        type_rule => {

+            from1 => $self->type_rule->{from1},

+            from2 => $self->type_rule->{from2}

+        },

+    );

+    $result;

 }

 sub get_table_info {

@@ -918,6 +923,8 @@ sub show_tables {

 sub type_rule {

     my $self = shift;

+

+    $self->{_type_rule_is_called} = 1;

     if (@_) {

         my $type_rule = ref $_[0] eq 'HASH' ? $_[0] : {@_};

@@ -1185,8 +1192,11 @@ sub _create_query {

 sub _create_bind_values {

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

+    $bind_type = _array_to_hash($bind_type) if ref $bind_type eq 'ARRAY';

+    

     # Create bind values

     my $bind = [];

+    my $types = [];

     my $count = {};

     my $not_exists = {};

     for my $column (@$columns) {

@@ -1224,13 +1234,14 @@ sub _create_bind_values {

         $value = $tf2->($value) if $tf2;

         # Bind values

-        push @$bind, {value => $value, bind_type => $bind_type->{$column}};

+        push @$bind, $value;

+        push @$types, $bind_type->{$column};

         # Count up 

         $count->{$column}++;

     }

-    return $bind;

+    return ($bind, $types);

 }

 sub _id_to_param {

@@ -162,6 +162,18 @@ $result = $dbi->execute('select length(key1) as key1_length from table1');

 $row = $result->one;

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

+test 'bind_type option'; # DEPRECATED!

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

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

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

+$dbi->insert({key1 => $binary, key2 => 'あ'}, table => 'table1', bind_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);

+

 test 'type_rule from';

 $dbi = DBIx::Custom->connect;

 $dbi->type_rule(