class CQL::Postgres::RowStream

• CQL::Postgres::RowStream
• Reference
• Object

Overview

The rows of one statement, read from the server fetch_size at a time through a portal, so a large result is never held in memory whole. It is an Iterator, valid only inside the block of Session#stream (the session is locked and the portal open until the block ends).

Included Modules

• Iterator(Array(Bool | CQL::Postgres::Types::Custom | CQL::Postgres::Types::DecimalText | Float32 | Float64 | Int16 | Int32 | Int64 | JSON::Any | Slice(UInt8) | String | Time | Time::Span | UInt32 | UUID | Nil))

Defined in:

postgres/row_stream.cr

Constructors

• .new(session : Session, columns : Array(Column), fetch_size : Int32)

Instance Method Summary

• #aborted? : Bool

  The statement failed or the session was dropped; nothing is left to clean up.

• #columns : Array(Column)
• #finished? : Bool

  The server sent every row.

• #next

  Returns the next element in this iterator, or Iterator::Stop::INSTANCE if there are no more elements.

• #peak_buffered : Int32

  The most rows ever held at once; never more than the fetch size.

• #rows_affected : Int64
• #rows_read : Int64
• #tag : String

Constructor Detail

Instance Method Detail