wtx 0.45.0

A collection of different transport implementations and related tools focused primarily on web technologies.
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

pub(crate) mod with_schema;
pub(crate) mod without_schema;

use crate::{
  collection::Vector,
  database::{
    Database,
    schema_manager::{
      Commands, SchemaManagement, UserMigrationGroup, integration_tests::AuxTestParams,
    },
  },
};
use alloc::string::String;
use std::path::Path;

pub(crate) async fn migrate_works<DB, E>(
  buffer_cmd: &mut String,
  c: &mut Commands<E>,
  aux: AuxTestParams,
  wtx_schema_tables: usize,
) where
  DB: Database<Error = crate::Error>,
  E: SchemaManagement<Database = DB>,
{
  let path = Path::new("../.test-utils/wtx.toml");
  let mut db_migrations = Vector::new();
  c.migrate_from_toml_path(path).await.unwrap();
  let initial = UserMigrationGroup::new("initial", 1);
  c._executor_mut().migrations(buffer_cmd, &initial, &mut db_migrations).await.unwrap();
  assert_eq!(db_migrations[0].checksum(), 7573493478190316387);
  assert_eq!(db_migrations[0].uid(), 1);
  assert_eq!(db_migrations[0].name(), "create_author");
  assert_eq!(db_migrations[1].uid(), 2);
  assert_eq!(db_migrations[1].name(), "create_post");
  assert_eq!(db_migrations[2].uid(), 3);
  assert_eq!(db_migrations[2].name(), "insert_author");
  assert_eq!(db_migrations[3].uid(), 4);
  assert_eq!(db_migrations[3].name(), "insert_post");
  assert_eq!(db_migrations.get(4), None);
  let more_stuff = UserMigrationGroup::new("more_stuff", 2);
  db_migrations.clear();
  c._executor_mut().migrations(buffer_cmd, &more_stuff, &mut db_migrations).await.unwrap();
  assert_eq!(db_migrations[0].checksum(), 8208328219135761847);
  assert_eq!(db_migrations[0].uid(), 1);
  assert_eq!(db_migrations[0].name(), "create_stuff");
  assert_eq!(db_migrations[1].uid(), 2);
  assert_eq!(db_migrations[1].name(), "insert_stuff");
  assert_eq!(db_migrations.get(4), None);
  let mut idents = Vector::new();
  c._executor_mut().table_names(buffer_cmd, &mut idents, aux.default_schema).await.unwrap();
  assert_eq!(idents.len(), 4 + aux.schema_regulator);
  idents.clear();
  c._executor_mut().table_names(buffer_cmd, &mut idents, aux.wtx_schema).await.unwrap();
  assert_eq!(idents.len(), wtx_schema_tables);
}