Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

postgres

package

Go to main page

Versions in this module

v1

v1.0.2

Aug 31, 2026

v1.0.1-alpha

Apr 22, 2026

v1.0.0-alpha

Mar 25, 2026

v0

v0.3.0

Oct 28, 2026

v0.2.0

Mar 25, 2026

v0.1.0

Mar 25, 2026

Changes in this version

+ var OpenDB = sql.Open

+ var PingDB = func(db *sql.DB) error

+ func Connect(cfg *config.DatabaseConfig) (interfaces.DB, error)

+ func ConvertToPostgresArray(val interface{}) interface

+ func MapsToJSONStrings(arr []map[string]interface{}) ([]string, error)

+ func NewDatabaseRepo(db *PostgresDbService) interfaces.DatabaseRepo

+ func ParseNumeric(v interface{}) interface

+ func ParseStringArrayElements(strSlice []string) []interface

+ func ParseUUID(v interface{}) interface

+ func ParseValue(v interface{}) interface

+ func SplitQualifiedName(qualifiedName string) ([]string, error)

+ func TryParseJSON(b []byte) (interface{}, bool)

+ func TryParseJSONElement(elem string) interface

+ func ValidateAndQuoteColumnList(columns []string) ([]string, error)

+ func ValidateAndQuoteOrderByList(orderByList []string) ([]string, error)

+ func ValidateColumnName(name string) error

+ func ValidateOperator(op string) error

+ func ValidateQualifiedNameParts(parts []string, qualifiedName string) error

+ func ValidateQualifiedTableName(qualifiedName string) error

+ func ValidateTableName(name string) error

+ type BulkRepoImpl struct

+ func NewBulkRepo(db *PostgresDbService) *BulkRepoImpl

+ func (b *BulkRepoImpl) BulkDelete(tableName string, ids []interface{}, idColumn string) (int64, error)

+ func (b *BulkRepoImpl) BulkInsert(tableName string, records []map[string]interface{}) ([]map[string]interface{}, error)

+ func (b *BulkRepoImpl) BulkUpdate(tableName string, updates []map[string]interface{}, whereColumn string) (int64, error)

+ func (b *BulkRepoImpl) Upsert(tableName string, data map[string]interface{}, ...) (map[string]interface{}, error)

+ type Connector interface

+ Connect func(dsn string) (interfaces.DB, error)

+ func NewPostgresConnector() Connector

+ func NewPostgresConnectorWithConfig(maxOpen, maxIdle int, maxLifetime time.Duration) Connector

+ type CoreRepoImpl struct

+ func NewCoreRepo(db *PostgresDbService) *CoreRepoImpl

+ func (c *CoreRepoImpl) ExecuteFunction(ctx context.Context, name string, args map[string]interface{}) (any, error)

+ func (c *CoreRepoImpl) ExecuteQuery(name string, params models.QueryParams) (any, error)

+ func (c *CoreRepoImpl) ExecuteRawSQL(ctx context.Context, sql string) error

+ func (c *CoreRepoImpl) ListCollections(schema string) ([]models.Table, error)

+ func (c *CoreRepoImpl) Ping() (bool, error)

+ type DDLRepoImpl struct

+ func NewDDLRepo(db *PostgresDbService) *DDLRepoImpl

+ func (d *DDLRepoImpl) AddField(collection string, req models.AddColumnRequest) error

+ func (d *DDLRepoImpl) AlterCollection(collection string, req models.AlterTableRequest) error

+ func (d *DDLRepoImpl) CheckTableExists(tableName string) (bool, error)

+ func (d *DDLRepoImpl) CreateCollection(req models.CreateTableRequest) error

+ type DMLRepoImpl struct

+ func NewDMLRepo(db *PostgresDbService) *DMLRepoImpl

+ func (d *DMLRepoImpl) Delete(collection string, id any) error

+ func (d *DMLRepoImpl) Insert(collection string, data map[string]any) (any, error)

+ func (d *DMLRepoImpl) Update(collection string, id any, data map[string]any) (any, error)

+ type DSNBuilder interface

+ BuildDSN func(cfg *config.DatabaseConfig) (string, error)

+ func NewPostgresDSNBuilder() DSNBuilder

+ type DatabaseRepoImpl struct

+ func (dr *DatabaseRepoImpl) AsBulkRepo() interfaces.BulkRepo

+ func (dr *DatabaseRepoImpl) AsCoreRepo() interfaces.CoreRepo

+ func (dr *DatabaseRepoImpl) AsDDLRepo() interfaces.DDLRepo

+ func (dr *DatabaseRepoImpl) AsDMLRepo() interfaces.DMLRepo

+ func (dr *DatabaseRepoImpl) AsMigrationRepo() interfaces.MigrationRepo

+ func (dr *DatabaseRepoImpl) AsPerformanceRepo() interfaces.PerformanceRepo

+ func (dr *DatabaseRepoImpl) AsRelationshipRepo() interfaces.RelationshipRepo

+ type MigrationRepoImpl struct

+ func NewMigrationRepo(db *PostgresDbService) *MigrationRepoImpl

+ func (m *MigrationRepoImpl) GetMigrationHistory() ([]map[string]interface{}, error)

+ func (m *MigrationRepoImpl) RecordMigration(name, sql, checksum string) error

+ type PerformanceRepoImpl struct

+ func NewPerformanceRepo(db *PostgresDbService) *PerformanceRepoImpl

+ func (p *PerformanceRepoImpl) AnalyzeQuery(query string) ([]string, error)

+ func (p *PerformanceRepoImpl) CreateIndex(tableName, indexName, columns string) error

+ func (p *PerformanceRepoImpl) GetPerformanceMetrics() (map[string]interface{}, error)

+ type PostgresConnectorImpl struct

+ ConnMaxLifetime time.Duration

+ MaxIdleConns int

+ MaxOpenConns int

+ func (pc *PostgresConnectorImpl) Connect(dsn string) (interfaces.DB, error)

+ type PostgresDSNBuilder struct

+ func (pb *PostgresDSNBuilder) BuildDSN(cfg *config.DatabaseConfig) (string, error)

+ type PostgresDbService struct

+ func NewPostgresDbServiceInstance(db interfaces.DB) *PostgresDbService

+ func (postgresDbService *PostgresDbService) AddField(collection string, req models.AddColumnRequest) error

+ func (postgresDbService *PostgresDbService) AlterCollection(collection string, req models.AlterTableRequest) error

+ func (postgresDbService *PostgresDbService) AnalyzeQuery(query string) ([]string, error)

+ func (postgresDbService *PostgresDbService) BuildAdvancedQuery(tableName string, params models.QueryParams) (string, []interface{})

+ func (postgresDbService *PostgresDbService) BuildAggregateParts(aggregates []models.AggregateFunction) []string

+ func (postgresDbService *PostgresDbService) BuildAnyCondition(filter models.QueryFilter, argCounter int) (string, []interface{}, int)

+ func (postgresDbService *PostgresDbService) BuildColumnDefinitions(columns []models.ColumnDefinition) []string

+ func (postgresDbService *PostgresDbService) BuildComplexFilter(filter models.ComplexFilter, argCounter int) (string, []interface{}, int)

+ func (postgresDbService *PostgresDbService) BuildFilterCondition(filter models.QueryFilter, argCounter int) (string, []interface{}, int)

+ func (postgresDbService *PostgresDbService) BuildForeignKeyDefinitions(foreignKeys []models.ForeignKeyDef) []string

+ func (postgresDbService *PostgresDbService) BuildGroupByClause(groupBy []string) string

+ func (postgresDbService *PostgresDbService) BuildHavingClause(having []models.QueryFilter, argCounter int) (string, []interface{}, int)

+ func (postgresDbService *PostgresDbService) BuildInCondition(filter models.QueryFilter, useNot bool, argCounter int) (string, []interface{}, int)

+ func (postgresDbService *PostgresDbService) BuildJoinClause(joins []models.JoinClause) string

+ func (postgresDbService *PostgresDbService) BuildLimitOffsetClause(limit, offset *int, argCounter int) (string, []interface{})

+ func (postgresDbService *PostgresDbService) BuildNullCondition(filter models.QueryFilter, useNot bool, argCounter int) (string, []interface{}, int)

+ func (postgresDbService *PostgresDbService) BuildOrderByClause(orderBy []string) string

+ func (postgresDbService *PostgresDbService) BuildSelectClause(params models.QueryParams) (string, []interface{}, int)

+ func (postgresDbService *PostgresDbService) BuildSelectColumnParts(selectCols []string) []string

+ func (postgresDbService *PostgresDbService) BuildSimpleCondition(filter models.QueryFilter, operator string, argCounter int) (string, []interface{}, int)

+ func (postgresDbService *PostgresDbService) BuildWhereClause(params models.QueryParams, argCounter int) (string, []interface{}, int)

+ func (postgresDbService *PostgresDbService) BulkDelete(tableName string, ids []interface{}, idColumn string) (int64, error)

+ func (postgresDbService *PostgresDbService) BulkInsert(tableName string, records []map[string]interface{}) ([]map[string]interface{}, error)

+ func (postgresDbService *PostgresDbService) BulkUpdate(tableName string, updates []map[string]interface{}, whereColumn string) (int64, error)

+ func (postgresDbService *PostgresDbService) CheckTableExists(tableName string) (bool, error)

+ func (postgresDbService *PostgresDbService) ConvertComplexArray(val interface{}) interface{}

+ func (postgresDbService *PostgresDbService) ConvertPrimitiveArray(val interface{}) interface{}

+ func (postgresDbService *PostgresDbService) CreateCollection(req models.CreateTableRequest) error

+ func (postgresDbService *PostgresDbService) CreateIndex(tableName, indexName, columns string) error

+ func (postgresDbService *PostgresDbService) CreateIndexFromDefinition(tableName string, idx models.IndexDefinition) error

+ func (postgresDbService *PostgresDbService) Delete(collection string, id any) error

+ func (postgresDbService *PostgresDbService) DropColumn(tableName string, req models.DropColumnRequest) error

+ func (postgresDbService *PostgresDbService) ExecuteQuery(name string, params models.QueryParams) (any, error)

+ func (postgresDbService *PostgresDbService) ExecuteRawSQL(ctx context.Context, sql string) error

+ func (postgresDbService *PostgresDbService) GetMigrationHistory() ([]map[string]interface{}, error)

+ func (postgresDbService *PostgresDbService) GetPerformanceMetrics() (map[string]interface{}, error)

+ func (postgresDbService *PostgresDbService) Insert(collection string, data map[string]any) (any, error)

+ func (postgresDbService *PostgresDbService) IsValidAggregateFunction(funcName string) bool

+ func (postgresDbService *PostgresDbService) ListCollections(schema string) ([]models.Table, error)

+ func (postgresDbService *PostgresDbService) ModifyColumn(tableName string, req models.ModifyColumnRequest) error

+ func (postgresDbService *PostgresDbService) Ping() (bool, error)

+ func (postgresDbService *PostgresDbService) RecordMigration(name, sql, checksum string) error

+ func (postgresDbService *PostgresDbService) RenameColumn(tableName string, req models.RenameColumnRequest) error

+ func (postgresDbService *PostgresDbService) ToInterfaceSlice(v interface{}) ([]interface{}, bool)

+ func (postgresDbService *PostgresDbService) Update(collection string, id any, data map[string]any) (any, error)

+ func (postgresDbService *PostgresDbService) Upsert(tableName string, data map[string]interface{}, conflictColumns []string, ...) (map[string]interface{}, error)

+ func (postgresDbService *PostgresDbService) ValidateCreateTableRequest(req models.CreateTableRequest) error

+ func (r *PostgresDbService) CreateForeignKeyConstraint(relationship *models.RelationshipDefinition) error

+ func (r *PostgresDbService) CreateJoinTable(relationship *models.RelationshipDefinition, ...) error

+ func (r *PostgresDbService) DropJoinTable(tableName string) error

+ func (r *PostgresDbService) DropRelationshipConstraints(relationship *models.RelationshipDefinition) error

+ func (r *PostgresDbService) ExecuteFunction(ctx context.Context, name string, args map[string]interface{}) (any, error)

+ func (r *PostgresDbService) ForeignKeyConstraintExists(tableName string, constraintName string) (bool, error)

+ func (r *PostgresDbService) GetRelationshipData(ctx context.Context, relationship *models.RelationshipDefinition, ...) ([]map[string]interface{}, error)

+ func (r *PostgresDbService) RemoveManyToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, ...) (int, error)

+ func (r *PostgresDbService) RemoveOneToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, ...) (int, error)

+ func (r *PostgresDbService) SetManyToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, ...) ([]map[string]interface{}, error)

+ func (r *PostgresDbService) SetOneToManyRelation(relationship *models.RelationshipDefinition, sourceID interface{}, ...) error

+ func (r *PostgresDbService) SetOneToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, ...) error

+ func (r *PostgresDbService) SetOneToOneRelation(relationship *models.RelationshipDefinition, sourceID interface{}, ...) error

+ func (s *PostgresDbService) ParseRow(columns []string, rawValues []interface{}) map[string]interface{}

+ type RelationshipRepoImpl struct

+ func NewRelationshipRepo(db *PostgresDbService) *RelationshipRepoImpl

+ func (r *RelationshipRepoImpl) CreateForeignKeyConstraint(relationship *models.RelationshipDefinition) error

+ func (r *RelationshipRepoImpl) CreateJoinTable(relationship *models.RelationshipDefinition, ...) error

+ func (r *RelationshipRepoImpl) DropJoinTable(tableName string) error

+ func (r *RelationshipRepoImpl) DropRelationshipConstraints(relationship *models.RelationshipDefinition) error

+ func (r *RelationshipRepoImpl) GetRelationshipData(ctx context.Context, relationship *models.RelationshipDefinition, ...) ([]map[string]interface{}, error)

+ func (r *RelationshipRepoImpl) RemoveManyToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, ...) (int, error)

+ func (r *RelationshipRepoImpl) RemoveOneToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, ...) (int, error)

+ func (r *RelationshipRepoImpl) SetManyToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, ...) ([]map[string]interface{}, error)

+ func (r *RelationshipRepoImpl) SetOneToManyRelation(relationship *models.RelationshipDefinition, sourceID interface{}, ...) error

+ func (r *RelationshipRepoImpl) SetOneToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, ...) error

+ func (r *RelationshipRepoImpl) SetOneToOneRelation(relationship *models.RelationshipDefinition, sourceID interface{}, ...) error