Crate faucet_source_mssql 

faucet-source-mssql

Microsoft SQL Server query source for the faucet-stream ecosystem, built on tiberius + bb8-tiberius.

Runs parameterized SQL, streams rows as JSON StreamPages through a connection pool, and supports incremental replication via a tracking column (see MssqlReplication). Mirrors the faucet-source-postgres / mysql / sqlite query sources.

let cfg = MssqlSourceConfig::new(
    "mssql://sa:Str0ng%40Pass@localhost:1433/sales",
    "SELECT id, email, updated_at FROM dbo.users",
);
let source = MssqlSource::new(cfg).await?;

Structs

MssqlConnectionConfig

Shared connection configuration for the MSSQL source and sink.

MssqlSource

Microsoft SQL Server query source.

MssqlSourceConfig

Configuration for MssqlSource.

MssqlTls

TLS configuration for an MSSQL connection.

ShardConfig

Primary-key range sharding settings for the MSSQL source.

Enums

MssqlReplication

How the source replicates rows across runs.

MssqlTlsMode

MSSQL encryption mode.