types

type ConnectionInfo struct {
	Host     string `json:"host"`
	Port     int    `json:"port"`
	Database string `json:"database"`
	User     string `json:"user"`
	Driver   string `json:"driver"`
	Version  string `json:"version"`
}

type DatabaseFeature string

type DatabaseStats struct {
	ActiveConnections int                    `json:"active_connections"`
	IdleConnections   int                    `json:"idle_connections"`
	MaxConnections    int                    `json:"max_connections"`
	WaitCount         int64                  `json:"wait_count"`
	WaitDuration      time.Duration          `json:"wait_duration"`
	MaxIdleClosed     int64                  `json:"max_idle_closed"`
	MaxIdleTimeClosed int64                  `json:"max_idle_time_closed"`
	MaxLifetimeClosed int64                  `json:"max_lifetime_closed"`
	ProviderData      map[string]interface{} `json:"provider_data"`
}

type ExecResult interface {
	LastInsertId() (int64, error)
	RowsAffected() (int64, error)
}

type PreparedStatement interface {
	Close() error
	Query(ctx context.Context, args ...interface{}) (QueryResult, error)
	QueryRow(ctx context.Context, args ...interface{}) (Row, error)
	Exec(ctx context.Context, args ...interface{}) (ExecResult, error)
}

type QueryResult interface {
	Close() error
	Next() bool
	Scan(dest ...interface{}) error
	Columns() ([]string, error)
	Err() error
}

type Row interface {
	Scan(dest ...interface{}) error
	Err() error
}

type Transaction interface {
	Commit() error
	Rollback() error
	Query(ctx context.Context, query string, args ...interface{}) (QueryResult, error)
	QueryRow(ctx context.Context, query string, args ...interface{}) (Row, error)
	Exec(ctx context.Context, query string, args ...interface{}) (ExecResult, error)
	Prepare(ctx context.Context, query string) (PreparedStatement, error)
}