From Code to Community: Sponsoring The Perl and Raku Conference 2025 Learn more

use strict;
use Test::More import => [ qw( is like note ok plan subtest ) ];
use Test::Deep qw( cmp_bag );
use Test::Fatal qw( dies_ok exception );
use Path::Tiny qw( cwd tempdir );
eval { require DBD::SQLite };
plan $@ eq '' ? ( tests => 23 ) : ( skip_all => 'DBD::SQLite required' );
subtest 'wrong dsn' => sub {
plan tests => 2;
like
exception { DBIx::Migration->new( dsn => 'dbi:SQLite:dbname=' . cwd->child( qw( t missing test.db ) ) )->version },
qr/unable to open database file/, 'calling version() throws exception';
like exception {
DBIx::Migration->new(
dsn => 'dbi:SQLite:dbname=' . cwd->child( qw( t missing test.db ) ),
dir => cwd->child( qw( t sql advanced ) )
)->migrate
}, qr/unable to open database file/, 'calling migrate() throws exception';
};
my $expected_tracking_table = 'dbix-tracking';
my $tempdir = tempdir( CLEANUP => 1 );
my $m = DBIx::Migration->new(
tracking_table => $expected_tracking_table,
dsn => 'dbi:SQLite:dbname=' . $tempdir->child( 'test.db' )
);
note 'dsn: ', $m->dsn;
is my $tracking_table = $m->tracking_table, $expected_tracking_table, 'get tracking table';
is $m->version, undef, "\"$tracking_table\" table does not exist == migrate() not called yet";
ok $m->dbh->{ Active }, '"dbh" should be an active database handle';
dies_ok { $m->dir( cwd->child( qw( t sql invalid ) ) ) }
'"dir" is not valid with respect to the latest() based "MigrationsDir" constraint';
dies_ok { $m->latest } 'cannot call latest() because "dir" is not set';
dies_ok { $m->migrate( 0 ) } 'cannot call migrate() because "dir" not set';
$m->dir( cwd->child( qw( t sql advanced ) ) );
ok $m->migrate( 0 ), "initially (if the \"$tracking_table\" table does not exist yet) a database is at version 0";
subtest "privious migrate() has triggered the \"$tracking_table\" table creation" => sub {
plan tests => 2;
is $m->version, 0, 'check version';
cmp_bag [ $m->dbh->tables( '%', '%', '%', 'TABLE' ) ], [ "\"main\".\"$tracking_table\"" ], 'check tables';
};
sub migrate_to_version_assertion {
my ( $version, $tables ) = @_;
plan tests => 3;
ok $m->migrate( $version ), 'migrate';
is $m->version, $version, 'check version';
cmp_bag [ $m->dbh->tables( '%', '%', '%', 'TABLE' ) ], [ map { '"main".' . "\"$_\"" } @$tables ], 'check tables';
}
my $target_version = 1;
subtest
"migrate to version $target_version" => \&migrate_to_version_assertion,
$target_version, [ $tracking_table, 'Manufacturers' ];
$target_version = 2;
subtest
"migrate to version $target_version" => \&migrate_to_version_assertion,
$target_version, [ $tracking_table, 'Manufacturers', 'Products' ];
$target_version = 1;
subtest
"migrate to version $target_version" => \&migrate_to_version_assertion,
$target_version, [ $tracking_table, 'Manufacturers' ];
$target_version = 0;
subtest "migrate to version $target_version" => \&migrate_to_version_assertion, $target_version, [ $tracking_table ];
my $expected_latest_version = 3;
is $target_version = $m->latest, $expected_latest_version, 'get latest version';
ok $m->migrate, 'migrate to latest version';
is $m->version, $target_version, 'check version';
cmp_bag [ $m->dbh->tables( '%', '%', '%', 'TABLE' ) ],
[ map { '"main".' . "\"$_\"" } ( $tracking_table, 'Manufacturers', 'Products' ) ], 'check tables';
$target_version = 0;
subtest "migrate to version $target_version" => \&migrate_to_version_assertion, $target_version, [ $tracking_table ];
my $m1 = DBIx::Migration->new( dbh => $m->dbh, dir => $m->dir, tracking_table => $m->tracking_table );
is $m1->version, 0, "\"$tracking_table\" table exists and its \"version\" value is 0";
ok !$m1->migrate( 4 ), 'return false because sql up migration file is missing';
like exception {
DBIx::Migration->new(
dbh => $m->dbh,
dir => $m->dir,
do_before => [ 'PRAGMA foreign_keys = ON' ],
tracking_table => $m->tracking_table
)->migrate
}, qr/FOREIGN KEY constraint failed/, 'set do_before attribute to enable foreign key constraint';
$tempdir = tempdir( CLEANUP => 1 );
my $m2 = DBIx::Migration->new(
dsn => 'dbi:SQLite:dbname=' . $tempdir->child( 'test.db' ),
dir => cwd->child( qw( t sql rollback ) )
);
$tracking_table = $m2->tracking_table;
dies_ok { $m2->migrate } 'second migration section is broken';
cmp_bag [ $m2->dbh->tables( '%', '%', '%', 'TABLE' ) ], [ "\"main\".\"$tracking_table\"" ],
"check tables: creation of \"$tracking_table\" wasn't rolled back";