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
|
# frozen_string_literal: true
module Backup
class DatabaseModel
SUPPORTED_OVERRIDES = {
username: 'PGUSER',
host: 'PGHOST',
port: 'PGPORT',
password: 'PGPASSWORD',
# SSL
sslmode: 'PGSSLMODE',
sslkey: 'PGSSLKEY',
sslcert: 'PGSSLCERT',
sslrootcert: 'PGSSLROOTCERT',
sslcrl: 'PGSSLCRL',
sslcompression: 'PGSSLCOMPRESSION'
}.freeze
attr_reader :config
def initialize(name)
configure_model(name)
end
def connection
@model.connection
end
private
def configure_model(name)
source_model = Gitlab::Database.database_base_models_with_gitlab_shared[name]
@model = backup_model_for(name)
original_config = source_model.connection_db_config.configuration_hash.dup
@config = config_for_backup(original_config)
@model.establish_connection(
ActiveRecord::DatabaseConfigurations::HashConfig.new(
source_model.connection_db_config.env_name,
name.to_s,
original_config.merge(@config[:activerecord])
)
)
Gitlab::Database::LoadBalancing::Setup.new(@model).setup
end
def backup_model_for(name)
klass_name = name.camelize
return "#{self.class.name}::#{klass_name}".constantize if self.class.const_defined?(klass_name.to_sym, false)
self.class.const_set(klass_name, Class.new(ApplicationRecord))
end
def config_for_backup(config)
db_config = {
activerecord: config,
pg_env: {}
}
SUPPORTED_OVERRIDES.each do |opt, arg|
# This enables the use of different PostgreSQL settings in
# case PgBouncer is used. PgBouncer clears the search path,
# which wreaks havoc on Rails if connections are reused.
override = "GITLAB_BACKUP_#{arg}"
val = ENV[override].presence || config[opt].to_s.presence
next unless val
db_config[:pg_env][arg] = val
db_config[:activerecord][opt] = val
end
db_config
end
end
end
|
