Parse values from a binary result packet

Read message. Args: result (Result): A `Result` based type object.

Compress packet and write it to the comm channel.

Set the given packet id, if any, else increment packet id.

Set the size of the pool This method sets the size of the pool but it will not resize the pool. Raises an AttributeError when the po

Reformat the IOError error message. This function reformats the IOError error message.

Helper method for testing cnx.cmd_change_user() with MFA.

Helper method for testing connection with MFA.

Helper method for testing connection with MFA.

Check the query attributes (named parameters) are transmitted.

Converts a time instance to a string suitable for MySQL. The returned string has format: %H:%M:%S[.%f] If the instance isn't

Converts TIME column value to python datetime.time value type. Converts the TIME column MySQL type passed as bytes to a python dateti

Compress packet and write it to the comm channel.

Insert a value into the specified array in documents of a collection. Args: field (string): A document path that identifi

Serialize :class:`mysqlx.DbDoc` to a JSON formatted ``str``. Returns: str: A JSON formatted ``str`` representation of the documen

Get whether autocommit is on or off

Binds value(s) to a specific placeholder(s). Args: *args: The name of the placeholder and the value to bind. A

Check whether we can connect with given TLS version Attempts a connection to a server using a specific TLS version but does not verify which

Closes the connection. This method closes the socket.

Close the connection.

Send the DEBUG command This method sends the DEBUG command to the MySQL server, which requires the MySQL user to have SUPER privilege

Shut down the MySQL Server This method sends the SHUTDOWN command to the MySQL server. The `shutdown_type` is not used, and it's kept

Reset data for prepared statement sent as long data The result is a dictionary with OK packet information. Returns a dict()

Compresses data and returns it. Args: data (str, bytes or buffer object): Data to be compressed. Returns: by

Instantiates and returns a cursor using C Extension By default, CMySQLCursor is returned. Depending on the options while connecting,

Parse a JSON-style document path, like WL#7909, but prefix by @. instead of $. We parse this as a string because the protocol doesn't

Generate an embedding for a single text string. References: https://dev.mysql.com/doc/heatwave/en/mys-hwgenai-ml-embed-r

Ends span.

Fetch column information using the MySQL result. Fetch the column information using the given MySQL result and the number of fields. The return

Return next row of a query result set. Returns: tuple or None: A row from query result set.

Finalize the options.

Finalize the options.

Creates a new message, initialized with parsed data and returns a :class:`mysqlx.protobuf.Message` object. Args: msg_type

Construct and populate a MyVectorStore instance from raw texts and metadata. Args: texts: List of strings to vectorize a

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

Returns the list of columns. Returns: `list`: The list of columns. .. versionadded:: 8.0.12

Return a list of (column_name, referenced_table_name, referenced_column_name) for all key columns in the given table.

Scans the MySQL script looking for `filenames` (one for each `LOCAL INFILE` statement found). Arguments: script: a MySQL script that

Gets the MySQL version. Returns: The MySQL server version as a tuple. If not previously connected, it will return `No

Return a description of the table with the DB-API cursor.description interface."

Returns a list of tables for this schema. Returns: `list`: List of Table objects.

Returns the view of the given name for this schema. Returns: mysqlx.View: View object.

Import an object from a fully qualified module path. Args: obj (str): A string representing the fully qualified name of the object.

Sends a query which only returns 1 row. Shortcut for: ``` cursor = self.cursor(buffered=True) cursor.execute(query)

Initialize the options.

Initialize the options.

Unpacks the given buffer to an integer

Check whether the type of object is a decimal. Check whether the object passed via parameter is an instance of decimal class. @param obj

Returns `True` if is a number signed. Returns: bool: Returns `True` if is a number signed.

Verify if the session has been disconnect from the server. Returns: bool: `True` if the connection has been closed from the serve

Create new Protobuf message. Args: name (str): Message type name. Returns: object: Protobuf

Converts option strings Converts option strings to lower case and replaces dashes(-) with underscores(_) if keep_dashes variable is s

Parse a MySQL Binary Protocol OK packet.

Parse the statistics packet

Convert a Python decimal.Decimal to MySQL DECIMAL. Convert a Python decimal.Decimal to MySQL DECIMAL. This function also removes the 'L' suffix f

Quote the parameters for commands. General rules: o numbers are returns as bytes using ascii codec o None is returned as

Read authenticate OK. Raises: :class:`mysqlx.InterfaceError`: If message type is `Mysqlx.Error`.

Attempts to reconnect to the MySQL server. The argument `attempts` should be the number of times a reconnect is tried. The `delay` ar

Removes all the connections from the pool.

Resets the number of times this statement has been executed.

Run the command.

Send authenticate start. Args: method (str): Message method. auth_data (Optional[str]): Authentication data.

Send execute statement. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Prot

Serializes a message to a string. Returns: str: A string representing a message containing parsed data.

Toggle autocommit.

Sets login information for MySQL. Sets the username and/or password for the user connecting to the MySQL Server. Args: u

Set the MySQL major version and change the charset mapping if is 5.7. Args: version (tuple): MySQL version tuple.

Set the disconnection message from the server. Args: reason (str): disconnection reason from the server.

Search for and return the most similar documents in the store to the given query. Args: query: String query to embed and

Waits for current connections to be closed or be the expected

Emits a warning if a deprecated cipher is being utilized. Args: cipher: Must be ingested as OpenSSL name. tls_versions: TLS versi

Emits a warning if a deprecated TLS version is being utilized. Args: tls_versions: TLS version to check. Raises: Deprecation