clickhouse

func (*ClickHouseDriver) Close ¶

func (d *ClickHouseDriver) Close() error

func (*ClickHouseDriver) Connect ¶

func (d *ClickHouseDriver) Connect() error

func (*ClickHouseDriver) CountKlineDaily ¶

func (d *ClickHouseDriver) CountKlineDaily() (int64, error)

func (*ClickHouseDriver) GetBasicsBySymbol ¶

func (d *ClickHouseDriver) GetBasicsBySymbol(symbol string) ([]model.BasicDaily, error)

func (*ClickHouseDriver) GetGbbq ¶

func (d *ClickHouseDriver) GetGbbq() ([]model.GbbqData, error)

func (*ClickHouseDriver) GetHolidays ¶

func (d *ClickHouseDriver) GetHolidays() ([]time.Time, error)

func (*ClickHouseDriver) GetLatestDate ¶

func (d *ClickHouseDriver) GetLatestDate(tableName string, dateCol string) (time.Time, error)

func (*ClickHouseDriver) GetMinDate ¶

func (d *ClickHouseDriver) GetMinDate(tableName string, dateCol string) (time.Time, error)

func (*ClickHouseDriver) GetSymbolsByClass ¶

func (d *ClickHouseDriver) GetSymbolsByClass(classes ...string) ([]string, error)

func (*ClickHouseDriver) ImportAdjustFactors ¶

func (d *ClickHouseDriver) ImportAdjustFactors(path string) error

func (*ClickHouseDriver) ImportBasic ¶

func (d *ClickHouseDriver) ImportBasic(path string) error

func (*ClickHouseDriver) ImportBlockInfo ¶

func (d *ClickHouseDriver) ImportBlockInfo(path string) error

func (*ClickHouseDriver) ImportBlockMembers ¶

func (d *ClickHouseDriver) ImportBlockMembers(path string) error

func (*ClickHouseDriver) ImportCSV ¶

func (d *ClickHouseDriver) ImportCSV(meta *model.TableMeta, filePath string) error

func (*ClickHouseDriver) ImportGBBQ ¶

func (d *ClickHouseDriver) ImportGBBQ(path string) error

func (*ClickHouseDriver) ImportHolidays ¶

func (d *ClickHouseDriver) ImportHolidays(path string) error

func (*ClickHouseDriver) ImportKline1Min ¶

func (d *ClickHouseDriver) ImportKline1Min(path string) error

func (*ClickHouseDriver) ImportKlineDaily ¶

func (d *ClickHouseDriver) ImportKlineDaily(path string) error

func (*ClickHouseDriver) ImportSymbolNames ¶

func (d *ClickHouseDriver) ImportSymbolNames(path string) error

func (*ClickHouseDriver) InitSchema ¶

func (d *ClickHouseDriver) InitSchema() error

InitSchema 创建所有表 + 视图，表与视图定义均来自 model registry。

func (*ClickHouseDriver) Query ¶

func (d *ClickHouseDriver) Query(table string, conditions map[string]interface{}, dest interface{}) error

func (*ClickHouseDriver) QueryKlineDaily ¶

func (d *ClickHouseDriver) QueryKlineDaily(symbol string, startDate, endDate *time.Time) ([]model.KlineDay, error)

func (*ClickHouseDriver) ReadSchemaVersion ¶

func (d *ClickHouseDriver) ReadSchemaVersion() (string, error)

func (*ClickHouseDriver) RebuildSymbolClass ¶

func (d *ClickHouseDriver) RebuildSymbolClass() error

RebuildSymbolClass 全量重建 symbol_class 表（从 raw_kline_daily 取 distinct symbol 后归类）。 写入逻辑跟 Import 系列同性质，放这里。

func (*ClickHouseDriver) TruncateTable ¶

func (d *ClickHouseDriver) TruncateTable(meta *model.TableMeta) error

func (*ClickHouseDriver) WriteSchemaVersion ¶

func (d *ClickHouseDriver) WriteSchemaVersion() error