Documentation
¶
Index ¶
- Constants
- Variables
- func CloseConnection()
- func CloseConnection_err() error
- func Connect()
- func Connect_WithApplicationName(ApplicationName string)
- func Connect_WithApplicationName_err(ApplicationName string) error
- func Connect_err() error
- func FillSettings()
- func GetConnection() *pgx.Conn
- func GetConnectionString(ApplicationName string) string
- func GetConnection_WithApplicationName(ApplicationName string) *pgx.Conn
- func GetContext() *context.Context
- func GetWaitGroup() *sync.WaitGroup
- func IsClosed() bool
- func LogInfo_Connected(err error)
- func Ping_err(ctxMain context.Context) error
- func RawMultipleSQL(tx IConnectionTransaction, TextSQL string) (pgx.Rows, error)
- func Reconnect(err error)
- func ReplaceSchema(TextSQL string) string
- func ReplaceSchemaName(TextSQL, SchemaNameFrom string) string
- func SetContext(ctx *context.Context)
- func SetWaitGroup(wg *sync.WaitGroup)
- func Start(ApplicationName string)
- func StartDB()
- func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error
- func WaitStop()
- type IConnectionTransaction
- type SettingsINI
Constants ¶
const PackageName = "postgres_pgx"
PackageName - имя текущего пакета, для логирования
const TextConnBusy = "conn busy"
TextConnBusy - текст ошибки "conn busy"
Variables ¶
var Conn *pgx.Conn
Conn - соединение к базе данных
var NeedReconnect bool
NeedReconnect - флаг необходимости переподключения
var Settings = SettingsINI{}
Settings хранит все нужные переменные окружения
Functions ¶
func CloseConnection_err ¶
func CloseConnection_err() error
CloseConnection - закрытие соединения с базой данных
func Connect_WithApplicationName ¶ added in v1.0.187
func Connect_WithApplicationName(ApplicationName string)
Connect_WithApplicationName - подключается к базе данных, с указанием имени приложения
func Connect_WithApplicationName_err ¶
Connect_WithApplicationName_err - подключается к базе данных, с указанием имени приложения
func FillSettings ¶
func FillSettings()
FillSettings загружает переменные окружения в структуру из файла или из переменных окружения
func GetConnection ¶
GetConnection - возвращает соединение к нужной базе данных
func GetConnectionString ¶
GetConnectionString - возвращает строку соединения к базе данных
func GetConnection_WithApplicationName ¶
GetConnection_WithApplicationName - возвращает соединение к нужной базе данных, с указанием имени приложения
func GetContext ¶ added in v1.0.247
GetContext возвращает указатель на контекст с защитой RLock
func GetWaitGroup ¶ added in v1.0.247
GetWaitGroup - возвращает группу ожидания завершения всех частей программы
func LogInfo_Connected ¶ added in v1.0.58
func LogInfo_Connected(err error)
LogInfo_Connected - выводит сообщение в Лог, или паника при ошибке
func RawMultipleSQL ¶ added in v1.0.18
func RawMultipleSQL(tx IConnectionTransaction, TextSQL string) (pgx.Rows, error)
func Reconnect ¶
func Reconnect(err error)
Reconnect повторное подключение к базе данных, если оно отключено или полная остановка программы
func ReplaceSchema ¶ added in v1.0.215
ReplaceSchema - заменяет "public." на Settings.DB_SCHEMA
func ReplaceSchemaName ¶ added in v1.0.215
ReplaceSchemaName - заменяет имя схемы в тексте SQL
func SetContext ¶ added in v1.0.247
SetContext устанавливает новое значение контекста с защитой Lock
func SetWaitGroup ¶ added in v1.0.247
SetWaitGroup - присваивает внешний WaitGroup
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 чтобы передавать в функцию любой их них
Source Files