Removed false starts.
This commit is contained in:
parent
aef8c68853
commit
0a889b6c3c
@ -8,6 +8,9 @@ impl Databases {
|
|||||||
pub fn new() -> Self {
|
pub fn new() -> Self {
|
||||||
Self {}
|
Self {}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn add_database(&self, _name: &str) {
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Clone)]
|
#[derive(Clone)]
|
||||||
@ -83,8 +86,10 @@ mod databases {
|
|||||||
use super::*;
|
use super::*;
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn get_bytes_for_new() {
|
fn add_database() {
|
||||||
Databases::new();
|
let dbs = Databases::new();
|
||||||
|
let name = "db1";
|
||||||
|
dbs.add_database(name);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -1,398 +0,0 @@
|
|||||||
/*
|
|
||||||
use async_std::sync::{Arc, RwLock};
|
|
||||||
use std::{collections::HashMap, error::Error, fmt, str::FromStr};
|
|
||||||
|
|
||||||
#[derive(Debug)]
|
|
||||||
pub struct DBError {
|
|
||||||
detail: String,
|
|
||||||
source: Option<Box<DBError>>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl DBError {
|
|
||||||
fn new(detail: String) -> Self {
|
|
||||||
Self {
|
|
||||||
detail: detail.to_string(),
|
|
||||||
source: None,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl fmt::Display for DBError {
|
|
||||||
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
|
|
||||||
write!(f, "{}", &self.detail)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl Error for DBError {
|
|
||||||
fn source(&self) -> Option<&(dyn Error + 'static)> {
|
|
||||||
match &self.source {
|
|
||||||
Some(err) => Some(err),
|
|
||||||
None => None,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Clone, PartialEq)]
|
|
||||||
pub enum FieldType {
|
|
||||||
Table,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl fmt::Display for FieldType {
|
|
||||||
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
||||||
match self {
|
|
||||||
FieldType::Table => write!(f, "table"),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl FromStr for FieldType {
|
|
||||||
type Err = DBError;
|
|
||||||
|
|
||||||
fn from_str(input: &str) -> Result<FieldType, Self::Err> {
|
|
||||||
match input {
|
|
||||||
"table" => Ok(FieldType::Table),
|
|
||||||
_ => Err(DBError::new(format!("field type {} does not exist", input))),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub struct Table {
|
|
||||||
fields: Arc<RwLock<HashMap<String, FieldType>>>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl Table {
|
|
||||||
pub async fn new() -> Self {
|
|
||||||
Self {
|
|
||||||
fields: Arc::new(RwLock::new(HashMap::new())),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn update_field(&self, name: &str, ftype: &str) -> Result<(), Box<dyn Error>> {
|
|
||||||
let ftype = match FieldType::from_str(ftype) {
|
|
||||||
Ok(field) => field,
|
|
||||||
Err(err) => {
|
|
||||||
let mut error = DBError::new(format!("failed to add field {}", name));
|
|
||||||
error.source = Some(Box::new(err));
|
|
||||||
return Err(Box::new(error));
|
|
||||||
}
|
|
||||||
};
|
|
||||||
let mut fmap = self.fields.write().await;
|
|
||||||
match fmap.get(name) {
|
|
||||||
Some(_) => Err(Box::new(DBError::new(format!(
|
|
||||||
"field {} already exists",
|
|
||||||
name
|
|
||||||
)))),
|
|
||||||
None => {
|
|
||||||
fmap.insert(name.to_string(), ftype);
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn fields(&self) -> HashMap<String, FieldType> {
|
|
||||||
let fmap = self.fields.read().await;
|
|
||||||
fmap.clone()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
use async_std::sync::{Arc, RwLock};
|
|
||||||
use std::collections::HashMap;
|
|
||||||
|
|
||||||
pub mod error;
|
|
||||||
mod fieldtype;
|
|
||||||
|
|
||||||
use error::MTTError;
|
|
||||||
use fieldtype::FieldType;
|
|
||||||
|
|
||||||
#[derive(Clone)]
|
|
||||||
pub struct MoreThanText;
|
|
||||||
|
|
||||||
impl MoreThanText {
|
|
||||||
pub async fn new() -> Self {
|
|
||||||
Self {}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn add_table(&self, name: &str) -> Table {
|
|
||||||
Table::new()
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn get_table(&self, name: &str) -> Table {
|
|
||||||
Table::new()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Clone, PartialEq)]
|
|
||||||
struct FieldDef;
|
|
||||||
|
|
||||||
pub struct Table {
|
|
||||||
fields: Arc<RwLock<HashMap<String, FieldDef>>>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl Table {
|
|
||||||
fn new() -> Self {
|
|
||||||
Self {
|
|
||||||
fields: Arc::new(RwLock::new(HashMap::new())),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn add_field(&self, name: &str) {
|
|
||||||
let mut field_defs = self.fields.write().await;
|
|
||||||
field_defs.insert(name.to_string(), FieldDef {});
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn get_field(&self, name: &str) -> Option<FieldDef> {
|
|
||||||
let field_defs = self.fields.read().await;
|
|
||||||
match field_defs.get(name) {
|
|
||||||
Some(def) => Some(def.clone()),
|
|
||||||
None => None,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn new_record(&self) -> Record {
|
|
||||||
Record::new()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
struct Record {
|
|
||||||
data: Arc<RwLock<HashMap<String, FieldType>>>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl Record {
|
|
||||||
fn new() -> Self {
|
|
||||||
Self {
|
|
||||||
data: Arc::new(RwLock::new(HashMap::new())),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
async fn update_field(&self, name: String, data: FieldType) {
|
|
||||||
let mut map = self.data.write().await;
|
|
||||||
map.insert(name, data);
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn get_field(&self, name: &str) -> Option<FieldType> {
|
|
||||||
let map = self.data.read().await;
|
|
||||||
match map.get(name) {
|
|
||||||
Some(field) => Some(field.clone()),
|
|
||||||
None => None,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod databases {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn new_database() {
|
|
||||||
MoreThanText::new().await;
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn add_table() {
|
|
||||||
let db = MoreThanText::new().await;
|
|
||||||
let name = "table";
|
|
||||||
db.add_table(name).await;
|
|
||||||
db.get_table(name).await;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod tables {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn new_table() {
|
|
||||||
Table::new();
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn add_field_definition() {
|
|
||||||
let tbl = Table::new();
|
|
||||||
let name = "field";
|
|
||||||
let expected = FieldDef {};
|
|
||||||
tbl.add_field(name).await;
|
|
||||||
let output = tbl.get_field(name).await.unwrap();
|
|
||||||
assert!(output == expected, "Did not return a field definition.");
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn missing_field_definition() {
|
|
||||||
let tbl = Table::new();
|
|
||||||
let output = tbl.get_field("missing").await;
|
|
||||||
assert!(
|
|
||||||
output == None,
|
|
||||||
"Should return None if field does not exist."
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn get_empty_record() {
|
|
||||||
let tbl = Table::new();
|
|
||||||
tbl.new_record().await;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod records {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
/*
|
|
||||||
#[async_std::test]
|
|
||||||
async fn update_fields() {
|
|
||||||
let rec = Record::new();
|
|
||||||
let name = "elephant";
|
|
||||||
let data = "";
|
|
||||||
let sstr = StaticString::new();
|
|
||||||
rec.update_field(name.to_string(), sstr).await;
|
|
||||||
let output = rec.get_field(name).await.unwrap();
|
|
||||||
assert!(
|
|
||||||
output.to_string() == data,
|
|
||||||
"\n\nGot: {}\nWant: {}\n\n",
|
|
||||||
output.to_string(),
|
|
||||||
data
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn empty_field() {
|
|
||||||
let rec = Record::new();
|
|
||||||
let name = "mull";
|
|
||||||
let output = rec.get_field(name).await;
|
|
||||||
assert!(output == None, "Should return an option.");
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
#[cfg(test)]
|
|
||||||
mod tables {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn new_table() {
|
|
||||||
Table::new().await;
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn update_field() {
|
|
||||||
let table = Table::new().await;
|
|
||||||
let mut expected: HashMap<String, FieldType> = HashMap::new();
|
|
||||||
expected.insert("stan".to_string(), FieldType::Table);
|
|
||||||
expected.insert("lee".to_string(), FieldType::Table);
|
|
||||||
table.update_field("stan", "table").await.unwrap();
|
|
||||||
table.update_field("lee", "table").await.unwrap();
|
|
||||||
let output = table.fields().await;
|
|
||||||
assert!(output == expected, "Table did not get the fields added.");
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn add_bad_field() -> Result<(), String> {
|
|
||||||
let table = Table::new().await;
|
|
||||||
let name = "failure";
|
|
||||||
let bad_type = "ljksdbtt";
|
|
||||||
let expected = format!("failed to add field {}", name);
|
|
||||||
let source = format!("field type {} does not exist", bad_type);
|
|
||||||
match table.update_field(name, bad_type).await {
|
|
||||||
Ok(_) => Err("A bad field type should not return successfully".to_string()),
|
|
||||||
Err(err) => {
|
|
||||||
if format!("{}", err) != expected {
|
|
||||||
Err(format!("Got: '{}' - Want: '{}'", err, expected))
|
|
||||||
} else if format!("{}", err.source().unwrap()) != source {
|
|
||||||
Err(format!(
|
|
||||||
"Got: '{}' - Want: '{}'",
|
|
||||||
err.source().unwrap(),
|
|
||||||
source
|
|
||||||
))
|
|
||||||
} else {
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn add_duplicate_field() -> Result<(), String> {
|
|
||||||
let table = Table::new().await;
|
|
||||||
let name = "twice";
|
|
||||||
let expected = format!("field {} already exists", name);
|
|
||||||
table.update_field(name, "table").await.unwrap();
|
|
||||||
match table.update_field(name, "table").await {
|
|
||||||
Ok(_) => Err(format!("Cannot have two fields with named '{}'", name)),
|
|
||||||
Err(err) => {
|
|
||||||
if format!("{}", err) == expected {
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(format!("Got: '{}' - Want: '{}'", err, expected))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod databases {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn new_database() {
|
|
||||||
MoreThanText::new().await;
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn add_table() {
|
|
||||||
let db = MoreThanText::new().await;
|
|
||||||
db.add_table("fred".to_string()).await;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod fieldtypes {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
fn get_field_map() -> HashMap<String, FieldType> {
|
|
||||||
let mut fields: HashMap<String, FieldType> = HashMap::new();
|
|
||||||
fields.insert("table".to_string(), FieldType::Table);
|
|
||||||
return fields;
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn convert_to_string() {
|
|
||||||
for (key, value) in get_field_map().iter() {
|
|
||||||
assert!(
|
|
||||||
key == &value.to_string(),
|
|
||||||
"\n\nGot: {}\nWant: {}\n\n",
|
|
||||||
value.to_string(),
|
|
||||||
key
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn convert_from_string() {
|
|
||||||
for (key, value) in get_field_map().iter() {
|
|
||||||
assert!(
|
|
||||||
&FieldType::from_str(key).unwrap() == value,
|
|
||||||
"\n\nDid not return a FieldType::{}",
|
|
||||||
key
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn convert_from_string_error() -> Result<(), String> {
|
|
||||||
let ftype = "lkjsdfh";
|
|
||||||
let expected = format!("field type {} does not exist", ftype);
|
|
||||||
match FieldType::from_str(ftype) {
|
|
||||||
Ok(_) => Err(format!("Found field type {}", ftype)),
|
|
||||||
Err(err) => {
|
|
||||||
if format!("{}", err) == expected {
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(format!("Got: '{}' - Want: '{}'", err, expected))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
@ -1,120 +0,0 @@
|
|||||||
pub mod error;
|
|
||||||
pub mod fieldtype;
|
|
||||||
|
|
||||||
use async_std::sync::{Arc, RwLock};
|
|
||||||
use error::MTTError;
|
|
||||||
use std::collections::HashMap;
|
|
||||||
|
|
||||||
#[derive(Clone)]
|
|
||||||
pub struct MoreThanText {
|
|
||||||
tables: Arc<RwLock<HashMap<String, Table>>>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl MoreThanText {
|
|
||||||
pub async fn new() -> Self {
|
|
||||||
Self {
|
|
||||||
tables: Arc::new(RwLock::new(HashMap::new())),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn new_table<S>(&self, tname: S) -> Result<Table, MTTError>
|
|
||||||
where
|
|
||||||
S: Into<String>,
|
|
||||||
{
|
|
||||||
let mut tables = self.tables.write().await;
|
|
||||||
let name = tname.into();
|
|
||||||
match tables.get(&name) {
|
|
||||||
Some(_) => Err(MTTError::new(format!("table {} already exists", name))),
|
|
||||||
None => {
|
|
||||||
let table = Table::new().await;
|
|
||||||
tables.insert(name, table.clone());
|
|
||||||
Ok(table)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn get_table(&self, name: &str) -> Option<Table> {
|
|
||||||
let tables = self.tables.read().await;
|
|
||||||
match tables.get(name) {
|
|
||||||
Some(tbl) => Some(tbl.clone()),
|
|
||||||
None => None,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Clone)]
|
|
||||||
pub struct Table;
|
|
||||||
|
|
||||||
impl Table {
|
|
||||||
pub async fn new() -> Self {
|
|
||||||
Self {}
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn new_column(&self, _name: &str, _type: &str) {}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod database {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn create_table_with_str() {
|
|
||||||
let db = MoreThanText::new().await;
|
|
||||||
db.new_table("william").await.unwrap();
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn create_table_with_string() {
|
|
||||||
let db = MoreThanText::new().await;
|
|
||||||
db.new_table("marvin".to_string()).await.unwrap();
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn table_names_are_unique() -> Result<(), String> {
|
|
||||||
let db = MoreThanText::new().await;
|
|
||||||
let name = "alexandar";
|
|
||||||
let msg = format!("table {} already exists", name);
|
|
||||||
db.new_table(name).await.unwrap();
|
|
||||||
match db.new_table(name).await {
|
|
||||||
Ok(_) => Err("Duplicate table names are not allowed.".to_string()),
|
|
||||||
Err(err) => {
|
|
||||||
if err.to_string() == msg {
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(format!(
|
|
||||||
"Error message is incorrect: Got: '{}' Want: '{}'",
|
|
||||||
err.to_string(),
|
|
||||||
msg
|
|
||||||
))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn get_non_existant_table() {
|
|
||||||
let db = MoreThanText::new().await;
|
|
||||||
let table = db.get_table("missing").await;
|
|
||||||
assert!(table.is_none(), "There should be no table.");
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn get_a_table() {
|
|
||||||
let db = MoreThanText::new().await;
|
|
||||||
let name = "here";
|
|
||||||
db.new_table(name).await.unwrap();
|
|
||||||
let table = db.get_table(name).await;
|
|
||||||
assert!(table.is_some(), "Table should be found.");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod table {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn add_column() {
|
|
||||||
let tbl = Table::new().await;
|
|
||||||
tbl.new_column("fred", "StaticString").await;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,153 +0,0 @@
|
|||||||
pub mod error;
|
|
||||||
|
|
||||||
use async_std::sync::{Arc, RwLock};
|
|
||||||
use error::DBError;
|
|
||||||
use std::collections::HashMap;
|
|
||||||
|
|
||||||
#[derive(Clone)]
|
|
||||||
pub struct MoreThanText {
|
|
||||||
databases: Arc<RwLock<HashMap<String, Database>>>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl MoreThanText {
|
|
||||||
pub async fn new() -> Self {
|
|
||||||
Self {
|
|
||||||
databases: Arc::new(RwLock::new(HashMap::new())),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn create_database(&self, name: &str) -> Result<(), DBError> {
|
|
||||||
let mut databases = self.databases.write().await;
|
|
||||||
match databases.get(name) {
|
|
||||||
Some(_) => Err(DBError::new("duplicate database name")),
|
|
||||||
None => {
|
|
||||||
let db = Database::new().await;
|
|
||||||
databases.insert(name.to_string(), db);
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn use_database(&self, name: &str) -> Result<Database, DBError> {
|
|
||||||
let databases = self.databases.read().await;
|
|
||||||
match databases.get(name) {
|
|
||||||
Some(db) => Ok(db.clone()),
|
|
||||||
None => Err(DBError::new("database name not found")),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Clone)]
|
|
||||||
struct Database;
|
|
||||||
|
|
||||||
impl Database {
|
|
||||||
async fn new() -> Self {
|
|
||||||
Self {}
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn add_table(&self, _name: &str) {}
|
|
||||||
}
|
|
||||||
|
|
||||||
struct Table;
|
|
||||||
|
|
||||||
impl Table {
|
|
||||||
async fn new() -> Self {
|
|
||||||
Self {}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod engine_functions {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn create_database() {
|
|
||||||
let mtt = MoreThanText::new().await;
|
|
||||||
mtt.create_database("smith").await.unwrap();
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn database_names_must_be_unique() -> Result<(), DBError> {
|
|
||||||
let mtt = MoreThanText::new().await;
|
|
||||||
let msg = "duplicate database name";
|
|
||||||
mtt.create_database("john").await.unwrap();
|
|
||||||
match mtt.create_database("john").await {
|
|
||||||
Ok(_) => Err(DBError::new("Duplicate names should cause error")),
|
|
||||||
Err(err) => {
|
|
||||||
if err.to_string() == msg {
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(DBError::new(format!(
|
|
||||||
"incorrect err message: got: '{}' want: '{}'",
|
|
||||||
err.to_string(),
|
|
||||||
msg
|
|
||||||
)))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn use_database() -> Result<(), DBError> {
|
|
||||||
let mtt = MoreThanText::new().await;
|
|
||||||
let dbname = "Johnson";
|
|
||||||
mtt.create_database(dbname).await.unwrap();
|
|
||||||
mtt.use_database(dbname).await.unwrap();
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn use_missing_database() -> Result<(), DBError> {
|
|
||||||
let error = "database name not found";
|
|
||||||
let mtt = MoreThanText::new().await;
|
|
||||||
match mtt.use_database("ssmith").await {
|
|
||||||
Ok(_) => Err(DBError::new("Should raise database missing error")),
|
|
||||||
Err(err) => {
|
|
||||||
if err.to_string() == error {
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(DBError::new(format!(
|
|
||||||
"Incorrect error message: Got '{}' Want '{}'",
|
|
||||||
err.to_string(),
|
|
||||||
error
|
|
||||||
)))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn create_get_table() {
|
|
||||||
let db = "thedatabase";
|
|
||||||
let mtt = MoreThanText::new().await;
|
|
||||||
mtt.create_database(db).await.unwrap();
|
|
||||||
let dbase = mtt.use_database(db).await.unwrap();
|
|
||||||
dbase.add_table("melvin").await;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod database_functions {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn new_database() {
|
|
||||||
Database::new().await;
|
|
||||||
}
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn new_table() {
|
|
||||||
let db = Database::new().await;
|
|
||||||
db.add_table("fred").await;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod table_functions {
|
|
||||||
use super::*;
|
|
||||||
|
|
||||||
#[async_std::test]
|
|
||||||
async fn new_table() {
|
|
||||||
Table::new().await;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue
Block a user