mrpostgres

package
v0.11.4 Latest Latest
Warning

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

 Go to latest Published: Jun 30, 2024 License: Apache-2.0 Imports: 17 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnAdapter added in v0.3.1 

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

ConnAdapter - адаптер для работы с Postgres клиентом.

func New 

func New() *ConnAdapter

New - создаёт объект ConnAdapter.

func (*ConnAdapter) Cli added in v0.3.1 

func (c *ConnAdapter) Cli() *pgxpool.Pool

Cli - comment method.

func (*ConnAdapter) Close added in v0.3.1 

func (c *ConnAdapter) Close() error

Close - comment method.

func (*ConnAdapter) Connect added in v0.3.1 

func (c *ConnAdapter) Connect(ctx context.Context, opts Options) error

Connect - comment method.

func (*ConnAdapter) Exec added in v0.3.1 

func (c *ConnAdapter) Exec(ctx context.Context, sql string, args ...any) error

Exec - comment method.

func (*ConnAdapter) Ping added in v0.3.1 

func (c *ConnAdapter) Ping(ctx context.Context) error

Ping - comment method.

func (*ConnAdapter) Query added in v0.3.1 

func (c *ConnAdapter) Query(ctx context.Context, sql string, args ...any) (mrstorage.DBQueryRows, error)

Query - comment method.

func (*ConnAdapter) QueryRow added in v0.3.1 

func (c *ConnAdapter) QueryRow(ctx context.Context, sql string, args ...any) mrstorage.DBQueryRow

QueryRow - comment method.

type ConnManager added in v0.11.0 

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

ConnManager - Менеджер транзакций.

func NewConnManager added in v0.11.0 

func NewConnManager(conn *ConnAdapter) *ConnManager

NewConnManager - создаёт объект ConnManager.

func (*ConnManager) Conn added in v0.11.0 

func (m *ConnManager) Conn(ctx context.Context) mrstorage.DBConn

Conn - Возвращает соединение с PostgreSQL.

func (*ConnManager) Do added in v0.11.0 

func (m *ConnManager) Do(ctx context.Context, job func(ctx context.Context) error) error

Do - Запуск команды в транзакции. Пытается запустить в текущей транзакции, если ее нет, создает новую транзакцию.

type Options 

type Options struct {
	Host             string
	Port             string
	Database         string
	Username         string
	Password         string
	MaxPoolSize      int
	ConnAttempts     int
	ConnTimeout      time.Duration
	AfterConnectFunc func() any
}

Options - опции для создания соединения для ConnAdapter.

type SQLBuilderCondition added in v0.11.0 

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

SQLBuilderCondition - comment struct.

func NewSQLBuilderCondition added in v0.11.0 

func NewSQLBuilderCondition(where *SQLBuilderWhere) *SQLBuilderCondition

NewSQLBuilderCondition - создаёт объект SQLBuilderCondition.

func (*SQLBuilderCondition) Where added in v0.11.0 

func (b *SQLBuilderCondition) Where(f func(w mrstorage.SQLBuilderWhere) mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPart

Where - comment method.

type SQLBuilderLimit added in v0.11.0 

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

SQLBuilderLimit - comment struct.

func NewSQLBuilderLimit added in v0.11.0 

func NewSQLBuilderLimit(maxSize uint64) *SQLBuilderLimit

NewSQLBuilderLimit - создаёт объект SQLBuilderLimit.

func (*SQLBuilderLimit) OffsetLimit added in v0.11.0 

func (b *SQLBuilderLimit) OffsetLimit(index, size uint64) mrstorage.SQLBuilderPartFunc

OffsetLimit - comment method.

type SQLBuilderOrderBy added in v0.11.0 

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

SQLBuilderOrderBy - comment struct.

func NewSQLBuilderOrderBy added in v0.11.0 

func NewSQLBuilderOrderBy(ctx context.Context, defaultSort mrtype.SortParams) *SQLBuilderOrderBy

NewSQLBuilderOrderBy - создаёт объект SQLBuilderOrderBy.

func (*SQLBuilderOrderBy) DefaultField added in v0.11.0 

func (b *SQLBuilderOrderBy) DefaultField() mrstorage.SQLBuilderPartFunc

DefaultField - comment method.

func (*SQLBuilderOrderBy) Field added in v0.11.0 

func (b *SQLBuilderOrderBy) Field(name string, direction mrenum.SortDirection) mrstorage.SQLBuilderPartFunc

Field - comment method.

func (*SQLBuilderOrderBy) Join added in v0.11.0 

func (b *SQLBuilderOrderBy) Join(fields ...mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPartFunc

Join - comment method.

type SQLBuilderSelect added in v0.11.0 

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

SQLBuilderSelect - comment struct.

func NewSQLBuilderSelect added in v0.11.0 

func NewSQLBuilderSelect(where *SQLBuilderWhere, orderBy *SQLBuilderOrderBy, limit *SQLBuilderLimit) *SQLBuilderSelect

NewSQLBuilderSelect - создаёт объект SQLBuilderSelect.

func (*SQLBuilderSelect) Limit added in v0.11.0 

func (b *SQLBuilderSelect) Limit(f func(p mrstorage.SQLBuilderLimit) mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPart

Limit - comment method.

func (*SQLBuilderSelect) OrderBy added in v0.11.0 

func (b *SQLBuilderSelect) OrderBy(f func(o mrstorage.SQLBuilderOrderBy) mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPart

OrderBy - comment method.

func (*SQLBuilderSelect) Where added in v0.11.0 

func (b *SQLBuilderSelect) Where(f func(w mrstorage.SQLBuilderWhere) mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPart

Where - comment method.

type SQLBuilderSet added in v0.11.0 

type SQLBuilderSet struct{}

SQLBuilderSet - comment struct.

func NewSQLBuilderSet added in v0.11.0 

func NewSQLBuilderSet() *SQLBuilderSet

NewSQLBuilderSet - создаёт объект SQLBuilderSet.

func (*SQLBuilderSet) Field added in v0.11.0 

func (b *SQLBuilderSet) Field(name string, value any) mrstorage.SQLBuilderPartFunc

Field - comment method.

func (*SQLBuilderSet) Fields added in v0.11.0 

func (b *SQLBuilderSet) Fields(names []string, args []any) mrstorage.SQLBuilderPartFunc

Fields - comment method.

func (*SQLBuilderSet) Join added in v0.11.0 

func (b *SQLBuilderSet) Join(fields ...mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPartFunc

Join - comment method.

type SQLBuilderUpdate added in v0.11.0 

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

SQLBuilderUpdate - comment struct.

func NewSQLBuilderUpdate added in v0.11.0 

func NewSQLBuilderUpdate(set *SQLBuilderSet, where *SQLBuilderWhere) *SQLBuilderUpdate

NewSQLBuilderUpdate - создаёт объект SQLBuilderUpdate.

func NewSQLBuilderUpdateWithMeta added in v0.11.0 

func NewSQLBuilderUpdateWithMeta(meta *mrsql.EntityMetaUpdate, set *SQLBuilderSet, where *SQLBuilderWhere) *SQLBuilderUpdate

NewSQLBuilderUpdateWithMeta - создаёт объект SQLBuilderUpdate с метаинформацией.

func (*SQLBuilderUpdate) Set added in v0.11.0 

func (b *SQLBuilderUpdate) Set(f func(s mrstorage.SQLBuilderSet) mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPart

Set - comment method.

func (*SQLBuilderUpdate) SetFromEntity added in v0.11.0 

func (b *SQLBuilderUpdate) SetFromEntity(entity any) (mrstorage.SQLBuilderPart, error)

SetFromEntity - comment method.

func (*SQLBuilderUpdate) SetFromEntityWith added in v0.11.0 

func (b *SQLBuilderUpdate) SetFromEntityWith(
	entity any,
	extFields func(s mrstorage.SQLBuilderSet) mrstorage.SQLBuilderPartFunc,
) (mrstorage.SQLBuilderPart, error)

SetFromEntityWith - comment method.

func (*SQLBuilderUpdate) Where added in v0.11.0 

func (b *SQLBuilderUpdate) Where(f func(w mrstorage.SQLBuilderWhere) mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPart

Where - comment method.

type SQLBuilderWhere added in v0.11.0 

type SQLBuilderWhere struct{}

SQLBuilderWhere - comment struct.

func NewSQLBuilderWhere added in v0.11.0 

func NewSQLBuilderWhere() *SQLBuilderWhere

NewSQLBuilderWhere - создаёт объект SQLBuilderWhere.

func (*SQLBuilderWhere) Equal added in v0.11.0 

func (b *SQLBuilderWhere) Equal(name string, value any) mrstorage.SQLBuilderPartFunc

Equal - comment method.

func (*SQLBuilderWhere) Expr added in v0.11.0 

func (b *SQLBuilderWhere) Expr(expr string) mrstorage.SQLBuilderPartFunc

Expr - comment method.

func (*SQLBuilderWhere) ExprWithValue added in v0.11.0 

func (b *SQLBuilderWhere) ExprWithValue(expr string, value any) mrstorage.SQLBuilderPartFunc

ExprWithValue - sample: "UPPER(field_name) = %s".

func (*SQLBuilderWhere) FilterAnyOf added in v0.11.0 

func (b *SQLBuilderWhere) FilterAnyOf(name string, values any) mrstorage.SQLBuilderPartFunc

FilterAnyOf - 'values' support only slices else the func returns nil.

func (*SQLBuilderWhere) FilterEqualBool added in v0.11.0 

func (b *SQLBuilderWhere) FilterEqualBool(name string, value *bool) mrstorage.SQLBuilderPartFunc

FilterEqualBool - comment method.

func (*SQLBuilderWhere) FilterEqualInt64 added in v0.11.0 

func (b *SQLBuilderWhere) FilterEqualInt64(name string, value, empty int64) mrstorage.SQLBuilderPartFunc

FilterEqualInt64 - comment method.

func (*SQLBuilderWhere) FilterEqualString added in v0.11.0 

func (b *SQLBuilderWhere) FilterEqualString(name, value string) mrstorage.SQLBuilderPartFunc

FilterEqualString - comment method.

func (*SQLBuilderWhere) FilterEqualUUID added in v0.11.0 

func (b *SQLBuilderWhere) FilterEqualUUID(name string, value uuid.UUID) mrstorage.SQLBuilderPartFunc

FilterEqualUUID - comment method.

func (*SQLBuilderWhere) FilterLike added in v0.11.0 

func (b *SQLBuilderWhere) FilterLike(name, value string) mrstorage.SQLBuilderPartFunc

FilterLike - comment method.

func (*SQLBuilderWhere) FilterLikeFields added in v0.11.0 

func (b *SQLBuilderWhere) FilterLikeFields(names []string, value string) mrstorage.SQLBuilderPartFunc

FilterLikeFields - comment method.

func (*SQLBuilderWhere) FilterRangeInt64 added in v0.11.0 

func (b *SQLBuilderWhere) FilterRangeInt64(name string, value mrtype.RangeInt64, empty int64) mrstorage.SQLBuilderPartFunc

FilterRangeInt64 - comment method.

func (*SQLBuilderWhere) Greater added in v0.11.0 

func (b *SQLBuilderWhere) Greater(name string, value any) mrstorage.SQLBuilderPartFunc

Greater - comment method.

func (*SQLBuilderWhere) GreaterOrEqual added in v0.11.0 

func (b *SQLBuilderWhere) GreaterOrEqual(name string, value any) mrstorage.SQLBuilderPartFunc

GreaterOrEqual - comment method.

func (*SQLBuilderWhere) JoinAnd added in v0.11.0 

func (b *SQLBuilderWhere) JoinAnd(conds ...mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPartFunc

JoinAnd - comment method.

func (*SQLBuilderWhere) JoinOr added in v0.11.0 

func (b *SQLBuilderWhere) JoinOr(conds ...mrstorage.SQLBuilderPartFunc) mrstorage.SQLBuilderPartFunc

JoinOr - comment method.

func (*SQLBuilderWhere) Less added in v0.11.0 

func (b *SQLBuilderWhere) Less(name string, value any) mrstorage.SQLBuilderPartFunc

Less - comment method.

func (*SQLBuilderWhere) LessOrEqual added in v0.11.0 

func (b *SQLBuilderWhere) LessOrEqual(name string, value any) mrstorage.SQLBuilderPartFunc

LessOrEqual - comment method.

func (*SQLBuilderWhere) NotEqual added in v0.11.0 

func (b *SQLBuilderWhere) NotEqual(name string, value any) mrstorage.SQLBuilderPartFunc

NotEqual - comment method.

type TxManagerStub added in v0.11.0 

type TxManagerStub struct{}

TxManagerStub - фиктивный менеджер транзакций, который запускает только переданную работу без открытия транзакции.

func NewTxManagerStub added in v0.11.0 

func NewTxManagerStub() *TxManagerStub

NewTxManagerStub - создаёт объект TxManagerStub.

func (*TxManagerStub) Do added in v0.11.0 

func (m *TxManagerStub) Do(ctx context.Context, job func(ctx context.Context) error) error

Do - запускает работу без использования транзакции.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.