This is an automated email from the ASF dual-hosted git repository.
thunguo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-seata-go-samples.git
The following commit(s) were added to refs/heads/main by this push:
new 35a4796 fix: return error instead of nil in AT server samples to
trigger rollback (#98)
35a4796 is described below
commit 35a4796421ce20e45b1a8716a7b9f35c0adcb744
Author: tachibana22 <[email protected]>
AuthorDate: Thu Jun 25 11:48:05 2026 +0800
fix: return error instead of nil in AT server samples to trigger rollback
(#98)
---
at/gin/server/insert_on_update.go | 4 ++--
at/gin/server/update.go | 4 ++--
at/rollback/server/insert_on_update.go | 4 ++--
at/rollback/server/main.go | 2 +-
at/rollback/server/update.go | 4 ++--
at/rollback/server2/insert_on_update.go | 4 ++--
util/db.go | 2 +-
7 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/at/gin/server/insert_on_update.go
b/at/gin/server/insert_on_update.go
index cc9e1b6..9f317cb 100644
--- a/at/gin/server/insert_on_update.go
+++ b/at/gin/server/insert_on_update.go
@@ -29,13 +29,13 @@ func insertOnUpdateDataSuccess(ctx context.Context) error {
ret, err := db.ExecContext(ctx, sql, 1, "NO-100001", "C100000", 100,
nil, "init desc", fmt.Sprintf("insert on update descs %d", time.Now().Unix()))
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
rows, err := ret.RowsAffected()
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
fmt.Printf("update success： %d.\n", rows)
return nil
diff --git a/at/gin/server/update.go b/at/gin/server/update.go
index 10b210d..ff67568 100644
--- a/at/gin/server/update.go
+++ b/at/gin/server/update.go
@@ -28,13 +28,13 @@ func updateDataSuccess(ctx context.Context) error {
ret, err := db.ExecContext(ctx, sql, fmt.Sprintf("NewDescs1-%d",
time.Now().UnixMilli()), 1)
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
rows, err := ret.RowsAffected()
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
fmt.Printf("update success： %d.\n", rows)
return nil
diff --git a/at/rollback/server/insert_on_update.go
b/at/rollback/server/insert_on_update.go
index ea78a5d..62d4f72 100644
--- a/at/rollback/server/insert_on_update.go
+++ b/at/rollback/server/insert_on_update.go
@@ -29,13 +29,13 @@ func insertOnUpdateDataSuccess(ctx context.Context) error {
ret, err := db.ExecContext(ctx, sql, 1, "NO-100001", "C100000", 100,
nil, "init desc", fmt.Sprintf("insert on update success %d", time.Now().Unix()))
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
rows, err := ret.RowsAffected()
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
fmt.Printf("update success： %d.\n", rows)
return nil
diff --git a/at/rollback/server/main.go b/at/rollback/server/main.go
index 36f1100..a8d7e52 100644
--- a/at/rollback/server/main.go
+++ b/at/rollback/server/main.go
@@ -56,7 +56,7 @@ func main() {
c.JSON(http.StatusBadRequest, "insertOnUpdateData
failure")
return
}
- c.JSON(http.StatusInternalServerError, "insertOnUpdateData
failure")
+ c.JSON(http.StatusOK, "insertOnUpdateData ok")
})
if err := r.Run(":8080"); err != nil {
diff --git a/at/rollback/server/update.go b/at/rollback/server/update.go
index 10b210d..ff67568 100644
--- a/at/rollback/server/update.go
+++ b/at/rollback/server/update.go
@@ -28,13 +28,13 @@ func updateDataSuccess(ctx context.Context) error {
ret, err := db.ExecContext(ctx, sql, fmt.Sprintf("NewDescs1-%d",
time.Now().UnixMilli()), 1)
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
rows, err := ret.RowsAffected()
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
fmt.Printf("update success： %d.\n", rows)
return nil
diff --git a/at/rollback/server2/insert_on_update.go
b/at/rollback/server2/insert_on_update.go
index 9eeba04..8f8f221 100644
--- a/at/rollback/server2/insert_on_update.go
+++ b/at/rollback/server2/insert_on_update.go
@@ -30,13 +30,13 @@ func insertOnUpdateDataFail(ctx context.Context) error {
ret, err := db.ExecContext(ctx, sql, "NO-100001", "C100000", 100, nil,
"init desc", fmt.Sprintf("insert on update descs %d", time.Now().Unix()))
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
rows, err := ret.RowsAffected()
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
- return nil
+ return err
}
fmt.Printf("update success： %d.\n", rows)
return nil
diff --git a/util/db.go b/util/db.go
index b83fbab..1efff10 100644
--- a/util/db.go
+++ b/util/db.go
@@ -55,7 +55,7 @@ func defaultEnv() {
_ = os.Setenv("MYSQL_USERNAME", "root")
}
if os.Getenv("MYSQL_PASSWORD") == "" {
- _ = os.Setenv("MYSQL_PASSWORD", "123456")
+ _ = os.Setenv("MYSQL_PASSWORD", "12345678")
}
if os.Getenv("MYSQL_DB") == "" {
_ = os.Setenv("MYSQL_DB", "seata_client")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
