postgresql

Jan 26, 2025

Changes in this version

type PostgresDatabase

+ func (dbs *PostgresDatabase) AdvancedQuery(EntityFactory) database.IAdvancedQuery

Jan 21, 2025

Changes in this version

type PostgresDatabase

+ func (dbs *PostgresDatabase) QueryAdvanced(factory EntityShardedFactory) database.IAdvancedQuery

Dec 9, 2024

Changes in this version

type NotificationPayload

+ Entity entity.Entity

Dec 8, 2024

Changes in this version

+ type NotificationHandler func(np NotificationPayload)

+ type NotificationPayload struct

+ Data interface{}

+ ID string

+ Operation string

type PostgresDatabase

+ func (dbs *PostgresDatabase) Subscribe(channel string, handler NotificationHandler) error

Jul 27, 2023

Changes in this version

type PostgresDatabase

+ func (dbs *PostgresDatabase) ListIndices(pattern string) (map[string]int, error)

Jun 29, 2023

Changes in this version

type PostgresDatabase

+ func (dbs *PostgresDatabase) ExecuteQuery(sql string, args ...any) ([]Json, error)

Jun 21, 2023

Changes in this version

type PostgresDatabase

+ func (dbs *PostgresDatabase) CloneDatabase() (database.IDatabase, error)

+ func (dbs *PostgresDatabase) CloneDatastore() (database.IDatastore, error)

May 17, 2023

Changes in this version

type PostgresDatabase

+ func (dbs *PostgresDatabase) BulkSetFields(factory EntityFactory, field string, values map[string]any, keys ...string) (affected int64, error error)

Mar 30, 2023

Changes in this version

+ func NewPostgresDatabaseWithMessageBus(URI string, bus messaging.IMessageBus) (dbs database.IDatabase, err error)

Feb 12, 2023

Changes in this version

+ func NewPostgresDatabase(URI string) (dbs database.IDatabase, err error)

type PostgresDatabase

+ func (dbs *PostgresDatabase) CreateEntityIndex(factory EntityFactory, key string) (name string, err error)

+ func (dbs *PostgresDatabase) CreateIndex(indexName string) (name string, err error)

+ func (dbs *PostgresDatabase) DropIndex(indexName string) (ack bool, err error)

+ func (dbs *PostgresDatabase) IndexExists(indexName string) (exists bool)

Dec 27, 2022

Changes in this version

+ func NewPostgresStore(URI string) (dbs database.IDatabase, err error)

+ type PostgresDatabase struct

+ func (dbs *PostgresDatabase) BulkDelete(factory EntityFactory, entityIDs []string, keys ...string) (affected int64, err error)

+ func (dbs *PostgresDatabase) BulkInsert(entities []Entity) (affected int64, err error)

+ func (dbs *PostgresDatabase) BulkUpdate(entities []Entity) (affected int64, err error)

+ func (dbs *PostgresDatabase) BulkUpsert(entities []Entity) (affected int64, err error)

+ func (dbs *PostgresDatabase) Close()

+ func (dbs *PostgresDatabase) Delete(factory EntityFactory, entityID string, keys ...string) (err error)

+ func (dbs *PostgresDatabase) DropTable(table string) (err error)

+ func (dbs *PostgresDatabase) ExecuteDDL(ddl map[string][]string) (err error)

+ func (dbs *PostgresDatabase) ExecuteSQL(sql string, args ...any) (affected int64, err error)

+ func (dbs *PostgresDatabase) Exists(factory EntityFactory, entityID string, keys ...string) (result bool, err error)

+ func (dbs *PostgresDatabase) Get(factory EntityFactory, entityID string, keys ...string) (result Entity, err error)

+ func (dbs *PostgresDatabase) Insert(entity Entity) (added Entity, err error)

+ func (dbs *PostgresDatabase) List(factory EntityFactory, entityIDs []string, keys ...string) (list []Entity, err error)

+ func (dbs *PostgresDatabase) Ping(retries uint, intervalInSeconds uint) error

+ func (dbs *PostgresDatabase) PurgeTable(table string) (err error)

+ func (dbs *PostgresDatabase) Query(factory EntityFactory) database.IQuery

+ func (dbs *PostgresDatabase) SetField(factory EntityFactory, entityID string, field string, value any, ...) (err error)

+ func (dbs *PostgresDatabase) SetFields(factory EntityFactory, entityID string, fields map[string]any, keys ...string) (err error)

+ func (dbs *PostgresDatabase) Update(entity Entity) (updated Entity, err error)

+ func (dbs *PostgresDatabase) Upsert(entity Entity) (updated Entity, err error)