Răsfoiți Sursa

导入sql事务

yxh 4 ani în urmă
părinte
comite
279a32aea7
1 a modificat fișierele cu 1 adăugiri și 1 ștergeri
  1. 1 1
      app/system/service/tools_gen_table.go

+ 1 - 1
app/system/service/tools_gen_table.go

@@ -689,7 +689,7 @@ func (s *toolsGenTable) writeDb(path string, ctx context.Context) (err error) {
 			sql := strings.Join(sqlStr, "")
 			gstr.ReplaceByArray(sql, []string{"@parentId", gconv.String(id), "@now", now.Format("Y-m-d H:i:s")})
 			//插入业务
-			res, err = g.DB().Exec(sql)
+			res, err = tx.Exec(sql)
 			if err != nil {
 				tx.Rollback()
 				return