mysql

type AcceptedValuesCheck struct {
	// contains filtered or unexported fields
}

type BasicOperator struct {
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

type Config struct {
	Username    string
	Password    string
	Host        string
	Port        int
	Database    string
	Driver      string
	SslCaPath   string
	SslCertPath string
	SslKeyPath  string
	ReadOnly    bool
}

type DB interface {
	Querier
	Selector
}

type MySQLClient interface {
	RunQueryWithoutResult(ctx context.Context, query *query.Query) error
	Select(ctx context.Context, query *query.Query) ([][]interface{}, error)
	SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)
	BuildTableExistsQuery(tableName string) (string, error)
	Ping(ctx context.Context) error
	GetDatabaseSummary(ctx context.Context) (*ansisql.DBDatabase, error)
	CreateSchemaIfNotExist(ctx context.Context, asset *pipeline.Asset) error
}

type MySQLConfig interface {
	GetIngestrURI() string
	ToDBConnectionURI() string
}

type PatternCheck struct {
	// contains filtered or unexported fields
}

type Querier interface {
	RunQueryWithoutResult(ctx context.Context, query *query.Query) error
}

type Selector interface {
	Select(ctx context.Context, query *query.Query) ([][]interface{}, error)
	SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)
}