String implements sql.Table.

convertMapScanResultToStrings converts each value in the specified map |m| into a string. This is necessary because MapScan doesn't honor (or know abo

Send sends the given message over the connection.

Load loads a mysql.Position instance from the database. The returned mysql.Position represents the set of GTIDs that have been successfully executed a

Name implements sql.Table.

Test Helper Functions waitForReplicaToCatchUp waits (up to 30s) for the replica to catch up with the primary database. The lag is measured by checki

Next retrieves the next row. It will return io.EOF if it's the last row.

NewContext creates a new sql.Context instance for the connection |c|. The optional |query| can be specified to populate the sql.Context's query field.

startReplicationAndCreateTestDb starts up replication on the replica, connecting to |port| on the primary, creates the test database, db01, on the pri

ID returns the identifier of the index.

startSqlServersWithSystemVars starts a MySQL server and a my-sql-server for use in tests. Before the my-sql-server is started, the specified |persiste

Next retrieves the next row. It will return io.EOF if it's the last row.

RemoveComments removes comments from a query string. It supports line comments (--), block comments (/* ... */), and quoted strings. Author: Claude So

run runs the given statement and sends a CommandComplete message to the client

Database returns the database name this index belongs to.

Schema implements sql.Table.

showReplicaStatus returns a map with the results of SHOW REPLICA STATUS, keyed by the name of each column.

Conn returns the underlying net.Conn for this connection.

see querySignature for the detail

QueryCatalog is a helper function to query the catalog, such as information_schema. Unlike QueryContext, this function does not require a schema name

Encode returns the struct as an AuthenticationSASLContinue message.

appendForEncoding appends the |value| to the specified |bytes| and returns the updated byte slice. If |largeEncoding| is true, then 4 bytes are added

requireReplicaResults runs the specified |query| on the replica database and asserts that the results match |expectedResults|. Note that the actual re

ExecCatalog is a helper function to execute a catalog modification query, such as creating a database. Unlike ExecContext, this function does not requ

Rollback implements sql.TransactionSession.

StopDuckSqlServer stops the running Dolt sql-server. If any errors are encountered while stopping the Dolt sql-server, this function will fail the cur

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

Addr returns the address that the listener is listening on.

GetValue implements sql.SystemVariableScope.

StartDuckSqlServer starts a sql-server on a free port from the specified directory |dir|. If |peristentSystemVars| is populated, then those system var

Stop stops the replication process and blocks until clean shutdown occurs.

querySignature returns a normalized signature of the query Examples: - "SELECT 1 % true" -> "select_1_%_true" - "select_1_%_true" -> "select_1_%_true"

GetTableInsensitive implements sql.Database.

Table returns the table name this index belongs to.

loadReplicationConfiguration loads the replication configuration for default channel ("") from the "mysql" database, |mysqlDb|.