postgres_pgx

package
v1.0.202 Latest Latest
Warning

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

 Go to latest Published: Jul 2, 2025 License: MIT Imports: 20 Imported by: 1

Documentation

Overview

копия файла из https://github.com/jackc/pgtype/timestamptz.go чтоб не выдавала ошибку на null чтобы дата NULL = time.Time{}

Index

Constants

View Source 
const TextConnBusy = "conn busy"

TextConnBusy - текст ошибки "conn busy"

Variables

View Source 
var Conn *pgx.Conn

Conn - соединение к базе данных

View Source 
var NeedReconnect bool

NeedReconnect - флаг необходимости переподключения

View Source 
var Settings = SettingsINI{}

Settings хранит все нужные переменные окружения

Functions

func AppendInt16 added in v1.0.200 

func AppendInt16(buf []byte, n int16) []byte

func AppendInt32 added in v1.0.200 

func AppendInt32(buf []byte, n int32) []byte

func AppendInt64 added in v1.0.200 

func AppendInt64(buf []byte, n int64) []byte

func AppendUint16 added in v1.0.200 

func AppendUint16(buf []byte, n uint16) []byte

func AppendUint32 added in v1.0.200 

func AppendUint32(buf []byte, n uint32) []byte

func AppendUint64 added in v1.0.200 

func AppendUint64(buf []byte, n uint64) []byte

func CloseConnection 

func CloseConnection()

CloseConnection - закрытие соединения с базой данных

func CloseConnection_err 

func CloseConnection_err() error

CloseConnection - закрытие соединения с базой данных

func Connect 

func Connect()

Connect_err - подключается к базе данных

func Connect_WithApplicationName added in v1.0.187 

func Connect_WithApplicationName(ApplicationName string)

Connect_WithApplicationName - подключается к базе данных, с указанием имени приложения

func Connect_WithApplicationName_err 

func Connect_WithApplicationName_err(ApplicationName string) error

Connect_WithApplicationName_err - подключается к базе данных, с указанием имени приложения

func Connect_err 

func Connect_err() error

Connect_err - подключается к базе данных

func FillSettings 

func FillSettings()

FillSettings загружает переменные окружения в структуру из файла или из переменных окружения

func GetConnection 

func GetConnection() *pgx.Conn

GetConnection - возвращает соединение к нужной базе данных

func GetConnectionString 

func GetConnectionString(ApplicationName string) string

GetConnectionString - возвращает строку соединения к базе данных

func GetConnection_WithApplicationName 

func GetConnection_WithApplicationName(ApplicationName string) *pgx.Conn

GetConnection_WithApplicationName - возвращает соединение к нужной базе данных, с указанием имени приложения

func IsClosed 

func IsClosed() bool

IsClosed проверка что база данных закрыта

func LogInfo_Connected added in v1.0.58 

func LogInfo_Connected(err error)

LogInfo_Connected - выводит сообщение в Лог, или паника при ошибке

func Ping_err added in v1.0.159 

func Ping_err(ctxMain context.Context) error

Ping_err - выполняет пустой запрос для теста соединения

func RawMultipleSQL added in v1.0.18 

func RawMultipleSQL(tx IConnectionTransaction, TextSQL string) (pgx.Rows, error)

func Reconnect 

func Reconnect(err error)

Reconnect повторное подключение к базе данных, если оно отключено или полная остановка программы

func SetInt32 added in v1.0.200 

func SetInt32(buf []byte, n int32)

func Start 

func Start(ApplicationName string)

Start - делает соединение с БД, отключение и др.

func StartDB 

func StartDB()

StartDB - делает соединение с БД, отключение и др.

func Start_ctx added in v1.0.58 

func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error

Start_ctx - необходимые процедуры для подключения к серверу БД Свой контекст и WaitGroup нужны для остановки работы сервиса Graceful shutdown Для тех кто пользуется этим репозиторием для старта и останова сервиса можно просто StartDB()

func WaitStop 

func WaitStop()

WaitStop - ожидает отмену глобального контекста

Types

type IConnectionTransaction added in v1.0.197 

type IConnectionTransaction interface {
	// Transaction management
	Begin(ctx context.Context) (pgx.Tx, error)

	// Query execution
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row

	// Batch operations
	SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults

	// Bulk copy operations
	CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
}

IConnectionTransaction - интерфейс для работы с базой данных объединяет в себе функции pgx.Conn, pgxpool.Pool и pgx.Tx чтобы передавать в функцию любой их них

type SettingsINI 

type SettingsINI struct {
	DB_HOST     string
	DB_PORT     string
	DB_NAME     string
	DB_SCHEMA   string
	DB_USER     string
	DB_PASSWORD string
}

SettingsINI - структура для хранения всех нужных переменных окружения

type Timestamptz added in v1.0.200 

type Timestamptz struct {
	Time             time.Time
	InfinityModifier pgtype.InfinityModifier
	Valid            bool
}

Timestamptz represents the PostgreSQL timestamptz type.

func (Timestamptz) MarshalJSON added in v1.0.200 

func (tstz Timestamptz) MarshalJSON() ([]byte, error)

func (*Timestamptz) Scan added in v1.0.200 

func (tstz *Timestamptz) Scan(src any) error

Scan implements the database/sql Scanner interface.

func (*Timestamptz) ScanTimestamptz added in v1.0.200 

func (tstz *Timestamptz) ScanTimestamptz(v Timestamptz) error

func (Timestamptz) TimestamptzValue added in v1.0.200 

func (tstz Timestamptz) TimestamptzValue() (Timestamptz, error)

func (*Timestamptz) UnmarshalJSON added in v1.0.200 

func (tstz *Timestamptz) UnmarshalJSON(b []byte) error

func (Timestamptz) Value added in v1.0.200 

func (tstz Timestamptz) Value() (driver.Value, error)

Value implements the database/sql/driver Valuer interface.

type TimestamptzCodec added in v1.0.200 

type TimestamptzCodec struct {
	// ScanLocation is the location to return scanned timestamptz values in. This does not change the instant in time that
	// the timestamptz represents.
	ScanLocation *time.Location
}

func (*TimestamptzCodec) DecodeDatabaseSQLValue added in v1.0.200 

func (c *TimestamptzCodec) DecodeDatabaseSQLValue(m *pgtype.Map, oid uint32, format int16, src []byte) (driver.Value, error)

func (*TimestamptzCodec) DecodeValue added in v1.0.200 

func (c *TimestamptzCodec) DecodeValue(m *pgtype.Map, oid uint32, format int16, src []byte) (any, error)

func (*TimestamptzCodec) FormatSupported added in v1.0.200 

func (*TimestamptzCodec) FormatSupported(format int16) bool

func (*TimestamptzCodec) PlanEncode added in v1.0.200 

func (*TimestamptzCodec) PlanEncode(m *pgtype.Map, oid uint32, format int16, value any) pgtype.EncodePlan

func (*TimestamptzCodec) PlanScan added in v1.0.200 

func (c *TimestamptzCodec) PlanScan(m *pgtype.Map, oid uint32, format int16, target any) pgtype.ScanPlan

func (*TimestamptzCodec) PreferredFormat added in v1.0.200 

func (*TimestamptzCodec) PreferredFormat() int16

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.