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 DB
• type Service
  • func New(ctx context.Context, module *schema.Module, ...) (*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) UpdateConnections(ctx context.Context, module *schema.Module, ...) error

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 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 Service

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

Service proxies query requests to multiple database instances

func New

func New(ctx context.Context, module *schema.Module, addresses *xsync.MapOf[string, string]) (*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) UpdateConnections

func (s *Service) UpdateConnections(ctx context.Context, module *schema.Module, addresses *xsync.MapOf[string, string]) error

UpdateConnections updates the connections based on a new module and addresses during hot reloading. It fails if any database has configuration or connection issues.