Struct CqlSession 

pub struct CqlSession {
    driver: ScyllaDriver,
    current_keyspace: Option<String>,
    pub connection_display: String,
    pub cluster_name: Option<String>,
    pub cql_version: Option<String>,
    pub release_version: Option<String>,
    pub scylla_version: Option<String>,
}

High-level CQL session managing driver state and user preferences.

Fields

driver: ScyllaDriver

current_keyspace: Option<String>

Current keyspace (updated on USE commands).

connection_display: String

Display name for the connection (host:port).

cluster_name: Option<String>

Cluster name retrieved after connecting.

cql_version: Option<String>

CQL version from the connected node.

release_version: Option<String>

Release version of the connected node.

scylla_version: Option<String>

ScyllaDB version (None if connected to Apache Cassandra).

Implementations

impl CqlSession

pub async fn connect(config: &MergedConfig) -> Result<Self>

Create a new session by connecting using the merged configuration.

pub async fn execute(&mut self, query: &str) -> Result<CqlResult>

Execute a CQL statement. Handles USE keyspace commands specially.

pub async fn execute_query(&self, query: &str) -> Result<CqlResult>

Execute a raw CQL query without USE interception.

Used by DESCRIBE and other internal commands that need to query system tables directly.

pub async fn execute_paged( &self, query: &str, page_size: i32, ) -> Result<CqlResult>

Execute a CQL statement with paging.

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

Prepare a CQL statement.

pub async fn execute_prepared( &self, id: &PreparedId, values: &[CqlValue], ) -> Result<CqlResult>

Execute a previously prepared statement with typed bound values.

pub async fn use_keyspace(&mut self, keyspace: &str) -> Result<()>

Switch to a different keyspace.

pub fn current_keyspace(&self) -> Option<&str>

Get the current keyspace.

pub fn get_consistency(&self) -> Consistency

Get the current consistency level.

pub fn set_consistency(&self, consistency: Consistency)

Set the consistency level.

pub fn set_consistency_str(&self, level: &str) -> Result<()>

Set the consistency level from a string. Returns error if invalid.

pub fn get_serial_consistency(&self) -> Option<Consistency>

Get the current serial consistency level.

pub fn set_serial_consistency(&self, consistency: Option<Consistency>)

Set the serial consistency level.

pub fn set_serial_consistency_str(&self, level: &str) -> Result<()>

Set the serial consistency level from a string. Returns error if invalid.

pub fn set_tracing(&self, enabled: bool)

Enable or disable tracing.

pub fn is_tracing_enabled(&self) -> bool

Check if tracing is enabled.

pub fn last_trace_id(&self) -> Option<Uuid>

Get the last tracing session ID.

pub async fn get_trace_session( &self, trace_id: Uuid, ) -> Result<Option<TracingSession>>

Retrieve tracing session data.

pub async fn get_keyspaces(&self) -> Result<Vec<KeyspaceMetadata>>

Get metadata for all keyspaces.

pub async fn get_tables(&self, keyspace: &str) -> Result<Vec<TableMetadata>>

Get metadata for tables in a keyspace.

pub async fn get_table_metadata( &self, keyspace: &str, table: &str, ) -> Result<Option<TableMetadata>>

Get metadata for a specific table.

pub async fn get_udts(&self, keyspace: &str) -> Result<Vec<UdtMetadata>>

Get metadata for all user-defined types in a keyspace.

pub async fn get_functions( &self, keyspace: &str, ) -> Result<Vec<FunctionMetadata>>

Get metadata for all user-defined functions in a keyspace.

pub async fn get_aggregates( &self, keyspace: &str, ) -> Result<Vec<AggregateMetadata>>

Get metadata for all user-defined aggregates in a keyspace.

pub async fn is_connected(&self) -> bool

Check if the connection is still alive.