require "rubygems"
require 'active_record'
require 'mysqlplus'
class Mysql; alias :query :async_query; end

class DBConn < ActiveRecord::Base
  establish_connection(
  :adapter => "mysql",
  :database => "test",
  :username => "root",
  :password => "123",
  :host => "localhost"
  )
end

# Return all documents; do not convert into ActiveRecord objects, keep as a hashmap
1000000.times do
  DBConn.connection.insert("insert into person(name, age) values ('5', '1')")
end

threads = []
100.times do |n|

 threads <<  Thread.new {
    1000000.times do
      DBConn.connection.insert("insert into person(name, age) values ('5', '1')")
    end
  }
end

# block and wait for all threads to finish
threads.each { |t| t.join }