Struct MemoryConnection 

pub struct MemoryConnection { /* private fields */ }

A Connection that records statements and replays queued rows.

Implementations

impl MemoryConnection

pub fn new(dialect: Dialect) -> Self

A connection speaking dialect that returns no rows and reports one affected row per write.

pub fn returning(self, rows: impl IntoIterator<Item = OwnedRow>) -> Self

Queue the rows the next query should return.

Answers are consumed in order; once the queue is empty, queries return nothing.

pub fn with_outcome(self, rows_affected: u64, last_insert_id: i64) -> Self

Set the outcome every write reports.

pub fn sharded(self, family: impl Into<String>) -> Self

Present as a sharded connector in the named family.

pub fn allocating(self, id: u64) -> Self

Mint this id whenever the repository asks for a shard-encoded key.

pub fn failing(self, message: impl Into<String>) -> Self

Make every statement fail with message.

pub fn recorded(&self) -> Vec<RecordedStatement>

Every statement run so far, in order.

pub fn statements(&self) -> Vec<String>

The SQL of every statement run so far.

pub fn last_statement(&self) -> Option<String>

The most recent statement’s SQL.

pub fn last_route(&self) -> Option<ShardRoute>

The most recent statement’s shard route.

pub fn bindings(&self) -> Vec<Vec<Value>>

The bind values of every statement run so far.

pub fn statement_count(&self) -> usize

How many statements have run.

Trait Implementations

impl Connection for MemoryConnection

fn dialect(&self) -> Dialect

The SQL dialect this backend speaks.

fn shard_family(&self) -> Option<String>

The shard family this connector routes within, or None for a single database.

fn allocate_id(&self, _shard_key: u64) -> Option<u64>

Mint a shard-encoded primary key for a row owned by shard_key.

fn fetch<'a>( &'a self, route: ShardRoute, sql: &'a str, params: Vec<Value>, _columns: Vec<ColumnRequest>, ) -> BoxFuture<'a, Result<Vec<OwnedRow>>>

Run a query, copying the named columns out of each row.

fn execute<'a>( &'a self, route: ShardRoute, sql: &'a str, params: Vec<Value>, ) -> BoxFuture<'a, Result<Vec<ExecOutcome>>>

Run a write and report its outcome. Send.

fn fetch_raw<'a>( &'a self, route: ShardRoute, sql: &'a str, params: Vec<Value>, ) -> BoxFuture<'a, Result<Vec<Box<dyn Row>>>>

Run a query and hand back the driver’s own rows.

impl Debug for MemoryConnection

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

Formats the value using the given formatter.

impl Default for MemoryConnection

fn default() -> MemoryConnection

Returns the “default value” for a type.