= ruby-binlog
== Description
ruby-binlog is Ruby binding for MySQL Binary log API.
* http://www.oscon.com/oscon2011/public/schedule/detail/18785
* https://launchpad.net/mysql-replication-listener
* https://bitbucket.org/winebarrel/mysql-replication-listener
== Install
gem install ruby-binlog
== Required Privileges
* SUPER
* REPLICATION SLAVE
* EVENT
== Example
#!/usr/bin/env ruby
require "rubygems"
require "binlog"
require "pstore"
$db = PStore.new("/tmp/foo")
#master_log_file = "mysql-bin.000001"
#master_log_pos = 4
master_log_file = nil
master_log_pos = nil
$db.transaction do
master_log_file = $db["master_log_file"]
master_log_pos = $db["master_log_pos"]
end
def save_position(master_log_file, master_log_pos)
$db.transaction do
$db["master_log_file"] = master_log_file
$db["master_log_pos"] = master_log_pos
end
end
begin
# XXX: Do not reuse a client instance, after connection goes out.
client = Binlog::Client.new("mysql://repl:repl@example.com")
sleep 0.3 until client.connect
if master_log_file and master_log_pos
client.set_position(master_log_file, master_log_pos)
end
while event = client.wait_for_next_event
puts "(#{event.event_type})"
master_log_pos = event.next_position
case event
when Binlog::QueryEvent
puts event.db_name
puts event.query
save_position(master_log_file, master_log_pos)
when Binlog::RowEvent
puts event.event_type
puts event.db_name
puts event.table_name
p event.columns
p event.rows
save_position(master_log_file, master_log_pos)
when Binlog::RotateEvent
master_log_file = event.binlog_file
master_log_pos = event.binlog_pos
save_position(master_log_file, master_log_pos)
end
end
rescue Binlog::Error => e
puts e
retry if client.closed?
raise e
end
== Notice
The following type are not supported in row mode.
* DECIMAL
* INT24
* DATE
* TIME
* YEAR
* BIT
* ENUM
* SET
* GEOMETRY
see the following urls:
* http://bazaar.launchpad.net/~mysql/mysql-replication-listener/trunk/view/head:/src/value.cpp#L310
* https://bitbucket.org/winebarrel/ruby-binlog/downloads
* There is a patch of a library.