Struct SqlExporter 

pub struct SqlExporter {
    pub batch_size: usize,
    pub drop_existing: bool,
    pub if_not_exists: bool,
}

Generates SQL DDL and DML statements for TSDB data.

SqlExporter is stateless: each method takes the relevant inputs and returns a String. No database connection is required.

Fields

batch_size: usize

Number of rows per batched INSERT statement (0 = all rows in one statement).

drop_existing: bool

When true, a DROP TABLE IF EXISTS is emitted before CREATE TABLE.

if_not_exists: bool

When true, IF NOT EXISTS is added to CREATE TABLE.

Implementations

impl SqlExporter

pub fn new() -> Self

Create an exporter with sensible defaults.

pub fn with_batch_size(self, size: usize) -> Self

Set batch size.

pub fn with_drop_existing(self, drop: bool) -> Self

Include DROP TABLE IF EXISTS before CREATE TABLE.

pub fn create_table_sql(&self, schema: &MetricSchema) -> String

Generate a CREATE TABLE statement for the given schema.

pub fn insert_sql( &self, schema: &MetricSchema, points: &[SqlDataPoint], ) -> Vec<String>

Generate a batched INSERT INTO statement for a slice of points.

Points are split into chunks of batch_size (or all at once if batch_size == 0). Returns a Vec of SQL strings, one per batch.

pub fn export_to_sql_file( &self, schema: &MetricSchema, points: &[SqlDataPoint], path: &Path, ) -> TsdbResult<()>

Generate a complete SQL script (DDL + DML) and write it to path.

The script contains:

1. CREATE TABLE (and optionally DROP TABLE IF EXISTS).
2. All INSERT INTO batches.

pub fn select_range_sql( &self, schema: &MetricSchema, start_ms: i64, end_ms: i64, ) -> String

Generate a SELECT query for a metric within a time range.

pub fn count_sql(&self, schema: &MetricSchema) -> String

Generate a SELECT COUNT(*) query.

pub fn summary_sql(&self, schema: &MetricSchema) -> String

Generate a SELECT MIN/MAX/AVG(value) summary query.

pub fn delete_before_sql(&self, schema: &MetricSchema, before_ms: i64) -> String

Generate a DELETE FROM statement to purge data older than before_ms.

pub fn create_index_sql(&self, schema: &MetricSchema) -> String

Generate a CREATE INDEX for fast time-range queries.

pub fn add_tag_column_sql(&self, schema: &MetricSchema, tag_key: &str) -> String

Generate an ALTER TABLE ... ADD COLUMN for a new tag.

pub fn infer_schema(metric_name: &str, points: &[SqlDataPoint]) -> MetricSchema

Infer a MetricSchema from a slice of SqlDataPoints and a metric name.

Trait Implementations

impl Clone for SqlExporter

fn clone(&self) -> SqlExporter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqlExporter

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

Formats the value using the given formatter.

impl Default for SqlExporter

fn default() -> SqlExporter

Returns the “default value” for a type.