go - 处理动态查询(无法扫描到结构中)
问题描述
当使用查询结构是静态的 go-pg 时 - 直接查询/扫描到已知结构就像做梦一样。但是,我正在努力处理动态查询——那些没有结构可供扫描的查询。
例如,根据一些运行时参数 - 查询可能如下所示:
select foo from table
或者它可能是
select foo,bar,baz from table1
或者
select x,y,z from table2
我一直在试图弄清楚如何使用将结果加载到地图中。下面的代码抛出错误“无效字符'\'寻找值的开头”
m := make(map[string]interface{})
_,err:=db.Query(&m, "select foo,bar from table1")
if err!=nil{
fmt.Println(err)
}
我刚刚开始学习围棋——我完全迷路了。关于如何处理动态查询的任何提示
解决方案
您可以通过首先将数据库行值扫描到一个切片中,然后构建一个包含该行值的映射来实现此目的。
这是一个示例,其中查询结果被扫描到指向 interface{} 类型变量的指针切片中。
sql := "select foo,bar from table1"
rows, err := db.Query(sql)
columns, err := rows.Columns()
// for each database row / record, a map with the column names and row values is added to the allMaps slice
var allMaps []map[string]interface{}
for rows.Next() {
values := make([]interface{}, len(columns))
pointers := make([]interface{}, len(columns))
for i,_ := range values {
pointers[i] = &values[i]
}
err := rows.Scan(pointers...)
resultMap := make(map[string]interface{})
for i,val := range values {
fmt.Printf("Adding key=%s val=%v\n", columns[i], val)
resultMap[columns[i]] = val
}
allMaps = append(allMaps, resultMap)
}
为简洁起见,不对任何错误执行错误检查。
推荐阅读
- gps - 代号 一个位置有时不工作
- angularjs - 仅使用 Angularjs 和发送网格从联系我们表单发送电子邮件而没有后端 API
- reactjs - 在外部 API 服务层中使用 React 钩子
- apache-kafka - 无法与 Kafka 集群上的特定消费者组一起消费
- random - NIST 的二进制输入文件序列
- reactjs - 拒绝服务 - http 代理 - React
- python - 如何检测类中的pygame表面上的点击
- java - 当“\n”设置为分隔符时,为什么我的扫描仪正在读取“'B'和\n”而不是“B”?
- c++ - C++17,初始化数组
- java - Spring:无法从服务器下载文件(FileInputStream)