数据库操作

ORM方法操作相对链式操作更偏底层操作一些，在项目开发中常用链式操作，因为链式操作更简单灵活，但链式操作执行不了太过于复杂的SQL操作，可以交给方法操作来处理。

方法操作

  1. // SQL操作方法，返回原生的标准库sql对象
  2. Query(query string, args ...interface{}) (*sql.Rows, error)
  3. Exec(query string, args ...interface{}) (sql.Result, error)
  4. Prepare(query string) (*sql.Stmt, error)
  6. // 数据表记录查询：
  7. // 查询单条记录、查询多条记录、获取记录对象、查询单个字段值(链式操作同理)
  8. GetAll(query string, args ...interface{}) (Result, error)
  9. GetOne(query string, args ...interface{}) (Record, error)
  10. GetStruct(obj interface{}, query string, args ...interface{}) error
  11. GetValue(query string, args ...interface{}) (Value, error)
  12. Select(tables, fields string, condition interface{}, groupBy, orderBy string, first, limit int, args ...interface{}) (Result, error)
  14. // 开启事务操作
  15. Begin() (*Tx, error)
  17. // 数据单条操作
  18. Insert(table string, data Map) (sql.Result, error)
  19. Replace(table string, data Map) (sql.Result, error)
  20. Save(table string, data Map) (sql.Result, error)
  22. // 数据批量操作
  23. BatchInsert(table string, list List, batch int) (sql.Result, error)
  24. BatchReplace(table string, list List, batch int) (sql.Result, error)
  25. BatchSave(table string, list List, batch int) (sql.Result, error)
  27. // 数据修改/删除
  28. Update(table string, data interface{}, condition interface{}, args ...interface{}) (sql.Result, error)
  29. Delete(table string, condition interface{}, args ...interface{}) (sql.Result, error)
  31. // 创建链式操作对象(Table为From的别名)
  32. Table(tables string) (*Model)
  33. From(tables string) (*Model)
  35. // 关闭数据库
  36. Close() error

操作示例

  1. ORM对象

    1.  // 获取默认配置的数据库对象(配置名称为"default")
    2.  db, err := gdb.New()
    3.  // 或者
    4.  db := g.Database()
    5.  // 或者(别名方式)
    6.  db := g.DB()
    8.  // 获取配置分组名称为"user-center"的数据库对象
    9.  db, err := gdb.New("user-center")
    10.  // 或者 
    11.  db := g.Database("user-center")
    12.  // 或者 (别名方式)
    13.  db := g.DB("user-center")
    15.  // 注意不用的时候不需要使用Close方法关闭数据库连接(并且gdb也没有提供Close方法)，
    16.  // 数据库引擎底层采用了链接池设计，当链接不再使用时会自动关闭

  2. 数据写入

    1.  r, err := db.Insert("user", gdb.Map {
    2.      "name": "john",
    3.  })

  3. 数据查询(列表)

    1.  list, err := db.GetAll("select * from user limit 2")
    2.  list, err := db.Select("user", "*", nil, "", "", 0, 2)

  4. 数据查询(单条)

    1.  one, err := db.GetOne("select * from user limit 2")
    2.  // 或者
    3.  one, err := db.GetOne("select * from user where uid=1000")

  5. 数据保存

    1.  r, err := db.Save("user", gdb.Map {
    2.      "uid"  :  1,
    3.      "name" : "john",
    4.  })

  6. 批量操作

    1.  // BatchInsert/BatchReplace/BatchSave 同理
    2.  _, err := db.BatchInsert("user", gdb.List {
    3.      {"name": "john_1"},
    4.      {"name": "john_2"},
    5.      {"name": "john_3"},
    6.      {"name": "john_4"},
    7.  }, 10)

  7. 数据更新/删除

    1.  // db.Update/db.Delete 同理
    2.  r, err := db.Update("user", gdb.Map {"name": "john"}, "uid=?", 10000)
    3.  r, err := db.Update("user", "name='john'", "uid=10000")
    4.  r, err := db.Update("user", "name=?", "uid=?", "john", 10000)

    注意，参数域支持并建议使用预处理模式进行输入，避免SQL注入风险。