pgsql

package
v0.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 15, 2026 License: MIT Imports: 14 Imported by: 0

README

postgres

A PostgreSQL Driver for GOE ORM

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewConfig

func NewConfig(c Config) config

Types

type Config

type Config struct {
	Logger           model.Logger
	IncludeArguments bool          // include all arguments used on query
	QueryThreshold   time.Duration // query threshold to warning on slow queries

	MigratePath string // output sql file, if defined the driver will not auto apply the migration.
}

type Connection

type Connection struct {
	// contains filtered or unexported fields
}

func (Connection) ExecContext

func (c Connection) ExecContext(ctx context.Context, query *model.Query) error

func (Connection) QueryContext

func (c Connection) QueryContext(ctx context.Context, query *model.Query) (model.Rows, error)

func (Connection) QueryRowContext

func (c Connection) QueryRowContext(ctx context.Context, query *model.Query) model.Row

type Driver

type Driver struct {
	// contains filtered or unexported fields
}

func Open

func Open(dsn string, c config) (driver *Driver)

func OpenDSN

func OpenDSN(dsn string) (driver *Driver)

func (*Driver) AddLogger

func (dr *Driver) AddLogger(logger model.Logger, err error) error

func (*Driver) Close

func (dr *Driver) Close() error

func (*Driver) DropColumn

func (db *Driver) DropColumn(schema, table, column string) error

func (*Driver) DropTable

func (db *Driver) DropTable(schema, table string) error

func (*Driver) ErrorTranslator

func (dr *Driver) ErrorTranslator() func(err error) error

func (*Driver) GetDatabaseConfig

func (d *Driver) GetDatabaseConfig() *model.DatabaseConfig

func (*Driver) Init

func (dr *Driver) Init() error

func (*Driver) KeywordHandler

func (dr *Driver) KeywordHandler(s string) string

func (*Driver) MigrateContext

func (db *Driver) MigrateContext(ctx context.Context, migrator *model.Migrator) error

func (*Driver) Name

func (dr *Driver) Name() string

func (*Driver) NewConnection

func (dr *Driver) NewConnection() model.Connection

func (*Driver) NewTransaction

func (dr *Driver) NewTransaction(ctx context.Context, opts *sql.TxOptions) (model.Transaction, error)

func (*Driver) RenameColumn

func (db *Driver) RenameColumn(schema, table, oldColumn, newColumn string) error

func (*Driver) RenameTable

func (db *Driver) RenameTable(schema, table, newTable string) error

func (*Driver) Stats

func (dr *Driver) Stats() sql.DBStats

type Row added in v0.8.1

type Row struct {
	// contains filtered or unexported fields
}

func (Row) Scan added in v0.8.1

func (r Row) Scan(dest ...any) error

type Rows

type Rows struct {
	// contains filtered or unexported fields
}

func (Rows) Close

func (rs Rows) Close() error

func (Rows) Next added in v0.8.1

func (rs Rows) Next() bool

func (Rows) Scan added in v0.8.1

func (rs Rows) Scan(dest ...any) error

type SavePoint

type SavePoint struct {
	// contains filtered or unexported fields
}

func (SavePoint) Commit

func (s SavePoint) Commit() error

func (SavePoint) Rollback

func (s SavePoint) Rollback() error

type Transaction

type Transaction struct {
	// contains filtered or unexported fields
}

func (Transaction) Commit

func (t Transaction) Commit() error

func (Transaction) ExecContext

func (t Transaction) ExecContext(ctx context.Context, query *model.Query) error

func (Transaction) QueryContext

func (t Transaction) QueryContext(ctx context.Context, query *model.Query) (model.Rows, error)

func (Transaction) QueryRowContext

func (t Transaction) QueryRowContext(ctx context.Context, query *model.Query) model.Row

func (Transaction) Rollback

func (t Transaction) Rollback() error

func (Transaction) SavePoint

func (t Transaction) SavePoint() (model.SavePoint, error)

Jump to

Keyboard shortcuts

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