Skip to content

Instantly share code, notes, and snippets.

@swizzley
Created January 19, 2022 19:29
Show Gist options
  • Save swizzley/62e7f6ef6c720630486347828d52970f to your computer and use it in GitHub Desktop.
Save swizzley/62e7f6ef6c720630486347828d52970f to your computer and use it in GitHub Desktop.
sql to json
func (c Client) SelectJSON(query string) ([]byte, error) {
db, err := sql.Open(driver, c.DSN)
if err != nil {
return nil, err
}
defer db.Close()
rows, err := db.Query(query)
if err != nil {
return nil, err
}
defer rows.Close()
columns, err := rows.Columns()
if err != nil {
return nil, err
}
count := len(columns)
tableData := make([]map[string]interface{}, 0)
values := make([]interface{}, count)
valuePtrs := make([]interface{}, count)
for rows.Next() {
for i := 0; i < count; i++ {
valuePtrs[i] = &values[i]
}
rows.Scan(valuePtrs...)
entry := make(map[string]interface{})
for i, col := range columns {
var v interface{}
val := values[i]
b, ok := val.([]byte)
if ok {
v = string(b)
} else {
v = val
}
entry[col] = v
}
tableData = append(tableData, entry)
}
jsonData, err := json.Marshal(tableData)
if err != nil {
return nil, err
}
return jsonData, nil
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment