Execute the statement. Raises: NotImplementedError: This method must be implemented.

Instantiates and returns a cursor By default, MySQLCursor is returned. Depending on the options while connecting, a buffered and/or r

Creates a :class:`mysqlx.SqlStatement` object to allow running the SQL statement on the target MySQL Server. Args: sql (s

Fetch all items. Returns: `list`: The list of items of :class:`mysqlx.DbDoc` or :class:`mysqlx.Row`.

Set the values to be inserted. Args: *values: The values of the columns to be inserted. Returns: mysqlx.Inse

Adds a list of documents to a collection. Args: *values: The document list to be added into the collection. Returns:

Close the cursor Returns True when successful, otherwise False.

Retrieves documents from a collection. Args: condition (Optional[str]): The string with the filter expression of

Returns the value of an element of the message dictionary. Args: name (string): Key name. default (object): The defau

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

Drops a collection. Args: name (str): The name of the collection to be dropped.

Creates a Session instance using the provided connection data. Returns: Session: Session object.

Creates in the current schema a new collection with the specified name and retrieves an object representing the new collection created.

Returns a new copy of a :class:`mysqlx.DbDoc` object containing the `doc_id` provided. If `doc_id` is not provided, it will be removed from

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

Returns the table of the given name for this schema. Returns: mysqlx.Table: Table object.

Sets the search condition to filter. Args: condition (str): Sets the search condition to filter records. Returns:

Creates a new :class:`mysqlx.SelectStatement` object. Args: *fields: The fields to be retrieved. Returns: my

Creates a new :class:`mysqlx.InsertStatement` object. Args: *fields: The fields to be inserted. Returns: mys

Counts the rows in the table. Returns: int: The total of rows in the table.

Sets or updates attributes on documents in a collection. Args: doc_path (string): The document path of the item to be set.

Closes the sessions opened by this client.

Returns the number of affected items for the last operation. Returns: int: The number of affected items.

Retrieves a Schema object from the current session by it's name. Args: name (string): The name of the Schema object to be retriev

Get all rows returned by the MySQL server This method gets all rows returned by the MySQL server after sending, for example, the quer

Starts a transaction context on the server.

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

Commits all the operations executed after a call to startTransaction().

Creates a collection index. Args: index_name (str): Index name. fields_desc (dict): A dictionary containing the field

Execute the given operation multiple times The executemany() method will execute the operation iterating over the list of parameters

Creates a new :class:`mysqlx.UpdateStatement` object. Returns: mysqlx.UpdateStatement: UpdateStatement object

Binds value(s) to a specific placeholder(s). Args: *args: The value(s) to bind. Returns: mysqlx.SqlStatement

Commit current transaction

Returns the value of a MySQL X Protobuf enumerator. Args: name (string): MySQL X Protobuf numerator name. Returns: int: Valu

Sets the maximum number of items to be returned. Args: row_count (int): The maximum number of items. Returns:

Execute a read operation with `EXCLUSIVE LOCK`. Only one lock can be active at a time. Args: lock_contention (:class:`

Returns the dictionary representing a message containing parsed data. Returns: dict: The dictionary representing a messag

Sets a document field filter. Args: *fields: The string expressions identifying the fields to be extracted.

Returns the collection of the given name for this schema. Returns: mysqlx.Collection: Collection object.

Verifies if this object exists in the database. Returns: bool: `True` if object exists in database.

Fetch one item. Returns: :class:`mysqlx.Row` or :class:`mysqlx.DbDoc`: one result item.

Execute a read operation with `SHARED LOCK`. Only one lock can be active at a time. Args: lock_contention (:class:`mys

Remove the topdir of the MySQL server

Sets the sorting criteria. Args: *clauses: The expression strings defining the sort criteria. Returns: mysql

Takes a :class:`mysqlx.DbDoc`, string JSON format or a dict with the changes and applies it on all matching documents. Args:

Read packets from the MySQL server.

Drops a collection index. Args: index_name (str): Index name.

Return the next set of rows of a query result set. When no more rows are available, it returns an empty list. The number of rows retu

Returns the generated ids.

Sets the character set and collation for the current connection. This method sets the character set and collation to be used for the

Returns the value using the column name. Args: str_index (str): The column name. .. deprecated:: 8.0.12

Calls a stored procedure with the given arguments The arguments will be set during this session, meaning they will be called like _<

Get packet from the MySQL server comm channel.

Context manager that wraps a MySQL database cursor and ensures transaction rollback in case of exception. NOTE: DDL statements such as C

Generates the result sets stream caused by the last `execute*()`. Returns: A 2-tuple; the first element is the statement that cau

Get MySQL server configuration for running MySQL server If no name is given, then we will return the configuration of the first added.

Creates a new :class:`mysqlx.DeleteStatement` object. Returns: mysqlx.DeleteStatement: DeleteStatement object .. version

Discards all the operations executed after a call to startTransaction().

Creates a transaction savepoint. If a name is not provided, one will be generated using the uuid.uuid1() function. Args:

Make the client's authorization response. Args: auth_data: Authorization data. kwargs: Custom configuration to be pas

Adds a query attribute and its value into the connector's query attributes list. Query attributes must be enabled on the server - they are di

Execute an SQL query with optional parameters using the given cursor. Args: cursor: MySQLCursorAbstract object to execute the query.

Validate that the string is a legal SQL identifier (letters, digits, underscores). Args: name: Name (schema, table, or column) to va

Returns the keys. Returns: `list`: The keys.

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

Get the default client options set Returns a flag with all the default client options set

Stop the MySQL server Stop the MySQL server and returns whether it was successful or not. This method stops the process and exits wh

Send packets to the MySQL server.

Configuration is done through the pool. For pooled connections, the `config()` method raises a `PoolError` exception. Configuration f

Fit a model using DataFrame inputs. If an 'id' column is defined in either dataframe, it will be used as the primary key. R

Returns the name of this database object. Returns: str: The name of this database object.

Check whether there is an unread result

Frees the result

Receive data from the socket. Args: count (int): Buffer size. Returns: bytes: The data received.

Test with cached valid TGT.

Test with cached valid TGT.

Send `payload` to the MySQL server. NOTE: if `payload` is an instance of `bytearray`, then `payload` might be changed by this method