AllDatabases implements sql.DatabaseProvider.

CauseImplicitCommitAfter returns true if the statement cause an implicit commit after executing: https://dev.mysql.com/doc/refman/8.4/en/implicit-comm

CloseTxn implements adapter.ConnectionHolder.

ConnectionClosed reports that a connection has been closed.

CreatePublicationIfNotExists creates a publication with the given name if it does not already exist. Mostly useful for testing. Customers should run t

CreateReplicationSlotIfNotExists creates the replication slot named if it doesn't already exist.

CurrentCatalog retrieves the current catalog of the connection. Returns an empty string if the connection is not established or the catalog cannot be

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

FlushDelta writes the accumulated changes to the database.

GetCatalogConn implements adapter.ConnectionHolder.

GetSqlTableFromContext returns the table from the context. Uses the context's current database if an empty database name is provided. Returns nil if n

GetTableNames implements sql.Database.

GoDuckDBTypeNameToPostgresType parses a type name reported by the go-duckdb driver into a corresponding pgtype.Type with its precision and scale (if a

ERROR 1105 (HY000): unknown error: Catalog Error: SET schema: No catalog + schema named "mysql.db0" found.

IsPureDataQuery inspects if the plan is a pure data query, i.e., it operates on (>=1) data tables and does not touch any system tables. The following

IsReadOnly implements sql.SystemVariable.

IsRunning returns true if this instance is processing binlog events and has not been stopped.

IsUnique returns whether this index is unique

Name implements sql.Database.

NewLogicalReplicator creates a new logical replicator instance which connects to the primary and replication databases using the connection strings pr

NewSessionBuilder returns a session builder for the given database provider.

NormalizeIntsAndFloats normalizes all int and float types to int64 and float64, respectively.

NormalizeVal normalizes values to the Doltgres type expects, so it can be used to convert the values using the given Doltgres type. This is used to no

Persist implements the interface mysql_db.MySQLDbPersistence.

ToDNS Format SubscriptionConfig into a DNS

UnmarshalAndMarshalJsonString is used to normalize expected json type value to compare the actual value. JSON type value is in string format, and sinc

WaitForSqlServerToStart polls the specified database to wait for it to become available, pausing between retry attempts, and returning an error if it

applyRequestModifiers applies request modifiers to a query

base64HeaderBytes returns the GS2 header encoded as bytes.