postgresql

package

Go to main page

Versions in this module

v0

v0.6.0

Jul 26, 2025

Changes in this version

type PostgreSQLCapabilities

+ func (c *PostgreSQLCapabilities) SupportsForeignKeys() bool

type PostgreSQLMigrator

+ func (m *PostgreSQLMigrator) IsPrimaryKeyIndex(indexName string) bool

+ func (m *PostgreSQLMigrator) MapDatabaseTypeToFieldType(dbType string) schema.FieldType

+ func (m *PostgreSQLMigrator) NormalizeDefaultToPrismaFunction(value any, fieldType schema.FieldType) (string, bool)

+ func (m *PostgreSQLMigrator) ParseDefaultValue(value any, fieldType schema.FieldType) any

type PostgreSQLMigratorWrapper

+ func (w *PostgreSQLMigratorWrapper) GetSpecific() types.DatabaseSpecificMigrator

type PostgreSQLTransactionDB

+ func (t *PostgreSQLTransactionDB) GetLogger() logger.Logger

+ func (t *PostgreSQLTransactionDB) SetLogger(l logger.Logger)

v0.5.0

Jul 19, 2025

v0.4.0

Jul 8, 2025

v0.3.0

Jul 7, 2025

v0.2.0

Jul 7, 2025

Changes in this version

+ func NewPostgreSQLMigrator(db *sql.DB, postgresqlDB *PostgreSQLDB) types.DatabaseMigrator

+ type PostgreSQLCapabilities struct

+ func NewPostgreSQLCapabilities() *PostgreSQLCapabilities

+ func (c *PostgreSQLCapabilities) GetBooleanLiteral(value bool) string

+ func (c *PostgreSQLCapabilities) GetDriverType() types.DriverType

+ func (c *PostgreSQLCapabilities) GetNullsOrderingSQL(direction types.Order, nullsFirst bool) string

+ func (c *PostgreSQLCapabilities) GetPlaceholder(index int) string

+ func (c *PostgreSQLCapabilities) GetSupportedSchemes() []string

+ func (c *PostgreSQLCapabilities) IsNoSQL() bool

+ func (c *PostgreSQLCapabilities) IsSystemIndex(indexName string) bool

+ func (c *PostgreSQLCapabilities) IsSystemTable(tableName string) bool

+ func (c *PostgreSQLCapabilities) NeedsTypeConversion() bool

+ func (c *PostgreSQLCapabilities) QuoteIdentifier(name string) string

+ func (c *PostgreSQLCapabilities) RequiresLimitForOffset() bool

+ func (c *PostgreSQLCapabilities) SupportsAggregationPipeline() bool

+ func (c *PostgreSQLCapabilities) SupportsArrayFields() bool

+ func (c *PostgreSQLCapabilities) SupportsDefaultValues() bool

+ func (c *PostgreSQLCapabilities) SupportsDistinctOn() bool

+ func (c *PostgreSQLCapabilities) SupportsNestedDocuments() bool

+ func (c *PostgreSQLCapabilities) SupportsReturning() bool

+ func (c *PostgreSQLCapabilities) SupportsTransactions() bool

+ type PostgreSQLDB struct

+ func NewPostgreSQLDB(nativeURI string) (*PostgreSQLDB, error)

+ func (p *PostgreSQLDB) Begin(ctx context.Context) (types.Transaction, error)

+ func (p *PostgreSQLDB) Connect(ctx context.Context) error

+ func (p *PostgreSQLDB) CreateModel(ctx context.Context, modelName string) error

+ func (p *PostgreSQLDB) DropModel(ctx context.Context, modelName string) error

+ func (p *PostgreSQLDB) Exec(query string, args ...any) (sql.Result, error)

+ func (p *PostgreSQLDB) GetBooleanLiteral(value bool) string

+ func (p *PostgreSQLDB) GetCapabilities() types.DriverCapabilities

+ func (p *PostgreSQLDB) GetDriverType() string

+ func (p *PostgreSQLDB) GetMigrator() types.DatabaseMigrator

+ func (p *PostgreSQLDB) Model(modelName string) types.ModelQuery

+ func (p *PostgreSQLDB) Query(query string, args ...any) (*sql.Rows, error)

+ func (p *PostgreSQLDB) QueryRow(query string, args ...any) *sql.Row

+ func (p *PostgreSQLDB) Raw(query string, args ...any) types.RawQuery

+ func (p *PostgreSQLDB) SyncSchemas(ctx context.Context) error

+ func (p *PostgreSQLDB) Transaction(ctx context.Context, fn func(tx types.Transaction) error) error

+ type PostgreSQLMigrator struct

+ func (m *PostgreSQLMigrator) ApplyMigration(sql string) error

+ func (m *PostgreSQLMigrator) ConvertFieldToColumnInfo(field schema.Field) *types.ColumnInfo

+ func (m *PostgreSQLMigrator) FormatDefaultValue(value any) string

+ func (m *PostgreSQLMigrator) GenerateAddColumnSQL(tableName string, column any) (string, error)

+ func (m *PostgreSQLMigrator) GenerateColumnDefinition(field schema.Field) string

+ func (m *PostgreSQLMigrator) GenerateColumnDefinitionFromColumnInfo(column types.ColumnInfo) string

+ func (m *PostgreSQLMigrator) GenerateCreateIndexSQL(tableName, indexName string, columns []string, unique bool) string

+ func (m *PostgreSQLMigrator) GenerateCreateTableSQL(schema *schema.Schema) (string, error)

+ func (m *PostgreSQLMigrator) GenerateDropColumnSQL(tableName, columnName string) ([]string, error)

+ func (m *PostgreSQLMigrator) GenerateDropIndexSQL(indexName string) string

+ func (m *PostgreSQLMigrator) GenerateDropTableSQL(tableName string) string

+ func (m *PostgreSQLMigrator) GenerateModifyColumnSQL(change types.ColumnChange) ([]string, error)

+ func (m *PostgreSQLMigrator) GetDatabaseType() string

+ func (m *PostgreSQLMigrator) GetTableInfo(tableName string) (*types.TableInfo, error)

+ func (m *PostgreSQLMigrator) GetTables() ([]string, error)

+ func (m *PostgreSQLMigrator) IsSystemIndex(indexName string) bool

+ func (m *PostgreSQLMigrator) IsSystemTable(tableName string) bool

+ func (m *PostgreSQLMigrator) MapFieldType(field schema.Field) string

+ type PostgreSQLMigratorWrapper struct

+ func (w *PostgreSQLMigratorWrapper) CompareSchema(existingTable *types.TableInfo, desiredSchema any) (*types.MigrationPlan, error)

+ func (w *PostgreSQLMigratorWrapper) GenerateAddColumnSQL(tableName string, field any) (string, error)

+ func (w *PostgreSQLMigratorWrapper) GenerateCreateTableSQL(schemaInterface any) (string, error)

+ func (w *PostgreSQLMigratorWrapper) IsSystemTable(tableName string) bool

+ type PostgreSQLRawQuery struct

+ func (q *PostgreSQLRawQuery) Exec(ctx context.Context) (types.Result, error)

+ func (q *PostgreSQLRawQuery) Find(ctx context.Context, dest any) error

+ func (q *PostgreSQLRawQuery) FindOne(ctx context.Context, dest any) error

+ type PostgreSQLTransaction struct

+ func (t *PostgreSQLTransaction) Commit(ctx context.Context) error

+ func (t *PostgreSQLTransaction) CreateMany(ctx context.Context, modelName string, data []any) (types.Result, error)

+ func (t *PostgreSQLTransaction) DeleteMany(ctx context.Context, modelName string, condition types.Condition) (types.Result, error)

+ func (t *PostgreSQLTransaction) Model(modelName string) types.ModelQuery

+ func (t *PostgreSQLTransaction) Raw(query string, args ...any) types.RawQuery

+ func (t *PostgreSQLTransaction) ReleaseSavepoint(ctx context.Context, name string) error

+ func (t *PostgreSQLTransaction) Rollback(ctx context.Context) error

+ func (t *PostgreSQLTransaction) RollbackTo(ctx context.Context, name string) error

+ func (t *PostgreSQLTransaction) Savepoint(ctx context.Context, name string) error

+ func (t *PostgreSQLTransaction) UpdateMany(ctx context.Context, modelName string, condition types.Condition, data any) (types.Result, error)

+ type PostgreSQLTransactionDB struct

+ func (t *PostgreSQLTransactionDB) Begin(ctx context.Context) (types.Transaction, error)

+ func (t *PostgreSQLTransactionDB) Close() error

+ func (t *PostgreSQLTransactionDB) Connect(ctx context.Context) error

+ func (t *PostgreSQLTransactionDB) CreateModel(ctx context.Context, modelName string) error

+ func (t *PostgreSQLTransactionDB) DropModel(ctx context.Context, modelName string) error

+ func (t *PostgreSQLTransactionDB) Exec(query string, args ...any) (sql.Result, error)

+ func (t *PostgreSQLTransactionDB) GetCapabilities() types.DriverCapabilities

+ func (t *PostgreSQLTransactionDB) GetDriverType() string

+ func (t *PostgreSQLTransactionDB) GetMigrator() types.DatabaseMigrator

+ func (t *PostgreSQLTransactionDB) GetModelSchema(modelName string) (*schema.Schema, error)

+ func (t *PostgreSQLTransactionDB) GetModels() []string

+ func (t *PostgreSQLTransactionDB) GetSchema(modelName string) (*schema.Schema, error)

+ func (t *PostgreSQLTransactionDB) LoadSchema(ctx context.Context, schemaContent string) error

+ func (t *PostgreSQLTransactionDB) LoadSchemaFrom(ctx context.Context, filename string) error

+ func (t *PostgreSQLTransactionDB) Model(modelName string) types.ModelQuery

+ func (t *PostgreSQLTransactionDB) Ping(ctx context.Context) error

+ func (t *PostgreSQLTransactionDB) Query(query string, args ...any) (*sql.Rows, error)

+ func (t *PostgreSQLTransactionDB) QueryRow(query string, args ...any) *sql.Row

+ func (t *PostgreSQLTransactionDB) Raw(query string, args ...any) types.RawQuery

+ func (t *PostgreSQLTransactionDB) RegisterSchema(modelName string, s *schema.Schema) error

+ func (t *PostgreSQLTransactionDB) ResolveFieldName(modelName, fieldName string) (string, error)

+ func (t *PostgreSQLTransactionDB) ResolveFieldNames(modelName string, fieldNames []string) ([]string, error)

+ func (t *PostgreSQLTransactionDB) ResolveTableName(modelName string) (string, error)

+ func (t *PostgreSQLTransactionDB) SyncSchemas(ctx context.Context) error

+ func (t *PostgreSQLTransactionDB) Transaction(ctx context.Context, fn func(tx types.Transaction) error) error

+ type PostgreSQLTransactionRawQuery struct

+ func (q *PostgreSQLTransactionRawQuery) Exec(ctx context.Context) (types.Result, error)

+ func (q *PostgreSQLTransactionRawQuery) Find(ctx context.Context, dest any) error

+ func (q *PostgreSQLTransactionRawQuery) FindOne(ctx context.Context, dest any) error

+ type PostgreSQLURIParser struct

+ func NewPostgreSQLURIParser() *PostgreSQLURIParser

+ func (p *PostgreSQLURIParser) GetDriverType() string

+ func (p *PostgreSQLURIParser) GetSupportedSchemes() []string

+ func (p *PostgreSQLURIParser) ParseURI(uri string) (string, error)

v0.1.0

Jul 4, 2025

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL