基本介绍

gf框架的ORM功能由gdb模块实现，用于常用关系型数据库的ORM操作。其最大的特色在于同时支持map和struct两种方式操作数据库。gdb默认情况下使用的是map数据类型作为基础的数据表记录载体，开发者无需预先定义数据表记录struct便可直接对数据表记录执行各种操作。这样的设计赋予了开发者更高的灵活度和简便性。

gdb数据库引擎底层采用了链接池设计，当链接不再使用时会自动关闭，因此链接对象不用的时候不需要显式使用Close方法关闭数据库连接。这也是gdb数据库模块人性化设计的地方，方便开发者使用数据库而无需手动维护大量的数据库链接对象。

注意：为提高数据库操作安全性，在ORM操作中不建议直接将参数拼接成SQL字符串执行，建议尽量使用预处理的方式（充分使用?占位符）来传递SQL参数。gdb的底层实现中均采用的是预处理的方式处理开发者传递的参数，以充分保证数据库操作安全性。

接口文档： https://godoc.org/github.com/gogf/gf/database/gdb

数据结构

为便于数据表记录的操作，ORM定义了5种基本的数据类型：

  1. type Map         map[string]interface{} // 数据记录
  2. type List        []Map                  // 数据记录列表
  4. type Value       *gvar.Var              // 返回数据表记录值
  5. type Record      map[string]Value       // 返回数据表记录键值对
  6. type Result      []Record               // 返回数据表记录列表
  1. Map与List用于ORM操作过程中的输入参数类型（与全局类型g.Map和g.List一致，在项目开发中常用g.Map和g.List替换）；
  2. Value/Record/Result用于ORM操作的结果数据类型，具体说明请查看 ORM结果处理 章节；

接口方法

以下是DB接口提供的常用方法列表，详细的方法列表请参考接口文档：https://godoc.org/github.com/gogf/gf/database/gdb

  1. // 创建模型对象
  2. Model(table ...string) *Model
  4. // 切换数据库
  5. Schema(schema string) *Schema
  7. // 自定义上下文变量
  8. Ctx(ctx context.Context) DB
  10. // SQL操作方法，返回原生的标准库sql对象
  11. Query(query string, args ...interface{}) (*sql.Rows, error)
  12. Exec(query string, args ...interface{}) (sql.Result, error)
  13. Prepare(query string) (*sql.Stmt, error)
  15. // 数据表记录查询：
  16. // 查询单条记录、查询多条记录、获取记录对象、查询单个字段值(链式操作同理) 
  17. GetAll(sql string, args ...interface{}) (Result, error)
  18. GetOne(sql string, args ...interface{}) (Record, error)
  19. GetValue(sql string, args ...interface{}) (Value, error)
  20. GetArray(sql string, args ...interface{}) ([]Value, error)
  21. GetCount(sql string, args ...interface{}) (int, error)
  22. GetStruct(objPointer interface{}, sql string, args ...interface{}) error
  23. GetStructs(objPointerSlice interface{}, sql string, args ...interface{}) error
  24. GetScan(objPointer interface{}, sql string, args ...interface{}) error
  26. // 数据单条操作
  27. Insert(table string, data interface{}, batch...int) (sql.Result, error)
  28. Replace(table string, data interface{}, batch...int) (sql.Result, error)
  29. Save(table string, data interface{}, batch...int) (sql.Result, error)
  31. // 数据批量操作
  32. BatchInsert(table string, list interface{}, batch...int) (sql.Result, error)
  33. BatchReplace(table string, list interface{}, batch...int) (sql.Result, error)
  34. BatchSave(table string, list interface{}, batch...int) (sql.Result, error)
  36. // 数据修改/删除
  37. Update(table string, data interface{}, condition interface{}, args ...interface{}) (sql.Result, error)
  38. Delete(table string, condition interface{}, args ...interface{}) (sql.Result, error)
  41. // 开启事务操作
  42. Begin() (*TX, error)
  44. // 事务闭包操作
  45. Transaction(ctx context.Context, f func(ctx context.Context, tx *TX) error) (err error)
  47. // 设置管理 
  48. GetCache() *gcache.Cache
  49. SetDebug(debug bool)
  50. GetDebug() bool
  51. SetSchema(schema string)
  52. GetSchema() string
  53. GetPrefix() string
  54. GetGroup() string
  55. SetDryRun(dryrun bool)
  56. GetDryRun() bool
  57. SetLogger(logger *glog.Logger)
  58. GetLogger() *glog.Logger
  59. GetConfig() *ConfigNode
  60. SetMaxIdleConnCount(n int)
  61. SetMaxOpenConnCount(n int)
  62. SetMaxConnLifetime(d time.Duration)  
  64. // 工具类方法
  65. GetCtx() context.Context
  66. GetChars() (charLeft string, charRight string)
  67. GetMaster(schema ...string) (*sql.DB, error)
  68. GetSlave(schema ...string) (*sql.DB, error)
  69. QuoteWord(s string) string
  70. QuoteString(s string) string
  71. QuotePrefixTableName(table string) string
  72. Tables(schema ...string) (tables []string, err error)
  73. TableFields(table string, schema ...string) (map[string]*TableField, error)
  74. HasTable(name string) (bool, error)

g.DB与gdb.New、gdb.Instance

获取数据库操作对象有三种方式，一种是使用g.DB方法（推荐），一种是使用原生gdb.New方法，还有一种是使用包原生单例方法gdb.Instance，而第一种是推荐的使用方式。这三种方式的区别如下：

  1. g.DB对象管理方式获取的是单例对象，整合了配置文件的管理功能，支持配置文件热更新；
  2. gdb.New是创建一个新的数据库对象(非单例)，无法使用配置文件，需要使用包配置管理方法进行配置；
  3. gdb.Instance是包原生单例管理方法，需要结合配置方法一起使用，通过分组名称(非必需)获取对应配置的数据库单例对象；
  4. 其他使用无差别；

有这么多对象获取方式原因在于GF是一个模块化设计的框架，每个模块皆可单独使用。为了方便开发者使用常用的一些模块，因此框架也提供了一个g模块，这是一个高度耦合的模块，封装了一些常用对象的单例获取方式，详见 对象管理 章节。

获取ORM对象示例：

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

支持的数据库类型

由于go标准库的数据库操作对象采用接口实现，因此提供了非常好的可扩展性和兼容性。

MySQL

内置支持，无需额外扩展或第三方包接入，直接可用。 依赖的第三方包：https://github.com/go-sql-driver/mysql

SQLite

在使用时需要引入第三方包 ( go-sqlite3 )：

  1. _ "github.com/mattn/go-sqlite3"

限制

  1. 不支持Save/Replace方法

PostgreSQL

在使用时需要引入第三方包 (pq )：

  1. _ "github.com/lib/pq"

限制

  1. 不支持LastInsertId方法
  2. 不支持Save/Replace方法

SQL Server

使用时需导入第三方包 (go-mssqldb )：

  1. _ "github.com/denisenkom/go-mssqldb"

限制

  1. 不支持LastInsertId方法
  2. 不支持Save/Replace方法
  3. 仅支持SQL Server 2005及其后的版本

Oracle

使用时需导入第三方包 (go-oci8 )：

  1. _ "github.com/mattn/go-oci8"

限制

  1. 不支持LastInsertId方法
  2. 不支持Save/Replace方法

其他数据库类型

额外接入新的数据库相当方便，可参考源码中关于PostgreSQL、SQLite、Oracle、SQL Server的接入方式。具体介绍请参考后续 ORM接口开发-驱动开发 章节。

Content Menu