301 lines
9.9 KiB
Rust
301 lines
9.9 KiB
Rust
// Copyright 2016 Mozilla
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License"); you may not use
|
|
// this file except in compliance with the License. You may obtain a copy of the
|
|
// License at http://www.apache.org/licenses/LICENSE-2.0
|
|
// Unless required by applicable law or agreed to in writing, software distributed
|
|
// under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
|
|
// CONDITIONS OF ANY KIND, either express or implied. See the License for the
|
|
// specific language governing permissions and limitations under the License.
|
|
|
|
#![allow(dead_code)]
|
|
|
|
use failure::{
|
|
Backtrace,
|
|
Context,
|
|
Fail,
|
|
};
|
|
|
|
use std::collections::{
|
|
BTreeMap,
|
|
BTreeSet,
|
|
};
|
|
|
|
use rusqlite;
|
|
|
|
use edn::entities::{
|
|
TempId,
|
|
};
|
|
|
|
use core_traits::{
|
|
Entid,
|
|
KnownEntid,
|
|
TypedValue,
|
|
ValueType,
|
|
};
|
|
|
|
pub type Result<T> = ::std::result::Result<T, DbError>;
|
|
|
|
// TODO Error/ErrorKind pair
|
|
#[derive(Clone, Debug, Eq, PartialEq)]
|
|
pub enum CardinalityConflict {
|
|
/// A cardinality one attribute has multiple assertions `[e a v1], [e a v2], ...`.
|
|
CardinalityOneAddConflict {
|
|
e: Entid,
|
|
a: Entid,
|
|
vs: BTreeSet<TypedValue>,
|
|
},
|
|
|
|
/// A datom has been both asserted and retracted, like `[:db/add e a v]` and `[:db/retract e a v]`.
|
|
AddRetractConflict {
|
|
e: Entid,
|
|
a: Entid,
|
|
vs: BTreeSet<TypedValue>,
|
|
},
|
|
}
|
|
|
|
// TODO Error/ErrorKind pair
|
|
#[derive(Clone, Debug, Eq, PartialEq, Fail)]
|
|
pub enum SchemaConstraintViolation {
|
|
/// A transaction tried to assert datoms where one tempid upserts to two (or more) distinct
|
|
/// entids.
|
|
ConflictingUpserts {
|
|
/// A map from tempid to the entids it would upsert to.
|
|
///
|
|
/// In the future, we might even be able to attribute the upserts to particular (reduced)
|
|
/// datoms, i.e., to particular `[e a v]` triples that caused the constraint violation.
|
|
/// Attributing constraint violations to input data is more difficult to the multiple
|
|
/// rewriting passes the input undergoes.
|
|
conflicting_upserts: BTreeMap<TempId, BTreeSet<KnownEntid>>,
|
|
},
|
|
|
|
/// A transaction tried to assert a datom or datoms with the wrong value `v` type(s).
|
|
TypeDisagreements {
|
|
/// The key (`[e a v]`) has an invalid value `v`: it is not of the expected value type.
|
|
conflicting_datoms: BTreeMap<(Entid, Entid, TypedValue), ValueType>
|
|
},
|
|
|
|
/// A transaction tried to assert datoms that don't observe the schema's cardinality constraints.
|
|
CardinalityConflicts {
|
|
conflicts: Vec<CardinalityConflict>,
|
|
},
|
|
}
|
|
|
|
impl ::std::fmt::Display for SchemaConstraintViolation {
|
|
fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
|
|
use self::SchemaConstraintViolation::*;
|
|
match self {
|
|
&ConflictingUpserts { ref conflicting_upserts } => {
|
|
writeln!(f, "conflicting upserts:")?;
|
|
for (tempid, entids) in conflicting_upserts {
|
|
writeln!(f, " tempid {:?} upserts to {:?}", tempid, entids)?;
|
|
}
|
|
Ok(())
|
|
},
|
|
&TypeDisagreements { ref conflicting_datoms } => {
|
|
writeln!(f, "type disagreements:")?;
|
|
for (ref datom, expected_type) in conflicting_datoms {
|
|
writeln!(f, " expected value of type {} but got datom [{} {} {:?}]", expected_type, datom.0, datom.1, datom.2)?;
|
|
}
|
|
Ok(())
|
|
},
|
|
&CardinalityConflicts { ref conflicts } => {
|
|
writeln!(f, "cardinality conflicts:")?;
|
|
for ref conflict in conflicts {
|
|
writeln!(f, " {:?}", conflict)?;
|
|
}
|
|
Ok(())
|
|
},
|
|
}
|
|
}
|
|
}
|
|
|
|
#[derive(Copy, Clone, Eq, PartialEq, Debug, Fail)]
|
|
pub enum InputError {
|
|
/// Map notation included a bad `:db/id` value.
|
|
BadDbId,
|
|
|
|
/// A value place cannot be interpreted as an entity place (for example, in nested map
|
|
/// notation).
|
|
BadEntityPlace,
|
|
}
|
|
|
|
impl ::std::fmt::Display for InputError {
|
|
fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
|
|
use self::InputError::*;
|
|
match self {
|
|
&BadDbId => {
|
|
writeln!(f, ":db/id in map notation must either not be present or be an entid, an ident, or a tempid")
|
|
},
|
|
&BadEntityPlace => {
|
|
writeln!(f, "cannot convert value place into entity place")
|
|
},
|
|
}
|
|
}
|
|
}
|
|
|
|
#[derive(Debug)]
|
|
pub struct DbError {
|
|
inner: Context<DbErrorKind>,
|
|
}
|
|
|
|
impl ::std::fmt::Display for DbError {
|
|
fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
|
|
::std::fmt::Display::fmt(&self.inner, f)
|
|
}
|
|
}
|
|
|
|
impl Fail for DbError {
|
|
fn cause(&self) -> Option<&Fail> {
|
|
self.inner.cause()
|
|
}
|
|
|
|
fn backtrace(&self) -> Option<&Backtrace> {
|
|
self.inner.backtrace()
|
|
}
|
|
}
|
|
|
|
impl DbError {
|
|
pub fn kind(&self) -> DbErrorKind {
|
|
self.inner.get_context().clone()
|
|
}
|
|
}
|
|
|
|
impl From<DbErrorKind> for DbError {
|
|
fn from(kind: DbErrorKind) -> DbError {
|
|
DbError { inner: Context::new(kind) }
|
|
}
|
|
}
|
|
|
|
impl From<Context<DbErrorKind>> for DbError {
|
|
fn from(inner: Context<DbErrorKind>) -> DbError {
|
|
DbError { inner: inner }
|
|
}
|
|
}
|
|
|
|
impl From<rusqlite::Error> for DbError {
|
|
fn from(error: rusqlite::Error) -> DbError {
|
|
DbError { inner: Context::new(DbErrorKind::RusqliteError(error.to_string())) }
|
|
}
|
|
}
|
|
|
|
#[derive(Clone, PartialEq, Debug, Fail)]
|
|
pub enum DbErrorKind {
|
|
/// We're just not done yet. Message that the feature is recognized but not yet
|
|
/// implemented.
|
|
#[fail(display = "not yet implemented: {}", _0)]
|
|
NotYetImplemented(String),
|
|
|
|
/// We've been given a value that isn't the correct Mentat type.
|
|
#[fail(display = "value '{}' is not the expected Mentat value type {:?}", _0, _1)]
|
|
BadValuePair(String, ValueType),
|
|
|
|
/// We've got corrupt data in the SQL store: a value and value_type_tag don't line up.
|
|
/// TODO _1.data_type()
|
|
#[fail(display = "bad SQL (value_type_tag, value) pair: ({:?}, {:?})", _0, _1)]
|
|
BadSQLValuePair(rusqlite::types::Value, i32),
|
|
|
|
// /// The SQLite store user_version isn't recognized. This could be an old version of Mentat
|
|
// /// trying to open a newer version SQLite store; or it could be a corrupt file; or ...
|
|
// #[fail(display = "bad SQL store user_version: {}", _0)]
|
|
// BadSQLiteStoreVersion(i32),
|
|
|
|
/// A bootstrap definition couldn't be parsed or installed. This is a programmer error, not
|
|
/// a runtime error.
|
|
#[fail(display = "bad bootstrap definition: {}", _0)]
|
|
BadBootstrapDefinition(String),
|
|
|
|
/// A schema assertion couldn't be parsed.
|
|
#[fail(display = "bad schema assertion: {}", _0)]
|
|
BadSchemaAssertion(String),
|
|
|
|
/// An ident->entid mapping failed.
|
|
#[fail(display = "no entid found for ident: {}", _0)]
|
|
UnrecognizedIdent(String),
|
|
|
|
/// An entid->ident mapping failed.
|
|
#[fail(display = "no ident found for entid: {}", _0)]
|
|
UnrecognizedEntid(Entid),
|
|
|
|
/// Tried to transact an entid that isn't allocated.
|
|
#[fail(display = "entid not allocated: {}", _0)]
|
|
UnallocatedEntid(Entid),
|
|
|
|
#[fail(display = "unknown attribute for entid: {}", _0)]
|
|
UnknownAttribute(Entid),
|
|
|
|
#[fail(display = "cannot reverse-cache non-unique attribute: {}", _0)]
|
|
CannotCacheNonUniqueAttributeInReverse(Entid),
|
|
|
|
#[fail(display = "schema alteration failed: {}", _0)]
|
|
SchemaAlterationFailed(String),
|
|
|
|
/// A transaction tried to violate a constraint of the schema of the Mentat store.
|
|
#[fail(display = "schema constraint violation: {}", _0)]
|
|
SchemaConstraintViolation(SchemaConstraintViolation),
|
|
|
|
/// The transaction was malformed in some way (that was not recognized at parse time; for
|
|
/// example, in a way that is schema-dependent).
|
|
#[fail(display = "transaction input error: {}", _0)]
|
|
InputError(InputError),
|
|
|
|
#[fail(display = "Cannot transact a fulltext assertion with a typed value that is not :db/valueType :db.type/string")]
|
|
WrongTypeValueForFtsAssertion,
|
|
|
|
// SQL errors.
|
|
#[fail(display = "could not update a cache")]
|
|
CacheUpdateFailed,
|
|
|
|
#[fail(display = "Could not set_user_version")]
|
|
CouldNotSetVersionPragma,
|
|
|
|
#[fail(display = "Could not get_user_version")]
|
|
CouldNotGetVersionPragma,
|
|
|
|
#[fail(display = "Could not search!")]
|
|
CouldNotSearch,
|
|
|
|
#[fail(display = "Could not insert transaction: failed to add datoms not already present")]
|
|
TxInsertFailedToAddMissingDatoms,
|
|
|
|
#[fail(display = "Could not insert transaction: failed to retract datoms already present")]
|
|
TxInsertFailedToRetractDatoms,
|
|
|
|
#[fail(display = "Could not update datoms: failed to retract datoms already present")]
|
|
DatomsUpdateFailedToRetract,
|
|
|
|
#[fail(display = "Could not update datoms: failed to add datoms not already present")]
|
|
DatomsUpdateFailedToAdd,
|
|
|
|
#[fail(display = "Failed to create temporary tables")]
|
|
FailedToCreateTempTables,
|
|
|
|
#[fail(display = "Could not insert non-fts one statements into temporary search table!")]
|
|
NonFtsInsertionIntoTempSearchTableFailed,
|
|
|
|
#[fail(display = "Could not insert fts values into fts table!")]
|
|
FtsInsertionFailed,
|
|
|
|
#[fail(display = "Could not insert FTS statements into temporary search table!")]
|
|
FtsInsertionIntoTempSearchTableFailed,
|
|
|
|
#[fail(display = "Could not drop FTS search ids!")]
|
|
FtsFailedToDropSearchIds,
|
|
|
|
#[fail(display = "Could not update partition map")]
|
|
FailedToUpdatePartitionMap,
|
|
|
|
#[fail(display = "Can't operate over mixed timelines")]
|
|
TimelinesMixed,
|
|
|
|
#[fail(display = "Can't move transactions to a non-empty timeline")]
|
|
TimelinesMoveToNonEmpty,
|
|
|
|
#[fail(display = "Supplied an invalid transaction range")]
|
|
TimelinesInvalidRange,
|
|
|
|
// It would be better to capture the underlying `rusqlite::Error`, but that type doesn't
|
|
// implement many useful traits, including `Clone`, `Eq`, and `PartialEq`.
|
|
#[fail(display = "SQL error: {}", _0)]
|
|
RusqliteError(String),
|
|
}
|