Enum mz_adapter::session::TransactionOps

pub enum TransactionOps<T> {
    None,
    Peeks {
        determination: TimestampDetermination<T>,
        cluster_id: ClusterId,
        requires_linearization: RequireLinearization,
    },
    Subscribe,
    Writes(Vec<WriteOp>),
    SingleStatement {
        stmt: Arc<Statement<Raw>>,
        params: Params,
    },
    DDL {
        ops: Vec<Op>,
        state: CatalogState,
        revision: u64,
    },
}

The type of operation being performed by the transaction.

This is needed because we currently do not allow mixing reads and writes in a transaction. Use this to record what we have done, and what may need to happen at commit.

Variants

None

The transaction has been initiated, but no statement has yet been executed in it.

Peeks

This transaction has had a peek (SELECT, SUBSCRIBE). If the inner value is has a timestamp, it must only do other peeks. However, if it doesn’t have a timestamp (i.e. the values are constants), the transaction can still perform writes.

Fields

determination: TimestampDetermination<T>

The timestamp and timestamp related metadata for the peek.

cluster_id: ClusterId

The cluster used to execute peeks.

requires_linearization: RequireLinearization

Whether this peek needs to be linearized.

Subscribe

This transaction has done a SUBSCRIBE and must do nothing else.

Writes(Vec<WriteOp>)

This transaction has had a write (INSERT, UPDATE, DELETE) and must only do other writes, or reads whose timestamp is None (i.e. constants).

SingleStatement

This transaction has a prospective statement that will execute during commit.

Fields

stmt: Arc<Statement<Raw>>

The prospective statement.

params: Params

The statement params.

DDL

This transaction has run some simple DDL and must do nothing else. Any statement/plan that uses this must return false in must_serialize_ddl() because this is serialized instead in sequence_plan() during COMMIT.

Fields

ops: Vec<Op>

Catalog operations that have already run, and must run before each subsequent op.

state: CatalogState

In-memory state that reflects the previously applied ops.

revision: u64

Transient revision of the Catalog when this transaction started.

Implementations

impl<T> TransactionOps<T>

fn timestamp_determination(self) -> Option<TimestampDetermination<T>>

Trait Implementations

impl<T: Debug> Debug for TransactionOps<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for TransactionOps<T>

fn default() -> Self

Returns the “default value” for a type.