Module: QC::Later::Queries

Extended by:
Queries
Included in:
Queries
Defined in:
lib/queue_classic/later.rb

Instance Method Summary collapse

Instance Method Details

#delete_and_capture(not_before) ⇒ Object 



35
36
37
38
39
 
# File 'lib/queue_classic/later.rb', line 35

def delete_and_capture(not_before)
  s = "DELETE FROM #{QC::Later::TABLE_NAME} WHERE not_before <= $1 RETURNING *"
  # need to ensure we return an Array even if Conn.execute returns a single item
  [QC::Conn.execute(s, not_before)].compact.flatten
end

#insert(q_name, not_before, method, args) ⇒ Object 



28
29
30
31
32
33
 
# File 'lib/queue_classic/later.rb', line 28

def insert(q_name, not_before, method, args)
  QC.log_yield(:action => "insert_later_job") do
    s = "INSERT INTO #{QC::Later::TABLE_NAME} (q_name, not_before, method, args) VALUES ($1, $2, $3, $4)"
    QC::Conn.execute(s, q_name, not_before, method, QC::OkJson.encode(args))
  end
end