duckdb

func (*DuckDBDriver) Close ¶

func (d *DuckDBDriver) Close() error

func (*DuckDBDriver) Connect ¶

func (d *DuckDBDriver) Connect() error

func (*DuckDBDriver) CountKlineDaily ¶

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

func (*DuckDBDriver) GetBasicsBySymbol ¶

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

func (*DuckDBDriver) GetGbbq ¶

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

func (*DuckDBDriver) GetHolidays ¶

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

func (*DuckDBDriver) GetLatestDate ¶

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

func (*DuckDBDriver) GetMinDate ¶

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

func (*DuckDBDriver) GetSymbolsByClass ¶

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

func (*DuckDBDriver) ImportAdjustFactors ¶

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

func (*DuckDBDriver) ImportBasic ¶

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

func (*DuckDBDriver) ImportBlockInfo ¶

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

func (*DuckDBDriver) ImportBlockMembers ¶

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

func (*DuckDBDriver) ImportCSV ¶

func (d *DuckDBDriver) ImportCSV(meta *model.TableMeta, csvPath string) error

func (*DuckDBDriver) ImportGBBQ ¶

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

func (*DuckDBDriver) ImportHolidays ¶

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

func (*DuckDBDriver) ImportKline1Min ¶

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

func (*DuckDBDriver) ImportKlineDaily ¶

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

func (*DuckDBDriver) ImportSymbolNames ¶

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

func (*DuckDBDriver) InitSchema ¶

func (d *DuckDBDriver) InitSchema() error

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

func (*DuckDBDriver) Query ¶

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

func (*DuckDBDriver) QueryKlineDaily ¶

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

func (*DuckDBDriver) ReadSchemaVersion ¶

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

func (*DuckDBDriver) RebuildSymbolClass ¶

func (d *DuckDBDriver) RebuildSymbolClass() error

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

func (*DuckDBDriver) TruncateTable ¶

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

func (*DuckDBDriver) WriteSchemaVersion ¶

func (d *DuckDBDriver) WriteSchemaVersion() error