postgresql_dep

Mar 20, 2024

Changes in this version

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

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

+ func NewPostgresStore(URI string) (dbs database.IDatastore, 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) BulkSetFields(factory EntityFactory, field string, values map[string]any, keys ...string) (affected int64, error error)

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

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

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

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

+ func (dbs *PostgresDatabase) Close() error

+ 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) Delete(factory EntityFactory, entityID string, keys ...string) (err error)

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

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

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

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

+ func (dbs *PostgresDatabase) ExecuteSQL(sql string, args ...any) (int64, 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) IndexExists(indexName string) (exists bool)

+ 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) ListIndices(pattern string) (map[string]int, 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)