Add ExecuteTx

Author: minhduc140583

echo/handler.go

@@ -4,9 +4,9 @@ import (
 	"context"
 	"database/sql"
 	"encoding/json"
+	"errors"
 	q "github.com/core-go/sql"
 	"github.com/labstack/echo/v4"
-	"github.com/pkg/errors"
 	"net/http"
 	"strconv"
 	"time"

echo_v3/handler.go

@@ -4,9 +4,9 @@ import (
 	"context"
 	"database/sql"
 	"encoding/json"
+	"errors"
 	q "github.com/core-go/sql"
 	"github.com/labstack/echo"
-	"github.com/pkg/errors"
 	"net/http"
 	"strconv"
 	"time"

exec.go

@@ -108,6 +108,18 @@ func CallbackTx(ctx context.Context, db *sql.DB, callback func(ctx2 context.Cont
 	err = tx.Commit()
 	return err
 }
+func ExecuteTx(ctx context.Context, db *sql.DB, callback func(context.Context)(int64, error), opts ...*sql.TxOptions) (int64, error) {
+	var res int64
+	er0 := CallbackTx(ctx, db, func(ctx2 context.Context) error {
+		result, err := callback(ctx)
+		if err != nil {
+			return err
+		}
+		res = result
+		return nil
+	}, opts...)
+	return res, er0
+}
 func ExecuteAll(ctx context.Context, db *sql.DB, stmts ...Statement) (int64, error) {
 	if stmts == nil || len(stmts) == 0 {
 		return 0, nil