db

Documentation

Index

• Constants
• Variables
• func IsQueryBuilderSetClauseError(err error) bool
• func KeyAccessServerProtoJSON(keyAccessServerJSON []byte) ([]*policy.KeyAccessServer, error)
• func MarshalCreateMetadata(metadata *common.MetadataMutable) ([]byte, *common.Metadata, error)
• func MarshalUpdateMetadata(m *common.MetadataMutable, b common.MetadataUpdateEnum, ...) ([]byte, *common.Metadata, error)
• func NewStatementBuilder() sq.StatementBuilderType
• func NewTableWithSchema(schema string) func(name string) Table
• func NewUniqueAlreadyExistsError(value string) error
• func StatusifyError(err error, fallbackErr string, log ...any) error
• func WrapIfKnownInvalidQueryErr(err error) error
• type Client
  • func NewClient(config Config) (*Client, error)
  • func (c *Client) Close()
  • func (c Client) Exec(ctx context.Context, sql string, args []interface{}) error
  • func (c *Client) MigrationDown(ctx context.Context) error
  • func (c *Client) MigrationStatus(ctx context.Context) ([]*goose.MigrationStatus, error)
  • func (c Client) Query(ctx context.Context, sql string, args []interface{}) (pgx.Rows, error)
  • func (c Client) QueryRow(ctx context.Context, sql string, args []interface{}) (pgx.Row, error)
  • func (c *Client) RunMigrations(ctx context.Context) (int, error)
• type Config
• type DBError
  • func (e DBError) Error() string
• type PgxIface
• type Table
  • func (t Table) Field(field string) string
  • func (t Table) Name() string
  • func (t Table) WithoutSchema() Table

Constants

const (
	ErrTextCreationFailed      = "resource creation failed"
	ErrTextDeletionFailed      = "resource deletion failed"
	ErrTextDeactivationFailed  = "resource deactivation failed"
	ErrTextGetRetrievalFailed  = "resource retrieval failed"
	ErrTextListRetrievalFailed = "resource list retrieval failed"
	ErrTextUpdateFailed        = "resource update failed"
	ErrTextNotFound            = "resource not found"
	ErrTextConflict            = "resource unique field violation"
	ErrTextRelationInvalid     = "resource relation invalid"
	ErrTextEnumValueInvalid    = "enum value invalid"
	ErrTextUUIDInvalid         = "invalid input syntax for type uuid"
	ErrTextRestrictViolation   = "intended action would violate a restriction"
	ErrTextFqnMissingValue     = "FQN must specify a valid value and be of format 'https://<namespace>/attr/<attribute name>/value/<value>'"
)

Variables

var NewTable func(name string) Table

Functions

func IsQueryBuilderSetClauseError

func IsQueryBuilderSetClauseError(err error) bool

func KeyAccessServerProtoJSON

func KeyAccessServerProtoJSON(keyAccessServerJSON []byte) ([]*policy.KeyAccessServer, error)

func MarshalCreateMetadata

func MarshalCreateMetadata(metadata *common.MetadataMutable) ([]byte, *common.Metadata, error)

func MarshalUpdateMetadata

func MarshalUpdateMetadata(m *common.MetadataMutable, b common.MetadataUpdateEnum, getExtendableMetadata func() (*common.Metadata, error)) ([]byte, *common.Metadata, error)

func NewStatementBuilder

func NewStatementBuilder() sq.StatementBuilderType

Postgres uses $1, $2, etc. for placeholders

func NewTableWithSchema

func NewTableWithSchema(schema string) func(name string) Table

func NewUniqueAlreadyExistsError

func NewUniqueAlreadyExistsError(value string) error

func StatusifyError

func StatusifyError(err error, fallbackErr string, log ...any) error

func WrapIfKnownInvalidQueryErr

func WrapIfKnownInvalidQueryErr(err error) error

Get helpful error message for PostgreSQL violation

Types

type Client

type Client struct {
	Pgx PgxIface

	// This is the stdlib connection that is used for transactions
	SqlDB *sql.DB
	// contains filtered or unexported fields
}

func NewClient

func NewClient(config Config) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (Client) Exec

func (c Client) Exec(ctx context.Context, sql string, args []interface{}) error

Common function for all exec calls

func (*Client) MigrationDown

func (c *Client) MigrationDown(ctx context.Context) error

func (*Client) MigrationStatus

func (c *Client) MigrationStatus(ctx context.Context) ([]*goose.MigrationStatus, error)

func (Client) Query

func (c Client) Query(ctx context.Context, sql string, args []interface{}) (pgx.Rows, error)

Common function for all query calls

func (Client) QueryRow

func (c Client) QueryRow(ctx context.Context, sql string, args []interface{}) (pgx.Row, error)

Common function for all queryRow calls

func (*Client) RunMigrations

func (c *Client) RunMigrations(ctx context.Context) (int, error)

type Config

type Config struct {
	Host          string `yaml:"host" default:"localhost"`
	Port          int    `yaml:"port" default:"5432"`
	Database      string `yaml:"database" default:"opentdf"`
	User          string `yaml:"user" default:"postgres"`
	Password      string `yaml:"password" default:"changeme"`
	RunMigrations bool   `yaml:"runMigrations" default:"true"`
	SSLMode       string `yaml:"sslmode" default:"prefer"`
	Schema        string `yaml:"schema" default:"opentdf"`
}

type DBError

type DBError string

const (
	ErrUniqueConstraintViolation DBError = "ErrUniqueConstraintViolation: value must be unique"
	ErrNotNullViolation          DBError = "ErrNotNullViolation: value cannot be null"
	ErrForeignKeyViolation       DBError = "ErrForeignKeyViolation: value is referenced by another table"
	ErrRestrictViolation         DBError = "ErrRestrictViolation: value cannot be deleted due to restriction"
	ErrNotFound                  DBError = "ErrNotFound: value not found"
	ErrEnumValueInvalid          DBError = "ErrEnumValueInvalid: not a valid enum value"
	ErrUUIDInvalid               DBError = "ErrUUIDInvalid: value not a valid UUID"
	ErrFqnMissingValue           DBError = "ErrFqnMissingValue: FQN must include a value"
	ErrMissingValue              DBError = "ErrMissingValue: value must be included"
)

func (DBError) Error

func (e DBError) Error() string

type PgxIface

type PgxIface interface {
	Acquire(ctx context.Context) (*pgxpool.Conn, error)
	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
	QueryRow(context.Context, string, ...any) pgx.Row
	Query(context.Context, string, ...any) (pgx.Rows, error)
	Ping(context.Context) error
	Close()
	Config() *pgxpool.Config
}

We can rename this but wanted to get mocks working.

type Table

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

func (Table) Field

func (t Table) Field(field string) string

func (Table) Name

func (t Table) Name() string

func (Table) WithoutSchema

func (t Table) WithoutSchema() Table