sqlbackend

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

type IExtendedQueryBackend interface {
	// HandleParse prepares a SQL statement for later execution.
	// paramOIDs may contain zeros for unspecified parameter types.
	HandleParse(ctx context.Context, stmtName string, query string, paramOIDs []uint32) ([]uint32, error)

	// HandleBind binds parameter values to a prepared statement, creating a portal.
	HandleBind(ctx context.Context, portalName string, stmtName string, paramFormats []int16, paramValues [][]byte, resultFormats []int16) error

	// HandleDescribeStatement returns parameter type OIDs and result column metadata
	// for a prepared statement.
	HandleDescribeStatement(ctx context.Context, stmtName string, query string, paramOIDs []uint32) ([]uint32, []sqldata.ISQLColumn, error)

	// HandleDescribePortal returns result column metadata for a bound portal.
	HandleDescribePortal(ctx context.Context, portalName string, stmtName string, query string, paramOIDs []uint32) ([]sqldata.ISQLColumn, error)

	// HandleExecute executes a bound portal and returns a result stream.
	// maxRows of 0 means unlimited.
	HandleExecute(ctx context.Context, portalName string, stmtName string, query string, paramFormats []int16, paramValues [][]byte, resultFormats []int16, maxRows int32) (sqldata.ISQLResultStream, error)

	// HandleCloseStatement closes a prepared statement.
	HandleCloseStatement(ctx context.Context, stmtName string) error

	// HandleClosePortal closes a portal.
	HandleClosePortal(ctx context.Context, portalName string) error
}

type ISQLBackend interface {
	HandleSimpleQuery(context.Context, string) (sqldata.ISQLResultStream, error)
	SplitCompoundQuery(string) ([]string, error)
	GetDebugStr() string
}

type QueryCallback func(context.Context, string) (sqldata.ISQLResultStream, error)

type SQLBackendFactory interface {
	NewSQLBackend() (ISQLBackend, error)
}

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