Contents

# Copyright (c) 2016 SolarWinds, LLC.
# All rights reserved.

class DJDBWorkerJob
  @queue = :normal

  def self.perform(*args)
    return unless defined?(::Sequel) && !defined?(JRUBY_VERSION)

    if ENV.key?('TRAVIS_MYSQL_PASS')
      @db = Sequel.connect("mysql2://root:#{ENV['TRAVIS_MYSQL_PASS']}@127.0.0.1:3306/travis_ci_test")
    else
      @db = Sequel.connect('mysql2://root@127.0.0.1:3306/travis_ci_test')
    end

    unless @db.table_exists?(:items)
      @db.create_table :items do
        primary_key :id
        String :name
        Float :price
      end
    end

    @db.run('select 1')

    items = @db[:items]
    items.count
  end
end

Version data entries

5 entries across 5 versions & 2 rubygems

Version	Path
appoptics_apm-4.0.3	test/jobs/delayed_job/db_worker_job.rb
appoptics_apm-4.0.2	test/jobs/delayed_job/db_worker_job.rb
appoptics_apm-4.0.1-x86_64-linux	test/jobs/delayed_job/db_worker_job.rb
traceview-3.8.4-java	test/jobs/delayed_job/db_worker_job.rb
traceview-3.8.4	test/jobs/delayed_job/db_worker_job.rb