基于serf的数据库同步模块库
liuxiaolong
2019-10-11 ed8c08492682ac04df90fe1b80298a73d5414194
dbself.go
@@ -119,11 +119,12 @@
         result := tx.Exec(sql)
         err = result.Error
         if err !=nil {
            return false,result.Error
            return false,err
         }
         if result.RowsAffected == 0{
            logger.Error("ExecuteSqlByGorm fail")
            return false,errors.New("ExecuteSqlByGorm fail")
            err = errors.New("ExecuteSqlByGorm fail")
            return false,err
         }
      }
      tx.Commit()