postgres_pgxpool

package
v1.0.194 Latest Latest
Warning

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

Go to latest
Published: Jun 26, 2025 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const TextConnBusy = "conn busy"

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

Variables

View Source
var NeedReconnect bool

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

View Source
var PgxPool *pgxpool.Pool

PgxPool - пул соединений к базе данных

Functions

func CloseConnection

func CloseConnection()

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

func CloseConnection_err

func CloseConnection_err() error

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

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() *pgxpool.Pool

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

func GetConnectionString

func GetConnectionString(ApplicationName string) string

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

func GetConnection_WithApplicationName

func GetConnection_WithApplicationName(ApplicationName string) *pgxpool.Pool

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

func IsClosed

func IsClosed() bool

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

func LogInfo_Connected

func LogInfo_Connected(err error)

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

func Ping_err

func Ping_err(ctxMain context.Context) error

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

func RawMultipleSQL

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

func Reconnect

func Reconnect(err error)

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

func Start

func Start(ApplicationName string)

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

func StartDB

func StartDB()

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

func Start_ctx

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

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

func WaitStop

func WaitStop()

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

Types

type SettingsINI

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

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

var Settings SettingsINI

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

Jump to

Keyboard shortcuts

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