Drops the schema with the specified name. Args: name (string): The name of the Schema object to be retrieved.

Get the exception matching the MySQL error This function will return an exception based on the SQLState. The given message will be passed on

Gets a connection from the pool. This method returns an PooledMySQLConnection instance which has a reference to the pool that created

Wait until the MySQL server is down This method can be used to wait until the MySQL server has stopped. True is returned when the MyS

Wait until the MySQL server is up This method can be used to wait until the MySQL server is started. True is returned when the MySQL

Creates a MySQL connection object. In its simpliest form, `connect()` will open a connection to a MySQL server and return a `MySQLConnectionA

Executes the given operation This wrapper method around the execute()-method of the cursor is mainly needed to re-raise using differe

Returns the column type. Returns: int: The column type.

Generate model predictions using DataFrame input. If an 'id' column is defined in either dataframe, it will be used as the primary k

Remove the topdir of the MySQL server

Gets a list of query attributes from the connector's side. Returns: List of existing query attributes.

Returns an exception object based on the MySQL error Returns an exception object based on the MySQL error in the given packet. Returns a

Returns a Document matching the Document ID. Args: doc_id (str): Document ID Returns: mysqlx.DbDoc: The Docu

Rollback current transaction

Rollback to a transaction savepoint with the given name. Args: name (string): The savepoint name.

Returns the column name. Returns: str: The column name.

Convert a Python value into its SQL-compatible string representation and parameters. Args: value: The value to format. Returns:

Check if the socket is connected. Return: bool: Returns `True` if the socket is connected to MySQL server.

Read option files for connection parameters. Checks if connection arguments contain option file arguments, and then reads option files a

Handle the result after a command was send. The result can be either an OK-packet or a dictionary containing column/eof information.

Send a command to the MySQL server This method sends a command with an optional argument. If packet is not None, it will be sent and

Send one or more statements to the MySQL server Similar to the cmd_query method, but instead returns a generator object to iterate th

Creates or gets a MySQL connection object. In its simpliest form, `connect()` will open a connection to a MySQL server and return a `MySQLCon

Takes an unsigned integer and packs it as bytes, with the information of how much bytes the encoded int takes.

Replace connection socket reader and writer. Asyncio SSL keep-alive connections raise errors after loop close. See https://github.com

Change the current logged in user This method allows to change the current logged in user information. The result is a dictionary wit

Disconnect from server.

Get the next rows returned by the MySQL server This method gets one row from the result set after sending, for example, the query com

Returns the table name. Returns: str: The table name.

Set the error indicator using a MySQL session. Set the error indicator using the MySQL error returned by the MySQL server. When exc_type is NU

Set the error indicator using a string. Set the error indicator using the given string. When exc_type is NULL, MySQLInterfaceError will be use

Returns an iterator for stored results This method returns an iterator over results which are stored when callproc() is called. The i

Creates a schema on the database and returns the corresponding object. Args: name (string): A string value indicating the

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

Write message. Args: msg_type (int): The message type. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message.

Check if the statement has been executed. Raises an error if the statement has not been executed.

Deletes the model from the model catalog if present Raises: DatabaseError: If a database connection issu

Handle a MySQL OK packet This method handles a MySQL OK packet. When the packet is found to be an Error packet, an error will be rais

Check if MySQL server is running Check if the MySQL server is running using the given pid, or when not specified, using the PID found

Execute a non query command. Args: namespace (str): The namespace. cmd (str): The command. raise_on_fail

Send a query which only returns 1 row

Removes attributes from documents in a collection. Args: doc_paths (list): The list of document paths of the attributes to be

Check whether there is an unread result

Send a command to the MySQL server. This method sends a command with an optional argument. If packet is not None, it will be sent and

Adds a connection to the pool. This method instantiates a `MySQLConnection` using the configuration passed when initializing the `MyS

Continue with the Kerberos TGT service request. With the TGT authentication service given response generate a TGT service request. Th

Change the current database This method changes the current (default) database by sending the INIT_DB command. The result is a dictio

Return all rows of a query result set. Returns: list: A list of tuples with all rows of a query result set.

Returns the underlying connection. Returns: mysqlx.connection.Connection: The connection object.

Sets the order by criteria. Args: *clauses: The expression strings defining the order by criteria. Returns:

Check availability of the MySQL server When reconnect is set to True, one or more attempts are made to try to reconnect to the MySQL

Quote the given identifier with backticks, converting backticks (`) in the identifier name with the correct escape sequence (``) unless the id

Set the error indicator using a prepare statement. Set the error indicator using the MySQL error returned when using prepared statements. When

Convert forward slashes with backslashes This function replaces forward slashes with backslashes. This is necessary using Microsoft Windows f

Convert forward slashes with backslashes This function replaces forward slashes with backslashes. This is necessary using Microsoft Windows f

Handle EOF packet

Prepare a MySQL statement This method will send the PREPARE command to MySQL together with the given statement. Returns a di

Convert input data to a pandas DataFrame if necessary. Args: arr: Input data as a pandas DataFrame, NumPy ndarray, pandas Series, or

Get character set by ID. Args: charset_id: The charset ID. Returns: Charset: The Charset dataclass instance.

Sets a grouping criteria for the resultset. Args: *fields: The string expressions identifying the grouping criteria. Ret

Authenticate with the MySQL server Authentication happens in two parts. We first send a response to the handshake. The MySQL server w

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

Check if MySQL server is running Check if the MySQL server is running using the given pid, or when not specified, using the PID found

Close the socket.

Return all rows of a query result set. Returns: list: A list of tuples with all rows of a query result set.

Retrieves a Schema object from the current session by the schema name configured in the connection settings. Returns: mys

Instrument the library. Args: trace_module: reference to the 'trace' module from opentelemetry. tracer_provider (opti

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

Make a MySQL Authentication packet. Args: handshake: Initial handshake. username: Account's username. pas

Make a MySQL packet with the Statement Execute command

Set the connection configuration for `MySQLConnectionAbstract` subclass instances. This method sets the configuration used for creating `MySQ

Starts a transaction. This method explicitly starts a transaction sending the START TRANSACTION statement to the MySQL server. You ca

Uninstrument the library.

Check if the statement has been executed. Raises an error if the statement has not been executed.

Handle a MySQL OK packet. This method handles a MySQL OK packet. When the packet is found to be an Error packet, an error will be rai

Helper: construct MyAnomalyDetector with MyBaseMLModel.__init__ patched as a no-op (for pure unit test).