engine

type AfterHandler func(ctx context.Context, ec *ExecutorContext, er *ExecutorResult)

type Chain struct {
	// contains filtered or unexported fields
}

type Execer interface {
	// NamedExecContext 使用命名参数执行sql
	NamedExecContext(ctx context.Context, execSQL string, arg any) (sql.Result, error)

	// ExecContext 使用数组参数执行sql
	ExecContext(ctx context.Context, execSQL string, args ...any) (sql.Result, error)
}

type Executor interface {
	Execer
	Queryer
}

type ExecutorContext struct {
	Type      SQLType
	TableName string
	SQL       string
	Args      []any
	NameArgs  any
	Start     time.Time
}

type ExecutorResult struct {
	Err       error         // 执行异常异常
	Affected  int64         // 新增、删除、修改返回的影响行数
	QueryRows int64         // 查询记录行数
	Duration  time.Duration // 耗时
}

type Hook interface {
	// Before sql 执行前
	Before(ctx context.Context, ec *ExecutorContext) error
	// After sql 执行后
	After(ctx context.Context, ec *ExecutorContext, er *ExecutorResult)
}

type Queryer interface {

	// SelectContext 查询多条数据
	SelectContext(ctx context.Context, dest any, query string, args ...any) error

	// GetContext 查询单条数据
	GetContext(ctx context.Context, dest any, query string, args ...any) error

	// QueryContext 查询多条数据，返回 sql.Rows
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
}

type SQLType string