cquill 0.0.9

Versioned CQL migrations for Cassandra and ScyllaDB
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

use scylla::transport::errors::QueryError as ScyllaQueryError;
use scylla::Session;

use crate::keyspace::KeyspaceOpts;

pub(crate) mod keyspace;
pub(crate) mod migrated;

#[derive(thiserror::Error, Debug)]
pub enum QueryError {
    #[error("cql query error: {source}")]
    TransportError {
        #[from]
        source: ScyllaQueryError,
    },
    #[error("{source}")]
    Other {
        #[from]
        source: anyhow::Error,
    },
}

pub(crate) async fn exec(session: &Session, query: String) -> Result<(), QueryError> {
    session.query(query, ()).await?;
    Ok(())
}