class RailsRedshiftReplicator::Adapters::SQLite
Public Instance Methods
query_command(sql)
click to toggle source
@param conn [ActiveRecord::ConnectionAdapter] @param sql [String] sql to execute
# File lib/rails_redshift_replicator/adapters/sqlite.rb, line 7 def query_command(sql) connection.exec_query sql end
write(file_path, query_result)
click to toggle source
Writes query results to a file @param file_path [String] path to output @param query_result [#each] Resultset from the query_command
@return [Integer] number of records
# File lib/rails_redshift_replicator/adapters/sqlite.rb, line 15 def write(file_path, query_result) line_number = 0 CSV.open(file_path, "w") do |csv| query_result.each do |row| csv << row.map{ |_,field| field.is_a?(String) ? field.gsub("\n", " ") : field } line_number+=1 end end line_number end