Struct QuerySync 

pub struct QuerySync<B: DatabaseBackend> { /* private fields */ }

QuerySync manages synchronization between ECS world and SQL database

Implementations

impl<B: DatabaseBackend> QuerySync<B>

pub fn new(backend: B, schema_generator: SchemaGenerator) -> Self

Create a new QuerySync instance

pub fn with_config( backend: B, schema_generator: SchemaGenerator, config: SyncConfig, ) -> Self

Create a new QuerySync instance with custom config

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

Initialize database schema

pub async fn track_entity_created(&self, entity_id: u64) -> Result<()>

Track entity creation

pub async fn track_component_change( &self, entity_id: u64, component_type: TypeId, component_name: String, data: HashMap<String, Value>, ) -> Result<()>

Track component change

pub async fn track_entity_deleted(&self, entity_id: u64) -> Result<()>

Track entity deletion

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

Flush pending changes to database

pub async fn query(&self, sql: &str) -> Result<QueryResult>

Query the database

pub async fn execute(&self, sql: &str) -> Result<u64>

Execute a SQL statement

pub fn config(&self) -> &SyncConfig

Get the current sync configuration

pub async fn is_connected(&self) -> bool

Check if backend is connected

pub async fn synced_entity_count(&self) -> usize

Get the number of synced entities

pub async fn pending_change_count(&self) -> usize

Get the number of pending changes

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

Clear all synced data from database

pub async fn full_sync( &self, entities: Vec<(u64, TypeId, String, HashMap<String, Value>)>, ) -> Result<()>

Perform a full sync of all components for given entities