Pipelining

Pipelining is an advanced feature to reduce the client-side waiting and the number of network round trips.

Use conn.exec_batch for executing many homogeneous queries,
and conn.pipeline for executing many heterogenous queries.

with conn.pipeline() as p:
    ticket1 = p.execute("SELECT ...")  # no network packet is sent
    ticket2 = p.execute("INSERT ...")  # no network packet is sent
    ticket3 = p.execute("INSERT ...")  # no network packet is sent

    # The buffered commands are sent with SYNC when the next response is requested.
    rows = p.claim(ticket1)
    p.claim_drop(ticket2)  # read the second response
    p.claim_drop(ticket3)

    ticket4 = p.execute("UPDATE ...")
    ticket5 = p.execute("INSERT ...")
    ticket6 = p.execute("SELECT ...")

    # Pipeline.__exit__ sends the pending queries with SYNC.
    # The responses for those queries are read and dropped.

It is recommended to prepare a set of statements before entering the pipeline.

stmt1, stmt2, stmt3 = conn.prepare_batch([
      "SELECT ...",
      "INSERT ...",
      "INSERT ...",
  ])

with conn.pipeline() as p:
    t1 = p.execute(stmt1, params)
    t2 = p.execute(stmt2, params)
    t3 = p.execute(stmt3, params)

    p.sync()  # you can explicitly call p.sync() or p.flush()

    rows = p.claim(t1)
    p.claim_drop(t2)
    p.claim_drop(t3)