postgresql

Documentation

Index

• func NewService() query.Service
• type Service
  • func (service *Service) AlterDatabase(conn postgresql.Conn, stmt stmt.AlterDatabase) (protocol.Responses, error)
  • func (service *Service) AlterTable(conn postgresql.Conn, stmt stmt.AlterTable) (protocol.Responses, error)
  • func (service *Service) Begin(conn postgresql.Conn, stmt stmt.Begin) (protocol.Responses, error)
  • func (service *Service) Commit(conn postgresql.Conn, stmt stmt.Commit) (protocol.Responses, error)
  • func (service *Service) Copy(conn postgresql.Conn, stmt stmt.Copy) (protocol.Responses, error)
  • func (service *Service) CopyData(conn postgresql.Conn, stmt stmt.Copy, stream *postgresql.CopyStream) (protocol.Responses, error)
  • func (service *Service) CreateDatabase(conn postgresql.Conn, stmt stmt.CreateDatabase) (protocol.Responses, error)
  • func (service *Service) CreateTable(conn postgresql.Conn, stmt stmt.CreateTable) (protocol.Responses, error)
  • func (service *Service) Delete(conn postgresql.Conn, stmt stmt.Delete) (protocol.Responses, error)
  • func (service *Service) DropDatabase(conn postgresql.Conn, stmt stmt.DropDatabase) (protocol.Responses, error)
  • func (service *Service) DropTable(conn postgresql.Conn, stmt stmt.DropTable) (protocol.Responses, error)
  • func (service *Service) Insert(conn postgresql.Conn, stmt stmt.Insert) (protocol.Responses, error)
  • func (service *Service) ParserError(conn postgresql.Conn, q string, err error) (protocol.Responses, error)
  • func (service *Service) Rollback(conn postgresql.Conn, stmt stmt.Rollback) (protocol.Responses, error)
  • func (service *Service) Select(conn postgresql.Conn, stmt stmt.Select) (protocol.Responses, error)
  • func (service *Service) ServiceName() string
  • func (service *Service) Start() error
  • func (service *Service) Stop() error
  • func (service *Service) Update(conn postgresql.Conn, stmt stmt.Update) (protocol.Responses, error)

Functions

func NewService

func NewService() query.Service

NewService returns a new PostgreSQL service.

Types

type Service

type Service struct {
	postgresql.Server
	*sql.Service
}

Service represents a new PostgreSQL service instance.

func (*Service) AlterDatabase

func (service *Service) AlterDatabase(conn postgresql.Conn, stmt stmt.AlterDatabase) (protocol.Responses, error)

AlterDatabase handles a ALTER DATABASE query.

func (*Service) AlterTable

func (service *Service) AlterTable(conn postgresql.Conn, stmt stmt.AlterTable) (protocol.Responses, error)

AlterTable handles a ALTER TABLE query.

func (*Service) Begin

func (service *Service) Begin(conn postgresql.Conn, stmt stmt.Begin) (protocol.Responses, error)

Begin handles a BEGIN query.

func (*Service) Commit

func (service *Service) Commit(conn postgresql.Conn, stmt stmt.Commit) (protocol.Responses, error)

Commit handles a COMMIT query.

func (*Service) Copy

func (service *Service) Copy(conn postgresql.Conn, stmt stmt.Copy) (protocol.Responses, error)

Copy handles a COPY query.

func (*Service) CopyData

func (service *Service) CopyData(conn postgresql.Conn, stmt stmt.Copy, stream *postgresql.CopyStream) (protocol.Responses, error)

Copy handles a COPY DATA protocol.

func (*Service) CreateDatabase

func (service *Service) CreateDatabase(conn postgresql.Conn, stmt stmt.CreateDatabase) (protocol.Responses, error)

CreateDatabase handles a CREATE DATABASE query.

func (*Service) CreateTable

func (service *Service) CreateTable(conn postgresql.Conn, stmt stmt.CreateTable) (protocol.Responses, error)

CreateTable handles a CREATE TABLE query.

func (*Service) Delete

func (service *Service) Delete(conn postgresql.Conn, stmt stmt.Delete) (protocol.Responses, error)

Delete handles a DELETE query.

func (*Service) DropDatabase

func (service *Service) DropDatabase(conn postgresql.Conn, stmt stmt.DropDatabase) (protocol.Responses, error)

DropDatabase handles a DROP DATABASE query.

func (*Service) DropTable

func (service *Service) DropTable(conn postgresql.Conn, stmt stmt.DropTable) (protocol.Responses, error)

DropIndex handles a DROP INDEX query.

func (*Service) Insert

func (service *Service) Insert(conn postgresql.Conn, stmt stmt.Insert) (protocol.Responses, error)

Insert handles a INSERT query.

func (*Service) ParserError

func (service *Service) ParserError(conn postgresql.Conn, q string, err error) (protocol.Responses, error)

ParserError handles a parser error.

func (*Service) Rollback

func (service *Service) Rollback(conn postgresql.Conn, stmt stmt.Rollback) (protocol.Responses, error)

Rollback handles a ROLLBACK query.

func (*Service) Select

func (service *Service) Select(conn postgresql.Conn, stmt stmt.Select) (protocol.Responses, error)

Select handles a SELECT query.

func (*Service) ServiceName

func (service *Service) ServiceName() string

ServiceName returns the plug-in service name.

func (*Service) Start

func (service *Service) Start() error

Start starts the service.

func (*Service) Stop

func (service *Service) Stop() error

Stop stops the service.

func (*Service) Update

func (service *Service) Update(conn postgresql.Conn, stmt stmt.Update) (protocol.Responses, error)

Update handles a UPDATE query.