go/starter
1
0
Fork 0
mirror of https://github.com/ManyakRus/starter.git synced 2025-11-23 22:45:11 +02:00
Code Issues Releases Activity

сделал убрал //запустим транзакцию

Browse Source
This commit is contained in:
Nikitin Aleksandr
2024-06-11 13:38:31 +03:00
parent 5580c74c1f
commit d11af8f1f9
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
postgres_pgx/postgres_pgx.go
View File

@@ -370,11 +370,11 @@ func RawMultipleSQL(db *pgx.Conn, TextSQL string) (pgx.Rows, error) {
ctx := contextmain.GetContext()
//запустим транзакцию
tx, err := db.Begin(ctx)
if err != nil {
log.Error(err)
return Rows, err
}
//tx, err := db.Begin(ctx)
//if err != nil {
// log.Error(err)
// return Rows, err
//}
//defer tx.Commit()
//
@@ -386,7 +386,7 @@ func RawMultipleSQL(db *pgx.Conn, TextSQL string) (pgx.Rows, error) {
if pos1 > 0 {
TextSQL1 = TextSQL[0:pos1]
TextSQL2 = TextSQL[pos1:]
_, err := tx.Exec(ctx, TextSQL1)
_, err := db.Exec(ctx, TextSQL1)
if err != nil {
TextError := fmt.Sprint("db.Exec() error: ", err, ", TextSQL: \n", TextSQL1)
err = errors.New(TextError)
@@ -396,7 +396,7 @@ func RawMultipleSQL(db *pgx.Conn, TextSQL string) (pgx.Rows, error) {
}
//запустим последний запрос, с возвратом результата
Rows, err = tx.Query(ctx, TextSQL2)
Rows, err = db.Query(ctx, TextSQL2)
if err != nil {
TextError := fmt.Sprint("db.Raw() error: ", err, ", TextSQL: \n", TextSQL2)
err = errors.New(TextError)