@@ -1,3 +1,14 @@

+0.2107

+  - removed EXPERIMENTAL status from the following methods and functinalities.

+      DBIx::Custom::Result::value method

+      DBIx::Custom::Result::column method

+      DBIx::Custom::insert method "bulk_insert" option

+      DBIx::Custom::insert method "multiplue insert functinality"

+      DBIx::Custom::select method "first argument is received as column option"

+      DBIx::Custom::Model::created_at attribute

+      DBIx::Custom::Model::updated_at attribute

+  - added EXPERIMENTAL DBIx::Custom::execute method "prepare_attr" option

+  - added EXPERIMETNAL DBIx::Custom::execute method "statement" option

 0.2106

   - renamed DBIx::Custom::Result::fetch_hash_first to fethc_hash_one

     because first is misleading name. fethc_hash_first is DEPRECATED!

@@ -354,6 +354,7 @@ sub execute {

   # Merge second parameter

   my @cleanup;

   my $saved_param;

+  $opt{statement} ||= '';

   if (($opt{statement} || '') ne 'insert' && ref $params eq 'ARRAY') {

     my $params2 = $params->[1];

     $params = $params->[0];

@@ -395,7 +396,8 @@ sub execute {

             unless $column =~ /^[$c\.]+$/;

         }

       }

-      $query = $self->_create_query($sql,$opt{after_build_sql} || $opt{sqlfilter});

+      $query = $self->_create_query($sql,

+        $opt{after_build_sql} || $opt{sqlfilter}, $opt{prepare_attr});

     }

     $query->{statement} = $opt{statement} || '';

     $opt{reuse}->{$sql} = $query if $opt{reuse};

@@ -554,7 +556,7 @@ sub execute {

   }

   # Not select statement

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

+  return $affected if !$sth->{NUM_OF_FIELDS} && $opt{statement} ne 'select';

   # Filter(DEPRECATED!)

   my $infilter = {};

@@ -1269,7 +1271,9 @@ sub where { DBIx::Custom::Where->new(dbi => shift, @_) }

 sub _create_query {

-  my ($self, $source, $after_build_sql) = @_;

+  my ($self, $source, $after_build_sql, $prepare_attr) = @_;

+  

+  $prepare_attr ||= {};

   # Cache

   my $cache = $self->{cache};

@@ -1344,7 +1348,7 @@ sub _create_query {

   # Prepare statement handle

   my $sth;

-  eval { $sth = $self->dbh->prepare($query->{sql}) };

+  eval { $sth = $self->dbh->prepare($query->{sql}, $prepare_attr) };

   if ($@) {

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

@@ -2631,6 +2635,13 @@ The following SQL is executed.

 Append some statement after SQL.

+=item C<prepare_attr> EXPERIMENTAL

+

+  prepare_attr => {async => 1}

+

+Statemend handle attributes,

+this is L<DBI>'s C<prepare> method second argument.

+

 =item C<bind_type>

 Specify database bind data type.

@@ -2694,6 +2705,12 @@ because generally creating query object is slow.

 Priamry key. This is used for C<id> option.

+=item C<statement> EXPERIMETAL

+

+  statement => 'select'

+

+If you set statement to C<select>, return value is always L<DBIx::Custom::Result> object.

+

 =item C<table>

   table => 'author'

@@ -2790,7 +2807,6 @@ as parameter value.

   {date => \"NOW()"}

 You can pass multiple parameters, this is very fast.

-This is EXPERIMETNAL.

   $dbi->insert(

     [

@@ -2801,7 +2817,7 @@ This is EXPERIMETNAL.

   );

 In multiple insert, you can't use C<id> option.

-and only first parameter is used by creating sql.

+and only first parameter is used to create sql.

 B<options>

@@ -2809,8 +2825,8 @@ C<insert> method use all of C<execute> method's options,

 and use the following new ones.

 =over 4

-b

-=item C<bulk_insert> EXPERIMENTAL

+

+=item C<bulk_insert>

   bulk_insert => 1

@@ -3030,7 +3046,6 @@ Register filters, used by C<filter> option of many methods.

 Execute select statement.

 You can pass odd number arguments. first argument is C<column>.

-This is EXPERIMENTAL.

   my $result = $dbi->select(['author', 'title'], table => 'book');

@@ -185,7 +185,7 @@ my $model = DBIx::Custom::Model->new(table => 'books');

 L<DBIx::Custom> object.

-=head2 C<created_at EXPERIMENTAL>

+=head2 C<created_at>

   my $created_at = $model->created_at;

   $model = $model->created_at('created_datatime');

@@ -225,7 +225,7 @@ Database data type, this is used as type optioon of C<insert>,

 C<update>, C<update_all>, C<delete>, C<delete_all>,

 and C<select> method

-=head2 C<updated_at EXPERIMENTAL>

+=head2 C<updated_at>

   my $updated_at = $model->updated_at;

   $model = $model->updated_at('updated_datatime');

@@ -327,7 +327,7 @@ sub _cache {

   $self->{_type_map} = {};

   $self->{_pos} = {};

   $self->{_columns} = {};

-  for (my $i = 0; $i < @{$self->{sth}->{NAME}}; $i++) {

+  for (my $i = 0; $i < @{$self->{sth}->{NAME} || []}; $i++) {

     my $type = lc $self->{sth}{TYPE}[$i];

     my $name = $self->{sth}{NAME}[$i];

     $self->{_type_map}{$type} ||= [];

@@ -496,7 +496,7 @@ and implements the following new ones.

 Same as C<fetch_hash_all>.

-=head2 C<column> EXPERIMENTAL

+=head2 C<column>

   my $column = $result->column;

@@ -645,7 +645,7 @@ By default, type rule is on.

 Turn C<from2> type rule on.

 By default, type rule is on.

-=head2 C<value> EXPERIMENTAL

+=head2 C<value>

   my $value = $result->value;

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

+use Test::More;

+use strict;

+use warnings;

+use utf8;

+

+use FindBin;

+use DBIx::Custom;

+

+my $dbi;

+my $dsn;

+my $args;

+my $user = 'dbix_custom';

+my $password = 'dbix_custom';

+my $database = 'dbix_custom';

+

+$dsn = "dbi:mysql:database=$database";

+$args = {dsn => $dsn, user => $user, password => $password,};

+

+plan skip_all => 'mysql private test' unless -f "$FindBin::Bin/run/mysql-async.run"

+  && eval { $dbi = DBIx::Custom->connect($args); 1 };

+plan 'no_plan';

+

+$SIG{__WARN__} = sub { warn $_[0] unless $_[0] =~ /DEPRECATED/};

+

+# Function for test name

+sub test { print "# $_[0]\n" }

+

+# Varialbes for tests

+my $dbname;

+my $row;

+my $rows;

+my $result;

+my $result2;

+my $model;

+my $dbi2;

+

+test 'connect';

+eval {

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

+    dsn => "dbi:mysql:database=$database;host=localhost;port=10000",

+    user => $user,

+    password => $password

+  );

+};

+ok(!$@);

+

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

+$dbi->do('create table table1 (key1 varchar(255), key2 varchar(255)) engine=InnoDB');

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

+

+test 'async test';

+

+use AnyEvent;

+use DBI;

+my $cond = AnyEvent->condvar;

+$result = $dbi->execute('SELECT SLEEP(1), 3', undef,

+  prepare_attr => {async => 1}, statement => 'select');

+

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

+  dsn => "dbi:mysql:database=$database;host=localhost;port=10000",

+  user => $user,

+  password => $password

+);

+$result2 = $dbi2->select('key1', table => 'table1', prepare_attr => {async => 1});

+

+my $timer = AnyEvent->timer(

+  interval => 1,

+  cb => sub {

+    1;

+  }

+);

+

+my $count = 0;

+

+my $mysql_watcher = AnyEvent->io(

+  fh   => $dbi->dbh->mysql_fd,

+  poll => 'r',

+  cb   => sub {

+    my $row = $result->fetch_one;

+    is($row->[1], 3, 'before');

+    $cond->send if ++$count == 2;

+    undef $result;

+  }

+);

+

+my $mysql_watcher2= AnyEvent->io(

+  fh   => $dbi2->dbh->mysql_fd,

+  poll => 'r',

+  cb   => sub {

+    my $row = $result2->fetch_one;

+    is($row->[0], 1, 'after');

+    $cond->send if ++$count == 2;

+    undef $result2;

+  }

+);

+$cond->recv;