Method: Que::Migrations.db_version

Defined in:
lib/que/migrations.rb

.db_version ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/que/migrations.rb', line 38

def db_version
  result =
    Que.execute <<-SQL
      SELECT relname, description
      FROM pg_class
      LEFT JOIN pg_description ON pg_description.objoid = pg_class.oid
      WHERE relname = 'que_jobs'
    SQL

  if result.none?
    # No table in the database at all.
    0
  elsif (d = result.first[:description]).nil?
    # The table exists but the version comment is missing
    _raise_db_version_comment_missing_error
  else
    d.to_i
  end
end