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