Sha256: f7dab34f1944c262c398a8d089ef900296e1b261500248731dd83708a13481e0

Contents?: true

Size: 361 Bytes

Versions: 70

Compression:

Stored size: 361 Bytes

Contents

# frozen_string_literal: true

require_relative '../../polyphony'
require 'mysql2/client'

# Mysql2::Client overrides
Mysql2::Client.prepend(Module.new do
  def initialize(config)
    config[:async] = true
    super
    @io = ::IO.for_fd(socket)
  end

  def query(sql, **options)
    super
    Polyphony.backend_wait_io(@io, false)
    async_result
  end
end)

Version data entries

70 entries across 70 versions & 1 rubygems

Version Path
polyphony-1.6 lib/polyphony/adapters/mysql2.rb
polyphony-1.5 lib/polyphony/adapters/mysql2.rb
polyphony-1.4 lib/polyphony/adapters/mysql2.rb
polyphony-1.3 lib/polyphony/adapters/mysql2.rb
polyphony-1.2.1 lib/polyphony/adapters/mysql2.rb
polyphony-1.2 lib/polyphony/adapters/mysql2.rb
polyphony-1.1.1 lib/polyphony/adapters/mysql2.rb
polyphony-1.1 lib/polyphony/adapters/mysql2.rb
polyphony-1.0.2 lib/polyphony/adapters/mysql2.rb
polyphony-1.0.1 lib/polyphony/adapters/mysql2.rb
polyphony-1.0 lib/polyphony/adapters/mysql2.rb
polyphony-0.99.6 lib/polyphony/adapters/mysql2.rb
polyphony-0.99.5 lib/polyphony/adapters/mysql2.rb
polyphony-0.99.4 lib/polyphony/adapters/mysql2.rb
polyphony-0.99.3 lib/polyphony/adapters/mysql2.rb
polyphony-0.99.2 lib/polyphony/adapters/mysql2.rb
polyphony-0.99.1 lib/polyphony/adapters/mysql2.rb
polyphony-0.99 lib/polyphony/adapters/mysql2.rb
polyphony-0.98 lib/polyphony/adapters/mysql2.rb
polyphony-0.97 lib/polyphony/adapters/mysql2.rb