User defined types¶

Scylla allows users to define their own data types with named fields (See the official documentation)
To use user defined types in the driver, you can create a corresponding struct in Rust, and use it to read and write UDT values.

For example let’s say my_type was created using this query:

CREATE TYPE ks.my_type (int_val int, text_val text)

To use this type in the driver, create a matching struct and derive:

• SerializeValue: in order to be able to use this struct in query parameters. \

• DeserializeValue: in order to be able to use this struct in query results. \

Both macros require fields of UDT and struct to have matching names, but the order of the fields is not required to be the same.
Note: you can use different name using rename attribute - see SerializeValue and DeserializeValue macros documentation.

use scylla::{DeserializeValue, SerializeValue};

// Define a custom struct that matches the User Defined Type created earlier.
// Fields don't have to be in the same order as they are in the database.
// By default, they must have the same names, but this can be worked around
// using `#[rename] field attribute.
// Wrapping a field in Option will gracefully handle null field values.
#[derive(Debug, DeserializeValue, SerializeValue)]
struct MyType {
    int_val: i32,
    text_val: Option<String>,
}

Important
For (de)serialization, by default fields in the Rust struct must be defined with the same names as they are in the database. The driver will (de)serialize the fields in the order defined by the UDT, matching Rust fields by name. You can change this behaviour using macro attributes, see SerializeValue/DeserializeValue macro documentation for more information.

Now it can be sent and received just like any other CQL value:

use futures::TryStreamExt;
use scylla::{DeserializeValue, SerializeValue};

#[derive(Debug, DeserializeValue, SerializeValue)]
struct MyType {
    int_val: i32,
    text_val: Option<String>,
}

// Insert my_type into the table
let to_insert = MyType {
    int_val: 17,
    text_val: Some("Some string".to_string()),
};

session
    .query_unpaged("INSERT INTO keyspace.table (a) VALUES(?)", (to_insert,))
    .await?;

// Read MyType from the table
let mut iter = session.query_iter("SELECT a FROM keyspace.table", &[])
    .await?
    .rows_stream::<(MyType,)>()?;
while let Some((my_type_value,)) = iter.try_next().await? {
    println!("{:?}", my_type_value);
}