自定义回调处理是最常见的接口开发实现，开发中只需要对接口中的部分方法进行替换与修改，在驱动默认实现逻辑中注入自定义逻辑。参考接口关系图（ORM接口开发）我们可以知道，所有的SQL语句执行必定会通过DoQuery或者DoExec或者 DoFilter接口，根据需求在自定义的驱动中实现并覆盖相关接口方法实现所需功能即可。

    其中，最长见的使用场景是在ORM底层实现对SQL的日志记录或者鉴权等统一判断操作。我们来看一个自定义回调处理的示例，现需要将所有执行的SQL语句记录到monitor表中，以方便于进行SQL审计。因此通过自定义Driver然后覆盖ORM的底层接口方法来实现是最简单的。为简化示例编写，以下代码实现了一个自定义的MySQL驱动，该驱动继承于drivers下mysql模块内已经实现的Driver。

    1. package driver
    3. import (
    4.     "context"
    6.     "github.com/gogf/gf/contrib/drivers/mysql/v2"
    7.     "github.com/gogf/gf/v2/database/gdb"
    8.     "github.com/gogf/gf/v2/os/gtime"
    9. )
    11. // MyDriver is a custom database driver, which is used for testing only.
    12. // For simplifying the unit testing case purpose, MyDriver struct inherits the mysql driver
    13. // gdb.Driver and overwrites its functions DoQuery and DoExec.
    14. // So if there's any sql execution, it goes through MyDriver.DoQuery/MyDriver.DoExec firstly
    15. // and then gdb.Driver.DoQuery/gdb.Driver.DoExec.
    16. // You can call it sql "HOOK" or "HiJack" as your will.
    17. type MyDriver struct {
    18.     *mysql.Driver
    19. }
    21. var (
    22.     // customDriverName is my driver name, which is used for registering.
    23.     customDriverName = "MyDriver"
    24. )
    26. func init() {
    27.     // It here registers my custom driver in package initialization function "init".
    28.     // You can later use this type in the database configuration.
    29.     if err := gdb.Register(customDriverName, &MyDriver{}); err != nil {
    30.         panic(err)
    31.     }
    32. }
    34. // New creates and returns a database object for mysql.
    35. // It implements the interface of gdb.Driver for extra database driver installation.
    36. func (d *MyDriver) New(core *gdb.Core, node *gdb.ConfigNode) (gdb.DB, error) {
    37.     return &MyDriver{
    38.         &mysql.Driver{
    39.             Core: core,
    40.         },
    41.     }, nil
    42. }
    44. // DoCommit commits current sql and arguments to underlying sql driver.
    45. func (d *MyDriver) DoCommit(ctx context.Context, in gdb.DoCommitInput) (out gdb.DoCommitOutput, err error) {
    46.     tsMilliStart := gtime.TimestampMilli()
    47.     out, err = d.Core.DoCommit(ctx, in)
    48.     tsMilliFinished := gtime.TimestampMilli()
    49.     _, _ = in.Link.ExecContext(ctx,
    50.         "INSERT INTO `monitor`(`sql`,`cost`,`time`,`error`) VALUES(?,?,?,?)",
    51.         gdb.FormatSqlWithArgs(in.Sql, in.Args),
    52.         tsMilliFinished-tsMilliStart,
    53.         gtime.Now(),
    54.         err,
    55.     )
    56.     return
    57. }

    我们看到，这里在包初始化方法init中使用了gdb.Register("MyDriver", &MyDriver{})来注册了了一个自定义名称的驱动。我们也可以通过gdb.Register("mysql", &MyDriver{})来覆盖已有的框架mysql驱动为自己的驱动。

    驱动名称mysql为框架默认的DriverMysql驱动的名称。

    由于这里我们使用了一个新的驱动名称MyDriver，因此在gdb配置中的type数据库类型时，需要填写该驱动名称。以下是一个使用配置的示例：

    1. database:
    2.   default:
    3.   - link: "MyDriver:root:12345678@tcp(127.0.0.1:3306)/user"