utils_test.go 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
  1. package sqlx
  2. import (
  3. "strings"
  4. "testing"
  5. "github.com/stretchr/testify/assert"
  6. )
  7. func TestEscape(t *testing.T) {
  8. s := "a\x00\n\r\\'\"\x1ab"
  9. out := escape(s)
  10. assert.Equal(t, `a\x00\n\r\\\'\"\x1ab`, out)
  11. }
  12. func TestDesensitize(t *testing.T) {
  13. datasource := "user:pass@tcp(111.222.333.44:3306)/any_table?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghai"
  14. datasource = desensitize(datasource)
  15. assert.False(t, strings.Contains(datasource, "user"))
  16. assert.False(t, strings.Contains(datasource, "pass"))
  17. assert.True(t, strings.Contains(datasource, "tcp(111.222.333.44:3306)"))
  18. }
  19. func TestDesensitize_WithoutAccount(t *testing.T) {
  20. datasource := "tcp(111.222.333.44:3306)/any_table?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghai"
  21. datasource = desensitize(datasource)
  22. assert.True(t, strings.Contains(datasource, "tcp(111.222.333.44:3306)"))
  23. }
  24. func TestFormat(t *testing.T) {
  25. tests := []struct {
  26. name string
  27. query string
  28. args []interface{}
  29. expect string
  30. hasErr bool
  31. }{
  32. {
  33. name: "mysql normal",
  34. query: "select name, age from users where bool=? and phone=?",
  35. args: []interface{}{true, "133"},
  36. expect: "select name, age from users where bool=1 and phone='133'",
  37. },
  38. {
  39. name: "mysql normal",
  40. query: "select name, age from users where bool=? and phone=?",
  41. args: []interface{}{false, "133"},
  42. expect: "select name, age from users where bool=0 and phone='133'",
  43. },
  44. {
  45. name: "pg normal",
  46. query: "select name, age from users where bool=$1 and phone=$2",
  47. args: []interface{}{true, "133"},
  48. expect: "select name, age from users where bool=1 and phone='133'",
  49. },
  50. {
  51. name: "pg normal reverse",
  52. query: "select name, age from users where bool=$2 and phone=$1",
  53. args: []interface{}{"133", false},
  54. expect: "select name, age from users where bool=0 and phone='133'",
  55. },
  56. {
  57. name: "pg error not number",
  58. query: "select name, age from users where bool=$a and phone=$1",
  59. args: []interface{}{"133", false},
  60. hasErr: true,
  61. },
  62. {
  63. name: "pg error more args",
  64. query: "select name, age from users where bool=$2 and phone=$1 and nickname=$3",
  65. args: []interface{}{"133", false},
  66. hasErr: true,
  67. },
  68. {
  69. name: "oracle normal",
  70. query: "select name, age from users where bool=:1 and phone=:2",
  71. args: []interface{}{true, "133"},
  72. expect: "select name, age from users where bool=1 and phone='133'",
  73. },
  74. {
  75. name: "oracle normal reverse",
  76. query: "select name, age from users where bool=:2 and phone=:1",
  77. args: []interface{}{"133", false},
  78. expect: "select name, age from users where bool=0 and phone='133'",
  79. },
  80. {
  81. name: "oracle error not number",
  82. query: "select name, age from users where bool=:a and phone=:1",
  83. args: []interface{}{"133", false},
  84. hasErr: true,
  85. },
  86. {
  87. name: "oracle error more args",
  88. query: "select name, age from users where bool=:2 and phone=:1 and nickname=:3",
  89. args: []interface{}{"133", false},
  90. hasErr: true,
  91. },
  92. {
  93. name: "select with date",
  94. query: "select * from user where date='2006-01-02 15:04:05' and name=:1",
  95. args: []interface{}{"foo"},
  96. expect: "select * from user where date='2006-01-02 15:04:05' and name='foo'",
  97. },
  98. {
  99. name: "select with date and escape",
  100. query: `select * from user where date=' 2006-01-02 15:04:05 \'' and name=:1`,
  101. args: []interface{}{"foo"},
  102. expect: `select * from user where date=' 2006-01-02 15:04:05 \'' and name='foo'`,
  103. },
  104. {
  105. name: "select with date and bad arg",
  106. query: `select * from user where date='2006-01-02 15:04:05 \'' and name=:a`,
  107. args: []interface{}{"foo"},
  108. hasErr: true,
  109. },
  110. {
  111. name: "select with date and escape error",
  112. query: `select * from user where date='2006-01-02 15:04:05 \`,
  113. args: []interface{}{"foo"},
  114. hasErr: true,
  115. },
  116. }
  117. for _, test := range tests {
  118. test := test
  119. t.Run(test.name, func(t *testing.T) {
  120. t.Parallel()
  121. actual, err := format(test.query, test.args...)
  122. if test.hasErr {
  123. assert.NotNil(t, err)
  124. } else {
  125. assert.Nil(t, err)
  126. assert.Equal(t, test.expect, actual)
  127. }
  128. })
  129. }
  130. }