sql

type Conn interface {
	net.Conn
	// Close closes the connection.
	Close() error
	// SetDatabase sets a database name.
	SetDatabase(db string)
	// Database returns the database name.
	Database() string
	// Timestamp returns the timestamp.
	Timestamp() time.Time
	// UUID returns the UUID.
	UUID() uuid.UUID
	// ID returns the ID.
	ID() ConnID
	// SetSpanContext sets a span context.
	SetSpanContext(ctx tracer.Context)
	// SpanContext returns a span context.
	SpanContext() tracer.Context
}

type ConnID uint64

type ConnOption = func(*conn)

type DDOExecutor interface {
	// CreateDatabase handles a CREATE DATABASE query.
	CreateDatabase(Conn, *query.CreateDatabase) (Responses, error)
	// CreateTable handles a CREATE TABLE query.
	CreateTable(Conn, *query.CreateTable) (Responses, error)
	// AlterDatabase handles a ALTER DATABASE query.
	AlterDatabase(Conn, *query.AlterDatabase) (Responses, error)
	// AlterTable handles a ALTER TABLE query.
	AlterTable(Conn, *query.AlterTable) (Responses, error)
	// DropDatabase handles a DROP DATABASE query.
	DropDatabase(Conn, *query.DropDatabase) (Responses, error)
	// DropIndex handles a DROP INDEX query.
	DropTable(Conn, *query.DropTable) (Responses, error)
}

type DMOExecutor interface {
	// Insert handles a INSERT query.
	Insert(Conn, *query.Insert) (Responses, error)
	// Select handles a SELECT query.
	Select(Conn, *query.Select) (Responses, error)
	// Update handles a UPDATE query.
	Update(Conn, *query.Update) (Responses, error)
	// Delete handles a DELETE query.
	Delete(Conn, *query.Delete) (Responses, error)
}

type ErrorHandler interface {
	ParserError(Conn, string, error) (Responses, error)
}

type Executor interface {
	TCLExecutor
	QueryExecutor
	SystemQueryExecutor
	ErrorHandler
}

type Parser interface {
	// ParseString parses a SQL statement string and returns the query statements.
	ParseString(string) ([]query.Statement, error)
}

type QueryExecutor interface {
	DDOExecutor
	DMOExecutor
}

type Response interface {
	// Bytes returns the message bytes.
	Bytes() ([]byte, error)
}

type Responses []Response

type SystemQueryExecutor interface {
	// SystemSelect handles a SELECT query for system tables.
	SystemSelect(Conn, *query.Select) (Responses, error)
}

type TCLExecutor interface {
	// Begin handles a BEGIN query.
	Begin(*Conn, *query.Begin) (Responses, error)
	// Commit handles a COMMIT query.
	Commit(*Conn, *query.Commit) (Responses, error)
	// Rollback handles a ROLLBACK query.
	Rollback(*Conn, *query.Rollback) (Responses, error)
}