1. 原生 SQL 和 SQL 生成器

1.1. 运行原生 SQL

执行原生 SQL时不能通过链式调用其他方法

  1. db.Exec("DROP TABLE users;")
  2. db.Exec("UPDATE orders SET shipped_at=? WHERE id IN (?)", time.Now(), []int64{11,22,33})
  3. // Scan
  4. type Result struct {
  5. Name string
  6. Age int
  7. }
  8. var result Result
  9. db.Raw("SELECT name, age FROM users WHERE name = ?", 3).Scan(&result)

1.2. sql.Row 和 sql.Rows

使用 *sql.Row 或者 *sql.Rows 获得查询结果

  1. row := db.Table("users").Where("name = ?", "jinzhu").Select("name, age").Row() // (*sql.Row)
  2. row.Scan(&name, &age)
  3. rows, err := db.Model(&User{}).Where("name = ?", "jinzhu").Select("name, age, email").Rows() // (*sql.Rows, error)
  4. defer rows.Close()
  5. for rows.Next() {
  6. ...
  7. rows.Scan(&name, &age, &email)
  8. ...
  9. }
  10. // 原生SQL
  11. rows, err := db.Raw("select name, age, email from users where name = ?", "jinzhu").Rows() // (*sql.Rows, error)
  12. defer rows.Close()
  13. for rows.Next() {
  14. ...
  15. rows.Scan(&name, &age, &email)
  16. ...
  17. }

1.3. 扫描 sql.Rows 数据到模型

  1. rows, err := db.Model(&User{}).Where("name = ?", "jinzhu").Select("name, age, email").Rows() // (*sql.Rows, error)
  2. defer rows.Close()
  3. for rows.Next() {
  4. var user User
  5. // ScanRows 扫描一行到 user 模型
  6. db.ScanRows(rows, &user)
  7. // do something
  8. }