сделал postgres_pgxpool

postgres_pgx/postgres_pgx.go

@@ -6,6 +6,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"github.com/ManyakRus/starter/constants"
 	"github.com/ManyakRus/starter/log"
 	"github.com/ManyakRus/starter/port_checker"
 	"github.com/jackc/pgx/v5"
@@ -141,7 +142,7 @@ func GetConnectionString(ApplicationName string) string {
 	dsn += "user=" + Settings.DB_USER + " "
 	dsn += "password=" + Settings.DB_PASSWORD + " "
 	dsn += "dbname=" + Settings.DB_NAME + " "
-	dsn += "port=" + Settings.DB_PORT + " sslmode=disable TimeZone=UTC "
+	dsn += "port=" + Settings.DB_PORT + " sslmode=disable TimeZone=" + constants.TIME_ZONE + " "
 	dsn += "application_name=" + ApplicationName
 
 	return dsn
@@ -380,31 +381,31 @@ loop:
 			break loop
 		case <-ticker.C:
 
-			//ping в базе данных
-			mutex_Connect.RLock() //race
-			//err = GetConnection().Ping(ctx) //ping делать нельзя т.к. data race
-			err = Ping_err(ctx)
-			mutex_Connect.RUnlock()
-			if err != nil {
-				switch err.Error() {
-				case TextConnBusy:
-					{
-						log.Warn("postgres_pgx Ping() warning: ", err)
-					}
-				default:
-					{
-						NeedReconnect = true
-						log.Error("postgres_pgx Ping() error: ", err)
-					}
-				}
-
-			} else {
-				//IsClosed
-				if GetConnection().IsClosed() == true {
-					NeedReconnect = true
-					log.Error("postgres_pgx error: IsClosed() = true")
-				}
-			}
+			////ping в базе данных
+			//mutex_Connect.RLock() //race
+			////err = GetConnection().Ping(ctx) //ping делать нельзя т.к. data race
+			//err = Ping_err(ctx)
+			//mutex_Connect.RUnlock()
+			//if err != nil {
+			//	switch err.Error() {
+			//	case TextConnBusy:
+			//		{
+			//			log.Warn("postgres_pgx Ping() warning: ", err)
+			//		}
+			//	default:
+			//		{
+			//			NeedReconnect = true
+			//			log.Error("postgres_pgx Ping() error: ", err)
+			//		}
+			//	}
+			//
+			//} else {
+			//	//IsClosed
+			//	if GetConnection().IsClosed() == true {
+			//		NeedReconnect = true
+			//		log.Error("postgres_pgx error: IsClosed() = true")
+			//	}
+			//}
 
 			//ping порта
 			err = port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
@@ -447,7 +448,8 @@ func GetConnection() *pgx.Conn {
 // GetConnection_WithApplicationName - возвращает соединение к нужной базе данных, с указанием имени приложения
 func GetConnection_WithApplicationName(ApplicationName string) *pgx.Conn {
 	if Conn == nil {
-		Connect_WithApplicationName_err(ApplicationName)
+		err := Connect_WithApplicationName_err(ApplicationName)
+		LogInfo_Connected(err)
 	}
 
 	return Conn

postgres_pgx/postgres_pgx_test.go

@@ -2,6 +2,7 @@ package postgres_pgx
 
 import (
 	"errors"
+	"golang.org/x/net/context"
 	"testing"
 	"time"
 
@@ -130,7 +131,11 @@ select 1;
 SELECT * FROM temp_TestRawMultipleSQL2
 `
 	//TextSQL := "SELECT 1; SELECT 2"
-	Rows, err := RawMultipleSQL(Conn, TextSQL)
+	ctx := context.Background()
+	tx, err := Conn.Begin(ctx)
+	defer tx.Commit(ctx)
+	Rows, err := RawMultipleSQL(tx, TextSQL)
+	defer Rows.Close()
 	if err != nil {
 		t.Error("TestRawMultipleSQL() error: ", err)
 		return

postgres_pgxpool/postgres_pgxpool.go

@@ -0,0 +1,525 @@
+// модуль для работы с базой данных
+
+package postgres_pgxpool
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"github.com/ManyakRus/starter/constants"
+	"github.com/ManyakRus/starter/log"
+	"github.com/ManyakRus/starter/port_checker"
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgxpool"
+	"strings"
+	"time"
+
+	"github.com/ManyakRus/starter/contextmain"
+	"github.com/ManyakRus/starter/micro"
+	"github.com/ManyakRus/starter/stopapp"
+	"os"
+	"sync"
+)
+
+// PgxPool - пул соединений к базе данных
+var PgxPool *pgxpool.Pool
+
+// mutex_Connect - защита от многопоточности Connect()
+var mutex_Connect = &sync.RWMutex{}
+
+// mutex_ReConnect - защита от многопоточности ReConnect()
+var mutex_ReConnect = &sync.RWMutex{}
+
+// Settings хранит все нужные переменные окружения
+var Settings SettingsINI
+
+// NeedReconnect - флаг необходимости переподключения
+var NeedReconnect bool
+
+// SettingsINI - структура для хранения всех нужных переменных окружения
+type SettingsINI struct {
+	DB_HOST     string
+	DB_PORT     string
+	DB_NAME     string
+	DB_SCHEMA   string
+	DB_USER     string
+	DB_PASSWORD string
+}
+
+// TextConnBusy - текст ошибки "conn busy"
+const TextConnBusy = "conn busy"
+
+// timeOutSeconds - время ожидания для Ping()
+const timeOutSeconds = 60
+
+// Connect_err - подключается к базе данных
+func Connect() {
+
+	if Settings.DB_HOST == "" {
+		FillSettings()
+	}
+
+	port_checker.CheckPort(Settings.DB_HOST, Settings.DB_PORT)
+
+	err := Connect_err()
+	LogInfo_Connected(err)
+
+}
+
+// LogInfo_Connected - выводит сообщение в Лог, или паника при ошибке
+func LogInfo_Connected(err error) {
+	if err != nil {
+		log.Panicln("POSTGRES pgxpool Connect() to database host: ", Settings.DB_HOST, ", Error: ", err)
+	} else {
+		log.Info("POSTGRES pgxpool Connected. host: ", Settings.DB_HOST, ", base name: ", Settings.DB_NAME, ", schema: ", Settings.DB_SCHEMA)
+	}
+
+}
+
+// Connect_err - подключается к базе данных
+func Connect_err() error {
+	var err error
+	err = Connect_WithApplicationName_err("")
+
+	return err
+}
+
+// Connect_WithApplicationName_err - подключается к базе данных, с указанием имени приложения
+func Connect_WithApplicationName_err(ApplicationName string) error {
+	var err error
+
+	if Settings.DB_HOST == "" {
+		FillSettings()
+	}
+
+	//
+	if contextmain.GetContext().Err() != nil {
+		return contextmain.GetContext().Err()
+	}
+
+	//
+	ctxMain := contextmain.GetContext()
+	ctx, cancel := context.WithTimeout(ctxMain, 60*time.Second)
+	defer cancel()
+
+	databaseUrl := GetConnectionString(ApplicationName)
+
+	//
+	config, err := pgxpool.ParseConfig(databaseUrl)
+	//config.PreferSimpleProtocol = true //для мульти-запросов
+	PgxPool = nil
+	PgxPool, err = pgxpool.NewWithConfig(ctx, config)
+	if err != nil {
+		err = fmt.Errorf("pgxpool.NewWithConfig() error: %w", err)
+	}
+
+	if err == nil {
+		err = PgxPool.Ping(ctx)
+	}
+
+	return err
+}
+
+// GetConnectionString - возвращает строку соединения к базе данных
+func GetConnectionString(ApplicationName string) string {
+	ApplicationName = strings.ReplaceAll(ApplicationName, " ", "_")
+
+	dsn := "host=" + Settings.DB_HOST + " "
+	dsn += "user=" + Settings.DB_USER + " "
+	dsn += "password=" + Settings.DB_PASSWORD + " "
+	dsn += "dbname=" + Settings.DB_NAME + " "
+	dsn += "port=" + Settings.DB_PORT + " sslmode=disable TimeZone=" + constants.TIME_ZONE + " "
+	dsn += "application_name=" + ApplicationName
+
+	return dsn
+}
+
+// IsClosed проверка что база данных закрыта
+func IsClosed() bool {
+	var Otvet bool
+
+	if PgxPool == nil {
+		return true
+	}
+
+	ctx := contextmain.GetContext()
+	conn, err := GetConnection_err()
+	if err != nil {
+		return true
+	}
+	err = conn.Ping(ctx)
+	if err != nil {
+		return true
+	}
+	return Otvet
+}
+
+// Reconnect повторное подключение к базе данных, если оно отключено
+// или полная остановка программы
+func Reconnect(err error) {
+	mutex_ReConnect.Lock()
+	defer mutex_ReConnect.Unlock()
+
+	if err == nil {
+		return
+	}
+
+	if errors.Is(err, context.Canceled) {
+		return
+	}
+
+	if PgxPool == nil {
+		log.Warn("Reconnect()")
+		err := Connect_err()
+		if err != nil {
+			log.Error("error: ", err)
+		}
+		return
+	}
+
+	if IsClosed() {
+		micro.Pause(1000)
+		log.Warn("Reconnect()")
+		err := Connect_err()
+		if err != nil {
+			log.Error("error: ", err)
+		}
+		return
+	}
+
+	sError := err.Error()
+	if sError == "PgxPool closed" {
+		micro.Pause(1000)
+		log.Warn("Reconnect()")
+		err := Connect_err()
+		if err != nil {
+			log.Error("error: ", err)
+		}
+		return
+	}
+
+	//остановим программу т.к. она не должна работать при неработающеё БД
+	log.Error("STOP app. Error: ", err)
+	stopapp.StopApp()
+
+}
+
+// CloseConnection - закрытие соединения с базой данных
+func CloseConnection() {
+	if PgxPool == nil {
+		return
+	}
+
+	err := CloseConnection_err()
+	if err != nil {
+		log.Error("POSTGRES pgxpool CloseConnection() error: ", err)
+	} else {
+		log.Info("POSTGRES pgxpool connection closed")
+	}
+
+}
+
+// CloseConnection_err - закрытие соединения с базой данных
+func CloseConnection_err() error {
+	var err error
+
+	if PgxPool == nil {
+		return err
+	}
+
+	//ctxMain := contextmain.GetContext()
+	//ctx, cancel := context.WithTimeout(ctxMain, 60*time.Second)
+	//defer cancel()
+
+	mutex_Connect.Lock()
+	defer mutex_Connect.Unlock()
+
+	PgxPool.Reset()
+	//PgxPool.Close()
+
+	return err
+}
+
+// WaitStop - ожидает отмену глобального контекста
+func WaitStop() {
+	defer stopapp.GetWaitGroup_Main().Done()
+
+	select {
+	case <-contextmain.GetContext().Done():
+		log.Warn("Context app is canceled. postgres_pgxpool")
+	}
+
+	//
+	stopapp.WaitTotalMessagesSendingNow("postgres_pgxpool")
+
+	//
+	CloseConnection()
+}
+
+// StartDB - делает соединение с БД, отключение и др.
+func StartDB() {
+	var err error
+
+	ctx := contextmain.GetContext()
+	WaitGroup := stopapp.GetWaitGroup_Main()
+	err = Start_ctx(&ctx, WaitGroup)
+	LogInfo_Connected(err)
+
+}
+
+// Start_ctx - необходимые процедуры для подключения к серверу БД
+// Свой контекст и WaitGroup нужны для остановки работы сервиса Graceful shutdown
+// Для тех кто пользуется этим репозиторием для старта и останова сервиса можно просто StartDB()
+func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
+	var err error
+
+	//запомним к себе контекст
+	if contextmain.Ctx != ctx {
+		contextmain.SetContext(ctx)
+	}
+	//contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
+	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
+
+	//
+	err = Connect_err()
+	if err != nil {
+		return err
+	}
+
+	stopapp.GetWaitGroup_Main().Add(1)
+	go WaitStop()
+
+	stopapp.GetWaitGroup_Main().Add(1)
+	go ping_go()
+
+	return err
+}
+
+// Start - делает соединение с БД, отключение и др.
+func Start(ApplicationName string) {
+	err := Connect_WithApplicationName_err(ApplicationName)
+	LogInfo_Connected(err)
+
+	stopapp.GetWaitGroup_Main().Add(1)
+	go WaitStop()
+
+	stopapp.GetWaitGroup_Main().Add(1)
+	go ping_go()
+
+}
+
+// FillSettings загружает переменные окружения в структуру из файла или из переменных окружения
+func FillSettings() {
+	Settings = SettingsINI{}
+	Settings.DB_HOST = os.Getenv("DB_HOST")
+	Settings.DB_PORT = os.Getenv("DB_PORT")
+	Settings.DB_NAME = os.Getenv("DB_NAME")
+	Settings.DB_SCHEMA = os.Getenv("DB_SCHEME")
+	Settings.DB_USER = os.Getenv("DB_USER")
+	Settings.DB_PASSWORD = os.Getenv("DB_PASSWORD")
+
+	if Settings.DB_HOST == "" {
+		log.Panicln("Need fill DB_HOST ! in os.ENV ")
+	}
+
+	if Settings.DB_PORT == "" {
+		log.Panicln("Need fill DB_PORT ! in os.ENV ")
+	}
+
+	if Settings.DB_NAME == "" {
+		log.Panicln("Need fill DB_NAME ! in os.ENV ")
+	}
+
+	if Settings.DB_SCHEMA == "" {
+		log.Panicln("Need fill DB_SCHEME ! in os.ENV ")
+	}
+	if Settings.DB_USER == "" {
+		log.Panicln("Need fill DB_USER ! in os.ENV ")
+	}
+
+	if Settings.DB_PASSWORD == "" {
+		log.Panicln("Need fill DB_PASSWORD ! in os.ENV ")
+	}
+
+	//
+}
+
+// ping_go - делает пинг каждые 60 секунд, и реконнект
+func ping_go() {
+	var err error
+
+	defer stopapp.GetWaitGroup_Main().Done()
+
+	ticker := time.NewTicker(60 * time.Second)
+	defer ticker.Stop()
+
+	addr := Settings.DB_HOST + ":" + Settings.DB_PORT
+
+	var ctx context.Context
+	//бесконечный цикл
+loop:
+	for {
+		ctx = contextmain.GetContext()
+
+		select {
+		case <-ctx.Done():
+			log.Warn("Context app is canceled. postgres_pgxpool.ping")
+			break loop
+		case <-ticker.C:
+
+			//ping в базе данных
+			//mutex_Connect.RLock() //race
+			//err = GetConnection_err().Ping(ctx) //ping делать нельзя т.к. data race
+			err = Ping_err(ctx)
+			//mutex_Connect.RUnlock()
+			if err != nil {
+				switch err.Error() {
+				case TextConnBusy:
+					{
+						log.Warn("postgres_pgxpool Ping() warning: ", err)
+					}
+				default:
+					{
+						NeedReconnect = true
+						log.Error("postgres_pgxpool Ping() error: ", err)
+					}
+				}
+
+			}
+
+			//ping порта
+			err = port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
+			if err != nil {
+				NeedReconnect = true
+				log.Warn("postgres_pgxpool CheckPort(", addr, ") error: ", err)
+			} else if NeedReconnect == true {
+				log.Warn("postgres_pgxpool CheckPort(", addr, ") OK. Start Reconnect()")
+				NeedReconnect = false
+				err = Connect_err()
+				if err != nil {
+					NeedReconnect = true
+					log.Error("Connect_err() error: ", err)
+				}
+			}
+		}
+	}
+
+}
+
+// GetConnection_err - возвращает соединение к нужной базе данных
+func GetConnection_err() (*pgxpool.Conn, error) {
+	//мьютекс чтоб не подключаться одновременно
+	//mutex_Connect.RLock()
+	//defer mutex_Connect.RUnlock()
+
+	//
+	if PgxPool == nil {
+		err := Connect_err()
+		if err != nil {
+			log.Error("POSTGRES pgxpool Connect() to database host: ", Settings.DB_HOST, ", error: ", err)
+		} else {
+			log.Info("POSTGRES pgxpool Connected. host: ", Settings.DB_HOST, ", base name: ", Settings.DB_NAME, ", schema: ", Settings.DB_SCHEMA)
+		}
+	}
+
+	ctxMain := contextmain.GetContext()
+	ctx, cancelFunc := context.WithTimeout(ctxMain, timeOutSeconds*time.Second)
+	defer cancelFunc()
+
+	connection, err := PgxPool.Acquire(ctx)
+	if err != nil {
+		err = fmt.Errorf("Ошибка при получении соединения из пула базы данных, error: %w", err)
+		return connection, nil
+	}
+	return connection, nil
+}
+
+// GetConnection_WithApplicationName - возвращает соединение к нужной базе данных, с указанием имени приложения
+func GetConnection_WithApplicationName(ApplicationName string) *pgxpool.Pool {
+	if PgxPool == nil {
+		err := Connect_WithApplicationName_err(ApplicationName)
+		LogInfo_Connected(err)
+	}
+
+	return PgxPool
+}
+
+// RawMultipleSQL - выполняет текст запроса, отдельно для каждого запроса
+// после вызова, в конце необходимо закрыть rows!
+// if err != nil {
+// }
+// defer rows.Close()
+
+func RawMultipleSQL(tx *pgxpool.Conn, TextSQL string) (pgx.Rows, error) {
+	var rows pgx.Rows
+	var err error
+
+	if tx == nil {
+		TextError := "RawMultipleSQL() error: tx =nil"
+		log.Error(TextError)
+		err = errors.New(TextError)
+		return rows, err
+	}
+
+	ctx := contextmain.GetContext()
+
+	//запустим транзакцию
+	//tx, err := tx.Begin(ctx)
+	//if err != nil {
+	//	log.Error(err)
+	//	return rows, err
+	//}
+	//defer tx.Commit()
+
+	//
+	TextSQL1 := ""
+	TextSQL2 := TextSQL
+
+	//запустим все запросы, кроме последнего
+	pos1 := strings.LastIndex(TextSQL, ";")
+	if pos1 > 0 {
+		TextSQL1 = TextSQL[0:pos1]
+		TextSQL2 = TextSQL[pos1:]
+		_, err := tx.Exec(ctx, TextSQL1)
+		if err != nil {
+			TextError := fmt.Sprint("tx.Exec() error: ", err, ", TextSQL: \n", TextSQL1)
+			err = errors.New(TextError)
+			log.Error(err)
+			return rows, err
+		}
+	}
+
+	//запустим последний запрос, с возвратом результата
+	rows, err = tx.Query(ctx, TextSQL2)
+	if err != nil {
+		TextError := fmt.Sprint("tx.Raw() error: ", err, ", TextSQL: \n", TextSQL2)
+		err = errors.New(TextError)
+		return rows, err
+	}
+	//defer rows.Close()
+
+	return rows, err
+}
+
+// Ping_err - выполняет пустой запрос для теста соединения
+func Ping_err(ctxMain context.Context) error {
+	var err error
+
+	//ctx, cancelFunc := context.WithTimeout(ctxMain, timeOutSeconds*time.Second)
+	ctx, cancelFunc := context.WithTimeout(ctxMain, 1*time.Second)
+	defer cancelFunc()
+
+	//mutex_Connect.Lock() //убрал т.к. зависает всё
+	//defer mutex_Connect.Unlock()
+
+	_, err = PgxPool.Exec(ctx, ";")
+	return err
+}

postgres_pgxpool/postgres_pgxpool_test.go

@@ -0,0 +1,186 @@
+package postgres_pgxpool
+
+import (
+	"errors"
+	"testing"
+	"time"
+
+	//log "github.com/sirupsen/logrus"
+
+	"github.com/ManyakRus/starter/config_main"
+	"github.com/ManyakRus/starter/contextmain"
+	"github.com/ManyakRus/starter/micro"
+
+	//	logger "github.com/ManyakRus/starter/common/v0/logger"
+	"github.com/ManyakRus/starter/stopapp"
+)
+
+func TestConnect_err(t *testing.T) {
+	//Connect_Panic()
+
+	//ProgramDir := micro.ProgramDir_Common()
+	config_main.LoadEnv()
+	err := Connect_err()
+	if err != nil {
+		t.Error("TestConnect error: ", err)
+	}
+
+	err = CloseConnection_err()
+	if err != nil {
+		t.Error("TestConnect() error: ", err)
+	}
+}
+
+func TestIsClosed(t *testing.T) {
+	//ProgramDir := micro.ProgramDir_Common()
+	config_main.LoadEnv()
+
+	err := Connect_err()
+	if err != nil {
+		t.Error("TestIsClosed Connect() error: ", err)
+	}
+
+	isClosed := IsClosed()
+	if isClosed == true {
+		t.Error("TestIsClosed() isClosed = true ")
+	}
+
+	err = CloseConnection_err()
+	if err != nil {
+		t.Error("TestIsClosed() CloseConnection() error: ", err)
+	}
+
+}
+
+func TestReconnect(t *testing.T) {
+	//ProgramDir := micro.ProgramDir_Common()
+	config_main.LoadEnv()
+	err := Connect_err()
+	if err != nil {
+		t.Error("TestIsClosed Connect() error: ", err)
+	}
+
+	//ctx := context.Background()
+	Reconnect(errors.New(""))
+
+	err = CloseConnection_err()
+	if err != nil {
+		t.Error("TestReconnect() CloseConnection() error: ", err)
+	}
+
+}
+
+func TestWaitStop(t *testing.T) {
+	stopapp.StartWaitStop()
+
+	stopapp.GetWaitGroup_Main().Add(1)
+	go WaitStop()
+
+	micro.Pause(10)
+
+	//stopapp.SignalInterrupt <- syscall.SIGINT
+	contextmain.CancelContext()
+	contextmain.GetNewContext()
+}
+
+func TestStartDB(t *testing.T) {
+	//ProgramDir := micro.ProgramDir_Common()
+	config_main.LoadEnv()
+	StartDB()
+	err := CloseConnection_err()
+	if err != nil {
+		t.Error("db_test.TestStartDB() CloseConnection() error: ", err)
+	}
+}
+
+func TestConnect(t *testing.T) {
+	//ProgramDir := micro.ProgramDir_Common()
+	config_main.LoadEnv()
+	Connect()
+
+	CloseConnection()
+}
+
+func TestConnect_WithApplicationName_err(t *testing.T) {
+
+	config_main.LoadEnv()
+	err := Connect_WithApplicationName_err("test_starter_postgres_pgx")
+	if err != nil {
+		t.Error("TestConnect_WithApplicationName_err error: ", err)
+	}
+
+	CloseConnection()
+
+}
+
+func TestRawMultipleSQL(t *testing.T) {
+	config_main.LoadEnv()
+	connection, _ := GetConnection_err()
+	defer connection.Release()
+	//defer CloseConnection()
+
+	TimeStart := time.Now()
+
+	TextSQL := `
+drop table if exists temp_TestRawMultipleSQL2; 
+CREATE TEMPORARY TABLE temp_TestRawMultipleSQL2 (id int);
+
+insert into temp_TestRawMultipleSQL2
+select 1;
+
+SELECT * FROM temp_TestRawMultipleSQL2
+`
+	//TextSQL := "SELECT 1; SELECT 2"
+	Rows, err := RawMultipleSQL(connection, TextSQL)
+	if err != nil {
+		t.Error("TestRawMultipleSQL() error: ", err)
+		return
+	}
+	if Rows == nil {
+		t.Error("TestRawMultipleSQL() error: Rows == nil")
+		return
+	}
+	defer Rows.Close()
+
+	Otvet := 0
+	for Rows.Next() {
+		err := Rows.Scan(&Otvet)
+		if err != nil {
+			t.Error("TestRawMultipleSQL() Scan() error: ", err)
+		}
+	}
+
+	t.Log("Прошло время: ", time.Since(TimeStart))
+}
+
+// TestRawMultipleSQL2 - negative test, with error
+func TestRawMultipleSQL2(t *testing.T) {
+	config_main.LoadEnv()
+	GetConnection_err()
+	defer CloseConnection()
+
+	TimeStart := time.Now()
+	defer t.Log("Прошло время: ", time.Since(TimeStart))
+
+	TextSQL := `
+drop table if exists temp_TestRawMultipleSQL2; 
+CREATE TEMPORARY TABLE temp_TestRawMultipleSQL2 (id int);
+
+insert into temp_TestRawMultipleSQL2
+select 1;
+
+SELECT * FROM temp_TestRawMultipleSQL2
+`
+
+	ctx := contextmain.GetContext()
+	Rows, err := PgxPool.Query(ctx, TextSQL)
+	if err == nil {
+		t.Error("TestRawMultipleSQL2() Query() error: ", err)
+		return
+	}
+	if Rows == nil {
+		t.Error("TestRawMultipleSQL2() error: Rows == nil")
+		return
+	}
+
+}