connectionForQuery returns the connection to use for the given query

convertFilterMapToStringSlice converts the specified |filterMap| into a string slice, by iterating over every key in the top level map, which stores a

DiscardToSync discards all messages in the buffer until a Sync has been reached. If a Sync was never sent, then this may cause the connection to lock

encodeJsonArray encodes the specified |jsonArray| into MySQL's internal JSON encoding and returns the type ID indicating whether this is a small or la

encodeJsonDoc encodes the specified |jsonDoc| into MySQL's custom/internal binary encoding so that it can be included in a binlog event. The internal

encodeJsonObject encodes the specified |jsonObject| into MySQL's internal JSON encoding and returns the type ID indicating whether this is a small or

executeQueryWithEngine executes a query against the engine and returns an error if the query failed.

extractViewDefinitions is a helper function to extract view definitions from DuckDB

fileExists returns true if the specified |filepath| exists on disk and is not a directory, otherwise returns false. |filepath| is a fully specified pa

findFreePort returns an available port that can be used for a server. If any errors are encountered, this function will panic and fail the current tes

flushDeltaBuffer flushes the accumulated changes in the delta buffer

get the regex to match the operator 'ANY'

get the regex to match any table in pg_catalog in the query.

This function will return a regex that matches all type casts in the query.

handleCopyFromStdinQuery handles the COPY FROM STDIN query at the Doltgres layer, without passing it to the engine. COPY FROM STDIN can't be handled d

handlePseudoQuery handles special pseudo-queries that are used to orchestrate replication tests and returns whether one was handled.

handleStatementOutsideEngine handles any queries that should be handled by the handler directly, rather than being passed to the engine. The response

loadReplicaServerId loads the @@GLOBAL.server_id system variable needed to register the replica with the source, and returns an error specific to repl

Materialize the condensed delta view as a temporary table.

mayExtendBatchTxn checks if we should extend the current batch transaction

maybeReleaseAllLocks makes a best effort attempt to release all locks on the given connection. If the attempt fails, an error is logged but not return

newFilterConfiguration creates a new filterConfiguration instance and initializes members.

parseRow parses the binary row data from a MySQL binlog event and converts it into a go-mysql-server Row using the |schema| information provided. |col

persistReplicaRunningState records the running |state| of a replica to disk by creating a "replica-running" empty file in the .replica directory. An e

persistReplicationConfiguration saves the specified |replicaSourceInfo| to the "mysql" database |mysqlDb|. If any problems are encountered while savin

printFile opens the specified filepath |path| and outputs the contents of that file to stdout.

queryPGSetting will query the system variable value from the system variable map

readAllRowsIntoSlices reads all data from |rows| and returns a slice of slices, with all values converted to strings.

Helper method to check if a replication slot exists

returnsRow returns whether the query returns set of rows such as SELECT and FETCH statements.

the schema is 4 bytes length + data

setAutoIncrementValue is a helper function to update the sequence value

setPgSessionVar will set the session variable to the value provided for pg. And reply with the CommandComplete and ParameterStatus messages.

spoolRowsCallback returns a callback function that will send RowDescription message, then a DataRow message for each row in the result set.

Accept handles incoming connections.

AutoStart starts up replication if replication was running before the server was shutdown. If replication is not configured, hasn't been started, or h

Base64Header returns the base64-encoded GS2 header and channel binding data.

CaughtUp returns true if the replication slot is caught up to the primary, and false otherwise. This only works if there is only a single replication