Class: SerializationHelper::Dump
- Inherits:
-
Object
- Object
- SerializationHelper::Dump
show all
- Defined in:
- lib/serialization_helper.rb
Class Method Summary
collapse
Class Method Details
.after_table(io, table) ⇒ Object
167
168
169
|
# File 'lib/serialization_helper.rb', line 167
def self.after_table(io, table)
end
|
.base_tables ⇒ Object
171
172
173
174
175
176
177
|
# File 'lib/serialization_helper.rb', line 171
def self.base_tables
sql = "select table_name from information_schema.tables where table_schema='irm_dev' and table_type='base table';"
base_tables = ActiveRecord::Base.connection.execute(sql, 'SCHEMA').collect do |field|
field.first
end
base_tables.reject { |table| ['schema_info', 'schema_migrations','irm_data_accesses_top_org_t'].include?(table) }
end
|
.before_table(io, table) ⇒ Object
155
156
157
|
# File 'lib/serialization_helper.rb', line 155
def self.before_table(io, table)
end
|
.dump(io) ⇒ Object
159
160
161
162
163
164
165
|
# File 'lib/serialization_helper.rb', line 159
def self.dump(io)
base_tables.each do |table|
before_table(io, table)
dump_table(io, table)
after_table(io, table)
end
end
|
.dump_table(io, table) ⇒ Object
183
184
185
186
187
188
|
# File 'lib/serialization_helper.rb', line 183
def self.dump_table(io, table)
return if table_record_count(table).zero?
dump_table_columns(io, table)
dump_table_records(io, table)
end
|
.each_table_page(table, records_per_page = 1000) ⇒ Object
195
196
197
198
199
200
201
202
203
204
205
206
207
208
|
# File 'lib/serialization_helper.rb', line 195
def self.each_table_page(table, records_per_page=1000)
total_count = table_record_count(table)
pages = (total_count.to_f / records_per_page).ceil - 1
id = table_column_names(table).first
boolean_columns = SerializationHelper::Utils.boolean_columns(table)
quoted_table_name = SerializationHelper::Utils.quote_table(table)
(0..pages).to_a.each do |page|
query = Arel::Table.new(table).order(id).skip(records_per_page*page).take(records_per_page).project(Arel.sql('*'))
records = ActiveRecord::Base.connection.select_all(query)
records = SerializationHelper::Utils.convert_booleans(records, boolean_columns)
yield records
end
end
|
.table_column_names(table) ⇒ Object
190
191
192
|
# File 'lib/serialization_helper.rb', line 190
def self.table_column_names(table)
ActiveRecord::Base.connection.columns(table).map { |c| c.name }
end
|
.table_record_count(table) ⇒ Object
210
211
212
|
# File 'lib/serialization_helper.rb', line 210
def self.table_record_count(table)
ActiveRecord::Base.connection.select_one("SELECT COUNT(*) FROM #{SerializationHelper::Utils.quote_table(table)}").values.first.to_i
end
|
.tables ⇒ Object
179
180
181
|
# File 'lib/serialization_helper.rb', line 179
def self.tables
ActiveRecord::Base.connection.tables.reject { |table| ['schema_info', 'schema_migrations'].include?(table) }
end
|