postgresql

Documentation

Index

• func NewDataTypeFrom(t document.ElementType) (*system.DataType, error)
• func NewService() query.Service
• type Service
  • func (service *Service) AlterDatabase(conn *postgresql.Conn, stmt *query.AlterDatabase) (message.Responses, error)
  • func (service *Service) AlterTable(conn *postgresql.Conn, stmt *query.AlterTable) (message.Responses, error)
  • func (service *Service) Authenticate(conn *postgresql.Conn, startupMessage *message.Startup) (message.Response, error)
  • func (service *Service) Begin(conn *postgresql.Conn, stmt *query.Begin) (message.Responses, error)
  • func (service *Service) Commit(conn *postgresql.Conn, stmt *query.Commit) (message.Responses, error)
  • func (service *Service) Copy(conn *postgresql.Conn, stmt *query.Copy) (message.Responses, error)
  • func (service *Service) CopyData(conn *postgresql.Conn, stmt *query.Copy, stream *postgresql.CopyStream) (message.Responses, error)
  • func (service *Service) CreateDatabase(conn *postgresql.Conn, stmt *query.CreateDatabase) (message.Responses, error)
  • func (service *Service) CreateTable(conn *postgresql.Conn, stmt *query.CreateTable) (message.Responses, error)
  • func (service *Service) Delete(conn *postgresql.Conn, stmt *query.Delete) (message.Responses, error)
  • func (service *Service) DropDatabase(conn *postgresql.Conn, stmt *query.DropDatabase) (message.Responses, error)
  • func (service *Service) DropTable(conn *postgresql.Conn, stmt *query.DropTable) (message.Responses, error)
  • func (service *Service) Insert(conn *postgresql.Conn, stmt *query.Insert) (message.Responses, error)
  • func (service *Service) ParserError(conn *postgresql.Conn, q string, err error) (message.Responses, error)
  • func (service *Service) Rollback(conn *postgresql.Conn, stmt *query.Rollback) (message.Responses, error)
  • func (service *Service) Select(conn *postgresql.Conn, stmt *query.Select) (message.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 *query.Update) (message.Responses, error)

Functions

func NewDataTypeFrom

func NewDataTypeFrom(t document.ElementType) (*system.DataType, error)

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

func NewService

func NewService() query.Service

NewService returns a new MySQL service.

Types

type Service

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

Service represents a new MySQL service instance.

func (*Service) AlterDatabase

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

AlterDatabase handles a ALTER DATABASE query.

func (*Service) AlterTable

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

AlterTable handles a ALTER TABLE query.

func (*Service) Authenticate

func (service *Service) Authenticate(conn *postgresql.Conn, startupMessage *message.Startup) (message.Response, error)

Authenticate authenticates the connection with the startup message.

func (*Service) Begin

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

Begin handles a BEGIN query.

func (*Service) Commit

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

Commit handles a COMMIT query.

func (*Service) Copy

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

Copy handles a COPY query.

func (*Service) CopyData

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

Copy handles a COPY DATA message.

func (*Service) CreateDatabase

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

CreateDatabase handles a CREATE DATABASE query.

func (*Service) CreateTable

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

CreateTable handles a CREATE TABLE query.

func (*Service) Delete

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

Delete handles a DELETE query.

func (*Service) DropDatabase

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

DropDatabase handles a DROP DATABASE query.

func (*Service) DropTable

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

DropIndex handles a DROP INDEX query.

func (*Service) Insert

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

Insert handles a INSERT query.

func (*Service) ParserError

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

ParserError handles a parser error.

func (*Service) Rollback

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

Rollback handles a ROLLBACK query.

func (*Service) Select

func (service *Service) Select(conn *postgresql.Conn, stmt *query.Select) (message.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 *query.Update) (message.Responses, error)

Update handles a UPDATE query.