Permalink
Switch branches/tags
Nothing to show
Find file
Fetching contributors…
Cannot retrieve contributors at this time
51 lines (30 sloc) 1.25 KB
Async MySQL driver for Ruby/EventMachine
(c) 2008 Aman Gupta (tmm1)
== Fork comments
Can work with multiple databases.
db = Sequel.mysql config
EventedMysql.databases[db] ||= EmMysql.new(config)
db2 = Sequel.mysql config2
EventedMysql.databases[db2] ||= EmMysql.new(config2)
Requires mysqlplus.
require 'em/mysql'
# alias SQL for simpler syntax
SQL = EventedMysql
def SQL(query, &blk) SQL.select(query, &blk) end
# setup connection details and allow 4 connections to the server
SQL.settings.update :host => 'localhost',
:port => 3306,
:database => 'test',
:connections => 4
# use 4 connections to execute queries in parallel
SQL('select sleep(0.25)'){ p 'done' }
SQL('select sleep(0.25)'){ p 'done' }
SQL('select sleep(0.25)'){ p 'done' }
SQL('select sleep(0.25)'){ p 'done' }
Also includes a sequel async wrapper
require 'sequel'
require 'sequel/async'
DB = Sequel.connect(:adapter => 'mysql', :user => 'root', :database => 'test', ...)
EventedMysql.settings.update(..., :on_error => proc{|e| log 'error', e })
DB[:table].where(:field => 'value').async_update(:field => 'new value')
For more info, see the comments in lib/sequel/async.rb