Struct MysqlHandler 

pub struct MysqlHandler { /* private fields */ }

MySQL connection handler

Implementations

impl MysqlHandler

pub fn new( connection_id: ConnectionId, llm_client: OllamaClient, app_state: Arc<AppState>, status_tx: UnboundedSender<String>, server_id: Option<ServerId>, remote_addr: SocketAddr, ) -> Self

pub fn fast_auth_gate(&self) -> Arc<FastAuthGate>

The gate this handler will arm from authenticate, for the writer that answers it.

Trait Implementations

impl<W: AsyncWrite + Send + Unpin> AsyncMysqlShim<W> for MysqlHandler

fn default_auth_plugin(&self) -> &str

The plugin named in the greeting.

opensrv-mysql’s default is mysql_native_password, whose client plugin MySQL 9.0 deleted — so the shipping CLI cannot load it and never reaches the query phase. See caching_sha2, and note what it does not mean: nothing here checks a password.

fn auth_plugin_for_username<'life0, 'life1, 'async_trait>( &'life0 self, _user: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = &str> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Never ask a client to switch plugins.

An empty expectation is opensrv-mysql’s “no auth-switch”: whatever the client chose is what this connection uses. That is the honest answer for a server that verifies nothing, and it is what keeps an older mysql_native_password client working — it answers the greeting with its own plugin and is accepted as it always was, rather than being sent an AuthSwitchRequest for a plugin it may not have.

fn authenticate<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, _auth_plugin: &'life1 str, _username: &'life2 [u8], _salt: &'life3 [u8], auth_data: &'life4 [u8], ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Admit the connection. Nothing is verified — there is no password here to verify against, and the model is not consulted.

The only decision taken is which shape the end of the connection phase has: a client that sent a 32-byte caching_sha2_password scramble is blocked reading for AuthMoreData, and gets it; every other client is answered with the OK packet alone.

type Error = Error

The error type produced by operations on this shim.

fn on_prepare<'a, 'async_trait>( &'a mut self, query: &'a str, info: StatementMetaWriter<'a, W>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Called when the client issues a request to prepare query for later execution.

fn on_execute<'a, 'async_trait>( &'a mut self, stmt_id: u32, _params: ParamParser<'a>, results: QueryResultWriter<'a, W>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Called when the client executes a previously prepared statement.

fn on_close<'life0, 'async_trait>( &'life0 mut self, stmt_id: u32, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called when the client wishes to deallocate resources associated with a previously prepared statement.

fn on_query<'a, 'async_trait>( &'a mut self, query: &'a str, results: QueryResultWriter<'a, W>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Called when the client issues a query for immediate execution.

fn on_init<'a, 'async_trait>( &'a mut self, _database: &'a str, writer: InitWriter<'a, W>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Called when client switches database.

fn version(&self) -> String

Server version

fn connect_id(&self) -> u32

Connection id

fn salt(&self) -> [u8; 20]

Default salt(scramble) for auth plugin