Adapted from enginetests to skip known issues and pending fixes

RunReplicationScript runs the given ReplicationTest.

RunScripts runs the given collection of scripts.

Running returns whether replication is currently running

Save persists the specified |position| to disk. The |position| represents the set of GTIDs that have been successfully executed and applied on this re

SessionManager returns the session manager that the listener is using.

SetEngine sets the SQL engine this replica will use when running replicated statements and when loading the Catalog to find the "mysql" database.

SetExecutionContext sets the unique |ctx| for the replica's applier to use when applying changes from binlog events to a database. The applier cannot

SetTableWriterProvider sets the table writer provider for the replica's applier to use when writing replicated changes to the database.

SetValue implements sql.SystemVariable.

This function will replace all type casts in the query with the corresponding type cast in the simpleStringsConversion map.

StartPostgresServer configures a starts a fresh Postgres server instance in a Docker container and returns the port it is running on. If unable to sta

StartReplica implements the BinlogReplicaController interface.

ToArrowType translates the MySQL Type to Arrow Type.

ToConnectionInfo Format SubscriptionConfig into a ConnectionInfo

Truncate implements sql.TruncateableTable.

TzOffsetToDuration takes in a timezone offset (e.g. "+01:00") and returns it as a time.Duration. If any problems are encountered, an error is returned

ValidateCopyFrom returns an error if the CopyFrom node is invalid.

ValidateCopyTo returns an error if the CopyTo node is invalid, for example if it contains columns that are not in the table schema.

VitessTypeToObjectID returns a type, as defined by Vitess, into a type as defined by Postgres. OIDs can be obtained with the following query: `SELECT

appendStringLength appends a variable number of bytes to the specified |bytes| to encode |length|, the length of a string. For string lengths, if the

attachCatalogs attaches all the databases in the data directory

beginReplication starts a new replication connection to the primary server and returns it. The LSN provided is the last one we have confirmed that we

Since the data is sent to the server in the form of a byte stream, we use a Unix pipe to stream the data to DuckDB.

Helper function to build column list with timestamp handling

buildLoadData translates a MySQL LOAD DATA statement into a DuckDB INSERT INTO statement and executes it.

buildSQL builds the DuckDB INSERT statement.

buildSQL builds the DuckDB COPY FROM statement.

In the non-local case, we can directly use the file path to read the data.

calculateInitialArrayValuesOffset returns the initial offset value for the first array value in the encoded array byte slice. When |largeEncoding| is

calculateInitialObjectKeysOffset returns the initial offset value for the first key in the encoded object byte slice. When |largeEncoding| is false, t

chooseInitialDatabase attempts to choose the initial database for the connection, if one is specified in the startup message provided

configureFastConnectionRetry configures the replica to retry a failed connection after 5s, instead of the default 60s connection retry interval. This

configureReplicationUser creates or configures the super user account needed to apply replication changes and execute DDL statements on the running se

connectAndStartReplicationEventStream connects to the configured MySQL replication source, including pausing and retrying if errors are encountered.

containsVariable inspects if the plan contains a system or user variable.

convertBindParameters handles the conversion from bind parameters to variable values.

convertSliceScanResultToStrings returns a new slice, formed by converting each value in the slice |ss| into a string. This is necessary because SliceS

convertSqlTypesValues converts a sqltypes.Value instance (from vitess) into a sql.Type value (for go-mysql-server).

Generic util functions... convertToHexString returns a lower-case hex string representation of the specified uint16 value |v|.

Create database connection

createEmptyFile creates an empty file at |fullFilepath| if a file does not exist already. If a file does exist at that path, no action is taken.

createReplicaDir creates the .replica directory if it doesn't already exist.

Helper method to create a replication slot

decodeArrayToArrow decodes Postgres array data and appends directly to Arrow builder