Struct Database 

pub struct Database { /* private fields */ }

DuckDB-backed storage for ticks and bars.

Implementations

impl Database

pub fn open(path: &Path) -> Result<Self>

Open (or create) a DuckDB database at the given path.

pub fn open_in_memory() -> Result<Self>

Open an in-memory database (for testing).

pub fn insert_ticks(&self, ticks: &[Tick]) -> Result<usize>

Bulk insert ticks using INSERT OR IGNORE for dedup. Returns the number of rows actually inserted.

pub fn insert_bars(&self, bars: &[Bar]) -> Result<usize>

Bulk insert bars using INSERT OR IGNORE for dedup. Returns the number of rows actually inserted.

pub fn delete_ticks( &self, exchange: &str, symbol: &str, from: Option<NaiveDateTime>, to: Option<NaiveDateTime>, ) -> Result<usize>

Delete ticks matching exchange+symbol, optionally within a date range.

pub fn delete_bars( &self, exchange: &str, symbol: &str, timeframe: &str, from: Option<NaiveDateTime>, to: Option<NaiveDateTime>, ) -> Result<usize>

Delete bars matching exchange+symbol+timeframe, optionally within a date range.

pub fn delete_symbol( &self, exchange: &str, symbol: &str, ) -> Result<(usize, usize)>

Delete ALL data (ticks + bars) for an exchange+symbol pair.

pub fn delete_exchange(&self, exchange: &str) -> Result<(usize, usize)>

Delete ALL data for an entire exchange.

pub fn stats( &self, exchange: Option<&str>, symbol: Option<&str>, ) -> Result<Vec<StatRow>>

Get summary statistics, optionally filtered by exchange and/or symbol.

pub fn query_ticks(&self, opts: &QueryOpts) -> Result<(Vec<Tick>, u64)>

Query ticks with filtering and pagination.

pub fn query_bars(&self, opts: &BarQueryOpts) -> Result<(Vec<Bar>, u64)>

Query bars with filtering and pagination.

pub fn file_size(&self) -> Option<u64>

Get database file size in bytes (None for in-memory).