I am going to try this and see.
def initialize
local_db = ActiveRecord::Base.connection_config
@raw_connection = PG.connect(dbname: local_db[:database], host: 'localhost', user: 'postgres', port: local_db[:port])
@source_db_config = {
dbname: ENV["DB_NAME"] || 'copyme',
host: ENV["DB_HOST"] || 'localhost',
user: ENV["DB_USER"] || 'postgres'
}