database

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

type ClickHouseConnector struct {
	*BaseConnector
	// contains filtered or unexported fields
}

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

type Config struct {
	Driver                     string // mysql / clickhouse / starrocks
	Host                       string
	Port                       int
	User, Password, Database   string
	MaxOpenConns, MaxIdleConns int
	ConnTimeout                time.Duration
}

type Connector interface {
	Ping(ctx context.Context) error
	Query(ctx context.Context, sql string, args ...interface{}) (Rows, error)
	Close() error
}

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

type MySQLConnector struct {
	*BaseConnector
	// contains filtered or unexported fields
}

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

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

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

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

type Rows interface {
	Close() error
	Next() bool
	Scan(dest ...interface{}) error
}