test.rb

require 'lib/em/mysql'

# EM.kqueue
# EM.epoll
EM.run{
  EM.start_server '127.0.0.1', 12345 do |c|
    def c.receive_data data
      p 'sending http response'
      send_data "hello"
      close_connection_after_writing
    end
  end

  SQL = EventedMysql
  def SQL(query, &blk) SQL.select(query, &blk) end

  if true

    SQL.settings.update :logging => true,
                        :database => 'test',
                        :connections => 1

    SQL.execute('select 1+2')

    EM.add_timer(1){
      3.times do SQL.select('select sleep(0.5)+1'){|r| p(r) } end
    }

  elsif false

    SQL.settings.update :logging => true,
                        :database => 'test',
                        :connections => 10

    EM.add_timer(2.5){ SQL.all('use test') }

  else

    SQL.settings.update :logging => true,
                        :database => 'test',
                        :connections => 10,
                        :timeout => 1

    n = 0

    SQL.execute('drop table if exists testingabc'){
      SQL.execute('create table testingabc (a int, b int, c int)'){
        EM.add_periodic_timer(0.2) do
          cur_num = n+=1
          SQL.execute("insert into testingabc values (1,2,#{cur_num})"){
            SQL("select * from testingabc where c = #{cur_num} limit 1"){ |res| puts;puts }
          }
        end
      }
    }

  end

}