use Test::More; use strict; use warnings; # user password database our ($USER, $PASSWORD, $DATABASE) = connect_info(); plan skip_all => 'private MySQL test' unless $USER; plan 'no_plan'; # Function for test name my $test; sub test { $test = shift; } # Functions for tests sub connect_info { my $file = 'password.tmp'; open my $fh, '<', $file or return; my ($user, $password, $database) = split(/\s/, (<$fh>)[0]); close $fh; return ($user, $password, $database); } # Varialbes for tests my $dbi; my $dbname; my $rows; # Constant varialbes for test my $CREATE_TABLE = { 0 => 'create table table1 (key1 char(255), key2 char(255));' }; use DBIx::Custom::MySQL; test 'connect'; $dbi = DBIx::Custom::MySQL->new(user => $USER, password => $PASSWORD, database => $DATABASE, host => 'localhost', port => '10000'); $dbi->connect; like($dbi->data_source, qr/dbi:mysql:database=.*;host=localhost;port=10000;/, "$test : created data source"); is(ref $dbi->dbh, 'DBI::db', $test); test 'attributes'; $dbi = DBIx::Custom::MySQL->new; $dbi->host('a'); is($dbi->host, 'a', "$test: host"); $dbi->port('b'); is($dbi->port, 'b', "$test: port"); test 'limit'; $dbi = DBIx::Custom->connect( data_source => "dbi:mysql:database=$DATABASE", user => $USER, password => $PASSWORD ); $dbi->insert(table => 'table1', param => {key1 => 1, key2 => 2}); $dbi->insert(table => 'table1', param => {key1 => 1, key2 => 4}); $dbi->insert(table => 'table1', param => {key1 => 1, key2 => 6}); $dbi->query_builder->register_tag_processor( limit => sub { my ($count, $offset) = @_; my $s = ''; $offset = 0 unless defined $offset; $s .= "limit $offset"; $s .= ", $count"; return [$s, []]; } ); $rows = $dbi->select( table => 'table1', where => {key1 => 1}, append => "order by key2 {limit 1 0}" )->fetch_hash_all; is_deeply($rows, [{key1 => 1, key2 => 2}], $test); $rows = $dbi->select( table => 'table1', where => {key1 => 1}, append => "order by key2 {limit 2 1}" )->fetch_hash_all; is_deeply($rows, [{key1 => 1, key2 => 4},{key1 => 1, key2 => 6}], $test); $rows = $dbi->select( table => 'table1', where => {key1 => 1}, append => "order by key2 {limit 1}" )->fetch_hash_all; is_deeply($rows, [{key1 => 1, key2 => 2}], $test); $dbi->delete_all(table => 'table1');