1 Commits

Author SHA1 Message Date
637797116d Add support for pointer arguments
Some checks failed
Build / build (push) Failing after 41s
2025-05-08 19:42:57 +02:00
2 changed files with 4 additions and 33 deletions

View File

@@ -44,17 +44,13 @@ func (q *Query) bindInto(into *int, args ...any) *Query {
} }
for i, arg := range args { for i, arg := range args {
*into++ *into++
if arg == nil {
q.stmt.BindNull(*into)
continue
}
v := reflect.ValueOf(arg) v := reflect.ValueOf(arg)
if v.Kind() == reflect.Ptr { if v.Kind() == reflect.Ptr {
if v.IsNil() { if v.IsNil() {
q.stmt.BindNull(*into) q.stmt.BindNull(*into)
continue continue
} }
arg = v.Elem().Interface() arg = v.Elem().Interface() // Dereference the pointer
} }
if asString, ok := arg.(string); ok { if asString, ok := arg.(string); ok {
q.stmt.BindText(*into, asString) q.stmt.BindText(*into, asString)

View File

@@ -94,14 +94,9 @@ func TestUpdateQuery(t *testing.T) {
} }
func TestUpdateQueryWithWrongArguments(t *testing.T) { func TestUpdateQueryWithWrongArguments(t *testing.T) {
type S struct {
Field string
}
db := openTestDb(t) db := openTestDb(t)
abc := S{ value := "ipsum"
Field: "ipsum", err := db.Query("insert into mytable(key, value) values ('lorem', ?)").Bind(&value).Exec()
}
err := db.Query("insert into mytable(key, value) values ('lorem', ?)").Bind(abc).Exec()
require.Error(t, err) require.Error(t, err)
} }
@@ -122,26 +117,6 @@ func TestUpdateQueryWithPointerValue(t *testing.T) {
require.Equal(t, "ipsum", value) require.Equal(t, "ipsum", value)
} }
func TestUpdateQueryWithSetPointerValue(t *testing.T) {
type S struct {
value *string
}
db := openTestDb(t)
func() {
tx := db.MustBegin()
defer tx.MustRollback()
tx.Query("insert into mytable(key, value) values ('lorem', 'bar')").MustExec()
s := S{nil}
key := "lorem"
tx.Query("update mytable set value = ? where key = ?").Bind(s.value, key).MustExec()
tx.MustCommit()
}()
var value *string
db.Query("select value from mytable where key = 'lorem'").MustScanSingle(&value)
require.Equal(t, (*string)(nil), value)
}
func TestUpdateQueryWithNullValue(t *testing.T) { func TestUpdateQueryWithNullValue(t *testing.T) {
db := openTestDb(t) db := openTestDb(t)
func() { func() {
@@ -153,7 +128,7 @@ func TestUpdateQueryWithNullValue(t *testing.T) {
tx.MustCommit() tx.MustCommit()
}() }()
var value *string var value string
db.Query("select value from mytable where key = 'lorem'").MustScanSingle(&value) db.Query("select value from mytable where key = 'lorem'").MustScanSingle(&value)
require.Nil(t, value) require.Nil(t, value)
} }