Crate faucet_source_oracle 

faucet-source-oracle

Oracle Database query source for the faucet-stream ecosystem, built on the oracle driver (ODPI-C).

Runs parameterized SQL, streams rows as JSON pages (the fetch array size is the batch_size), supports incremental replication via a bookmark column, PK-range sharding for clustered execution, and discover() over the data dictionary. NUMBER values are emitted without precision loss.

Runtime requirement: Oracle Instant Client must be installed where ODPI-C can load it.

let conn = OracleConnectionConfig::new("localhost", 1521, "FREEPDB1", "app", "secret");
let source = OracleSource::new(OracleSourceConfig::new(conn, "SELECT * FROM ORDERS")).await?;

Structs

OracleConnectionConfig

Connection settings shared by the Oracle source, CDC source and sink.

OracleSource

Oracle Database query source.

OracleSourceConfig

Configuration for OracleSource.

OracleTls

TCPS settings applied to a host-form connection.

ShardConfig

Primary-key range sharding for clustered (Mode B) execution: each shard runs SELECT * FROM (<query>) WHERE "<key>" >= lo AND "<key>" < hi. The key must be an integer-valued output column, named exactly as Oracle reports it.

Enums

OracleReplication

How the source replicates rows across runs.

Constants

BOOKMARK_TOKEN

The placeholder a query uses to read the incremental bookmark (WHERE UPDATED_AT >= :bookmark, any case).

DESCRIPTOR

The connector’s static descriptor (RFC 0013): its capabilities, answered from config alone.