v0.0.218 bf

This commit is contained in:
2023-07-27 17:16:30 +02:00
parent b7003b9ec9
commit 190584e0e6
2 changed files with 6 additions and 6 deletions

View File

@@ -54,7 +54,7 @@ func (tx *transaction) Rollback() error {
result := tx.tx.Rollback()
if result != nil {
if result == nil {
tx.status = TxStatusRollback
}
@@ -75,7 +75,7 @@ func (tx *transaction) Commit() error {
result := tx.tx.Commit()
if result != nil {
if result == nil {
tx.status = TxStatusComitted
}
@@ -97,7 +97,7 @@ func (tx *transaction) Exec(ctx context.Context, sqlstr string, prep PP) (sql.Re
res, err := tx.tx.NamedExecContext(ctx, sqlstr, prep)
if tx.status == TxStatusInitial && err != nil {
if tx.status == TxStatusInitial && err == nil {
tx.status = TxStatusActive
}
@@ -122,7 +122,7 @@ func (tx *transaction) Query(ctx context.Context, sqlstr string, prep PP) (*sqlx
rows, err := sqlx.NamedQueryContext(ctx, tx.tx, sqlstr, prep)
if tx.status == TxStatusInitial && err != nil {
if tx.status == TxStatusInitial && err == nil {
tx.status = TxStatusActive
}