db

type ConnOptions struct {
	DSN      string // 原生 DSN（优先级最高）
	Host     string
	Port     int
	User     string
	Password string
	Database string
	Params   map[string]string // 额外参数
	Dialer   Dialer            // 自定义 dialer（如 SSH tunnel）
}

type Dialer interface {
	DialContext(ctx context.Context, network, addr string) (net.Conn, error)
}

type Driver interface {
	// Open 返回 *sql.DB；由具体 driver 实现连接参数解析。
	Open(ctx context.Context, opts ConnOptions) (*sql.DB, *errors.XError)
}

type QueryOptions struct {
	UnsafeAllowWrite bool   // 允许写操作（绕过只读保护）
	DBType           string // 数据库类型：mysql 或 pg
}

type QueryResult struct {
	Columns []string         `json:"columns" yaml:"columns"`
	Rows    []map[string]any `json:"rows" yaml:"rows"`
}