Struct scylla::transport::session::Session

pub struct Session { /* fields omitted */ }

Implementations

impl Session

Represents a CQL session, which can be used to communicate with the database

pub async fn connect(
    addr: impl ToSocketAddrs + Display,
    compression: Option<Compression>
) -> Result<Self>

Estabilishes a CQL session with the database

Arguments

• addr - address of the server
• compression - optional compression settings

pub async fn query<'_, '_>(
    &'_ self,
    query: impl Into<Query>,
    values: &'_ [Value]
) -> Result<Option<Vec<Row>>>

Sends a query to the database and receives a response. If query has paging enabled, this will return only the first page.

Arguments

• query - query to be performed
• values - values bound to the query

pub fn query_iter(
    &self,
    query: impl Into<Query>,
    values: &[Value]
) -> Result<RowIterator>

pub async fn prepare<'_, '_>(
    &'_ self,
    query: &'_ str
) -> Result<PreparedStatement>

Prepares a statement on the server side and returns a prepared statement, which can later be used to perform more efficient queries

Arguments

pub async fn execute<'_, '_, '_>(
    &'_ self,
    prepared: &'_ PreparedStatement,
    values: &'_ [Value]
) -> Result<Option<Vec<Row>>>

Executes a previously prepared statement

Arguments

• prepared - a statement prepared with prepare
• values - values bound to the query

pub fn execute_iter(
    &self,
    prepared: impl Into<PreparedStatement>,
    values: &[Value]
) -> Result<RowIterator>

pub fn get_connections(&self) -> Result<Vec<(Node, Vec<Arc<Connection>>)>>

Returns all connections that the session has currently opened.

pub async fn refresh_topology<'_>(&'_ self) -> Result<()>