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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDataTypeFrom ¶ added in v1.0.1
func NewDataTypeFrom(t document.ElementType) (*system.DataType, error)
NewDataTypeFrom returns a data type from the specified query data type.
Types ¶
type Service ¶
type Service struct {
*postgresql.Server
*sql.Service
}
Service represents a new MySQL service instance.
func (*Service) AlterDatabase ¶ added in v1.0.3
func (service *Service) AlterDatabase(conn *postgresql.Conn, stmt *query.AlterDatabase) (message.Responses, error)
AlterDatabase handles a ALTER DATABASE query.
func (*Service) AlterTable ¶ added in v1.0.3
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) Commit ¶ added in v1.0.3
func (service *Service) Commit(conn *postgresql.Conn, stmt *query.Commit) (message.Responses, error)
Commit handles a COMMIT query.
func (*Service) CopyData ¶ added in v1.0.3
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 ¶ added in v1.0.3
func (service *Service) ParserError(conn *postgresql.Conn, q string, err error) (message.Responses, error)
ParserError handles a parser error.
func (*Service) Rollback ¶ added in v1.0.3
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 ¶
ServiceName returns the plug-in service name.
Source Files
Click to show internal directories.
Click to hide internal directories.