rows_test.go 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. // Copyright 2017 The Xorm Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style
  3. // license that can be found in the LICENSE file.
  4. package xorm
  5. import (
  6. "testing"
  7. "github.com/stretchr/testify/assert"
  8. )
  9. func TestRows(t *testing.T) {
  10. assert.NoError(t, prepareEngine())
  11. type UserRows struct {
  12. Id int64
  13. IsMan bool
  14. }
  15. assert.NoError(t, testEngine.Sync2(new(UserRows)))
  16. cnt, err := testEngine.Insert(&UserRows{
  17. IsMan: true,
  18. })
  19. assert.NoError(t, err)
  20. assert.EqualValues(t, 1, cnt)
  21. rows, err := testEngine.Rows(new(UserRows))
  22. assert.NoError(t, err)
  23. defer rows.Close()
  24. cnt = 0
  25. user := new(UserRows)
  26. for rows.Next() {
  27. err = rows.Scan(user)
  28. assert.NoError(t, err)
  29. cnt++
  30. }
  31. assert.EqualValues(t, 1, cnt)
  32. sess := testEngine.NewSession()
  33. defer sess.Close()
  34. rows1, err := sess.Prepare().Rows(new(UserRows))
  35. assert.NoError(t, err)
  36. defer rows1.Close()
  37. cnt = 0
  38. for rows1.Next() {
  39. err = rows1.Scan(user)
  40. assert.NoError(t, err)
  41. cnt++
  42. }
  43. assert.EqualValues(t, 1, cnt)
  44. rows2, err := testEngine.SQL("SELECT * FROM user_rows").Rows(new(UserRows))
  45. assert.NoError(t, err)
  46. defer rows2.Close()
  47. cnt = 0
  48. for rows2.Next() {
  49. err = rows2.Scan(user)
  50. assert.NoError(t, err)
  51. cnt++
  52. }
  53. assert.EqualValues(t, 1, cnt)
  54. }