surrealdb-sql 1.1.0

Full type definitions for the SurrealQL query language
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

use crate::ctx::Context;
use crate::dbs::Statement;
use crate::dbs::{Options, Transaction};
use crate::doc::Document;
use crate::err::Error;
use crate::value::Value;

impl<'a> Document<'a> {
	pub async fn relate(
		&mut self,
		ctx: &Context<'_>,
		opt: &Options,
		txn: &Transaction,
		stm: &Statement<'_>,
	) -> Result<Value, Error> {
		// Check current record
		match self.current.doc.is_some() {
			// Create new edge
			false => {
				// Store record edges
				self.edges(ctx, opt, txn, stm).await?;
				// Alter record data
				self.alter(ctx, opt, txn, stm).await?;
				// Merge fields data
				self.field(ctx, opt, txn, stm).await?;
				// Reset fields data
				self.reset(ctx, opt, txn, stm).await?;
				// Clean fields data
				self.clean(ctx, opt, txn, stm).await?;
				// Check if allowed
				self.allow(ctx, opt, txn, stm).await?;
				// Store record data
				self.store(ctx, opt, txn, stm).await?;
				// Store index data
				self.index(ctx, opt, txn, stm).await?;
				// Run table queries
				self.table(ctx, opt, txn, stm).await?;
				// Run lives queries
				self.lives(ctx, opt, txn, stm).await?;
				// Run change feeds queries
				self.changefeeds(ctx, opt, txn, stm).await?;
				// Run event queries
				self.event(ctx, opt, txn, stm).await?;
				// Yield document
				self.pluck(ctx, opt, txn, stm).await
			}
			// Update old edge
			true => {
				// Check if allowed
				self.allow(ctx, opt, txn, stm).await?;
				// Store record edges
				self.edges(ctx, opt, txn, stm).await?;
				// Alter record data
				self.alter(ctx, opt, txn, stm).await?;
				// Merge fields data
				self.field(ctx, opt, txn, stm).await?;
				// Reset fields data
				self.reset(ctx, opt, txn, stm).await?;
				// Clean fields data
				self.clean(ctx, opt, txn, stm).await?;
				// Check if allowed
				self.allow(ctx, opt, txn, stm).await?;
				// Store record data
				self.store(ctx, opt, txn, stm).await?;
				// Store index data
				self.index(ctx, opt, txn, stm).await?;
				// Run table queries
				self.table(ctx, opt, txn, stm).await?;
				// Run lives queries
				self.lives(ctx, opt, txn, stm).await?;
				// Run change feeds queries
				self.changefeeds(ctx, opt, txn, stm).await?;
				// Run event queries
				self.event(ctx, opt, txn, stm).await?;
				// Yield document
				self.pluck(ctx, opt, txn, stm).await
			}
		}
	}
}