Struct Runner

Source

pub struct Runner { /* private fields */ }

Implementations§

Source §

impl Runner

Source

pub fn new(url: &str, server_id: u32) -> Result<Self, Box<dyn Error>>

Source

pub fn start_sync(&mut self, offset: OffsetConfig) -> Result<(), Box<dyn Error>>

Source

pub fn get_event(&mut self) -> Result<Event, Box<dyn Error>>

Methods from Deref<Target = Conn>§

Source

pub fn connection_id(&self) -> u32

Returns connection identifier.

Source

pub fn affected_rows(&self) -> u64

Returns number of rows affected by the last query.

Source

pub fn last_insert_id(&self) -> u64

Returns last insert id of the last query.

Returns zero if there was no last insert id.

Source

pub fn warnings(&self) -> u16

Returns number of warnings, reported by the server.

Source

pub fn info_ref(&self) -> &[u8] ⓘ

Info, reported by the server.

Will be empty if not defined.

Source

pub fn info_str(&self) -> Cow<'_, str>

Info, reported by the server.

Will be empty if not defined.

Source

pub fn reset(&mut self) -> Result<(), Error>

Resets MyConn (drops state then reconnects).

Source

pub fn ping(&mut self) -> bool

Executes COM_PING on Conn. Return true on success or false on error.

Source

pub fn select_db(&mut self, schema: &str) -> bool

Executes COM_INIT_DB on Conn.

Source

pub fn start_transaction( &mut self, tx_opts: TxOpts, ) -> Result<Transaction<'_>, Error>

Starts new transaction with provided options. readonly is only available since MySQL 5.6.5.

Source

pub fn set_local_infile_handler(&mut self, handler: Option<LocalInfileHandler>)

Sets a callback to handle requests for local files. These are caused by using LOAD DATA LOCAL INFILE queries. The callback is passed the filename, and a Writeable object to receive the contents of that file. Specifying None will reset the handler to the one specified in the Opts for this connection.

Source