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
155
156
157
|
# File 'lib/serialization_helper.rb', line 155
def self.after_table(io, table)
end
|
.before_table(io, table) ⇒ Object
143
144
145
|
# File 'lib/serialization_helper.rb', line 143
def self.before_table(io, table)
end
|
.dump(io) ⇒ Object
147
148
149
150
151
152
153
|
# File 'lib/serialization_helper.rb', line 147
def self.dump(io)
tables.each do |table|
before_table(io, table)
dump_table(io, table)
after_table(io, table)
end
end
|
.dump_table(io, table) ⇒ Object
163
164
165
166
167
168
|
# File 'lib/serialization_helper.rb', line 163
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
175
176
177
178
179
180
181
182
183
184
185
186
187
188
|
# File 'lib/serialization_helper.rb', line 175
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, ActiveRecord::Base).order(id).skip(records_per_page*page).take(records_per_page).project(Arel.sql('*'))
records = ActiveRecord::Base.connection.select_all(query.to_sql)
records = SerializationHelper::Utils.convert_booleans(records, boolean_columns)
yield records
end
end
|
.table_column_names(table) ⇒ Object
170
171
172
|
# File 'lib/serialization_helper.rb', line 170
def self.table_column_names(table)
ActiveRecord::Base.connection.columns(table).map { |c| c.name }
end
|
.table_record_count(table) ⇒ Object
190
191
192
|
# File 'lib/serialization_helper.rb', line 190
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
159
160
161
|
# File 'lib/serialization_helper.rb', line 159
def self.tables
ActiveRecord::Base.connection.tables.reject { |table| ['schema_info', 'schema_migrations'].include?(table) }
end
|