surrealdb_sql/
start.rs

1use crate::ctx::Context;
2use crate::dbs::{Options, Transaction};
3use crate::doc::CursorDoc;
4use crate::err::Error;
5use crate::number::Number;
6use crate::value::Value;
7use revision::revisioned;
8use serde::{Deserialize, Serialize};
9use std::fmt;
10
11#[derive(Clone, Debug, Default, Eq, PartialEq, PartialOrd, Serialize, Deserialize, Hash)]
12#[revisioned(revision = 1)]
13pub struct Start(pub Value);
14
15impl Start {
16	pub(crate) async fn process(
17		&self,
18		ctx: &Context<'_>,
19		opt: &Options,
20		txn: &Transaction,
21		doc: Option<&CursorDoc<'_>>,
22	) -> Result<usize, Error> {
23		match self.0.compute(ctx, opt, txn, doc).await {
24			// This is a valid starting number
25			Ok(Value::Number(Number::Int(v))) if v >= 0 => Ok(v as usize),
26			// An invalid value was specified
27			Ok(v) => Err(Error::InvalidStart {
28				value: v.as_string(),
29			}),
30			// A different error occurred
31			Err(e) => Err(e),
32		}
33	}
34}
35
36impl fmt::Display for Start {
37	fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
38		write!(f, "START {}", self.0)
39	}
40}
surrealdb_sql/start.rs

surrealdb_sql/
start.rs
