Module: Postqueue::Item::RawInserter

Included in:: Postqueue::Item

Defined in:: lib/postqueue/item/inserter.rb

Instance Method Summary collapse

Instance Method Details

#insert_item(op:, entity_id:) ⇒ `Object`



21
22
23

# File 'lib/postqueue/item/inserter.rb', line 21

def insert_item(op:, entity_id:)
  connection.raw_connection.exec_params(insert_sql, [op, entity_id])
end

#insert_sql ⇒ `Object`



17
18
19

# File 'lib/postqueue/item/inserter.rb', line 17

def insert_sql
  "INSERT INTO #{table_name}(op, entity_id) VALUES($1, $2)"
end