Loads the model specified by `self.model_name` into MySQL. After loading, the model is ready to handle ML operations. Refere

Prepare a payload for sending to the MySQL server.

Process query parameters.

Process query parameters given as dictionary

Reset the cursor to default. Args: preserve_last_executed_stmt: If it is False, the last executed

Write packet to the comm channel.

Test a MySQL connection. Try to connect to a MySQL server using a specified connection class and config.

Test a MySQL connection. Try to connect to a MySQL server using a specified connection class and config.

Write packet to the comm channel.

Build execute statement. Args: namespace (str): The namespace. stmt (Statement): A `Statement` based type object.

str: The character set name. .. versionadded:: 8.0.12

Close the cursor The result will be freed.

Cleans up the connection pool This public method gracefully shuts down the connection pool by disconnecting all of the open connection

Change the current logged in user

Close the current connection with the server This method sends the `QUIT` command to the MySQL server, closing the current connection

Delete and drop the entire vector store table. Returns: None

Drop a table from the SQL database if it exists. Args: cursor: MySQLCursorAbstract to execute the drop command. schema_name:

Escapes special characters as they are expected to by when MySQL receives them. As found in MySQL source mysys/charset.c

Fetch active result.

Fetch EOF and status information

Generate a pool name This function takes keyword arguments, usually the connection arguments for MySQLConnection, and tries to generate a nam

Returns the last insert id auto generated. Returns: int: The last insert id.

Returns the character set name. Returns: str: The character set name.

Returns the collation name. Returns: str: The collation name.

Returns options as a dictionary. Returns options from all the groups specified as arguments, returns the options from all groups if n

Returns the PID read from the PID file Returns None or int.

Returns the PID read from the PID file Returns None or int.

Return a dict with the platform arch and OS version.

Get all or a subset of rows returned by the MySQL server

Returns self for `weakref.proxy`. This method is used when the original object is needed when using `weakref.proxy`.

Get session or global system variables We use the MySQL connection cnx to query the INFORMATION_SCHEMA table SESSION_VARIABLES or, when globa

Returns the warnings. Returns: `list`: The list of warnings.

Sets a condition for records to be considered in agregate function operations. Args: condition (string): A condition on t

Returns the index of the column. Returns: int: The index of the column.

Send a query which only returns 1 row.

Takes an unsigned integer (4 bytes) and packs it as a bytes-object. Returns string.

Reports whether the connection to MySQL Server is available. This method checks whether the connection to MySQL is available. It is s

Check if connection is open. Returns: bool: `True` if connection is open.

Determine if a given SQL table is empty. Args: cursor: MySQLCursorAbstract with access to the database. schema_name: Name of

Determine if the underlying object is a view or not. Returns: bool: `True` if the underlying object is a view.

Kill connection using separate connection

Modifies a collection using a JSON schema validation. Args: name (str): The name of the collection. validation (Optio

Parse a MySQL auth more data packet. Args: pkt: Packet representing an `auth more data` response. Returns: a

Prepare an integer for the MySQL binary protocol

Prepare a time object for the MySQL binary protocol This method prepares a time object of type datetime.timedelta or datetime.time fo

Prepare a timestamp object for the MySQL binary protocol This method prepares a timestamp of type datetime.datetime or datetime.date

Removes documents based on the ``condition``. Args: condition (str): The string with the filter expression of the

Removes a connection from this pool. Args: cnx (PooledConnection): The connection object.

Set capabilities. Args: **kwargs: Arbitrary keyword arguments. Returns: mysqlx.protobuf.Message: MySQL X Pro

Set the connection timeout.

Sets this Router unavailable to open connections.

Load the entire contents of a SQL table into a pandas DataFrame. Args: cursor: MySQLCursorAbstract to execute the query. sch

int: The column type. .. versionadded:: 8.0.12

Generate docs/INFO_BIN. Args: mysql_version (Optional[str]): The MySQL version. Returns: bool: ``True`` if `docs/INFO_BIN` w

Generate docs/INFO_BIN. Args: mysql_version (Optional[str]): The MySQL version. Returns: bool: ``True`` if `docs/INFO_BIN` w

Generate docs/INFO_SRC. Returns: bool: ``True`` if `docs/INFO_SRC` was written successfully.

Generate docs/INFO_SRC. Returns: bool: ``True`` if `docs/INFO_SRC` was written successfully.

Network layer where transactions are made with plain (uncompressed) packets is enabled by default.

Network layer where transactions are made with plain (uncompressed) packets is enabled by default.

Apply filter. Args: msg (mysqlx.protobuf.Message): The MySQL X Protobuf Message. stmt (Statement): A `Statement` base

Converts TIME column MySQL to a python datetime.datetime type. Raises ValueError if the value can not be converted. Returns DATE col

Converts a datetime instance to a string suitable for MySQL. The returned string has format: %Y-%m-%d %H:%M:%S[.%f] If the i

Deallocates statement. Args: statement (Statement): A `Statement` based type object.

Debug function for showing buffers

Executes the prepared statement pipeline. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MyS

Execute a query. This method simply calls cmd_query() after checking for unread result. If there are still unread result, an Interfac

Returns the next row in the result set Returns a tuple or None.

Fetch warnings doing a SHOW WARNINGS. Can be called after getting the result. Returns a result set or None when there were n

Get connection based on configuration This method will return the appropriated connection object using the connection parameters.

Obtain and cache Kerberos ticket-granting ticket. Call `kinit` with a specified user and password for obtaining and caching Kerberos

Obtain and cache Kerberos ticket-granting ticket. Call `kinit` with a specified user and password for obtaining and caching Kerberos

Retrieves a list of pools that shares the given settings. Args: settings (dict): the configuration of the pool. Returns:

Fetch the current database user (without host). Returns: The username string associated with the connection. Ra

Handle a MySQL Binary Protocol OK packet This method handles a MySQL Binary Protocol OK packet. When the packet is found to be an Err

Handles result of execute() when there is no result set

Handle a MySQL Result This method handles a MySQL result, for example, after sending the query command. OK and EOF packets will be ha

Handle a MySQL Result. This method handles a MySQL result, for example, after sending the query command. OK and EOF packets will be h

Handle the server flags found in MySQL packets. This method handles the server flags send by MySQL OK and EOF packets. It, for exampl

Handle possible warnings after all results are consumed. Raises: Error: Also raises exceptions if raise_on_warnings is set.