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
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
use strict;
use warnings;
use Test::More;
use lib qw(t/lib);
use DBICTest;
{
package DBICTest::Schema::Casecheck;
use strict;
use warnings;
use base 'DBIx::Class';
__PACKAGE__->load_components(qw/Core/);
__PACKAGE__->table('casecheck');
__PACKAGE__->add_columns(qw/id name NAME uc_name/);
__PACKAGE__->column_info_from_storage(1);
__PACKAGE__->set_primary_key('id');
}
my ($dsn, $user, $pass) = @ENV{map { "DBICTEST_PG_${_}" } qw/DSN USER PASS/};
#warn "$dsn $user $pass";
plan skip_all => 'Set $ENV{DBICTEST_PG_DSN}, _USER and _PASS to run this test'
. ' (note: creates and drops tables named artist and casecheck!)' unless ($dsn && $user);
plan tests => 16;
DBICTest::Schema->load_classes( 'Casecheck' );
my $schema = DBICTest::Schema->connect($dsn, $user, $pass);
# Check that datetime_parser returns correctly before we explicitly connect.
SKIP: {
eval { require DateTime::Format::Pg };
skip "DateTime::Format::Pg required", 2 if $@;
my $store = ref $schema->storage;
is($store, 'DBIx::Class::Storage::DBI', 'Started with generic storage');
my $parser = $schema->storage->datetime_parser;
is( $parser, 'DateTime::Format::Pg', 'datetime_parser is as expected');
}
my $dbh = $schema->storage->dbh;
$schema->source("Artist")->name("testschema.artist");
$dbh->do("CREATE SCHEMA testschema;");
$dbh->do("CREATE TABLE testschema.artist (artistid serial PRIMARY KEY, name VARCHAR(100), charfield CHAR(10));");
ok ( $dbh->do('CREATE TABLE testschema.casecheck (id serial PRIMARY KEY, "name" VARCHAR(1), "NAME" VARCHAR(2), "UC_NAME" VARCHAR(3));'), 'Creation of casecheck table');
# This is in Core now, but it's here just to test that it doesn't break
$schema->class('Artist')->load_components('PK::Auto');
my $new = $schema->resultset('Artist')->create({ name => 'foo' });
is($new->artistid, 1, "Auto-PK worked");
$new = $schema->resultset('Artist')->create({ name => 'bar' });
is($new->artistid, 2, "Auto-PK worked");
my $test_type_info = {
'artistid' => {
'data_type' => 'integer',
'is_nullable' => 0,
'size' => 4,
},
'name' => {
'data_type' => 'character varying',
'is_nullable' => 1,
'size' => 100,
'default_value' => undef,
},
'charfield' => {
'data_type' => 'character',
'is_nullable' => 1,
'size' => 10,
'default_value' => undef,
},
};
my $type_info = $schema->storage->columns_info_for('testschema.artist');
my $artistid_defval = delete $type_info->{artistid}->{default_value};
like($artistid_defval,
qr/^nextval\('([^\.]*\.){0,1}artist_artistid_seq'::(?:text|regclass)\)/,
'columns_info_for - sequence matches Pg get_autoinc_seq expectations');
is_deeply($type_info, $test_type_info,
'columns_info_for - column data types');
my $name_info = $schema->source('Casecheck')->column_info( 'name' );
is( $name_info->{size}, 1, "Case sensitive matching info for 'name'" );
my $NAME_info = $schema->source('Casecheck')->column_info( 'NAME' );
is( $NAME_info->{size}, 2, "Case sensitive matching info for 'NAME'" );
my $uc_name_info = $schema->source('Casecheck')->column_info( 'uc_name' );
is( $uc_name_info->{size}, 3, "Case insensitive matching info for 'uc_name'" );
# Test SELECT ... FOR UPDATE
my $HaveSysSigAction = eval "require Sys::SigAction" && !$@;
if ($HaveSysSigAction) {
Sys::SigAction->import( 'set_sig_handler' );
}
SKIP: {
skip "Sys::SigAction is not available", 3 unless $HaveSysSigAction;
# create a new schema
my $schema2 = DBICTest::Schema->connect($dsn, $user, $pass);
$schema2->source("Artist")->name("testschema.artist");
$schema->txn_do( sub {
my $artist = $schema->resultset('Artist')->search(
{
artistid => 1
},
{
for => 'update'
}
)->first;
is($artist->artistid, 1, "select for update returns artistid = 1");
my $artist_from_schema2;
my $error_ok = 0;
eval {
my $h = set_sig_handler( 'ALRM', sub { die "DBICTestTimeout" } );
alarm(2);
$artist_from_schema2 = $schema2->resultset('Artist')->find(1);
$artist_from_schema2->name('fooey');
$artist_from_schema2->update;
alarm(0);
};
if (my $e = $@) {
$error_ok = $e =~ /DBICTestTimeout/;
}
# Make sure that an error was raised, and that the update failed
ok($error_ok, "update from second schema times out");
ok($artist_from_schema2->is_column_changed('name'), "'name' column is still dirty from second schema");
});
}
SKIP: {
skip "Sys::SigAction is not available", 3 unless $HaveSysSigAction;
# create a new schema
my $schema2 = DBICTest::Schema->connect($dsn, $user, $pass);
$schema2->source("Artist")->name("testschema.artist");
$schema->txn_do( sub {
my $artist = $schema->resultset('Artist')->search(
{
artistid => 1
},
)->first;
is($artist->artistid, 1, "select for update returns artistid = 1");
my $artist_from_schema2;
my $error_ok = 0;
eval {
my $h = set_sig_handler( 'ALRM', sub { die "DBICTestTimeout" } );
alarm(2);
$artist_from_schema2 = $schema2->resultset('Artist')->find(1);
$artist_from_schema2->name('fooey');
$artist_from_schema2->update;
alarm(0);
};
if (my $e = $@) {
$error_ok = $e =~ /DBICTestTimeout/;
}
# Make sure that an error was NOT raised, and that the update succeeded
ok(! $error_ok, "update from second schema DOES NOT timeout");
ok(! $artist_from_schema2->is_column_changed('name'), "'name' column is NOT dirty from second schema");
});
}
END {
if($dbh) {
$dbh->do("DROP TABLE testschema.artist;");
$dbh->do("DROP TABLE testschema.casecheck;");
$dbh->do("DROP SCHEMA testschema;");
}
}
|
