diff options
Diffstat (limited to 'log_db/src/lib.rs')
| -rw-r--r-- | log_db/src/lib.rs | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/log_db/src/lib.rs b/log_db/src/lib.rs index e92b68d..05db3dc 100644 --- a/log_db/src/lib.rs +++ b/log_db/src/lib.rs @@ -25,7 +25,7 @@ mod memtable_primary; mod memtable_secondary; mod record; -pub use common::{DBError, DBResult, OwnedBounds, Type, Value}; +pub use common::{DBError, DBResult, OwnedBounds, Value}; pub use config::{ReadConsistency, Schema, WriteDurability}; use common::*; @@ -58,9 +58,6 @@ impl<T, F: Eq + Clone> DB<T, F> { let record = Record::from(&(self.engine.config.into_record)(recordable)); debug!("Upserting record: {:?}", record); - record.validate(&self.engine.config.schema)?; - debug!("Record is valid"); - self.engine .with_exclusive_lock(move |engine| engine.upsert_record(record))?; @@ -297,7 +294,7 @@ mod tests { let mut db = DB::configure() .data_dir(data_dir.to_str().unwrap()) - .schema(vec![(Field::Id, Type::int())]) + .fields(vec![Field::Id]) .primary_key(Field::Id) .from_record(TestInst1::from_record) .into_record(TestInst1::into_record) @@ -384,7 +381,7 @@ mod tests { let mut db = DB::configure() .data_dir(data_dir.to_str().unwrap()) - .schema(vec![(Field::Id, Type::int())]) + .fields(vec![Field::Id]) .primary_key(Field::Id) .from_record(TestInst1::from_record) .into_record(TestInst1::into_record) @@ -438,10 +435,7 @@ mod tests { let mut db = DB::configure() .data_dir(data_dir.to_str().unwrap()) - .schema(vec![ - (Field::Id, Type::int()), - (Field::Name, Type::string()), - ]) + .fields(vec![Field::Id, Field::Name]) .primary_key(Field::Id) .secondary_keys(vec![Field::Name]) .from_record(TestInst2::from_record) |