postgres_pgxpool2

func AfterConnect_NoNull ¶

func AfterConnect_NoNull(ctx context.Context, conn *pgx.Conn) error

AfterConnect_NoNull - регистрирует обработчики для нужных типов чтобы NULL=default value

func CloseConnection ¶

func CloseConnection()

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

func CloseConnection_err ¶

func CloseConnection_err() error

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

func Connect ¶

func Connect()

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

func Connect_NoNull ¶

func Connect_NoNull(ApplicationName string)

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

func Connect_NoNull_err ¶

func Connect_NoNull_err(ApplicationName string) error

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

func Connect_WithApplicationName ¶

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_NoNull ¶

func GetConnection_NoNull(ApplicationName string) *pgxpool.Pool

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

func GetConnection_WithApplicationName ¶

func GetConnection_WithApplicationName(ApplicationName string) *pgxpool.Pool

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

func GetContext ¶ added in v1.0.247

func GetContext() *context.Context

GetContext возвращает указатель на контекст с защитой RLock

func GetWaitGroup ¶ added in v1.0.247

func GetWaitGroup() *sync.WaitGroup

GetWaitGroup - возвращает группу ожидания завершения всех частей программы

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 postgres_pgx.IConnectionTransaction, TextSQL string) (pgx.Rows, error)

func Reconnect ¶

func Reconnect(err error)

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

func ReplaceSchema ¶

func ReplaceSchema(TextSQL string) string

ReplaceSchema - заменяет "public." на Settings.DB_SCHEMA

func ReplaceSchemaName ¶

func ReplaceSchemaName(TextSQL, SchemaNameFrom string) string

ReplaceSchemaName - заменяет имя схемы в тексте SQL

func SetContext ¶ added in v1.0.247

func SetContext(ctx *context.Context)

SetContext устанавливает новое значение контекста с защитой Lock

func SetWaitGroup ¶ added in v1.0.247

func SetWaitGroup(wg *sync.WaitGroup)

SetWaitGroup - присваивает внешний WaitGroup

func Start ¶

func Start(ApplicationName string)

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

func StartDB ¶

func StartDB()

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

func Start_NoNull ¶

func Start_NoNull(ApplicationName string)

Start_NoNull - делает соединение с БД, отключение и др. запросы вместо null возвращают значение по умолчанию (пока только дата)

func Start_ctx ¶

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

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

func WaitStop ¶

func WaitStop()

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