Commit | Line | Data |
c9d2e0a2 |
1 | #!/usr/bin/perl |
2 | use strict; |
3 | use warnings; |
4 | use Test::More; |
86ef9f0d |
5 | use File::Spec; |
f925f7cb |
6 | use File::Copy; |
1475105d |
7 | use Time::HiRes qw/time sleep/; |
c9d2e0a2 |
8 | |
1d48fcff |
9 | #warn "$dsn $user $pass"; |
10 | my ($dsn, $user, $pass); |
11 | |
c9d2e0a2 |
12 | BEGIN { |
1d48fcff |
13 | ($dsn, $user, $pass) = @ENV{map { "DBICTEST_MYSQL_${_}" } qw/DSN USER PASS/}; |
14 | |
15 | plan skip_all => 'Set $ENV{DBICTEST_MYSQL_DSN}, _USER and _PASS to run this test' |
8424c090 |
16 | unless ($dsn); |
1d48fcff |
17 | |
18 | |
0e2c6809 |
19 | eval "use DBD::mysql; use SQL::Translator 0.09;"; |
c9d2e0a2 |
20 | plan $@ |
0e2c6809 |
21 | ? ( skip_all => 'needs DBD::mysql and SQL::Translator 0.09 for testing' ) |
e9fbbbf4 |
22 | : ( tests => 22 ); |
c9d2e0a2 |
23 | } |
24 | |
b4b1e91c |
25 | my $version_table_name = 'dbix_class_schema_versions'; |
26 | my $old_table_name = 'SchemaVersions'; |
27 | |
1475105d |
28 | my $ddl_dir = File::Spec->catdir ('t', 'var'); |
29 | my $fn = { |
30 | v1 => File::Spec->catfile($ddl_dir, 'DBICVersion-Schema-1.0-MySQL.sql'), |
31 | v2 => File::Spec->catfile($ddl_dir, 'DBICVersion-Schema-2.0-MySQL.sql'), |
32 | trans => File::Spec->catfile($ddl_dir, 'DBICVersion-Schema-1.0-2.0-MySQL.sql'), |
33 | }; |
34 | |
c9d2e0a2 |
35 | use lib qw(t/lib); |
c9d2e0a2 |
36 | use_ok('DBICVersionOrig'); |
37 | |
99a74c4a |
38 | my $schema_orig = DBICVersion::Schema->connect($dsn, $user, $pass, { ignore_version => 1 }); |
b4b1e91c |
39 | eval { $schema_orig->storage->dbh->do('drop table ' . $version_table_name) }; |
40 | eval { $schema_orig->storage->dbh->do('drop table ' . $old_table_name) }; |
c9d2e0a2 |
41 | |
1475105d |
42 | is($schema_orig->ddl_filename('MySQL', '1.0', $ddl_dir), $fn->{v1}, 'Filename creation working'); |
43 | unlink( $fn->{v1} ) if ( -e $fn->{v1} ); |
44 | $schema_orig->create_ddl_dir('MySQL', undef, $ddl_dir); |
c9d2e0a2 |
45 | |
1475105d |
46 | ok(-f $fn->{v1}, 'Created DDL file'); |
1d48fcff |
47 | $schema_orig->deploy({ add_drop_table => 1 }); |
c9d2e0a2 |
48 | |
1d48fcff |
49 | my $tvrs = $schema_orig->{vschema}->resultset('Table'); |
a2800991 |
50 | is($schema_orig->_source_exists($tvrs), 1, 'Created schema from DDL file'); |
c9d2e0a2 |
51 | |
1475105d |
52 | # loading a new module defining a new version of the same table |
53 | DBICVersion::Schema->_unregister_source ('Table'); |
c9d2e0a2 |
54 | eval "use DBICVersionNew"; |
1475105d |
55 | |
56 | my $schema_upgrade = DBICVersion::Schema->connect($dsn, $user, $pass, { ignore_version => 1 }); |
f925f7cb |
57 | { |
1475105d |
58 | unlink($fn->{v2}); |
59 | unlink($fn->{trans}); |
f925f7cb |
60 | |
f925f7cb |
61 | is($schema_upgrade->get_db_version(), '1.0', 'get_db_version ok'); |
1d48fcff |
62 | is($schema_upgrade->schema_version, '2.0', 'schema version ok'); |
1475105d |
63 | $schema_upgrade->create_ddl_dir('MySQL', '2.0', $ddl_dir, '1.0'); |
64 | ok(-f $fn->{trans}, 'Created DDL file'); |
65 | |
66 | { |
67 | my $w; |
68 | local $SIG{__WARN__} = sub { $w = shift }; |
e9fbbbf4 |
69 | |
70 | sleep 1; # remove this when TODO below is completed |
71 | |
1475105d |
72 | $schema_upgrade->upgrade(); |
73 | like ($w, qr/Attempting upgrade\.$/, 'Warn before upgrade'); |
74 | } |
75 | |
1d48fcff |
76 | is($schema_upgrade->get_db_version(), '2.0', 'db version number upgraded'); |
f925f7cb |
77 | |
78 | eval { |
f925f7cb |
79 | $schema_upgrade->storage->dbh->do('select NewVersionName from TestVersion'); |
80 | }; |
81 | is($@, '', 'new column created'); |
99a74c4a |
82 | |
1475105d |
83 | # should overwrite files and warn about it |
84 | my @w; |
85 | local $SIG{__WARN__} = sub { push @w, shift }; |
86 | $schema_upgrade->create_ddl_dir('MySQL', '2.0', $ddl_dir, '1.0'); |
87 | |
88 | is (2, @w, 'A warning generated for both the DDL and the diff'); |
89 | like ($w[0], qr/^Overwriting existing DDL file - $fn->{v2}/, 'New version DDL overwrite warning'); |
90 | like ($w[1], qr/^Overwriting existing diff file - $fn->{trans}/, 'Upgrade diff overwrite warning'); |
f925f7cb |
91 | } |
b4b1e91c |
92 | |
93 | { |
94 | my $schema_version = DBICVersion::Schema->connect($dsn, $user, $pass); |
95 | eval { |
96 | $schema_version->storage->dbh->do('select * from ' . $version_table_name); |
97 | }; |
98 | is($@, '', 'version table exists'); |
99 | |
100 | eval { |
101 | $schema_version->storage->dbh->do("DROP TABLE IF EXISTS $old_table_name"); |
102 | $schema_version->storage->dbh->do("RENAME TABLE $version_table_name TO $old_table_name"); |
103 | }; |
104 | is($@, '', 'versions table renamed to old style table'); |
105 | |
106 | $schema_version = DBICVersion::Schema->connect($dsn, $user, $pass); |
107 | is($schema_version->get_db_version, '2.0', 'transition from old table name to new okay'); |
108 | |
109 | eval { |
110 | $schema_version->storage->dbh->do('select * from ' . $old_table_name); |
111 | }; |
112 | ok($@, 'old version table gone'); |
113 | |
114 | } |
f81b9157 |
115 | |
116 | # check behaviour of DBIC_NO_VERSION_CHECK env var and ignore_version connect attr |
117 | { |
118 | my $schema_version = DBICVersion::Schema->connect($dsn, $user, $pass); |
119 | eval { |
d0dfedc2 |
120 | $schema_version->storage->dbh->do("DELETE from $version_table_name"); |
f81b9157 |
121 | }; |
122 | |
d0dfedc2 |
123 | |
124 | my $warn = ''; |
fc38383e |
125 | local $SIG{__WARN__} = sub { $warn = shift }; |
f81b9157 |
126 | $schema_version = DBICVersion::Schema->connect($dsn, $user, $pass); |
d0dfedc2 |
127 | like($warn, qr/Your DB is currently unversioned/, 'warning detected without env var or attr'); |
f81b9157 |
128 | |
d0dfedc2 |
129 | |
130 | # should warn |
131 | $warn = ''; |
f81b9157 |
132 | $schema_version = DBICVersion::Schema->connect($dsn, $user, $pass, { ignore_version => 1 }); |
d0dfedc2 |
133 | is($warn, '', 'warning not detected with attr set'); |
f81b9157 |
134 | # should not warn |
135 | |
1475105d |
136 | local $ENV{DBIC_NO_VERSION_CHECK} = 1; |
d0dfedc2 |
137 | $warn = ''; |
f81b9157 |
138 | $schema_version = DBICVersion::Schema->connect($dsn, $user, $pass); |
d0dfedc2 |
139 | is($warn, '', 'warning not detected with env var set'); |
f81b9157 |
140 | # should not warn |
141 | |
d0dfedc2 |
142 | $warn = ''; |
f81b9157 |
143 | $schema_version = DBICVersion::Schema->connect($dsn, $user, $pass, { ignore_version => 0 }); |
d0dfedc2 |
144 | like($warn, qr/Your DB is currently unversioned/, 'warning detected without env var or attr'); |
f81b9157 |
145 | # should warn |
146 | } |
1475105d |
147 | |
148 | # attempt a deploy/upgrade cycle within one second |
e9fbbbf4 |
149 | TODO: { |
150 | |
151 | local $TODO = 'To fix this properly the table must be extended with an autoinc column, mst will not accept anything less'; |
152 | |
1475105d |
153 | eval { $schema_orig->storage->dbh->do('drop table ' . $version_table_name) }; |
154 | eval { $schema_orig->storage->dbh->do('drop table ' . $old_table_name) }; |
155 | eval { $schema_orig->storage->dbh->do('drop table TestVersion') }; |
156 | |
157 | # this attempts to sleep until the turn of the second |
158 | my $t = time(); |
159 | sleep (int ($t) + 1 - $t); |
160 | diag ('Fast deploy/upgrade start: ', time() ); |
161 | |
162 | { |
163 | local $DBICVersion::Schema::VERSION = '1.0'; |
164 | $schema_orig->deploy; |
165 | } |
1475105d |
166 | |
e9fbbbf4 |
167 | local $SIG{__WARN__} = sub { warn if $_[0] !~ /Attempting upgrade\.$/ }; |
1475105d |
168 | $schema_upgrade->upgrade(); |
1475105d |
169 | |
170 | is($schema_upgrade->get_db_version(), '2.0', 'Fast deploy/upgrade'); |
e9fbbbf4 |
171 | }; |
1475105d |
172 | |
173 | unless ($ENV{DBICTEST_KEEP_VERSIONING_DDL}) { |
174 | unlink $_ for (values %$fn); |
175 | } |