Enum ReplicationStatement 

pub enum ReplicationStatement {
    ChangeSource {
        options: ThinVec<ChangeReplicationSourceOption>,
        channel: Option<Literal>,
        meta: Meta,
    },
    ChangeFilter {
        rules: ThinVec<ReplicationFilterRule>,
        channel: Option<Literal>,
        meta: Meta,
    },
    StartReplica {
        threads: ThinVec<ReplicaThreadOption>,
        until: ThinVec<ReplicaUntilCondition>,
        user: Option<Literal>,
        password: Option<Literal>,
        default_auth: Option<Literal>,
        plugin_dir: Option<Literal>,
        channel: Option<Literal>,
        meta: Meta,
    },
    StopReplica {
        threads: ThinVec<ReplicaThreadOption>,
        channel: Option<Literal>,
        meta: Meta,
    },
    StartGroupReplication {
        options: ThinVec<GroupReplicationOption>,
        meta: Meta,
    },
    StopGroupReplication {
        meta: Meta,
    },
}

A MySQL replication-administration statement — the boxed payload of Statement::Replication.

Six verbs across the five measured families ride one enum because they are one dialect unit reached through the replication-specific leading-keyword sequences. START/STOP GROUP_REPLICATION are two variants (the two verbs carry different tails — only START takes options) of the single GROUP REPLICATION family.

Variants

ChangeSource

CHANGE REPLICATION SOURCE TO <option-list> [FOR CHANNEL '<ch>'].

The option list is non-empty (a bare CHANGE REPLICATION SOURCE TO is ER_PARSE_ERROR on mysql:8.4.10) and comma-separated; each element is a ChangeReplicationSourceOption. FOR CHANNEL is a trailing suffix, not a list member — an option after the channel (… FOR CHANNEL 'c', SOURCE_PORT = 1) rejects.

Fields

options: ThinVec<ChangeReplicationSourceOption>

The <name> = <value> options in source order; always non-empty.

channel: Option<Literal>

The optional FOR CHANNEL '<name>' replication-channel name.

meta: Meta

Source location and node identity.

ChangeFilter

CHANGE REPLICATION FILTER <rule-list> [FOR CHANNEL '<ch>'].

The rule list is non-empty and comma-separated; each element is a ReplicationFilterRule.

Fields

rules: ThinVec<ReplicationFilterRule>

The filter rules in source order; always non-empty.

channel: Option<Literal>

The optional FOR CHANNEL '<name>' replication-channel name.

meta: Meta

Source location and node identity.

StartReplica

START REPLICA [<thread-list>] [UNTIL <cond-list>] [USER='u'] [PASSWORD='p'] [DEFAULT_AUTH='a'] [PLUGIN_DIR='d'] [FOR CHANNEL '<ch>'].

The connection options are four independent fixed-order optionals (MySQL’s opt_user_option … opt_plugin_dir_option, space-separated — not a comma list, unlike StartGroupReplication). Each may appear alone (START REPLICA PASSWORD = 'p' is grammar-valid on mysql:8.4.10).

Fields

threads: ThinVec<ReplicaThreadOption>

The SQL_THREAD/IO_THREAD thread-type list (opt_replica_thread_option_list); empty when none was written (start both threads).

until: ThinVec<ReplicaUntilCondition>

The UNTIL <cond-list> stop condition (opt_replica_until); empty when no UNTIL was written. See ReplicaUntilCondition.

user: Option<Literal>

The USER = '<u>' connection user; None when absent.

password: Option<Literal>

The PASSWORD = '<p>' connection password; None when absent.

default_auth: Option<Literal>

The DEFAULT_AUTH = '<a>' authentication plugin; None when absent.

plugin_dir: Option<Literal>

The PLUGIN_DIR = '<d>' plugin directory; None when absent.

channel: Option<Literal>

The optional FOR CHANNEL '<name>' replication-channel name.

meta: Meta

Source location and node identity.

StopReplica

STOP REPLICA [<thread-list>] [FOR CHANNEL '<ch>'].

Unlike StartReplica, STOP REPLICA takes no UNTIL or connection tail — STOP REPLICA UNTIL … / STOP REPLICA USER = … is ER_PARSE_ERROR on mysql:8.4.10.

Fields

threads: ThinVec<ReplicaThreadOption>

The SQL_THREAD/IO_THREAD thread-type list; empty when none was written.

channel: Option<Literal>

The optional FOR CHANNEL '<name>' replication-channel name.

meta: Meta

Source location and node identity.

StartGroupReplication

START GROUP_REPLICATION [<option-list>].

The options are USER/PASSWORD/DEFAULT_AUTH in any order, comma-separated (group_replication_start_options — the distinguishing difference from StartReplica’s space-separated fixed-order tail), so they ride an ordered list. Empty when none was written.

Fields

options: ThinVec<GroupReplicationOption>

The connection options in source order; empty when none was written.

meta: Meta

Source location and node identity.

StopGroupReplication

STOP GROUP_REPLICATION — takes no options (STOP GROUP_REPLICATION USER = … is ER_PARSE_ERROR on mysql:8.4.10).

Fields

meta: Meta

Source location and node identity.

Trait Implementations

impl Clone for ReplicationStatement

fn clone(&self) -> ReplicationStatement

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicationStatement

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ReplicationStatement

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ReplicationStatement

impl Hash for ReplicationStatement

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 ReplicationStatement

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

Equality operator ==.

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

Inequality operator !=.

impl Render for ReplicationStatement

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

Return the render for this value.

fn operand_binding_power(&self) -> Option<BindingPower>

The binding power this node contributes when it appears as an operand, or None (the default) for a self-delimiting node — an atom, call, or constructor — that never needs parentheses.

impl Serialize for ReplicationStatement

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Spanned for ReplicationStatement

fn span(&self) -> Span

Return the span for this value.

impl StructuralPartialEq for ReplicationStatement