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
|
# frozen_string_literal: true
require "spec_helper"
describe DataMigrate::Tasks::DataMigrateTasks do
describe :dump do
let(:db_config) do
{
adapter: "sqlite3",
database: "spec/db/other_test.db"
}
end
before do
allow(DataMigrate::DataMigrator).to receive(:db_config) { db_config }
allow(DataMigrate::DatabaseTasks).to receive(:db_dir).and_return("spec/db")
end
after do
ActiveRecord::Migration.drop_table("data_migrations")
end
context 'when not given a separate db config' do
it 'does not override the default connection' do
DataMigrate::Tasks::DataMigrateTasks.migrate
expect(ActiveRecord::Base).not_to receive(:establish_connection)
expect(DataMigrate::SchemaDumper).to receive(:dump)
DataMigrate::Tasks::DataMigrateTasks.dump
end
end
context 'when given ' do
let(:override_config) do
{
'host' => '127.0.0.1',
'database' => 'other_test',
'adapter' => 'sqlite3',
'username' => 'root',
'password' => nil,
}
end
before do
DataMigrate.configure do |config|
config.db_configuration = override_config
end
end
it 'overrides the default connection' do
DataMigrate::Tasks::DataMigrateTasks.migrate
expect(ActiveRecord::Base).to receive(:establish_connection).with(override_config)
DataMigrate::Tasks::DataMigrateTasks.dump
end
end
end
describe :migrate do
let(:db_config) do
{
adapter: "sqlite3",
database: "spec/db/test.db"
}
end
before do
allow(DataMigrate::DataMigrator).to receive(:db_config) { db_config }
ActiveRecord::Base.establish_connection(db_config)
end
after do
ActiveRecord::Migration.drop_table("data_migrations")
end
it do
expect {
DataMigrate::Tasks::DataMigrateTasks.migrate
}.to output(/20091231235959 SomeName: migrating/).to_stdout
end
it do
expect {
DataMigrate::Tasks::DataMigrateTasks.migrate
}.to output(/20171231235959 SuperUpdate: migrating/).to_stdout
end
end
describe :abort_if_pending_migrations do
subject { DataMigrate::Tasks::DataMigrateTasks.abort_if_pending_migrations(migrations, message) }
let(:message) { "ABORT_MESSAGE" }
context "when there are no pending migrations" do
let(:migrations) { [] }
it "shouldn't do anything" do
expect { subject }.to_not raise_error
end
end
context "when there are pending migrations" do
let(:migrations) do
[{
name: "A",
version: 1
}, {
name: 'B',
version: 2
}]
end
it "should abort with given message and print names and versions of pending migrations" do
expect { subject }
.to raise_error(SystemExit, message)
.and output("You have 2 pending migrations:\n 1 A\n 2 B\n").to_stdout
end
end
end
end
|
