sql

type AggregateFunction = query.AggregateFunction

type AggregateResultSet = query.AggregateResultSet

type AlterDatabase interface {
	Query
	DatabaseName() string
	RenameTo() *query.Database
}

type AlterTable interface {
	Query
	TableName() string
	AddColumn() (*query.Column, bool)
	AddIndex() (*query.Index, bool)
	DropColumn() (*query.Column, bool)
	RenameColumns() (*query.Column, *query.Column, bool)
	RenameTo() (*query.Table, bool)
}

type Begin interface {
	Query
}

type Commit interface {
	Query
}

type Conn interface {
	tracer.Context
	// RemoteAddr returns the remote address.
	RemoteAddr() net.Addr
	// 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 Copy interface {
	Query
	Columns() query.ColumnList
	TableName() string
}

type CreateDatabase interface {
	Query
	DatabaseName() string
	IfNotExists() bool
}

type CreateTable interface {
	Query
	TableName() string
	Schema() *Schema
	IfNotExists() bool
}

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

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

type Delete interface {
	Query
	TableName() string
	Where() *query.Condition
}

type DropDatabase interface {
	Query
	DatabaseName() string
	IfExists() bool
}

type DropTable interface {
	Query
	Tables() query.TableList
	IfExists() bool
}

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

type Executor interface {
	TCLExecutor
	QueryExecutor
	ErrorHandler
}

type Function = query.Function

type FunctionExecutor = query.FunctionExecutor

type Insert interface {
	Query
	TableName() string
	Columns() query.ColumnList
	IsSelectAll() bool
}

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

type Query interface {
	StatementType() query.StatementType
	String() string
}

type QueryExecutor interface {
	DDOExecutor
	DMOExecutor
}

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

type Rollback interface {
	Query
}

type Schema = query.Schema

type Select interface {
	Query
	IsSelectAll() bool
	Selectors() query.SelectorList
	From() query.TableList
	Limit() *query.Limit
	GroupBy() *query.GroupBy
	OrderBy() *query.OrderBy
	Where() *query.Condition
}

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

type Truncate interface {
	Query
	Tables() query.TableList
}

type Update interface {
	Query
	TableName() string
	Columns() query.ColumnList
	Where() *query.Condition
}

type Use interface {
	Query
	DatabaseName() string
}

type Vacuum interface {
	Query
	TableName() string
}