query

Documentation

Index

• func Exec[Req any](ctx context.Context, dbName string, rawSQL string, params []any, ...) error
• func Many[Req, Resp any](ctx context.Context, dbName string, rawSQL string, params []any, ...) ([]Resp, error)
• func One[Req, Resp any](ctx context.Context, dbName string, rawSQL string, params []any, ...) (resp Resp, err error)
• type Config
  • func (c *Config) Validate() error
• type DB
• type MultiService
  • func NewMultiService() *MultiService
  • func (m *MultiService) AddService(module string, name string, svc *Service) error
  • func (m *MultiService) Close() error
  • func (m *MultiService) GetService(ref schema.RefKey) (*Service, bool)
  • func (m *MultiService) GetServices() map[schema.RefKey]*Service
• type Service
  • func New(ctx context.Context, config Config) (*Service, error)
  • func (s *Service) BeginTransaction(ctx context.Context, req *connect.Request[querypb.BeginTransactionRequest]) (*connect.Response[querypb.BeginTransactionResponse], error)
  • func (s *Service) Close() error
  • func (s *Service) CommitTransaction(ctx context.Context, req *connect.Request[querypb.CommitTransactionRequest]) (*connect.Response[querypb.CommitTransactionResponse], error)
  • func (s *Service) ExecuteQuery(ctx context.Context, req *connect.Request[querypb.ExecuteQueryRequest], ...) error
  • func (s *Service) Ping(ctx context.Context, req *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)
  • func (s *Service) RollbackTransaction(ctx context.Context, req *connect.Request[querypb.RollbackTransactionRequest]) (*connect.Response[querypb.RollbackTransactionResponse], error)
  • func (s *Service) SetEndpoint(endpoint *url.URL)

Functions

func Exec

func Exec[Req any](ctx context.Context, dbName string, rawSQL string, params []any, colFieldNames []tuple.Pair[string, string]) error

func Many

func Many[Req, Resp any](ctx context.Context, dbName string, rawSQL string, params []any, colFieldNames []tuple.Pair[string, string]) ([]Resp, error)

func One

func One[Req, Resp any](ctx context.Context, dbName string, rawSQL string, params []any, colFieldNames []tuple.Pair[string, string]) (resp Resp, err error)

Types

type Config

type Config struct {
	DSN      string
	Engine   string
	Endpoint *url.URL
}

func (*Config) Validate

func (c *Config) Validate() error

type DB

type DB interface {
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

DB represents a database that can execute queries

type MultiService

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

MultiService handles multiple database instances

func NewMultiService

func NewMultiService() *MultiService

func (*MultiService) AddService

func (m *MultiService) AddService(module string, name string, svc *Service) error

func (*MultiService) Close

func (m *MultiService) Close() error

func (*MultiService) GetService

func (m *MultiService) GetService(ref schema.RefKey) (*Service, bool)

func (*MultiService) GetServices

func (m *MultiService) GetServices() map[schema.RefKey]*Service

type Service

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

func New

func New(ctx context.Context, config Config) (*Service, error)

func (*Service) BeginTransaction

func (s *Service) BeginTransaction(ctx context.Context, req *connect.Request[querypb.BeginTransactionRequest]) (*connect.Response[querypb.BeginTransactionResponse], error)

func (*Service) Close

func (s *Service) Close() error

func (*Service) CommitTransaction

func (s *Service) CommitTransaction(ctx context.Context, req *connect.Request[querypb.CommitTransactionRequest]) (*connect.Response[querypb.CommitTransactionResponse], error)

func (*Service) ExecuteQuery

func (s *Service) ExecuteQuery(ctx context.Context, req *connect.Request[querypb.ExecuteQueryRequest], stream *connect.ServerStream[querypb.ExecuteQueryResponse]) error

func (*Service) Ping

func (s *Service) Ping(ctx context.Context, req *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*Service) RollbackTransaction

func (s *Service) RollbackTransaction(ctx context.Context, req *connect.Request[querypb.RollbackTransactionRequest]) (*connect.Response[querypb.RollbackTransactionResponse], error)

func (*Service) SetEndpoint

func (s *Service) SetEndpoint(endpoint *url.URL)

SetEndpoint sets the endpoint after the server is confirmed ready