Struct SqliteDatabase 

pub struct SqliteDatabase { /* private fields */ }

Available on crate feature sqlite only.

SQLite database connection pool

Implementations

impl SqliteDatabase

pub fn new(config: &DatabaseConfig) -> Result<Self, CommerceError>

Create a new SQLite database connection

pub fn in_memory() -> Result<Self, CommerceError>

Create an in-memory database (useful for testing)

pub fn conn( &self, ) -> Result<PooledConnection<SqliteConnectionManager>, CommerceError>

Get a connection from the pool

pub fn health_check(&self) -> Result<DbHealthStatus, CommerceError>

Run a health check: verify DB connectivity, return pool and storage stats.

pub fn shutdown(&self) -> Result<(), CommerceError>

Graceful shutdown: checkpoint WAL and optimize before closing.

Call this before dropping the database to ensure all WAL data is flushed to the main database file. Safe to call multiple times.

pub fn orders(&self) -> SqliteOrderRepository

Get order repository

pub fn inventory(&self) -> SqliteInventoryRepository

Get inventory repository

pub fn customers(&self) -> SqliteCustomerRepository

Get customer repository

pub fn products(&self) -> SqliteProductRepository

Get product repository

pub fn custom_objects(&self) -> SqliteCustomObjectRepository

Get custom objects repository (custom states / metaobjects)

pub fn returns(&self) -> SqliteReturnRepository

Get return repository

pub fn bom(&self) -> SqliteBomRepository

Get BOM (Bill of Materials) repository

pub fn work_orders(&self) -> SqliteWorkOrderRepository

Get work order repository

pub fn shipments(&self) -> SqliteShipmentRepository

Get shipment repository

pub fn payments(&self) -> SqlitePaymentRepository

Get payment repository

pub fn warranties(&self) -> SqliteWarrantyRepository

Get warranty repository

pub fn purchase_orders(&self) -> SqlitePurchaseOrderRepository

Get purchase order repository

pub fn invoices(&self) -> SqliteInvoiceRepository

Get invoice repository

pub fn carts(&self) -> SqliteCartRepository

Get cart repository

pub fn analytics(&self) -> SqliteAnalyticsRepository

Get analytics repository

pub fn currency(&self) -> SqliteCurrencyRepository

Get currency repository

pub fn tax(&self) -> SqliteTaxRepository

Get tax repository

pub fn promotions(&self) -> SqlitePromotionRepository

Get promotions repository

pub fn subscriptions(&self) -> SqliteSubscriptionRepository

Get subscriptions repository

pub fn quality(&self) -> SqliteQualityRepository

Get quality repository

pub fn lots(&self) -> SqliteLotRepository

Get lots repository

pub fn serials(&self) -> SqliteSerialRepository

Get serials repository

pub fn warehouse(&self) -> SqliteWarehouseRepository

Get warehouse repository

pub fn receiving(&self) -> SqliteReceivingRepository

Get receiving repository

pub fn fulfillment(&self) -> SqliteFulfillmentRepository

Get fulfillment repository

pub fn accounts_payable(&self) -> SqliteAccountsPayableRepository

Get accounts payable repository

pub fn cost_accounting(&self) -> SqliteCostAccountingRepository

Get cost accounting repository

pub fn credit(&self) -> SqliteCreditRepository

Get credit repository

pub fn backorder(&self) -> SqliteBackorderRepository

Get backorder repository

pub fn accounts_receivable(&self) -> SqliteAccountsReceivableRepository

Get accounts receivable repository

pub fn general_ledger(&self) -> SqliteGeneralLedgerRepository

Get general ledger repository

pub fn x402_payment_intents(&self) -> SqliteX402PaymentIntentRepository

Get x402 payment intent repository

pub fn x402_credits(&self) -> SqliteX402CreditRepository

Get x402 credit ledger repository

pub fn a2a_quotes(&self) -> SqliteA2ARepository

Get A2A quote/purchase repository

pub fn a2a_purchases(&self) -> SqliteA2ARepository

Get A2A quote/purchase repository

pub fn agent_cards(&self) -> SqliteAgentCardRepository

Get agent card repository

pub fn agent_identities(&self) -> SqliteAgentIdentityRepository

Get agent identity repository (ERC-8004)

pub fn agent_reputation(&self) -> SqliteAgentReputationRepository

Get agent reputation repository (ERC-8004)

pub fn agent_validation(&self) -> SqliteAgentValidationRepository

Get agent validation repository (ERC-8004)

pub fn gift_cards(&self) -> SqliteGiftCardRepository

Get gift card repository

pub fn store_credits(&self) -> SqliteStoreCreditRepository

Get store credit repository

pub fn segments(&self) -> SqliteSegmentRepository

Get customer segment repository

pub fn shipping_zones(&self) -> SqliteShippingZoneRepository

Get shipping zone repository

pub fn channels(&self) -> SqliteChannelRepository

Get channel repository

pub fn companies(&self) -> SqliteCompanyRepository

Get company (B2B account) repository

pub fn transfer_orders(&self) -> SqliteTransferOrderRepository

Get transfer order repository

pub fn units_of_measure(&self) -> SqliteUnitOfMeasureRepository

Get units-of-measure repository

pub fn production_batches(&self) -> SqliteProductionBatchRepository

Get production batch repository

pub fn supplier_skus(&self) -> SqliteSupplierSkuRepository

Get supplier SKU repository

pub fn fixed_assets(&self) -> SqliteFixedAssetRepository

Get fixed asset repository

pub fn revenue_recognition(&self) -> SqliteRevenueRecognitionRepository

Get revenue recognition repository

pub fn vendor_returns(&self) -> SqliteVendorReturnRepository

Get vendor return repository

pub fn vendor_credits(&self) -> SqliteVendorCreditRepository

Get vendor credit repository

pub fn payment_obligations(&self) -> SqlitePaymentObligationRepository

Get payment obligation repository

pub fn price_levels(&self) -> SqlitePriceLevelRepository

Get price level repository

pub fn prepayments(&self) -> SqlitePrepaymentRepository

Get prepayment repository

pub fn price_schedules(&self) -> SqlitePriceScheduleRepository

Get price schedule repository

pub fn http_idempotency(&self) -> SqliteHttpIdempotencyRepository

Get the durable HTTP idempotency repository

pub fn activity_logs(&self) -> SqliteActivityLogRepository

Get activity log repository

pub fn integration_mappings(&self) -> SqliteIntegrationMappingRepository

Get integration mapping repository

pub fn inbound_shipments(&self) -> SqliteInboundShipmentRepository

Get inbound shipment repository

pub fn purgatory(&self) -> SqlitePurgatoryRepository

Get purgatory (order ingestion staging) repository

pub fn print_stations(&self) -> SqlitePrintStationRepository

Get print station repository

pub fn edi_documents(&self) -> SqliteEdiDocumentRepository

Get EDI document repository

pub fn integration_field_mappings( &self, ) -> SqliteIntegrationFieldMappingRepository

Get integration field-mapping repository

pub fn topology_snapshots(&self) -> SqliteTopologySnapshotRepository

Get topology snapshot repository

pub fn stock_snapshots(&self) -> SqliteStockSnapshotRepository

Get stock snapshot repository

pub fn zone_shipping_methods(&self) -> SqliteZoneShippingMethodRepository

Get zone shipping method repository

pub fn reviews(&self) -> SqliteReviewRepository

Get product review repository

pub fn wishlists(&self) -> SqliteWishlistRepository

Get wishlist repository

pub fn loyalty_programs(&self) -> SqliteLoyaltyProgramRepository

Get loyalty program repository

pub fn rewards(&self) -> SqliteRewardRepository

Get reward catalog repository

pub fn fraud(&self) -> SqliteFraudRepository

Get fraud detection repository

pub fn search_configs(&self) -> SqliteSearchConfigRepository

Get search configuration repository

pub const fn pool(&self) -> &Pool<SqliteConnectionManager>

Get underlying pool (for advanced use)

Trait Implementations

impl Database for SqliteDatabase

fn backend_name(&self) -> &'static str

Human-readable backend name.

fn supports_capability(&self, capability: DatabaseCapability) -> bool

Whether the backend supports a given optional repository domain.

fn orders(&self) -> Box<dyn OrderRepository + '_>

Get the order repository

fn inventory(&self) -> Box<dyn InventoryRepository + '_>

Get the inventory repository

fn customers(&self) -> Box<dyn CustomerRepository + '_>

Get the customer repository

fn products(&self) -> Box<dyn ProductRepository + '_>

Get the product repository

fn custom_objects(&self) -> Box<dyn CustomObjectRepository + '_>

Get the custom objects repository (custom states / metaobjects)

fn returns(&self) -> Box<dyn ReturnRepository + '_>

Get the return repository

fn bom(&self) -> Box<dyn BomRepository + '_>

Get the BOM (Bill of Materials) repository

fn work_orders(&self) -> Box<dyn WorkOrderRepository + '_>

Get the work order repository

fn shipments(&self) -> Box<dyn ShipmentRepository + '_>

Get the shipment repository

fn payments(&self) -> Box<dyn PaymentRepository + '_>

Get the payment repository

fn warranties(&self) -> Box<dyn WarrantyRepository + '_>

Get the warranty repository

fn purchase_orders(&self) -> Box<dyn PurchaseOrderRepository + '_>

Get the purchase order repository

fn invoices(&self) -> Box<dyn InvoiceRepository + '_>

Get the invoice repository

fn carts(&self) -> Box<dyn CartRepository + '_>

Get the cart/checkout repository

fn analytics(&self) -> Box<dyn AnalyticsRepository + '_>

Get the analytics repository

fn currency(&self) -> Box<dyn CurrencyRepository + '_>

Get the currency repository

fn tax(&self) -> Box<dyn TaxRepository + '_>

Get the tax repository

fn promotions(&self) -> Box<dyn PromotionRepository + '_>

Get the promotions repository

fn subscriptions(&self) -> Box<dyn SubscriptionRepository + '_>

Get the subscriptions repository

fn quality(&self) -> Box<dyn QualityRepository + '_>

Get the quality repository

fn lots(&self) -> Box<dyn LotRepository + '_>

Get the lots repository

fn serials(&self) -> Box<dyn SerialRepository + '_>

Get the serials repository

fn warehouse(&self) -> Box<dyn WarehouseRepository + '_>

Get the warehouse repository

fn receiving(&self) -> Box<dyn ReceivingRepository + '_>

Get the receiving repository

fn fulfillment(&self) -> Box<dyn FulfillmentRepository + '_>

Get the fulfillment repository

fn accounts_payable(&self) -> Box<dyn AccountsPayableRepository + '_>

Get the accounts payable repository

fn cost_accounting(&self) -> Box<dyn CostAccountingRepository + '_>

Get the cost accounting repository

fn credit(&self) -> Box<dyn CreditRepository + '_>

Get the credit repository

fn backorder(&self) -> Box<dyn BackorderRepository + '_>

Get the backorder repository

fn accounts_receivable(&self) -> Box<dyn AccountsReceivableRepository + '_>

Get the accounts receivable repository

fn general_ledger(&self) -> Box<dyn GeneralLedgerRepository + '_>

Get the general ledger repository

fn x402_payment_intents(&self) -> Box<dyn X402PaymentIntentRepository + '_>

Get the x402 payment intent repository

fn x402_credits(&self) -> Box<dyn X402CreditRepository + '_>

Get the x402 credit ledger repository

fn a2a_quotes(&self) -> Box<dyn A2ACommerceRepository + '_>

Get the agent-to-agent commerce repository (quotes and purchases)

fn a2a_purchases(&self) -> Box<dyn A2ACommerceRepository + '_>

Get the agent-to-agent commerce repository (quotes and purchases)

fn agent_cards(&self) -> Box<dyn AgentCardRepository + '_>

Get the agent card repository

fn agent_identities(&self) -> Box<dyn AgentIdentityRepository + '_>

Get the agent identity registry repository (ERC-8004)

fn agent_reputation(&self) -> Box<dyn AgentReputationRepository + '_>

Get the agent reputation registry repository (ERC-8004)

fn agent_validation(&self) -> Box<dyn AgentValidationRepository + '_>

Get the agent validation registry repository (ERC-8004)

fn gift_cards(&self) -> Box<dyn GiftCardRepository + '_>

Get the gift card repository

fn store_credits(&self) -> Box<dyn StoreCreditRepository + '_>

Get the store credit repository

fn segments(&self) -> Box<dyn SegmentRepository + '_>

Get the customer segment repository

fn shipping_zones(&self) -> Box<dyn ShippingZoneRepository + '_>

Get the shipping zone repository

fn zone_shipping_methods(&self) -> Box<dyn ZoneShippingMethodRepository + '_>

Get the zone shipping method repository

fn reviews(&self) -> Box<dyn ReviewRepository + '_>

Get the product review repository

fn wishlists(&self) -> Box<dyn WishlistRepository + '_>

Get the wishlist repository

fn loyalty_programs(&self) -> Box<dyn LoyaltyProgramRepository + '_>

Get the loyalty program repository

fn rewards(&self) -> Box<dyn RewardRepository + '_>

Get the reward catalog repository

fn fraud(&self) -> Box<dyn FraudRepository + '_>

Get the fraud detection repository

fn search_configs(&self) -> Box<dyn SearchConfigRepository + '_>

Get the search configuration repository

fn channels(&self) -> Box<dyn ChannelRepository + '_>

Get the sales/fulfillment channel repository

fn companies(&self) -> Box<dyn CompanyRepository + '_>

Get the B2B company repository

fn transfer_orders(&self) -> Box<dyn TransferOrderRepository + '_>

Get the transfer order repository

fn units_of_measure(&self) -> Box<dyn UnitOfMeasureRepository + '_>

Get the units-of-measure repository

fn production_batches(&self) -> Box<dyn ProductionBatchRepository + '_>

Get the production batch repository

fn supplier_skus(&self) -> Box<dyn SupplierSkuRepository + '_>

Get the supplier SKU repository

fn vendor_returns(&self) -> Box<dyn VendorReturnRepository + '_>

Get the vendor return repository

fn vendor_credits(&self) -> Box<dyn VendorCreditRepository + '_>

Get the vendor credit repository

fn payment_obligations(&self) -> Box<dyn PaymentObligationRepository + '_>

Get the payment obligation repository

fn price_levels(&self) -> Box<dyn PriceLevelRepository + '_>

Get the price level repository

fn prepayments(&self) -> Box<dyn PrepaymentRepository + '_>

Get the prepayment repository

fn price_schedules(&self) -> Box<dyn PriceScheduleRepository + '_>

Get the price schedule repository

fn activity_logs(&self) -> Box<dyn ActivityLogRepository + '_>

Get the activity log repository

fn integration_mappings(&self) -> Box<dyn IntegrationMappingRepository + '_>

Get the integration mapping repository

fn inbound_shipments(&self) -> Box<dyn InboundShipmentRepository + '_>

Get the inbound shipment repository

fn purgatory(&self) -> Box<dyn PurgatoryRepository + '_>

Get the purgatory repository

fn print_stations(&self) -> Box<dyn PrintStationRepository + '_>

Get the print station repository

fn edi_documents(&self) -> Box<dyn EdiDocumentRepository + '_>

Get the EDI document repository

fn integration_field_mappings( &self, ) -> Box<dyn IntegrationFieldMappingRepository + '_>

Get the integration field-mapping repository

fn topology_snapshots(&self) -> Box<dyn TopologySnapshotRepository + '_>

Get the topology snapshot repository

fn stock_snapshots(&self) -> Box<dyn StockSnapshotRepository + '_>

Get the stock snapshot repository

fn fixed_assets(&self) -> Box<dyn FixedAssetRepository + '_>

Get the fixed asset repository

fn revenue_recognition(&self) -> Box<dyn RevenueRecognitionRepository + '_>

Get the revenue recognition repository

fn http_idempotency(&self) -> Option<Box<dyn HttpIdempotencyRepository + '_>>

Get the durable HTTP idempotency repository, if the backend provides one. Backends without durable idempotency support return None, in which case callers fall back to in-memory behavior.

fn ensure_capability(&self, capability: DatabaseCapability) -> Result<()>

Fail fast when a caller requests an unsupported optional repository domain.

impl DatabaseExt for SqliteDatabase

fn with_transaction<F, T>(&self, f: F) -> Result<T>

where F: FnMut(&Connection) -> Result<T, Error>,

Execute a closure within a database transaction.

fn with_transaction_opts<F, T>( &self, opts: TransactionOptions, f: F, ) -> Result<T>

where F: FnMut(&Connection) -> Result<T, Error>,

Execute a closure within a database transaction with custom options.

impl Debug for SqliteDatabase

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

Formats the value using the given formatter.