8 use Test::SQL::Translator;
10 use SQL::Translator::Diff;
13 maybe_plan(undef, 'DBD::Pg');
15 my ( $pg_tst, $ddl, $ret, $dsn, $user, $pass );
16 if ($ENV{DBICTEST_PG_DSN}) {
17 ($dsn, $user, $pass) = map { $ENV{"DBICTEST_PG_$_"} } qw(DSN USER PASS);
21 maybe_plan(undef, 'Test::PostgreSQL');
22 open my $fh, '<:raw', $INC{"Test/PostgreSQL.pm"} or die "No Test::PostgreSQL: $!\n";
23 my $d = Digest->new('MD5');
25 diag sprintf "Test::PostgreSQL %s found at %s (md5: %s)",
26 Test::PostgreSQL->VERSION, $INC{"Test/PostgreSQL.pm"}, $d->hexdigest;
27 $pg_tst = eval { Test::PostgreSQL->new }
28 or plan skip_all => "Can't create test database: $Test::PostgreSQL::errstr";
32 my $dbh = DBI->connect($dsn, $user, $pass, { RaiseError => 1, AutoCommit => 1 });
33 $dbh->do('SET client_min_messages=warning');
35 my $source_ddl = <<DDL;
36 CREATE TABLE sqlt_test_foo (
37 pk SERIAL PRIMARY KEY,
42 ok( $ret = $dbh->do($source_ddl), "create table" );
44 ok( $ret = $dbh->do(q| INSERT INTO sqlt_test_foo (bar) VALUES ('buzz') |), "insert data" );
46 cmp_ok( $ret, '==', 1, "one row inserted" );
48 my $target_ddl = <<DDL;
49 CREATE TABLE sqlt_test_fluff (
50 pk SERIAL PRIMARY KEY,
55 my $source_sqlt = SQL::Translator->new(
57 parser => 'SQL::Translator::Parser::PostgreSQL',
58 )->translate(\$source_ddl);
60 my $target_sqlt = SQL::Translator->new(
62 parser => 'SQL::Translator::Parser::PostgreSQL',
63 )->translate(\$target_ddl);
65 my $table = $target_sqlt->get_table('sqlt_test_fluff');
66 $table->extra( renamed_from => 'sqlt_test_foo' );
67 my $field = $table->get_field('biff');
68 $field->extra( renamed_from => 'bar' );
70 my @diff = SQL::Translator::Diff->new({
71 output_db => 'PostgreSQL',
72 source_schema => $source_sqlt,
73 target_schema => $target_sqlt,
74 })->compute_differences->produce_diff_sql;
76 foreach my $line (@diff) {
78 next if $line =~ /^--/;
79 lives_ok { $dbh->do($line) } "$line";
82 ok ( $ret = $dbh->selectall_arrayref(q(SELECT biff FROM sqlt_test_fluff), { Slice => {} }), "query DB for data" );
84 cmp_ok( scalar(@$ret), '==', 1, "Got 1 row");
86 cmp_ok( $ret->[0]->{biff}, 'eq', 'buzz', "col biff has value buzz" );
88 # Make sure Test::PostgreSQL can kill Pg
89 undef $dbh if $pg_tst;
92 if ($dbh && !$pg_tst) {
93 $dbh->do("drop table if exists sqlt_test_$_") foreach qw(foo fluff);
96 # do the teardown ourselves, work around RT#108460