class RailsRedshiftReplicator::Adapters::Mysql2

Public Instance Methods

connection() click to toggle source

Returns mysql2 driver so that we may perform query with the stream option

# File lib/rails_redshift_replicator/adapters/mysql2.rb, line 17
def connection
  @connection ||= @ar_client.instance_variable_get("@connection")
end
last_record_query_command(sql) click to toggle source

@see RailsRedshiftReplicator::Adapters::Generic#last_record_query_command

# File lib/rails_redshift_replicator/adapters/mysql2.rb, line 12
def last_record_query_command(sql)
  connection.query(sql, cast: false).first[0] rescue nil
end
query_command(sql) click to toggle source

Executes query in stream mode to optimize memory usage, using Mysql2 driver. @param sql [String] sql to execute

# File lib/rails_redshift_replicator/adapters/mysql2.rb, line 7
def query_command(sql)
  connection.query(sql, stream: true)
end