query

Documentation

Overview

Copyright (C) 2019 The go-postgresql Authors. 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
• func NewDataRowForSelectors(schema resultset.Schema, rowDesc *protocol.RowDescription, ...) (*protocol.DataRow, error)
• func NewDataRowsForAggregator(schema resultset.Schema, rowDesc *protocol.RowDescription, ...) ([]*protocol.DataRow, error)
• func NewResponseFromResultSet(rs resultset.ResultSet) (protocol.Responses, error)
• func NewRowFieldFrom(schema sql.ResultSetSchema, selector query.Selector, idx int) (*protocol.RowField, error)
• type AlterDatabase
• type AlterTable
• type AndExpr
• type Begin
• type BindParam
• type CmpExpr
• type Column
• type ColumnList
• type Commit
• type Condition
• type Copy
• type CreateDatabase
• type CreateIndex
• type CreateTable
• type DataType
  • func NewDataTypeFrom(t query.DataType) (*DataType, error)
• type Delete
• type DropDatabase
• type DropIndex
• type DropTable
• type Expr
• type Function
• type Insert
• type ObjectID
  • func NewObjectIDFrom(t query.DataType) (ObjectID, error)
• type OrExpr
• type Parser
  • func NewParser() *Parser
  • func (parser *Parser) ParseString(query string) ([]*Statement, error)
• type Rollback
• type Row
• type SQLExecutor
• type Schema
• type Select
• type SelectOption
• type Selector
• type SelectorList
• type Statement
  • func NewStatementWith(stmt query.Statement) *Statement
  • func (stmt *Statement) Bind(bindParams protocol.BindParams) error
  • func (stmt *Statement) Object() query.Statement
• type Table
• type TableList
• type Truncate
• type Update
• type Use
• type Vacuum

Constants

const (
	EQ  = query.EQ
	NEQ = query.NEQ
	LT  = query.LT
	LE  = query.LE
	GT  = query.GT
	GE  = query.GE
	IN  = query.IN
	NIN = query.NIN
)

Functions

func NewDataRowForSelectors

func NewDataRowForSelectors(schema resultset.Schema, rowDesc *protocol.RowDescription, selectors query.Selectors, row Row) (*protocol.DataRow, error)

NewDataRowForSelectors returns a new DataRow from the specified row.

func NewDataRowsForAggregator

func NewDataRowsForAggregator(schema resultset.Schema, rowDesc *protocol.RowDescription, selectors query.Selectors, rows []Row, groupBy string) ([]*protocol.DataRow, error)

NewDataRowsForAggregator returns a new DataRow list from the specified rows.

func NewResponseFromResultSet

func NewResponseFromResultSet(rs resultset.ResultSet) (protocol.Responses, error)

NewResponseFromResultSet creates a response from a result set.

func NewRowFieldFrom

func NewRowFieldFrom(schema sql.ResultSetSchema, selector query.Selector, idx int) (*protocol.RowField, error)

NewRowFieldFrom returns a new RowField from the specified selector.

Types

type AlterDatabase

type AlterDatabase = query.AlterDatabase

type AlterTable

type AlterTable = query.AlterTable

type AndExpr

type AndExpr = query.AndExpr

type Begin

type Begin = query.Begin

type BindParam

type BindParam = query.BindParam

type CmpExpr

type CmpExpr = query.CmpExpr

type Column

type Column = query.Column

type ColumnList

type ColumnList = query.Columns

type Commit

type Commit = query.Commit

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 DropIndex

type DropIndex = query.DropIndex

type DropTable

type DropTable = query.DropTable

type Expr

type Expr = query.Expr

type Function

type Function = query.Function

Function represents a function.

type Insert

type Insert = query.Insert

type ObjectID

type ObjectID = system.ObjectID

ObjectID represents a object identifier.

func NewObjectIDFrom

func NewObjectIDFrom(t query.DataType) (ObjectID, error)

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

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 Rollback

type Rollback = query.Rollback

type Row

type Row = map[string]any

Row represents a row of a result set.

type SQLExecutor

type SQLExecutor interface {
	sql.Executor
}

SQLExecutor represents a SQL executor.

type Schema

type Schema = query.Schema

type Select

type Select = query.Select

type SelectOption

type SelectOption = query.SelectOption

type Selector

type Selector = query.Selector

type SelectorList

type SelectorList = query.Selectors

type Statement

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

Statement represents a statement instance.

func NewStatementWith

func NewStatementWith(stmt query.Statement) *Statement

NewStatementWith returns a new statement.

func (*Statement) Bind

func (stmt *Statement) Bind(bindParams protocol.BindParams) error

Bind binds the statement with the specified parameters.

func (*Statement) Object

func (stmt *Statement) Object() query.Statement

Statement returns a statement object.

type Table

type Table = query.Table

type TableList

type TableList = query.TableList

type Truncate

type Truncate = query.Truncate

type Update

type Update = query.Update

type Use

type Use = query.Use

type Vacuum

type Vacuum = query.Vacuum