Struct D1Database 

pub struct D1Database { /* private fields */ }

Cloudflare D1 database client

Implementations

impl D1Database

pub fn new(account_id: &str, database_id: &str, api_token: &str) -> Self

pub async fn init(&self) -> Result<()>

Initialize system tables required by What (_kv_store and _collections). Safe to call multiple times — uses CREATE TABLE IF NOT EXISTS.

pub async fn get_collection(&self, name: &str) -> Result<Vec<Value>>

pub async fn query_collection( &self, name: &str, query: &CollectionQuery, ) -> Result<Vec<Value>>

pub async fn find_by( &self, collection: &str, field: &str, value: &Value, ) -> Result<Vec<Value>>

pub async fn find_one_by( &self, collection: &str, field: &str, value: &Value, ) -> Result<Option<Value>>

pub async fn create(&self, collection: &str, item: Value) -> Result<Value>

pub async fn update( &self, collection: &str, id: &Value, updates: Value, ) -> Result<Option<Value>>

pub async fn delete(&self, collection: &str, id: &Value) -> Result<bool>

pub async fn set(&self, key: &str, value: Value) -> Result<()>

pub async fn get(&self, key: &str) -> Result<Option<Value>>

pub async fn remove(&self, key: &str) -> Result<Option<Value>>

pub async fn atomic_modify<F>(&self, key: &str, f: F) -> Result<Value>

where F: FnOnce(Option<&Value>) -> Value,

pub async fn as_context(&self) -> Result<HashMap<String, Value>>

pub fn invalidate_schema_cache(&self)

Clear the cached table schemas, forcing re-detection on next access. Call this after ALTER TABLE or schema changes.

pub async fn set_collection(&self, name: &str, items: Vec<Value>) -> Result<()>

Trait Implementations

impl Clone for D1Database

fn clone(&self) -> D1Database

Returns a duplicate of the value.

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

Performs copy-assignment from source.