Sha256: c4ac6acd70d05ecdbab19b7ab643f2f0f0a2602a4b6913748d1678ba712feac8
Contents?: true
Size: 670 Bytes
Versions: 21
Compression:
Stored size: 670 Bytes
Contents
require 'flydata/source/sync_repair'
require 'flydata/source_mysql/mysql_accessible'
require 'flydata/source_mysql/source_pos'
module Flydata
module SourceMysql
class SyncRepair < Source::SyncRepair
def get_oldest_available_source_pos
binary_logs = BinarylogsCheck.new(de[Sync::SOURCE_PREFERENCE_NAME]).get_binary_logs
oldest_binlog_str = binary_logs.first.values.join("\t")
oldest_binlog = source.source_pos.create_source_pos(oldest_binlog_str)
end
class BinarylogsCheck
include MysqlAccessible
SHOW_BINARY_LOGS_QUERY = "SHOW BINARY LOGS;"
def get_binary_logs
exec_mysql_query(SHOW_BINARY_LOGS_QUERY)
end
end
end
end
end
Version data entries
21 entries across 21 versions & 1 rubygems