query

Documentation

Overview

Copyright (C) 2019 Satoshi Konno. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• Variables
• func NewDataRowForSelectors(schema *query.Schema, rowDesc *message.RowDescription, ...) (*message.DataRow, error)
• func NewDataRowsForAggregateFunction(schema *query.Schema, rowDesc *message.RowDescription, ...) ([]*message.DataRow, error)
• func NewErrColumnNotExist(v any) error
• func NewErrColumnValueNotExist(v any) error
• func NewErrColumnsNotEqual(v1, v2 int) error
• func NewErrDatabaseExist(v string) error
• func NewErrDatabaseNotExist(v string) error
• func NewErrExist(v any) error
• func NewErrGroupByColumnValueNotExist(v any) error
• func NewErrNotEqual(v1, v2 any) error
• func NewErrNotExist(v any) error
• func NewErrNotImplemented(msg string) error
• func NewErrNotSupported(msg string) error
• func NewErrPreparedQueryNotExist(name string) error
• func NewErrTableExist(v string) error
• func NewErrTableNotExist(v string) error
• func NewRowFieldFrom(schema *query.Schema, selector query.Selector, idx int) (*message.RowField, error)
• type AggregateFunction
• type AggregateResultSet
• type AndExpr
• type BindParam
• type CmpExpr
• type Column
• type ColumnList
• type Condition
• type Copy
• type CreateDatabase
• type CreateIndex
• type CreateTable
• type DataType
  • func NewDataTypeFrom(t query.DataType) (*DataType, error)
• type Delete
• type DropDatabase
• type DropTable
• type Expr
• type Function
• type FunctionExecutor
• type Insert
  • func NewInsertWith(tbl *Table, columns ColumnList) *Insert
• type OID
• type OrExpr
• type Parser
  • func NewParser() *Parser
  • func (parser *Parser) ParseString(query string) ([]*Statement, error)
• type Row
• type Schema
• type Select
• type Statement
  • func NewStatement(stmt query.Statement) *Statement
  • func (stmt *Statement) Bind(params message.BindParams) error
• type Table
• type Update

Constants

const (
	// Aliases for types defined in github.com/cybergarage/go-postgresql/postgresql/query.
	EQ  = query.EQ
	NEQ = query.NEQ
	LT  = query.LT
	LE  = query.LE
	GT  = query.GT
	GE  = query.GE
	IN  = query.IN
	NIN = query.NIN
)

Variables

var ErrExist = errors.New("exist")

ErrExist is returned when the specified object is exist.

var ErrNotEqual = errors.New("not equal")

ErrNotEqual is returned when the specified object is not equal.

var ErrNotExist = errors.New("not exist")

ErrNotExist is returned when the specified object is not exist.

var ErrNotImplemented = errors.New("not implemented")

ErrNotImplemented is returned when the operation is not implemented.

var ErrNotSupported = errors.New("not supported")

ErrNotSupported is returned when the operation is not supported.

Functions

func NewDataRowForSelectors

func NewDataRowForSelectors(schema *query.Schema, rowDesc *message.RowDescription, selectors query.SelectorList, row Row) (*message.DataRow, error)

NewDataRowForSelectors returns a new DataRow from the specified row.

func NewDataRowsForAggregateFunction

func NewDataRowsForAggregateFunction(schema *query.Schema, rowDesc *message.RowDescription, selectors query.SelectorList, rows []Row, groupBy string) ([]*message.DataRow, error)

NewDataRowsForAggregateFunction returns a new DataRow list from the specified rows.

func NewErrColumnNotExist

func NewErrColumnNotExist(v any) error

NewErrColumnNotExist returns a new column not exist error.

func NewErrColumnValueNotExist

func NewErrColumnValueNotExist(v any) error

NewErrColumnValueNotExist returns a new column value not exist error.

func NewErrColumnsNotEqual

func NewErrColumnsNotEqual(v1, v2 int) error

NewErrColumnsNotEqual returns a new columns not equal error.

func NewErrDatabaseExist

func NewErrDatabaseExist(v string) error

NewErrDatabaseExist returns a new database exist error.

func NewErrDatabaseNotExist

func NewErrDatabaseNotExist(v string) error

NewErrDatabaseNotExist returns a new database not exist error.

func NewErrExist

func NewErrExist(v any) error

NewErrExist returns a new exist error.

func NewErrGroupByColumnValueNotExist

func NewErrGroupByColumnValueNotExist(v any) error

NewErrGroupByColumnValueNotExist returns a new group by column not exist error.

func NewErrNotEqual

func NewErrNotEqual(v1, v2 any) error

NewErrNotEqual returns a new not equal error.

func NewErrNotExist

func NewErrNotExist(v any) error

NewErrNotExist returns a new not exist error.

func NewErrNotImplemented

func NewErrNotImplemented(msg string) error

NewErrNotImplemented returns a new ErrNotImplemented error.

func NewErrNotSupported

func NewErrNotSupported(msg string) error

NewErrNotSupported returns a new ErrNotSupported error.

func NewErrPreparedQueryNotExist

func NewErrPreparedQueryNotExist(name string) error

NewErrPreparedQueryNotExist returns a new prepared query not exist error.

func NewErrTableExist

func NewErrTableExist(v string) error

NewErrTableExist returns a new table exist error.

func NewErrTableNotExist

func NewErrTableNotExist(v string) error

NewErrTableNotExist returns a new table not exist error.

func NewRowFieldFrom

func NewRowFieldFrom(schema *query.Schema, selector query.Selector, idx int) (*message.RowField, error)

NewRowFieldFrom returns a new RowField from the specified selector.

Types

type AggregateFunction

type AggregateFunction = query.AggregateFunction

AggregateFunction represents an aggregate function.

type AggregateResultSet

type AggregateResultSet = query.AggregateResultSet

AggregateResultSet represents an aggregate result set.

type AndExpr

type AndExpr = query.AndExpr

type BindParam

type BindParam = query.BindParam

Aliases for types defined in github.com/cybergarage/go-postgresql/postgresql/query.

type CmpExpr

type CmpExpr = query.CmpExpr

type Column

type Column = query.Column

type ColumnList

type ColumnList = query.ColumnList

type Condition

type Condition = query.Condition

type Copy

type Copy = query.Copy

type CreateDatabase

type CreateDatabase = query.CreateDatabase

type CreateIndex

type CreateIndex = query.CreateIndex

type CreateTable

type CreateTable = query.CreateTable

type DataType

type DataType = system.DataType

DataType represents a data type.

func NewDataTypeFrom

func NewDataTypeFrom(t query.DataType) (*DataType, error)

NewDataTypeFrom returns a data type from the specified query data type.

type Delete

type Delete = query.Delete

type DropDatabase

type DropDatabase = query.DropDatabase

type DropTable

type DropTable = query.DropTable

type Expr

type Expr = query.Expr

type Function

type Function = query.Function

Function represents a function.

type FunctionExecutor

type FunctionExecutor = query.FunctionExecutor

FunctionExecutor represents a function executor.

type Insert

type Insert = query.Insert

func NewInsertWith

func NewInsertWith(tbl *Table, columns ColumnList) *Insert

NewInsertWith returns a new insert statement instance with the specified parameters.

type OID

type OID = system.OID

OID represents a object identifier.

type OrExpr

type OrExpr = query.OrExpr

type Parser

type Parser struct {
	sql.Parser
}

Parse returns a SQL parser.

func NewParser

func NewParser() *Parser

NewParser returns a new parser.

func (*Parser) ParseString

func (parser *Parser) ParseString(query string) ([]*Statement, error)

ParseString parses the specified query string and returns statements.

type Row

type Row = map[string]any

Row represents a row of a result set.

type Schema

type Schema = query.Schema

type Select

type Select = query.Select

type Statement

type Statement struct {
	query.Statement
}

Statement represents a statement instance.

func NewStatement

func NewStatement(stmt query.Statement) *Statement

NewStatement returns a new statement.

func (*Statement) Bind

func (stmt *Statement) Bind(params message.BindParams) error

Bind binds the statement with the specified parameters.

type Table

type Table = query.Table

type Update

type Update = query.Update