Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataRepository ¶
type DataRepository interface {
Connect() error
Close() error
InitSchema() error
ReadSchemaVersion() (string, error)
WriteSchemaVersion() error
ImportKlineDaily(csvPath string) error
ImportKline1Min(csvPath string) error
ImportKline5Min(csvPath string) error
ImportAdjustFactors(csvPath string) error
ImportGBBQ(csvPath string) error
ImportBasic(csvPath string) error
ImportHolidays(csvPath string) error
TruncateTable(meta *model.TableMeta) error
Query(table string, conditions map[string]interface{}, dest interface{}) error
QueryKlineDaily(symbol string, startDate, endDate *time.Time) ([]model.KlineDay, error)
GetLatestDate(tableName string, dateCol string) (time.Time, error)
GetSymbolsByClass(class string) ([]string, error)
RebuildSymbolClass() error
CountKlineDaily() (int64, error)
GetBasicsBySymbol(symbol string) ([]model.StockBasic, error)
GetGbbq() ([]model.GbbqData, error)
GetHolidays() ([]time.Time, error)
}
func NewDB ¶
func NewDB(dbURI string) (DataRepository, error)
Click to show internal directories.
Click to hide internal directories.