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

#[tokio::test]
#[serial]
async fn archive_lv_for_node_archives() {
	let node_id = Uuid::parse_str("9ab2d498-757f-48cc-8c07-a7d337997445").unwrap();
	let clock = Arc::new(RwLock::new(SizedClock::Fake(FakeClock::new(Timestamp::default()))));
	let test = init(node_id, clock).await.unwrap();
	let mut tx = test.db.transaction(Write, Optimistic).await.unwrap();
	let namespace = "test_namespace";
	let database = "test_database";
	let table = "test_table";
	tx.set_nd(node_id).await.unwrap();

	let lv_id = crate::uuid::Uuid::from(Uuid::from_bytes([
		0x10, 0x11, 0x12, 0x13, 0x14, 0x15, 0x16, 0x17, 0x18, 0x19, 0x1A, 0x1B, 0x1C, 0x1D, 0x1E,
		0x1F,
	]));

	let key = crate::key::node::lq::new(node_id, lv_id.0, namespace, database);
	tx.putc(key, table, None).await.unwrap();

	let mut stm = LiveStatement::from_source_parts(Fields::all(), Table(table.into()), None, None);
	stm.id = lv_id;
	tx.putc_tblq(namespace, database, table, stm, None).await.unwrap();

	let this_node_id = crate::uuid::Uuid::from(Uuid::from_bytes([
		0x20, 0x21, 0x22, 0x23, 0x24, 0x25, 0x26, 0x27, 0x28, 0x29, 0x2A, 0x2B, 0x2C, 0x2D, 0x2E,
		0x2F,
	]));
	// We commit after setup because otherwise in memory does not have read your own writes
	// i.e. setup data is part of same transaction as required implementation checks
	tx.commit().await.unwrap();

	let mut tx = test.db.transaction(Write, Optimistic).await.unwrap();
	let results = test
		.db
		.archive_lv_for_node(&mut tx, &crate::uuid::Uuid(node_id), this_node_id)
		.await
		.unwrap();
	assert_eq!(results.len(), 1);
	tx.commit().await.unwrap();
	let (lq, opt_err) = &results[0];
	match opt_err {
		None => {
			//expected
		}
		Some(err) => {
			panic!("Unexpected error: {:?}", err);
		}
	}
	assert_eq!(lq.nd, crate::uuid::Uuid(node_id));
	assert_eq!(lq.ns, namespace);
	assert_eq!(lq.db, database);
	assert_eq!(lq.tb, table);
	assert_eq!(lq.lq, lv_id);

	let mut tx = test.db.transaction(Write, Optimistic).await.unwrap();
	let lv = tx.all_tb_lives(namespace, database, table).await.unwrap();
	assert_eq!(lv.len(), 1, "{:?}", lv);
	assert_eq!(lv[0].archived, Some(this_node_id));
	tx.commit().await.unwrap();
}