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 



22
23
24
 
# File 'lib/postqueue/item/inserter.rb', line 22

def insert_item(op:, entity_id:)
  connection.raw_connection.exec_prepared(prepared_inserter_statement, [op, entity_id])
end

#prepared_inserter_statement ⇒ Object 



14
15
16
17
18
19
20
 
# File 'lib/postqueue/item/inserter.rb', line 14

def prepared_inserter_statement
  @prepared_inserter_statement ||= begin
    name = "postqueue-insert-{table_name}-#{Thread.current.object_id}"
    connection.raw_connection.prepare(name, "INSERT INTO #{table_name}(op, entity_id) VALUES($1, $2)")
    name
  end
end