skeleton insert code

[dbsrgits/DBIx-Data-Store-old.git] / t / 01basic_collection.t

use Test::More;
use DBIx::Data::Store;
use DBIx::Data::Store::CRUD;
use DBIx::Data::Collection::Set;
use DBI;

use strict;
use warnings FATAL => 'all';

my $dsn = 'dbi:SQLite:tmp.db';

my @expect;

sub sort_set {
  sort { $a->{name} cmp $b->{name} } @_
}

{
  unlink('tmp.db');
  my $dbh = DBI->connect($dsn);
  $dbh->do(q{
    CREATE TABLE person (
      id INTEGER NOT NULL PRIMARY KEY,
      name VARCHAR(255) NOT NULL
    )
  });
  my $pop = $dbh->prepare(q{INSERT INTO person (name) VALUES (?)});
  my @names = qw(Joe Jim Bob Pterry);
  $pop->execute($_) for @names;
  @expect = sort_set do {
    my $id = 0; map +{ id => ++$id, name => $_ }, @names
  };
}

sub make_set {
  my ($set, $crud) = @_;
  DBIx::Data::Collection::Set->new(
    set_over => [ 'id' ],
    store => DBIx::Data::Store::CRUD->new(
      raw_store => DBIx::Data::Store->connect($dsn),
      select_sql => q{SELECT id, name FROM person},
      select_column_order => [ qw(id name) ],
      %$crud,
    ),
    %$set
  );
}

my $set = make_set;

is_deeply([ sort_set $set->flatten ], \@expect, 'Basic data out ok (flatten)');

{
  my $stream = $set->as_stream;

  my @got; while (my ($next) = $stream->next) { push @got, $next }

  is_deeply([ sort_set @got ], \@expect, 'Basic data out ok (stream)');
}

$set = make_set { class => 'Spoon' };

is_deeply(
  [ sort_set $set->flatten ],
  [ map { bless({ %$_ }, 'Spoon') } @expect ],
  'Basic data with class out ok'
);

$set = make_set {}, {
  insert_sql => q{INSERT INTO person (name) VALUES (?) },
  insert_argument_order => [ 'name' ],
  insert_command_constructor => sub {
    require DBIx::Data::Store::Command::Insert::LastInsertId;
    my $self = shift;
    DBIx::Data::Store::Command::Insert::LastInsertId->new(
      id_column => 'id',
      raw_store => $self->raw_store,
      insert_call_command => $self->raw_store->new_call_command(@_)
    );
  }
};

my $doug = $set->add({ name => 'Doug' });

use Devel::Dwarn;

Dwarn $doug;

done_testing;