Struct SqlServer 

pub struct SqlServer;

Trait Implementations

impl CdcSourceDdlValidator for SqlServer

fn check_and_fill_create_with_options( props: &mut BTreeMap<String, String>, ) -> ConnectorResult<()>

Checks the WITH (...) options of a CREATE statement, and fills in the options that the CDC source generates when they are omitted, such as a random slot.name for Postgres. The connector node later renders the filled options into the Debezium config through the .properties template of the CDC source. An override calls check_common_with_options first.

fn check_license() -> Result<(), FeatureNotAvailable>

Checks that the license allows the CDC source.

fn check_alter_with_options( props: &BTreeMap<String, String>, secret_refs: &BTreeMap<String, PbSecretRef>, ) -> ConnectorResult<()>

Checks that ALTER SOURCE ... CONNECTOR WITH (...) only changes options that a running CDC source can apply. An override calls check_common_with_options first.

fn check_format_encode( format: PbFormatType, encode: PbEncodeType, ) -> ConnectorResult<()>

Checks the FORMAT ... ENCODE ... clause of a CREATE statement.

fn check_include_column(additional_column_type: &str) -> ConnectorResult<()>

Checks an additional column type in the INCLUDE clause of a CREATE statement, such as timestamp in INCLUDE timestamp AS ts.

impl CdcSourceRuntimeFlags for SqlServer

const CAN_BACKFILL: bool = true

When true, only shared sources are supported; otherwise only direct sources are supported.

const NEEDS_NON_EMPTY_INITIAL_OFFSET: bool = true

When true, the source executor waits for a non-empty split offset before reporting the initial CDC offset.

const CAN_BACKFILL_IN_PARALLEL: bool = false

When true, the planner may choose parallelized backfill.

const CAN_USE_TRANSACTION_METADATA: bool = false

When true, a shared source sets Debezium’s provide.transaction.metadata, so that all rows of one upstream transaction go into a single chunk.

const NEEDS_OFFSET_COMMIT_ON_CHECKPOINT: bool = false

When true, the consumed offset is committed back to the upstream database on each checkpoint via a JNI call.

impl CdcSourceTypeTrait for SqlServer

const CDC_CONNECTOR_NAME: &'static str = "sqlserver-cdc"

fn source_type() -> CdcSourceType

impl Clone for SqlServer

fn clone(&self) -> SqlServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqlServer

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

Formats the value using the given formatter.

impl Default for SqlServer

fn default() -> SqlServer

Returns the “default value” for a type.

impl Eq for SqlServer

impl Hash for SqlServer

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for SqlServer

fn eq(&self, other: &SqlServer) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for SqlServer