in at/rollback/server2/update.go [26:45]
func updateDataFail(ctx context.Context) error {
// generate an err : data row not exists where id=10000 , affected rows is 0.
sql := "update order_tbl set descs=? where id=?"
ret, err := db.ExecContext(ctx, sql, fmt.Sprintf("NewDescs1-%d", time.Now().UnixMilli()), 10000)
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
return err
}
rows, err := ret.RowsAffected()
if err != nil {
fmt.Printf("update failed, err:%v\n", err)
return err
}
fmt.Printf("update success: %d.\n", rows)
if rows == 0 {
return fmt.Errorf("rows affected 0")
}
return nil
}