diff --git a/postgres_pgx/postgres_pgx.go b/postgres_pgx/postgres_pgx.go index 05bf3865..8f464265 100644 --- a/postgres_pgx/postgres_pgx.go +++ b/postgres_pgx/postgres_pgx.go @@ -468,7 +468,7 @@ func GetConnection_WithApplicationName(ApplicationName string) *pgx.Conn { // } // defer rows.Close() -func RawMultipleSQL(tx pgx.Tx, TextSQL string) (pgx.Rows, error) { +func RawMultipleSQL(tx IConnectionTransaction, TextSQL string) (pgx.Rows, error) { var rows pgx.Rows var err error diff --git a/postgres_pgxpool/postgres_pgxpool.go b/postgres_pgxpool/postgres_pgxpool.go index 67741a17..1eeb0ff8 100644 --- a/postgres_pgxpool/postgres_pgxpool.go +++ b/postgres_pgxpool/postgres_pgxpool.go @@ -9,6 +9,7 @@ import ( "github.com/ManyakRus/starter/constants" "github.com/ManyakRus/starter/log" "github.com/ManyakRus/starter/port_checker" + "github.com/ManyakRus/starter/postgres_pgx" "github.com/jackc/pgx/v5" "github.com/jackc/pgx/v5/pgxpool" "strings" @@ -464,7 +465,7 @@ func GetConnection_WithApplicationName(ApplicationName string) *pgxpool.Pool { // } // defer rows.Close() -func RawMultipleSQL(tx pgx.Tx, TextSQL string) (pgx.Rows, error) { +func RawMultipleSQL(tx postgres_pgx.IConnectionTransaction, TextSQL string) (pgx.Rows, error) { var rows pgx.Rows var err error