CauseImplicitCommitBefore returns true if the statement implicitly commits the current transaction: https://dev.mysql.com/doc/refman/8.4/en/implicit-c

ComBind is called when a connection receives a request to bind a prepared statement to a set of values.

ComExecuteBound is called when a connection receives a request to execute a prepared statement that has already bound to a set of values.

ComPrepareParsed is called when a connection receives a prepared statement query that has already been parsed.

Replace the operator 'ANY' with a function call.

Replaces all matching function names in the query with "__sys__.<funcName>". e.g. SELECT pg_catalog.abc(123, 'test') AS result1, defg('hello', world

Wraps all table macro calls in "(FROM ...)". e.g. If the function names in the list of InternalMacros are "information_schema._pg_expandarray"(Table M

DiscardDeltaBuffer discards the accumulated changes.

DropPublication drops the publication with the given name if it exists. Mostly useful for testing.

DropReplicationSlotIfExists drops the replication slot with the given name. Any error from the slot not existing is ignored.

ErrorChan returns the error channel through which this event producer sends any errors.

EventChan returns the event channel through which this event producer sends binlog events.

ExecuteRestore downloads the specified file from the remote storage and restores it to the specified local directory. Note that this should only be ca

Expressions returns the indexed expressions. If the result is more than one expression, it means the index has multiple columns indexed. If it's just

Finish finalizes the current load operation and commits the inserted rows so that the data becomes visibile to clients. Implementations should check t

CheckConstraints implements sql.CheckTable.

GetDefault implements sql.SystemVariable.

GetIndexes implements sql.IndexAddressableTable. This is only used for show index in SHOW INDEX and SHOW CREATE TABLE.

Find the test statements under ScriptTest by name.

GetSqlDatabaseFromContext returns the database from the context. Uses the context's current database if an empty string is provided. Returns nil if th

GetTableWriter returns a TableWriter for writing to the specified |table| in the specified |database|.

GetTxn implements adapter.ConnectionHolder.

GetType implements sql.SystemVariable.

Go starts this binlogEventProducer in a new goroutine. Right before this routine exits, it will close the two communication channels it owns.

HandleConnection handles a connection's session, reading messages, executing queries, and sending responses. Expected to run in a goroutine per connec

Init initializes or appends to SystemVariables as it functions as a global variable. Currently, we append all of postgres configuration parameters to

InitValue implements sql.SystemVariable.

ERROR 1105 (HY000): duckdb: Catalog Error: Index with name "x_idx" already exists!

Constraint Error: NOT NULL constraint failed: <column>

ERROR 1105 (HY000): duckdb: Constraint Error: Data contains duplicates on indexed column(s)

IsFullText returns whether this index is a Full-Text index

IsSpatial returns whether this index is a spatial index

LoadChunk reads the records from |data| and inserts them into the previously configured table. Data records are not guaranteed to stard and end cleanl

MessageBare returns the message without the GS2 header.

MessageWithoutProof returns the client-final-message-without-proof.

NewConnectionHandler returns a new ConnectionHandler for the connection provided

NewContext implements the Handler interface.

copy from go-mysql-server/enginetest/initialization.go NewEngine creates an engine and sets it up for testing using harness, provider, and setup data

NormalizeArrayType normalizes array types by normalizing its elements first, then to a string using the type IoOutput method.

NormalizeExpectedRow normalizes each value's type, as the tests only want to compare values. Returns a new row.

NormalizeRow normalizes each value's type, as the tests only want to compare values. Returns a new row.

NormalizeRows normalizes each value's type within each row, as the tests only want to compare values. Returns a new set of rows in the same order.

NormalizeValToString normalizes values into types that can be compared. JSON types, any pg types and time and decimal type values are converted into s

ParseCopyFrom parses a COPY FROM statement and returns the query, format, and options.

ParseCopyOptions parses the options string and returns the CopyOptions. The options string is a comma-separated list of key-value pairs: `OPT1 1, OPT2

ParseCopyTo parses a COPY TO statement and returns the query, format, and options.

PrimaryKeySchema implements sql.PrimaryKeyTable.

Provider returns the database provider for the session.

ReadRows reads all of the given rows into a slice, then closes the rows. If `normalizeRows` is true, then the rows will be normalized such that all in

registerReplicaController registers the replica controller into the engine to handle the replication commands, such as START REPLICA, STOP REPLICA, et