dalgo2postgres

Nov 4, 2026

Changes in this version

type Database

+ func (d *Database) ReadNativeAccess(ctx context.Context, ref *dal.CollectionRef) (*dbschema.NativeAccess, error)

Oct 31, 2026

Changes in this version

type Database

+ func (d *Database) RunReadonlySchemaTransaction(ctx context.Context, worker func(context.Context, dbschema.SchemaReader) error) (err error)

Oct 7, 2026

Changes in this version

type Database

+ func (d *Database) ListSourceViews(ctx context.Context) ([]dbschema.SourceViewDef, error)

Oct 5, 2026

Changes in this version

type ConnectionError

+ func (e *ConnectionError) Is(target error) bool

Oct 5, 2026

Changes in this version

type Database

+ func (d *Database) ListSchemaCollections(ctx context.Context, schema string) ([]dal.CollectionRef, error)

+ func (d *Database) ListSchemaViews(ctx context.Context, schema string) ([]dal.CollectionRef, error)

+ func (d *Database) ListSchemas(ctx context.Context) ([]string, error)

+ func (d *Database) ListViews(ctx context.Context) ([]dal.CollectionRef, error)

Oct 5, 2026

Changes in this version

type Database

+ func (d *Database) CanExecuteJoin(ctx context.Context, q dal.StructuredQuery) error

+ func (d *Database) JoinFields(ctx context.Context, source dal.RecordsetSource) ([]string, error)

+ func (d *Database) QueryCapabilities() dal.QueryCapabilities

Oct 4, 2026

Changes in this version

+ type ConnectionError struct

+ Database string

+ Host string

+ Kind FailureKind

+ Port string

+ SQLState string

+ func (e *ConnectionError) Error() string

+ type FailureKind int

+ const FailureInvalidDSN

+ const FailureMisread

+ const FailureNetwork

+ const FailureOther

+ const FailureServer

+ const FailureTLS

+ const FailureTimeout

Oct 4, 2026

Changes in this version

type Database

+ func (d *Database) NonDeterministicTextColumns(ctx context.Context, ref *dal.CollectionRef) ([]string, error)

Oct 4, 2026

Changes in this version

+ const DefaultSchema

+ type IdentifierMode int

+ const IdentifierExact

+ const IdentifierFoldLower

+ type Option func(*Database)

+ func WithIdentifierMode(mode IdentifierMode) Option

+ func WithSchema(name string) Option

Aug 23, 2026

Changes in this version

+ func IsAlreadyExists(err error) bool

Jul 25, 2026

Changes in this version

type Database

+ func (d *Database) SupportsConcurrentConnections() bool

Jul 9, 2026

Changes in this version

+ const Version

+ type Database struct

+ func NewDatabase(dsn string) (*Database, error)

+ func NewDatabaseWithOptions(dsn string, schema dal.Schema, opts dalgo2sql.DbOptions) (*Database, error)

+ func (d *Database) Adapter() dal.Adapter

+ func (d *Database) AlterCollection(ctx context.Context, name string, ops ...ddl.AlterOp) error

+ func (d *Database) Close() error

+ func (d *Database) CreateCollection(ctx context.Context, c dbschema.CollectionDef, opts ...ddl.Option) error

+ func (d *Database) Delete(ctx context.Context, key *dal.Key) error

+ func (d *Database) DeleteMulti(ctx context.Context, keys []*dal.Key) error

+ func (d *Database) DescribeCollection(ctx context.Context, ref *dal.CollectionRef) (*dbschema.CollectionDef, error)

+ func (d *Database) DropCollection(ctx context.Context, name string, opts ...ddl.Option) error

+ func (d *Database) ExecuteQueryToRecordsReader(ctx context.Context, query dal.Query) (dal.RecordsReader, error)

+ func (d *Database) ExecuteQueryToRecordsetReader(ctx context.Context, query dal.Query, opts ...recordset.Option) (dal.RecordsetReader, error)

+ func (d *Database) Exists(ctx context.Context, key *dal.Key) (bool, error)

+ func (d *Database) Get(ctx context.Context, record dal.Record) error

+ func (d *Database) GetMulti(ctx context.Context, records []dal.Record) error

+ func (d *Database) ID() string

+ func (d *Database) Insert(ctx context.Context, record dal.Record, opts ...dal.InsertOption) error

+ func (d *Database) ListCollections(ctx context.Context, parent *dal.Key) ([]dal.CollectionRef, error)

+ func (d *Database) ListConstraints(ctx context.Context, ref *dal.CollectionRef) ([]dbschema.ConstraintDef, error)

+ func (d *Database) ListIndexes(ctx context.Context, ref *dal.CollectionRef) ([]dbschema.IndexDef, error)

+ func (d *Database) ListReferrers(ctx context.Context, ref *dal.CollectionRef) ([]dbschema.Referrer, error)

+ func (d *Database) RunReadonlyTransaction(ctx context.Context, f dal.ROTxWorker, opts ...dal.TransactionOption) error

+ func (d *Database) RunReadwriteTransaction(ctx context.Context, f dal.RWTxWorker, opts ...dal.TransactionOption) error

+ func (d *Database) Schema() dal.Schema

+ func (d *Database) Set(ctx context.Context, record dal.Record) error

+ func (d *Database) SetMulti(ctx context.Context, records []dal.Record) error

+ func (d *Database) SupportsTransactionalDDL() bool

+ func (d *Database) Update(ctx context.Context, key *dal.Key, updates []update.Update, ...) error

+ func (d *Database) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []update.Update, ...) error

+ func (d *Database) UpdateRecord(ctx context.Context, record dal.Record, updates []update.Update, ...) error

+ func (d *Database) Upsert(ctx context.Context, record dal.Record) error