1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
#!/usr/bin/perl
# test for prepare_cached()
use strict;
use warnings;
use Test::More;
use lib 't','.';
use TestFirebird;
my $T = TestFirebird->new;
my ($dbh, $error_str) = $T->connect_to_database();
if ($error_str) {
BAIL_OUT("Unknown: $error_str!");
}
unless ( $dbh->isa('DBI::db') ) {
plan skip_all => 'Connection to database failed, cannot continue testing';
}
else {
plan tests => 37;
}
ok($dbh, 'Connected to the database');
# ------- TESTS ------------------------------------------------------------- #
#
# Find a possible new table name
#
my $table = find_new_table($dbh);
ok($table, qq{Table is '$table'});
{
my $def = "CREATE TABLE $table (id INTEGER NOT NULL, PRIMARY KEY(id))";
ok($dbh->do($def));
my $stmt = "INSERT INTO $table (id) VALUES(?)";
ok($dbh->do($stmt, undef, 1));
}
my $prepare_sub = sub { $dbh->prepare(shift), "prepare" };
SKIP: {
skip("prepare() tests", 10) if $ENV{SKIP_PREPARE};
simple_query($dbh, $prepare_sub);
faulty_query($dbh, $prepare_sub);
simple_query($dbh, $prepare_sub);
}
TEST_CACHED: {
$prepare_sub = sub { $dbh->prepare_cached(shift), "prepare_cached" };
my ($query, $n_cached);
$query = simple_query($dbh, $prepare_sub);
for (values %{$dbh->{CachedKids}}) {
$n_cached++ if $_->{Statement} eq $query;
}
is($n_cached, 1, qq{cached "$query"});
$dbh->commit() unless $dbh->{AutoCommit};
# print Dumper $dbh->{CachedKids} unless $dbh->{AutoCommit};
# $k = faulty_query($dbh, $mode);
# ok($dbh->{CachedKids}{$k}, qq{cached "$k"});
# $dbh->rollback() unless $dbh->{AutoCommit};
$query = simple_query($dbh, $prepare_sub);
is(scalar keys(%{$dbh->{CachedKids}}), 1);
# clear cached sth
%{$dbh->{CachedKids}} = ();
# wrong:
# $dbh->{CachedKids} = undef;
# repeat with AutoCommit off
if ($dbh->{AutoCommit}) {
$dbh->{AutoCommit} = 0;
pass("AutoCommit is now turned Off");
goto TEST_CACHED;
} else {
$dbh->{AutoCommit} = 1;
last TEST_CACHED;
}
}
ok($dbh->do("DROP TABLE $table"), "DROP TABLE $table");
ok($dbh->disconnect);
# 4 tests
sub simple_query {
my ($dbh, $prepare_sub) = @_;
my $sql = "SELECT id FROM $table";
my ($sth, $mode) = $prepare_sub->($sql);
ok($sth, "$mode() for SELECT");
ok(defined($sth->execute()), "execute()");
# print "Active? ", $sth->{Active}, "\n";
my $r = $sth->fetchall_arrayref;
is($r->[0][0], 1, "check fetch result");
is($sth->err, undef, "fetch all result set");
return $sql;
}
# 2 tests
sub faulty_query {
my ($dbh, $prepare_sub) = @_;
my $sql = "INSERT INTO $table VALUES(?)";
my ($sth, $mode) = $prepare_sub->($sql);
ok($sth, "$mode() for INSERT");
eval { $sth->execute(1) };
ok ($@, 'expected INSERT failure');
return $sql;
}
|
