Was this page helpful?
Counter¶
Counter is represented as struct Counter(pub i64)
Counter can’t be inserted, it can only be read or updated.
use futures::TryStreamExt;
use scylla::value::Counter;
// Add to counter value
let to_add: Counter = Counter(100);
session
.query_unpaged("UPDATE keyspace.table SET c = c + ? WHERE pk = 15", (to_add,))
.await?;
// Read counter from the table
let mut stream = session.query_iter("SELECT c FROM keyspace.table", &[])
.await?
.rows_stream::<(Counter,)>()?;
while let Some((counter_value,)) = stream.try_next().await? {
let counter_int_value: i64 = counter_value.0;
println!("{}", counter_int_value);
}