add raw driver benchmark with casting for the mysql gem
This commit is contained in:
parent
f2a731e0a7
commit
30e06479e0
82
benchmark/query_with_mysql_casting.rb
Normal file
82
benchmark/query_with_mysql_casting.rb
Normal file
@ -0,0 +1,82 @@
|
||||
# encoding: UTF-8
|
||||
|
||||
require 'rubygems'
|
||||
require 'benchmark'
|
||||
require 'mysql'
|
||||
require 'mysql2_ext'
|
||||
require 'do_mysql'
|
||||
|
||||
number_of = 100
|
||||
database = 'test'
|
||||
sql = "SELECT * FROM mysql2_test LIMIT 100"
|
||||
|
||||
class Mysql
|
||||
include Enumerable
|
||||
end
|
||||
|
||||
def mysql_cast(type, value)
|
||||
case type
|
||||
when Mysql::Field::TYPE_NULL
|
||||
nil
|
||||
when Mysql::Field::TYPE_TINY, Mysql::Field::TYPE_SHORT, Mysql::Field::TYPE_LONG,
|
||||
Mysql::Field::TYPE_INT24, Mysql::Field::TYPE_LONGLONG, Mysql::Field::TYPE_YEAR
|
||||
value.to_i
|
||||
when Mysql::Field::TYPE_DECIMAL, Mysql::Field::TYPE_NEWDECIMAL
|
||||
BigDecimal.new(value)
|
||||
when Mysql::Field::TYPE_DOUBLE, Mysql::Field::TYPE_FLOAT
|
||||
value.to_f
|
||||
when Mysql::Field::TYPE_DATE
|
||||
Date.parse(value)
|
||||
when Mysql::Field::TYPE_TIME, Mysql::Field::TYPE_DATETIME, Mysql::Field::TYPE_TIMESTAMP
|
||||
Time.parse(value)
|
||||
when Mysql::Field::TYPE_BLOB, Mysql::Field::TYPE_BIT, Mysql::Field::TYPE_STRING,
|
||||
Mysql::Field::TYPE_VAR_STRING, Mysql::Field::TYPE_CHAR, Mysql::Field::TYPE_SET
|
||||
Mysql::Field::TYPE_ENUM
|
||||
value
|
||||
else
|
||||
value
|
||||
end
|
||||
end
|
||||
|
||||
Benchmark.bmbm do |x|
|
||||
mysql2 = Mysql2::Client.new(:host => "localhost", :username => "root")
|
||||
mysql2.query "USE #{database}"
|
||||
x.report do
|
||||
puts "Mysql2"
|
||||
number_of.times do
|
||||
mysql2_result = mysql2.query sql
|
||||
mysql2_result.each(:symbolize_keys => true) do |res|
|
||||
# puts res.inspect
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
mysql = Mysql.new("localhost", "root")
|
||||
mysql.query "USE #{database}"
|
||||
x.report do
|
||||
puts "Mysql"
|
||||
number_of.times do
|
||||
mysql_result = mysql.query sql
|
||||
fields = mysql_result.fetch_fields
|
||||
mysql_result.each do |row|
|
||||
row_hash = {}
|
||||
row.each_with_index do |f, j|
|
||||
row_hash[fields[j].name.to_sym] = mysql_cast(fields[j].type, row[j])
|
||||
end
|
||||
# puts row_hash.inspect
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
do_mysql = DataObjects::Connection.new("mysql://localhost/#{database}")
|
||||
command = DataObjects::Mysql::Command.new do_mysql, sql
|
||||
x.report do
|
||||
puts "do_mysql"
|
||||
number_of.times do
|
||||
do_result = command.execute_reader
|
||||
do_result.each do |res|
|
||||
# puts res.inspect
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
Loading…
Reference in New Issue
Block a user