Struct TableSchema 

pub struct TableSchema {
    pub keyspace: String,
    pub table: String,
    pub partition_keys: Vec<KeyColumn>,
    pub clustering_keys: Vec<ClusteringColumn>,
    pub columns: Vec<Column>,
    pub comments: HashMap<String, String>,
}

Table schema definition loaded from JSON

Fields

keyspace: String

Keyspace name

table: String

Table name

partition_keys: Vec<KeyColumn>

Partition key columns (ordered)

clustering_keys: Vec<ClusteringColumn>

Clustering key columns (ordered)

columns: Vec<Column>

All columns in the table

comments: HashMap<String, String>

Optional metadata

Implementations

impl TableSchema

pub fn from_sstable_header(header: &SSTableHeader) -> Result<Self>

Extract schema from SSTable header column metadata

This method constructs a TableSchema from the column information embedded in the SSTable header’s SerializationHeader.

pub fn from_file<P: AsRef<Path>>(path: P) -> Result<Self>

Load schema from JSON file

pub fn from_json(json: &str) -> Result<Self>

Parse schema from JSON string

pub fn to_file<P: AsRef<Path>>(&self, path: P) -> Result<()>

Save schema to JSON file

pub fn validate(&self) -> Result<()>

Validate schema consistency

pub fn get_column(&self, name: &str) -> Option<&Column>

Get column by name

pub fn is_partition_key(&self, name: &str) -> bool

Check if column is a partition key

pub fn is_clustering_key(&self, name: &str) -> bool

Check if column is a clustering key

pub fn ordered_partition_keys(&self) -> Vec<&KeyColumn>

Get partition key columns in order

pub fn ordered_clustering_keys(&self) -> Vec<&ClusteringColumn>

Get clustering key columns in order

pub fn get_column_comparator(&self, column_name: &str) -> Result<ComparatorType>

Get ComparatorType for a specific column

pub fn get_all_comparators(&self) -> Result<HashMap<String, ComparatorType>>

Get ComparatorTypes for all columns

pub fn get_partition_key_comparators(&self) -> Result<Vec<ComparatorType>>

Get ComparatorTypes for partition key columns in order

pub fn get_clustering_key_comparators(&self) -> Result<Vec<ComparatorType>>

Get ComparatorTypes for clustering key columns in order

pub fn is_column_type_compatible( &self, column_name: &str, expected_type: &str, ) -> Result<bool>

Check if a column type is compatible with an expected type

Trait Implementations

impl Clone for TableSchema

fn clone(&self) -> TableSchema

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CqlVisitor<TableSchema> for SchemaBuilderVisitor

fn visit_statement(&mut self, statement: &CqlStatement) -> Result<TableSchema>

fn visit_create_table(&mut self, create: &CqlCreateTable) -> Result<TableSchema>

fn visit_select(&mut self, _select: &CqlSelect) -> Result<TableSchema>

fn visit_insert(&mut self, _insert: &CqlInsert) -> Result<TableSchema>

fn visit_update(&mut self, _update: &CqlUpdate) -> Result<TableSchema>

fn visit_delete(&mut self, _delete: &CqlDelete) -> Result<TableSchema>

fn visit_drop_table(&mut self, _drop: &CqlDropTable) -> Result<TableSchema>

fn visit_create_index( &mut self, _create: &CqlCreateIndex, ) -> Result<TableSchema>

fn visit_alter_table(&mut self, _alter: &CqlAlterTable) -> Result<TableSchema>

fn visit_data_type(&mut self, _data_type: &CqlDataType) -> Result<TableSchema>

fn visit_expression( &mut self, _expression: &CqlExpression, ) -> Result<TableSchema>

fn visit_identifier( &mut self, _identifier: &CqlIdentifier, ) -> Result<TableSchema>

fn visit_literal(&mut self, _literal: &CqlLiteral) -> Result<TableSchema>

impl Debug for TableSchema

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TableSchema

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TableSchema

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.