Compare commits

..

2 Commits

Author SHA1 Message Date
87f10c73d6 Add support for array binding
All checks were successful
Build / build (push) Successful in 1m39s
2025-03-24 12:05:10 +01:00
58d63b6cf3 Fix missing error and add test 2025-03-24 11:52:28 +01:00
2 changed files with 51 additions and 6 deletions

View File

@ -34,21 +34,37 @@ func (d *Db) query(query string) *Query {
}
func (q *Query) Bind(args ...any) *Query {
into := 0
return q.bindInto(&into, args...)
}
func (q *Query) bindInto(into *int, args ...any) *Query {
if q.err != nil || q.stmt == nil {
return q
}
for i, arg := range args {
*into++
if asString, ok := arg.(string); ok {
q.stmt.BindText(i+1, asString)
q.stmt.BindText(*into, asString)
} else if asInt, ok := arg.(int); ok {
q.stmt.BindInt64(i+1, int64(asInt))
q.stmt.BindInt64(*into, int64(asInt))
} else if asInt, ok := arg.(int64); ok {
q.stmt.BindInt64(i+1, asInt)
q.stmt.BindInt64(*into, asInt)
} else if asBool, ok := arg.(bool); ok {
q.stmt.BindBool(i+1, asBool)
q.stmt.BindBool(*into, asBool)
} else {
q.err = fmt.Errorf("unsupported column type %s at index %d", reflect.TypeOf(arg).Name(), i)
return q
// Check if the argument is a slice or array of any type
v := reflect.ValueOf(arg)
if v.Kind() == reflect.Slice || v.Kind() == reflect.Array {
*into--
for i := 0; i < v.Len(); i++ {
q.bindInto(into, v.Index(i).Interface())
}
} else {
*into--
q.err = fmt.Errorf("unsupported column type %s at index %d", reflect.TypeOf(arg).Name(), i)
return q
}
}
}
return q
@ -138,6 +154,9 @@ type Rows struct {
}
func (q *Query) ScanMulti() (*Rows, error) {
if q.err != nil {
return nil, q.err
}
return &Rows{
query: q,
}, nil

View File

@ -133,3 +133,29 @@ func TestTransactionRollback(t *testing.T) {
db.Query("select value from mytable where key = 'foo'").MustScanSingle(&value)
require.Equal(t, "bar", value, "expected original value after rollback")
}
func TestQueryWithInClause(t *testing.T) {
db := openTestDb(t)
// Insert additional test rows
db.Query("insert into mytable(key, value) values ('key1', 'value1')").MustExec()
db.Query("insert into mytable(key, value) values ('key2', 'value2')").MustExec()
// Execute query with IN clause
args := []string{"foo", "key2"}
rows, err := db.Query("select key, value from mytable where key in (?, ?)").Bind(args).ScanMulti()
require.NoError(t, err)
defer rows.MustFinish()
// Check results
results := make(map[string]string)
for rows.MustNext() {
var key, value string
rows.MustScan(&key, &value)
results[key] = value
}
// Verify we got exactly the expected results
require.Equal(t, 2, len(results), "expected 2 matching rows")
require.Equal(t, "bar", results["foo"], "unexpected value for key 'foo'")
require.Equal(t, "value2", results["key2"], "unexpected value for key 'key2'")
}