5 use DBIx::Class::Optional::Dependencies ();
8 DBICTEST_PG => 'rdbms_pg',
9 DBICTEST_MYSQL => 'test_rdbms_mysql',
12 plan skip_all => join (' ',
13 'Set $ENV{DBICTEST_PG_DSN} and/or $ENV{DBICTEST_MYSQL_DSN} _USER and _PASS to run these tests.',
14 ) unless grep { $ENV{"${_}_DSN"} } keys %$env2optdep;
22 for my $prefix (keys %$env2optdep) { SKIP: {
23 my ($dsn, $user, $pass) = map { $ENV{"${prefix}_$_"} } qw/DSN USER PASS/;
25 skip ("Skipping tests with $prefix: set \$ENV{${prefix}_DSN} _USER and _PASS", 1)
28 skip ("Testing with ${prefix}_DSN needs " . DBIx::Class::Optional::Dependencies->req_missing_for( $env2optdep->{$prefix} ), 1)
29 unless DBIx::Class::Optional::Dependencies->req_ok_for($env2optdep->{$prefix});
31 $schema = DBICTest::Schema->connect ($dsn,$user,$pass,{ auto_savepoint => 1 });
34 $schema->storage->ensure_connected;
35 if ($schema->storage->isa('DBIx::Class::Storage::DBI::Pg')) {
36 $create_sql = "CREATE TABLE artist (artistid serial PRIMARY KEY, name VARCHAR(100), rank INTEGER NOT NULL DEFAULT '13', charfield CHAR(10))";
37 $schema->storage->dbh->do('SET client_min_messages=WARNING');
39 elsif ($schema->storage->isa('DBIx::Class::Storage::DBI::mysql')) {
40 $create_sql = "CREATE TABLE artist (artistid INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, name VARCHAR(100), rank INTEGER NOT NULL DEFAULT '13', charfield CHAR(10)) ENGINE=InnoDB";
43 skip( 'Untested driver ' . $schema->storage, 1 );
46 note "Testing $prefix";
48 my $stats = DBICTest::Stats->new;
49 $schema->storage->debugobj($stats);
50 $schema->storage->debug(1);
52 $schema->storage->dbh->do ('DROP TABLE IF EXISTS artist');
53 $schema->storage->dbh->do ($create_sql);
55 $schema->resultset('Artist')->create({ name => 'foo' });
59 my $arty = $schema->resultset('Artist')->find(1);
61 my $name = $arty->name;
63 # First off, test a generated savepoint name
66 cmp_ok($stats->{'SVP_BEGIN'}, '==', 1, 'Statistics svp_begin tickled');
68 $arty->update({ name => 'Jheephizzy' });
70 $arty->discard_changes;
72 cmp_ok($arty->name, 'eq', 'Jheephizzy', 'Name changed');
74 # Rollback the generated name
76 $schema->svp_rollback;
78 cmp_ok($stats->{'SVP_ROLLBACK'}, '==', 1, 'Statistics svp_rollback tickled');
80 $arty->discard_changes;
82 cmp_ok($arty->name, 'eq', $name, 'Name rolled back');
84 $arty->update({ name => 'Jheephizzy'});
87 $schema->svp_begin('testing1');
89 $arty->update({ name => 'yourmom' });
92 $schema->svp_begin('testing2');
94 $arty->update({ name => 'gphat' });
95 $arty->discard_changes;
96 cmp_ok($arty->name, 'eq', 'gphat', 'name changed');
98 # Rollback doesn't DESTROY the savepoint, it just rolls back to the value
100 $schema->svp_rollback('testing2');
101 $arty->discard_changes;
102 cmp_ok($arty->name, 'eq', 'yourmom', 'testing2 reverted');
105 $schema->svp_begin('testing3');
106 $arty->update({ name => 'coryg' });
108 $schema->svp_begin('testing4');
109 $arty->update({ name => 'watson' });
111 # Release 3, which implicitly releases 4
113 $schema->svp_release('testing3');
114 $arty->discard_changes;
115 cmp_ok($arty->name, 'eq', 'watson', 'release left data');
116 # This rolls back savepoint 2
118 $schema->svp_rollback;
119 $arty->discard_changes;
120 cmp_ok($arty->name, 'eq', 'yourmom', 'rolled back to 2');
122 # Rollback the original savepoint, taking us back to the beginning, implicitly
123 # rolling back savepoint 1 and 2
124 $schema->svp_rollback('savepoint_0');
125 $arty->discard_changes;
126 cmp_ok($arty->name, 'eq', 'foo', 'rolled back to start');
130 # And now to see if txn_do will behave correctly
131 $schema->txn_do (sub {
134 $schema->txn_do (sub {
135 $artycp->name ('Muff');
140 $schema->txn_do (sub {
141 $artycp->name ('Moff');
143 $artycp->discard_changes;
144 is($artycp->name,'Moff','Value updated in nested transaction');
145 $schema->storage->dbh->do ("GUARANTEED TO PHAIL");
149 ok ($@,'Nested transaction failed (good)');
151 $arty->discard_changes;
153 is($arty->name,'Muff','auto_savepoint rollback worked');
155 $arty->name ('Miff');
160 $arty->discard_changes;
162 is($arty->name,'Miff','auto_savepoint worked');
164 cmp_ok($stats->{'SVP_BEGIN'},'==',7,'Correct number of savepoints created');
166 cmp_ok($stats->{'SVP_RELEASE'},'==',3,'Correct number of savepoints released');
168 cmp_ok($stats->{'SVP_ROLLBACK'},'==',5,'Correct number of savepoint rollbacks');
170 $schema->storage->dbh->do ("DROP TABLE artist");
176 eval { $schema->storage->dbh->do ("DROP TABLE artist") } if defined $schema;