# Copyright (c) 2015 AppNeta, Inc.
# All rights reserved.

class ResqueDBWorkerJob
  @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