Sha256: 3b9ecb3503dc93c5983718501df5063cfd10ab4a8ae5f04765b6f76fb7495cfd
Contents?: true
Size: 1.09 KB
Versions: 8
Compression:
Stored size: 1.09 KB
Contents
require_relative 'helper'
require 'swift/pool'
describe 'Adapter' do
supported_by Swift::DB::Postgres, Swift::DB::Mysql do
describe 'Asynchronous connection pool' do
before do
Swift.db do |db|
db.execute %q{drop table if exists users}
db.execute %Q{create table users(name varchar(64))}
end
end
it 'creates connection pool and runs queries' do
rows = []
Swift.pool(5) do |pool|
assert pool
assert Swift.db.write('users', %w{name}, StringIO.new("user1\nuser2\nuser3\n"))
pool.execute('select * from users') do |rs|
rows += rs.to_a
Thread.new do
sleep 0.25
pool.execute('select * from users order by name desc') {|rs| rows += rs.to_a; EM.stop }
end
end
pool.execute('select * from users') do |rs|
rows += rs.to_a
end
end
data = %w(user1 user2 user3)
assert_equal 9, rows.length
assert_equal data*2 + data.reverse, rows.map {|r| r[:name] }
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems