lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-22 06:53:52 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

compile and update migration package

Browse Source
This commit is contained in:
c9s 2024-01-24 15:56:04 +08:00
parent c7027db0c1
commit ee1a2727f6
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
77 changed files with 18 additions and 138 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/migrations/mysql/main_20200721225616_trades.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_trades, down_main_trades)
}
func up_main_trades(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20200819054742_trade_index.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_tradeIndex, down_main_tradeIndex)
}
func up_main_tradeIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20201102222546_orders.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_orders, down_main_orders)
}
func up_main_orders(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20201103173342_trades_add_order_id.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_tradesAddOrderId, down_main_tradesAddOrderId)
}
func up_main_tradesAddOrderId(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20201105092857_trades_index_fix.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_tradesIndexFix, down_main_tradesIndexFix)
}
func up_main_tradesIndexFix(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20201105093056_orders_add_index.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_ordersAddIndex, down_main_ordersAddIndex)
}
func up_main_ordersAddIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20201106114742_klines.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_klines, down_main_klines)
}
func up_main_klines(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20201211175751_fix_symbol_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixSymbolLength, down_main_fixSymbolLength)
}
func up_main_fixSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210118163847_fix_unique_index.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixUniqueIndex, down_main_fixUniqueIndex)
}
func up_main_fixUniqueIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210119232826_add_margin_columns.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addMarginColumns, down_main_addMarginColumns)
}
func up_main_addMarginColumns(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210129182704_trade_price_quantity_index.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_tradePriceQuantityIndex, down_main_tradePriceQuantityIndex)
}
func up_main_tradePriceQuantityIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210215203116_add_pnl_column.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addPnlColumn, down_main_addPnlColumn)
}
func up_main_addPnlColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210223080622_add_rewards_table.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addRewardsTable, down_main_addRewardsTable)
}
func up_main_addRewardsTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210301140656_add_withdraws_table.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addWithdrawsTable, down_main_addWithdrawsTable)
}
func up_main_addWithdrawsTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210307201830_add_deposits_table.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addDepositsTable, down_main_addDepositsTable)
}
func up_main_addDepositsTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210416230730_klines_symbol_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_klinesSymbolLength, down_main_klinesSymbolLength)
}
func up_main_klinesSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210421091430_increase_symbol_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_increaseSymbolLength, down_main_increaseSymbolLength)
}
func up_main_increaseSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210421095030_increase_decimal_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_increaseDecimalLength, down_main_increaseDecimalLength)
}
func up_main_increaseDecimalLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20210531234123_add_kline_taker_buy_columns.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addKlineTakerBuyColumns, down_main_addKlineTakerBuyColumns)
}
func up_main_addKlineTakerBuyColumns(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20211205162043_add_is_futures_column.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addIsFuturesColumn, down_main_addIsFuturesColumn)
}
func up_main_addIsFuturesColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20211211020303_add_ftx_kline.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addFtxKline, down_main_addFtxKline)
}
func up_main_addFtxKline(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20211211034819_add_nav_history_details.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addNavHistoryDetails, down_main_addNavHistoryDetails)
}
func up_main_addNavHistoryDetails(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20211211103657_update_fee_currency_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_updateFeeCurrencyLength, down_main_updateFeeCurrencyLength)
}
func up_main_updateFeeCurrencyLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20211226022411_add_kucoin_klines.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addKucoinKlines, down_main_addKucoinKlines)
}
func up_main_addKucoinKlines(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220304153317_add_profit_table.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addProfitTable, down_main_addProfitTable)
}
func up_main_addProfitTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220307132917_add_positions.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addPositions, down_main_addPositions)
}
func up_main_addPositions(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220317125555_fix_trade_indexes.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixTradeIndexes, down_main_fixTradeIndexes)
}
func up_main_fixTradeIndexes(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220419121046_fix_fee_column.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixFeeColumn, down_main_fixFeeColumn)
}
func up_main_fixFeeColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220503144849_add_margin_info_to_nav.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addMarginInfoToNav, down_main_addMarginInfoToNav)
}
func up_main_addMarginInfoToNav(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220504184155_fix_net_asset_column.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixNetAssetColumn, down_main_fixNetAssetColumn)
}
func up_main_fixNetAssetColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220512170322_fix_profit_symbol_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixProfitSymbolLength, down_main_fixProfitSymbolLength)
}
func up_main_fixProfitSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220520140707_kline_unique_idx.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_klineUniqueIdx, down_main_klineUniqueIdx)
}
func up_main_klineUniqueIdx(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220531012226_margin_loans.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_marginLoans, down_main_marginLoans)
}
func up_main_marginLoans(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220531013327_margin_repays.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_marginRepays, down_main_marginRepays)
}
func up_main_marginRepays(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220531013542_margin_interests.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_marginInterests, down_main_marginInterests)
}
func up_main_marginInterests(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20220531015005_margin_liquidations.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_marginLiquidations, down_main_marginLiquidations)
}
func up_main_marginLiquidations(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20230815173104_add_bybit_klines.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addBybitKlines, down_main_addBybitKlines)
}
func up_main_addBybitKlines(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/mysql/main_20231123125402_fix_order_status_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixOrderStatusLength, down_main_fixOrderStatusLength)
}
func up_main_fixOrderStatusLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

17
pkg/migrations/mysql/migration_api.go
View File

@ -9,14 +9,9 @@ import (
"github.com/c9s/rockhopper/v2"
)
type registryKey struct {
Package string
Version int64
}
var registeredGoMigrations = map[rockhopper.RegistryKey]*rockhopper.Migration{}
var registeredGoMigrations = map[registryKey]*rockhopper.Migration{}
func MergeMigrationsMap(ms map[registryKey]*rockhopper.Migration) {
func MergeMigrationsMap(ms map[rockhopper.RegistryKey]*rockhopper.Migration) {
for k, m := range ms {
if _, ok := registeredGoMigrations[k]; !ok {
registeredGoMigrations[k] = m
@ -26,7 +21,7 @@ func MergeMigrationsMap(ms map[registryKey]*rockhopper.Migration) {
}
}
func GetMigrationsMap() map[registryKey]*rockhopper.Migration {
func GetMigrationsMap() map[rockhopper.RegistryKey]*rockhopper.Migration {
return registeredGoMigrations
}
@ -71,10 +66,6 @@ func _parseFuncPackageName(funcName string) string {
// AddNamedMigration adds a named migration to the registered go migration map
func AddNamedMigration(packageName, filename string, up, down rockhopper.TransactionHandler) {
if registeredGoMigrations == nil {
registeredGoMigrations = make(map[registryKey]*rockhopper.Migration)
}
v, err := rockhopper.FileNumericComponent(filename)
if err != nil {
panic(fmt.Errorf("unable to parse numeric component from filename %s: %v", filename, err))
@ -91,7 +82,7 @@ func AddNamedMigration(packageName, filename string, up, down rockhopper.Transac
UseTx: true,
}
key := registryKey{Package: packageName, Version: v}
key := rockhopper.RegistryKey{Package: packageName, Version: v}
if existing, ok := registeredGoMigrations[key]; ok {
panic(fmt.Sprintf("failed to add migration %q: version conflicts with key %+v: %+v", filename, key, existing))
}

6
pkg/migrations/mysql/migration_api_test.go
View File

@ -14,8 +14,8 @@ func TestGetMigrationsMap(t *testing.T) {
}
func TestMergeMigrationsMap(t *testing.T) {
MergeMigrationsMap(map[registryKey]*rockhopper.Migration{
registryKey{Version: 2}: &rockhopper.Migration{},
registryKey{Version: 2}: &rockhopper.Migration{},
MergeMigrationsMap(map[rockhopper.RegistryKey]*rockhopper.Migration{
rockhopper.RegistryKey{Version: 2}: &rockhopper.Migration{},
rockhopper.RegistryKey{Version: 2}: &rockhopper.Migration{},
})
}

1
pkg/migrations/sqlite3/main_20200721225616_trades.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_trades, down_main_trades)
}
func up_main_trades(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20200819054742_trade_index.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_tradeIndex, down_main_tradeIndex)
}
func up_main_tradeIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20201102222546_orders.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_orders, down_main_orders)
}
func up_main_orders(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20201103173342_trades_add_order_id.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_tradesAddOrderId, down_main_tradesAddOrderId)
}
func up_main_tradesAddOrderId(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20201105092857_trades_index_fix.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_tradesIndexFix, down_main_tradesIndexFix)
}
func up_main_tradesIndexFix(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20201105093056_orders_add_index.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_ordersAddIndex, down_main_ordersAddIndex)
}
func up_main_ordersAddIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

9
pkg/migrations/sqlite3/main_20201106114742_klines.go
View File

@ -8,24 +8,23 @@ import (
func init() {
AddMigration("main", up_main_klines, down_main_klines)
}
func up_main_klines(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {
// This code is executed when the migration is applied.
_, err = tx.ExecContext(ctx, "CREATE TABLE `klines`\n(\n `gid` INTEGER PRIMARY KEY AUTOINCREMENT,\n `exchange` VARCHAR(10) NOT NULL,\n `start_time` DATETIME(3) NOT NULL,\n `end_time` DATETIME(3) NOT NULL,\n `interval` VARCHAR(3) NOT NULL,\n `symbol` VARCHAR(7) NOT NULL,\n `open` DECIMAL(16, 8) NOT NULL,\n `high` DECIMAL(16, 8) NOT NULL,\n `low` DECIMAL(16, 8) NOT NULL,\n `close` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `volume` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `closed` BOOLEAN NOT NULL DEFAULT TRUE,\n `last_trade_id` INT NOT NULL DEFAULT 0,\n `num_trades` INT NOT NULL DEFAULT 0\n);")
_, err = tx.ExecContext(ctx, "CREATE TABLE `klines`\n(\n `gid` INTEGER PRIMARY KEY AUTOINCREMENT,\n `exchange` VARCHAR(10) NOT NULL,\n `start_time` DATETIME(3) NOT NULL,\n `end_time` DATETIME(3) NOT NULL,\n `interval` VARCHAR(3) NOT NULL,\n `symbol` VARCHAR(7) NOT NULL,\n `open` DECIMAL(16, 8) NOT NULL,\n `high` DECIMAL(16, 8) NOT NULL,\n `low` DECIMAL(16, 8) NOT NULL,\n `close` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `volume` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `closed` BOOLEAN NOT NULL DEFAULT TRUE,\n `last_trade_id` INT NOT NULL DEFAULT 0,\n `num_trades` INT NOT NULL DEFAULT 0\n);")
if err != nil {
return err
}
_, err = tx.ExecContext(ctx, "CREATE TABLE `okex_klines`\n(\n `gid` INTEGER PRIMARY KEY AUTOINCREMENT,\n `exchange` VARCHAR(10) NOT NULL,\n `start_time` DATETIME(3) NOT NULL,\n `end_time` DATETIME(3) NOT NULL,\n `interval` VARCHAR(3) NOT NULL,\n `symbol` VARCHAR(7) NOT NULL,\n `open` DECIMAL(16, 8) NOT NULL,\n `high` DECIMAL(16, 8) NOT NULL,\n `low` DECIMAL(16, 8) NOT NULL,\n `close` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `volume` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `closed` BOOLEAN NOT NULL DEFAULT TRUE,\n `last_trade_id` INT NOT NULL DEFAULT 0,\n `num_trades` INT NOT NULL DEFAULT 0\n);")
_, err = tx.ExecContext(ctx, "CREATE TABLE `okex_klines`\n(\n `gid` INTEGER PRIMARY KEY AUTOINCREMENT,\n `exchange` VARCHAR(10) NOT NULL,\n `start_time` DATETIME(3) NOT NULL,\n `end_time` DATETIME(3) NOT NULL,\n `interval` VARCHAR(3) NOT NULL,\n `symbol` VARCHAR(7) NOT NULL,\n `open` DECIMAL(16, 8) NOT NULL,\n `high` DECIMAL(16, 8) NOT NULL,\n `low` DECIMAL(16, 8) NOT NULL,\n `close` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `volume` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `closed` BOOLEAN NOT NULL DEFAULT TRUE,\n `last_trade_id` INT NOT NULL DEFAULT 0,\n `num_trades` INT NOT NULL DEFAULT 0\n);")
if err != nil {
return err
}
_, err = tx.ExecContext(ctx, "CREATE TABLE `binance_klines`\n(\n `gid` INTEGER PRIMARY KEY AUTOINCREMENT,\n `exchange` VARCHAR(10) NOT NULL,\n `start_time` DATETIME(3) NOT NULL,\n `end_time` DATETIME(3) NOT NULL,\n `interval` VARCHAR(3) NOT NULL,\n `symbol` VARCHAR(7) NOT NULL,\n `open` DECIMAL(16, 8) NOT NULL,\n `high` DECIMAL(16, 8) NOT NULL,\n `low` DECIMAL(16, 8) NOT NULL,\n `close` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `volume` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `closed` BOOLEAN NOT NULL DEFAULT TRUE,\n `last_trade_id` INT NOT NULL DEFAULT 0,\n `num_trades` INT NOT NULL DEFAULT 0\n);")
_, err = tx.ExecContext(ctx, "CREATE TABLE `binance_klines`\n(\n `gid` INTEGER PRIMARY KEY AUTOINCREMENT,\n `exchange` VARCHAR(10) NOT NULL,\n `start_time` DATETIME(3) NOT NULL,\n `end_time` DATETIME(3) NOT NULL,\n `interval` VARCHAR(3) NOT NULL,\n `symbol` VARCHAR(7) NOT NULL,\n `open` DECIMAL(16, 8) NOT NULL,\n `high` DECIMAL(16, 8) NOT NULL,\n `low` DECIMAL(16, 8) NOT NULL,\n `close` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `volume` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `closed` BOOLEAN NOT NULL DEFAULT TRUE,\n `last_trade_id` INT NOT NULL DEFAULT 0,\n `num_trades` INT NOT NULL DEFAULT 0\n);")
if err != nil {
return err
}
_, err = tx.ExecContext(ctx, "CREATE TABLE `max_klines`\n(\n `gid` INTEGER PRIMARY KEY AUTOINCREMENT,\n `exchange` VARCHAR(10) NOT NULL,\n `start_time` DATETIME(3) NOT NULL,\n `end_time` DATETIME(3) NOT NULL,\n `interval` VARCHAR(3) NOT NULL,\n `symbol` VARCHAR(7) NOT NULL,\n `open` DECIMAL(16, 8) NOT NULL,\n `high` DECIMAL(16, 8) NOT NULL,\n `low` DECIMAL(16, 8) NOT NULL,\n `close` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `volume` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `closed` BOOLEAN NOT NULL DEFAULT TRUE,\n `last_trade_id` INT NOT NULL DEFAULT 0,\n `num_trades` INT NOT NULL DEFAULT 0\n);")
_, err = tx.ExecContext(ctx, "CREATE TABLE `max_klines`\n(\n `gid` INTEGER PRIMARY KEY AUTOINCREMENT,\n `exchange` VARCHAR(10) NOT NULL,\n `start_time` DATETIME(3) NOT NULL,\n `end_time` DATETIME(3) NOT NULL,\n `interval` VARCHAR(3) NOT NULL,\n `symbol` VARCHAR(7) NOT NULL,\n `open` DECIMAL(16, 8) NOT NULL,\n `high` DECIMAL(16, 8) NOT NULL,\n `low` DECIMAL(16, 8) NOT NULL,\n `close` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `volume` DECIMAL(16, 8) NOT NULL DEFAULT 0.0,\n `closed` BOOLEAN NOT NULL DEFAULT TRUE,\n `last_trade_id` INT NOT NULL DEFAULT 0,\n `num_trades` INT NOT NULL DEFAULT 0\n);")
if err != nil {
return err
}

30
pkg/migrations/sqlite3/main_20201211175751_fix_symbol_length.go
View File

@ -1,30 +0,0 @@
package sqlite3
import (
"context"
"github.com/c9s/rockhopper/v2"
)
func init() {
AddMigration("main", up_main_fixSymbolLength, down_main_fixSymbolLength)
}
func up_main_fixSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {
// This code is executed when the migration is applied.
_, err = tx.ExecContext(ctx, "SELECT 1;")
if err != nil {
return err
}
return err
}
func down_main_fixSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {
// This code is executed when the migration is rolled back.
_, err = tx.ExecContext(ctx, "SELECT 1;")
if err != nil {
return err
}
return err
}

1
pkg/migrations/sqlite3/main_20210118163847_fix_unique_index.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixUniqueIndex, down_main_fixUniqueIndex)
}
func up_main_fixUniqueIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20210119232826_add_margin_columns.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addMarginColumns, down_main_addMarginColumns)
}
func up_main_addMarginColumns(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20210129182704_trade_price_quantity_index.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_tradePriceQuantityIndex, down_main_tradePriceQuantityIndex)
}
func up_main_tradePriceQuantityIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20210215203111_add_pnl_column.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addPnlColumn, down_main_addPnlColumn)
}
func up_main_addPnlColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20210223080622_add_rewards_table.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addRewardsTable, down_main_addRewardsTable)
}
func up_main_addRewardsTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20210301140656_add_withdraws_table.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addWithdrawsTable, down_main_addWithdrawsTable)
}
func up_main_addWithdrawsTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20210307201830_add_deposits_table.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addDepositsTable, down_main_addDepositsTable)
}
func up_main_addDepositsTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20210531234123_add_kline_taker_buy_columns.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addKlineTakerBuyColumns, down_main_addKlineTakerBuyColumns)
}
func up_main_addKlineTakerBuyColumns(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20211205162302_add_is_futures_column.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addIsFuturesColumn, down_main_addIsFuturesColumn)
}
func up_main_addIsFuturesColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20211211020303_add_ftx_kline.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addFtxKline, down_main_addFtxKline)
}
func up_main_addFtxKline(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20211211034818_add_nav_history_details.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addNavHistoryDetails, down_main_addNavHistoryDetails)
}
func up_main_addNavHistoryDetails(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20211211103657_update_fee_currency_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_updateFeeCurrencyLength, down_main_updateFeeCurrencyLength)
}
func up_main_updateFeeCurrencyLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20211226022411_add_kucoin_klines.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addKucoinKlines, down_main_addKucoinKlines)
}
func up_main_addKucoinKlines(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220304153309_add_profit_table.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addProfitTable, down_main_addProfitTable)
}
func up_main_addProfitTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220307132917_add_positions.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addPositions, down_main_addPositions)
}
func up_main_addPositions(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220317125555_fix_trade_indexes.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixTradeIndexes, down_main_fixTradeIndexes)
}
func up_main_fixTradeIndexes(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220419121046_fix_fee_column.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixFeeColumn, down_main_fixFeeColumn)
}
func up_main_fixFeeColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220503144849_add_margin_info_to_nav.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addMarginInfoToNav, down_main_addMarginInfoToNav)
}
func up_main_addMarginInfoToNav(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220504184155_fix_net_asset_column.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixNetAssetColumn, down_main_fixNetAssetColumn)
}
func up_main_fixNetAssetColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220512170330_fix_profit_symbol_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixProfitSymbolLength, down_main_fixProfitSymbolLength)
}
func up_main_fixProfitSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220520140707_kline_unique_idx.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_klineUniqueIdx, down_main_klineUniqueIdx)
}
func up_main_klineUniqueIdx(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220531012226_margin_loans.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_marginLoans, down_main_marginLoans)
}
func up_main_marginLoans(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220531013327_margin_repays.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_marginRepays, down_main_marginRepays)
}
func up_main_marginRepays(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220531013541_margin_interests.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_marginInterests, down_main_marginInterests)
}
func up_main_marginInterests(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20220531015005_margin_liquidations.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_marginLiquidations, down_main_marginLiquidations)
}
func up_main_marginLiquidations(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20230815173104_add_bybit_klines.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_addBybitKlines, down_main_addBybitKlines)
}
func up_main_addBybitKlines(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

1
pkg/migrations/sqlite3/main_20231123125402_fix_order_status_length.go
View File

@ -8,7 +8,6 @@ import (
func init() {
AddMigration("main", up_main_fixOrderStatusLength, down_main_fixOrderStatusLength)
}
func up_main_fixOrderStatusLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

17
pkg/migrations/sqlite3/migration_api.go
View File

@ -9,14 +9,9 @@ import (
"github.com/c9s/rockhopper/v2"
)
type registryKey struct {
Package string
Version int64
}
var registeredGoMigrations = map[rockhopper.RegistryKey]*rockhopper.Migration{}
var registeredGoMigrations = map[registryKey]*rockhopper.Migration{}
func MergeMigrationsMap(ms map[registryKey]*rockhopper.Migration) {
func MergeMigrationsMap(ms map[rockhopper.RegistryKey]*rockhopper.Migration) {
for k, m := range ms {
if _, ok := registeredGoMigrations[k]; !ok {
registeredGoMigrations[k] = m
@ -26,7 +21,7 @@ func MergeMigrationsMap(ms map[registryKey]*rockhopper.Migration) {
}
}
func GetMigrationsMap() map[registryKey]*rockhopper.Migration {
func GetMigrationsMap() map[rockhopper.RegistryKey]*rockhopper.Migration {
return registeredGoMigrations
}
@ -71,10 +66,6 @@ func _parseFuncPackageName(funcName string) string {
// AddNamedMigration adds a named migration to the registered go migration map
func AddNamedMigration(packageName, filename string, up, down rockhopper.TransactionHandler) {
if registeredGoMigrations == nil {
registeredGoMigrations = make(map[registryKey]*rockhopper.Migration)
}
v, err := rockhopper.FileNumericComponent(filename)
if err != nil {
panic(fmt.Errorf("unable to parse numeric component from filename %s: %v", filename, err))
@ -91,7 +82,7 @@ func AddNamedMigration(packageName, filename string, up, down rockhopper.Transac
UseTx: true,
}
key := registryKey{Package: packageName, Version: v}
key := rockhopper.RegistryKey{Package: packageName, Version: v}
if existing, ok := registeredGoMigrations[key]; ok {
panic(fmt.Sprintf("failed to add migration %q: version conflicts with key %+v: %+v", filename, key, existing))
}

6
pkg/migrations/sqlite3/migration_api_test.go
View File

@ -14,8 +14,8 @@ func TestGetMigrationsMap(t *testing.T) {
}
func TestMergeMigrationsMap(t *testing.T) {
MergeMigrationsMap(map[registryKey]*rockhopper.Migration{
registryKey{Version: 2}: &rockhopper.Migration{},
registryKey{Version: 2}: &rockhopper.Migration{},
MergeMigrationsMap(map[rockhopper.RegistryKey]*rockhopper.Migration{
rockhopper.RegistryKey{Version: 2}: &rockhopper.Migration{},
rockhopper.RegistryKey{Version: 2}: &rockhopper.Migration{},
})
}