persistence

Jun 3, 2022

Changes in this version

type PostgresPersistence

+ func (c *PostgresPersistence) QuotedTableName() string

Apr 27, 2021

Changes in this version

type PostgresPersistence

+ SchemaName string

+ func (c *PostgresPersistence) QuoteTableNameWithSchema() string

Apr 4, 2021

Changes in this version

+ type IPostgresPersistenceOverrides interface

+ ConvertFromPublic func(item interface{}) interface{}

+ ConvertFromPublicPartial func(item interface{}) interface{}

+ ConvertToPublic func(item pgx.Rows) interface{}

+ DefineSchema func()

type IdentifiableJsonPostgresPersistence

+ func InheritIdentifiableJsonPostgresPersistence(overrides IPostgresPersistenceOverrides, proto reflect.Type, tableName string) *IdentifiableJsonPostgresPersistence

type IdentifiablePostgresPersistence

+ func InheritIdentifiablePostgresPersistence(overrides IPostgresPersistenceOverrides, proto reflect.Type, tableName string) *IdentifiablePostgresPersistence

type PostgresPersistence

+ Overrides IPostgresPersistenceOverrides

+ func InheritPostgresPersistence(overrides IPostgresPersistenceOverrides, proto reflect.Type, tableName string) *PostgresPersistence

Feb 19, 2021

Changes in this version

type PostgresPersistence

+ DefineSchema func()

+ func (c *PostgresPersistence) ClearSchema()

+ func (c *PostgresPersistence) CreateSchema(correlationId string) (err error)

+ func (c *PostgresPersistence) EnsureSchema(schemaStatement string)

Nov 12, 2020

Changes in this version

type IdentifiableJsonPostgresPersistence

+ func (c *IdentifiableJsonPostgresPersistence) PerformConvertFromPublic(value interface{}) interface{}

+ func (c *IdentifiableJsonPostgresPersistence) PerformConvertToPublic(rows pgx.Rows) interface{}

type PostgresPersistence

+ func (c *PostgresPersistence) DereferenceObject(docPointer reflect.Value) interface{}

+ func (c *PostgresPersistence) PerformConvertFromPublic(value interface{}) interface{}

+ func (c *PostgresPersistence) PerformConvertFromPublicPartial(value interface{}) interface{}

+ func (c *PostgresPersistence) PerformConvertToPublic(rows pgx.Rows) interface{}

Nov 5, 2020

Changes in this version

+ type IPublicConvertable interface

+ ConvertFromPublic func(value interface{}) interface{}

+ ConvertFromPublicPartial func(value interface{}) interface{}

+ ConvertToPublic func(value interface{}) interface{}

+ type IdentifiableJsonPostgresPersistence struct

+ func NewIdentifiableJsonPostgresPersistence(proto reflect.Type, tableName string) *IdentifiableJsonPostgresPersistence

+ func (c *IdentifiableJsonPostgresPersistence) ConvertFromPublic(value interface{}) interface{}

+ func (c *IdentifiableJsonPostgresPersistence) ConvertFromPublicPartial(value interface{}) interface{}

+ func (c *IdentifiableJsonPostgresPersistence) ConvertToPublic(value interface{}) interface{}

+ func (c *IdentifiableJsonPostgresPersistence) EnsureTable(idType string, dataType string)

+ func (c *IdentifiableJsonPostgresPersistence) UpdatePartially(correlationId string, id interface{}, data *cdata.AnyValueMap) (result interface{}, err error)

+ type IdentifiablePostgresPersistence struct

+ func NewIdentifiablePostgresPersistence(proto reflect.Type, tableName string) *IdentifiablePostgresPersistence

+ func (c *IdentifiablePostgresPersistence) Create(correlationId string, item interface{}) (result interface{}, err error)

+ func (c *IdentifiablePostgresPersistence) DeleteById(correlationId string, id interface{}) (result interface{}, err error)

+ func (c *IdentifiablePostgresPersistence) DeleteByIds(correlationId string, ids []interface{}) error

+ func (c *IdentifiablePostgresPersistence) GetListByIds(correlationId string, ids []interface{}) (items []interface{}, err error)

+ func (c *IdentifiablePostgresPersistence) GetOneById(correlationId string, id interface{}) (item interface{}, err error)

+ func (c *IdentifiablePostgresPersistence) Set(correlationId string, item interface{}) (result interface{}, err error)

+ func (c *IdentifiablePostgresPersistence) Update(correlationId string, item interface{}) (result interface{}, err error)

+ func (c *IdentifiablePostgresPersistence) UpdatePartially(correlationId string, id interface{}, data *cdata.AnyValueMap) (result interface{}, err error)

+ type PostgresConnection struct

+ Connection *pgxpool.Pool

+ ConnectionResolver *pcon.PostgresConnectionResolver

+ DatabaseName string

+ Logger *clog.CompositeLogger

+ Options *cconf.ConfigParams

+ func NewPostgresConnection() *PostgresConnection

+ func (c *PostgresConnection) Close(correlationId string) error

+ func (c *PostgresConnection) Configure(config *cconf.ConfigParams)

+ func (c *PostgresConnection) GetConnection() *pgxpool.Pool

+ func (c *PostgresConnection) GetDatabaseName() string

+ func (c *PostgresConnection) IsOpen() bool

+ func (c *PostgresConnection) Open(correlationId string) error

+ func (c *PostgresConnection) SetReferences(references cref.IReferences)

+ type PostgresPersistence struct

+ Client *pgxpool.Pool

+ Connection *PostgresConnection

+ DatabaseName string

+ DependencyResolver *cref.DependencyResolver

+ Logger *clog.CompositeLogger

+ MaxPageSize int

+ Prototype reflect.Type

+ TableName string

+ func NewPostgresPersistence(proto reflect.Type, tableName string) *PostgresPersistence

+ func (c *PostgresPersistence) AutoCreateObject(dmlStatement string)

+ func (c *PostgresPersistence) AutoCreateObjects(correlationId string) (err error)

+ func (c *PostgresPersistence) Clear(correlationId string) error

+ func (c *PostgresPersistence) Close(correlationId string) (err error)

+ func (c *PostgresPersistence) Configure(config *cconf.ConfigParams)

+ func (c *PostgresPersistence) ConvertFromPublic(value interface{}) interface{}

+ func (c *PostgresPersistence) ConvertFromPublicPartial(value interface{}) interface{}

+ func (c *PostgresPersistence) ConvertFromRows(columns []pgproto3.FieldDescription, rows []interface{}) interface{}

+ func (c *PostgresPersistence) ConvertResultToPublic(docPointer reflect.Value) interface{}

+ func (c *PostgresPersistence) ConvertToPublic(value interface{}) interface{}

+ func (c *PostgresPersistence) Create(correlationId string, item interface{}) (result interface{}, err error)

+ func (c *PostgresPersistence) DeleteByFilter(correlationId string, filter string) (err error)

+ func (c *PostgresPersistence) EnsureIndex(name string, keys map[string]string, options map[string]string)

+ func (c *PostgresPersistence) GenerateColumns(values interface{}) string

+ func (c *PostgresPersistence) GenerateParameters(values interface{}) string

+ func (c *PostgresPersistence) GenerateSetParameters(values interface{}) (params string, columns string)

+ func (c *PostgresPersistence) GenerateValues(columns string, values interface{}) []interface{}

+ func (c *PostgresPersistence) GetCountByFilter(correlationId string, filter interface{}) (count int64, err error)

+ func (c *PostgresPersistence) GetListByFilter(correlationId string, filter interface{}, sort interface{}, sel interface{}) (items []interface{}, err error)

+ func (c *PostgresPersistence) GetOneRandom(correlationId string, filter interface{}) (item interface{}, err error)

+ func (c *PostgresPersistence) GetPageByFilter(correlationId string, filter interface{}, paging *cdata.PagingParams, ...) (page *cdata.DataPage, err error)

+ func (c *PostgresPersistence) IsOpen() bool

+ func (c *PostgresPersistence) NewObjectByPrototype() reflect.Value

+ func (c *PostgresPersistence) Open(correlationId string) (err error)

+ func (c *PostgresPersistence) QuoteIdentifier(value string) string

+ func (c *PostgresPersistence) SetReferences(references cref.IReferences)

+ func (c *PostgresPersistence) UnsetReferences()