This file handles SQL statements for managing PostgreSQL subscriptions. It supports: 1. Creating a subscription: CREATE SUBSCRIPTION mysub CONNECTION

TODO(ysg): Refactor this implementation by using interface{} to represent a DuckDB type, and implement the interface{} type for each corresponding MyS

This file implements the logic for handling BACKUP SQL statements. Syntax: BACKUP DATABASE my_database TO '<uri>' ENDPOINT = '<endpoint>' ACCESS_KEY_

References: - S3 client: https://docs.aws.amazon.com/code-library/latest/ug/go_2_s3_code_examples.html - Transfer Manager: https://aws.github.i

ConnectionDetails holds parsed connection string components.

ConnectionHandler is responsible for the entire lifecycle of a user connection: receiving messages they send, executing queries, sending the correct m

ConvertedStatement represents a statement that has been converted from the Postgres representation to the Vitess representation. String may contain th

DataLoader allows callers to insert rows from multiple chunks into a table. Rows encoded in each chunk will not necessarily end cleanly on a chunk bou

DriverRowIter wraps a standard driver.Rows as a RowIter.

DuckHandler is a handler uses DuckDB and the SQLe engine directly running Postgres specific queries.

ErrorResponseSeverity represents the severity of an ErrorResponse message.

Listener listens for connections to process PostgreSQL requests into Dolt requests.

LoadDataResults contains the results of a load data operation, including the number of rows loaded.

Mockup database server

MySQLPersister is an example struct which handles the persistence of the data in the "mysql" database.

NoopPlaintextPlugin is used to authenticate plaintext user plugins

ParameterContext sets level of difficulty of changing the parameter settings. For more detailed description on how to change the settings of specific

ParameterSource sets the source of the current parameter value.

PgsqlScope represents the scope of a PostgreSQL configuration parameter.

PgsqlScopeType represents the scope of a configuration parameter.

QueryExecutor is a function that executes a query and returns the result as a schema and iterator. Either of |parsed| or |analyzed| can be nil dependi

ReadyForQueryTransactionIndicator indicates the state of the transaction related to the query.

ReplicaOptions holds the options for a replica server. https://dev.mysql.com/doc/refman/8.4/en/replication-options-replica.html

RequestModifier is a function type that transforms a query string

This file implements the logic for handling RESTORE SQL statements. Syntax: RESTORE DATABASE my_database FROM '<uri>' ENDPOINT = '<endpoint>' ACCESS_

Result represents a query result.

ResultModifier transforms a Result.

Row represents a single row value in bytes format. |val| represents array of a single row elements, which each element value is in byte array format.

SASLBindingFlag are the flags for gs2-cbind-flag, used in SASL authentication.