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