postgresql

Documentation

Index

• func NewDataTypeFrom(t document.ElementType) (*system.DataType, error)
• func NewService() query.Service
• type Service
  • func (service *Service) Authenticate(*postgresql.Conn, *message.Startup) (message.Response, error)
  • func (service *Service) CancelTransactionWithError(ctx context.Context, txn store.Transaction, err error) error
  • func (service *Service) CreateDatabase(conn *postgresql.Conn, stmt *query.CreateDatabase) (message.Responses, error)
  • func (service *Service) CreateIndex(conn *postgresql.Conn, stmt *query.CreateIndex) (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) 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) Authenticate

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

Authenticate authenticates the connection with the startup message.

func (*Service) CancelTransactionWithError

func (service *Service) CancelTransactionWithError(ctx context.Context, txn store.Transaction, err error) error

Stop stops the service.

func (*Service) CreateDatabase

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

CreateDatabase handles a CREATE DATABASE query.

func (*Service) CreateIndex

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

CreateIndex handles a CREATE INDEX 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) 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-ing 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.