Skip to content

Commit 9f1101d

Browse files
committed
get to []map[string]string
1 parent 4f414a8 commit 9f1101d

File tree

2 files changed

+7
-3
lines changed

2 files changed

+7
-3
lines changed

orm/query_get.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -302,9 +302,11 @@ func (m Query[T]) scanRows(dest interface{}, rows *sql.Rows) error {
302302
case reflect.Map:
303303
var basePtrs = make([]interface{}, len(rowColumns))
304304

305+
valEle := ele.Elem()
306+
305307
for k := range basePtrs {
306-
var temp interface{}
307-
basePtrs[k] = &temp
308+
//var temp interface{}
309+
basePtrs[k] = reflect.New(valEle).Interface()
308310
}
309311
gerr = m.scanValues(basePtrs, rowColumns, rows, func() {
310312
newVal := reflect.MakeMap(ele)

orm_select_test.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,9 @@ var tdb, _ = sql.Open("mysql", "rfamro@tcp(mysql-rfam-public.ebi.ac.uk:4497)/Rfa
1111

1212
func TestSelect(t *testing.T) {
1313
t.Run("query_raw", func(t *testing.T) {
14-
data, query := orm.NewQueryRaw("family", tdb).Limit(5).GetRows()
14+
15+
var data []map[string]string
16+
query := orm.NewQueryRaw("", tdb).Raw("show create table family").GetTo(&data)
1517
t.Log(data)
1618
t.Log(query.Sql())
1719
t.Log(query.Error())

0 commit comments

Comments
 (0)