mysql

type Adapter struct {
	MySQLClient Client
}

type Client interface {
	GetPage(ctx context.Context, request *Request) (*Response, *framework.Error)
}

type Config struct {
	*config.CommonConfig

	// MySQL database to connect to.
	Database string `json:"database,omitempty"`

	Filters map[string]condexpr.Condition `json:"filters,omitempty"`
}

type Datasource struct {
	Client SQLClient
}

type MockSQLClient struct {
	DB   *sql.DB
	Mock sqlmock.Sqlmock
}

type Request struct {
	// BaseURL is the Base URL of the datasource to query.
	BaseURL string `json:"baseURL"`

	// Username is the user name used to authenticate with the MySQL instance.
	Username string `json:"username"`

	// Password is the password used to authenticate with the MySQL instance.
	Password string `json:"password"`

	// PageSize is the maximum number of objects to return from the entity.
	PageSize int64 `json:"pageSize,omitempty"`

	// EntityConfig contains the entity configuration for the current request.
	EntityConfig framework.EntityConfig

	// A filter to apply to the MySQL request when pulling data for the current entity.
	Filter *condexpr.Condition

	// Cursor identifies the first object of the page to return, as returned by
	// the last request for the entity.
	// nil in the request for the first page.
	Cursor *int64 `json:"cursor,omitempty"`

	// MySQL database to connect to.
	Database string `json:"database"`

	// UniqueAttributeExternalID is used to specify the unique ID that should be used when ordering results from
	// the specified table.
	UniqueAttributeExternalID string `json:"uniqueAttributeExternalID"`
}

type Response struct {
	// StatusCode is an HTTP status code.
	StatusCode int `json:"statusCode"`

	// RetryAfterHeader is the Retry-After response HTTP header, if set.
	RetryAfterHeader string `json:"retryAfterHeader"`

	// Objects is the list of objects returned from the datasource.
	// May be empty.
	Objects []map[string]any `json:"objects"`

	// NextCursor is the cursor that identifies the first object of the next page.
	// nil if this is the last page in this full sync.
	NextCursor *int64 `json:"nextCursor,omitempty"`
}

type SQLClient interface {
	IsProxied() bool
	Proxy(ctx context.Context, req *grpc_proxy_v1.ProxyRequestMessage) (*grpc_proxy_v1.Response, error)
	Connect(dataSourceName string) error
	Query(query string, args ...any) (*sql.Rows, error)
}

type SQLColumnTypes map[string]string

type SQLRow map[string]string

type SQLRows []SQLRow