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

IsValidPostgresConfigParameter returns true if the given parameter name is a valid postgres configuration parameter.

Start prepares the DataLoader for loading data. This may involve creating goroutines, opening files, etc. Start must be called before any calls to Loa

Execute SQL statement

queryReplicaStatus returns the results of `SHOW REPLICA STATUS` as a map, for the replica database. If any errors are encountered, this function will

setIoError updates the current replication status with the specific |errno| and |message| to describe an IO error.

updateStatus allows the caller to safely update the replica controller's status. The controller locks it's mutex before the specified function |f| is

Go spawns a new goroutine to run the applier's binlog event handler.

ReplicationDns returns the DNS for the primary database with the replication query parameter appended. Not suitable for normal query RPCs.

func NewReadOnlyDuckHarness() *DuckHarness { h := NewDefaultDuckHarness() h.readonly = true return h }

StartReplication starts the replication process for the given slot name. This function blocks until replication is stopped via the Stop method, or an

Stop requests for this binlogEventProducer to stop processing events as soon as possible.

--------------------- Test Helper Functions ---------------------

commitOngoingTxn commits the current transaction

convertQuery takes the given Postgres query, and converts it as a list of ast.ConvertedStatement that will work with the handler.

endOfMessages should be called from HandleConnection or a function within HandleConnection. This represents the end of the message slice, which may oc

Helper functions

Helper function to build the Arrow record and register the view

Collation implements sql.Table.

ComQuery is called when a connection receives a query. Note the contents of the query slice may change after the first call to callback. So the Doltgr

CurrentSchema retrieves the current schema of the connection. Returns an empty string if the connection is not established or the schema cannot be ret

EncodeIndexName uses a simple encoding scheme (table$$index) for better visibility which is useful for debugging.

Flush writes the accumulated changes to the database.

GetDeltaAppender returns a DeltaAppender for appending updates to the specified |table| in the specified |database|.

GetSessionScope implements sql.SystemVariable.

IsRunning returns true if this binlog applier is running and has not been stopped, otherwise returns false.

NewConnection reports that a new connection has been established.

NormalizeStrings normalizes a query string to convert any MySQL syntax to Postgres syntax

Numeric creates a numeric value from a string.

PrimaryDns returns the DNS for the primary database. Not suitable for RPCs used in replication e.g. StartReplication. See ReplicationDns.

assertWarning asserts that the specified |database| has a warning with |code| and |message|, otherwise it will fail the current test.

clientSpecFromQueryComment returns "replica" if the query is meant to be run on the replica, and "primary" if it's meant to be run on the primary, bas

encodeJsonObject encodes the specified |jsonValue| into MySQL's internal JSON encoding and returns the type ID indicating what type of value this is,

This function will return a regex that matches all function names in the list of InternalMacros. And the Macro must be a table macro. e.g. * A scalar

Helper function to get the primary key. For composite primary keys, `row()` is used.

This function will return a regex that matches all function names in the list of InternalMacros. And they will have optional "pg_catalog." prefix. How

startSqlServers starts a MySQL server and a Dolt sql-server for use in tests.