forked from kodorvan/stcs
Added alembic migrations
This commit is contained in:
36
alembic/versions/09db71875980_updated_user_deals_table.py
Normal file
36
alembic/versions/09db71875980_updated_user_deals_table.py
Normal file
@@ -0,0 +1,36 @@
|
||||
"""updated user deals table
|
||||
|
||||
Revision ID: 09db71875980
|
||||
Revises: 77197715747c
|
||||
Create Date: 2025-09-29 12:57:39.943294
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '09db71875980'
|
||||
down_revision: Union[str, Sequence[str], None] = '77197715747c'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('order_quantity', sa.Float(), nullable=True))
|
||||
op.create_unique_constraint('uq_user_symbol', 'user_deals', ['user_id', 'symbol'])
|
||||
op.drop_column('user_deals', 'quantity')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('quantity', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True))
|
||||
op.drop_constraint('uq_user_symbol', 'user_deals', type_='unique')
|
||||
op.drop_column('user_deals', 'order_quantity')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,40 @@
|
||||
"""Added conditional_order_type
|
||||
|
||||
Revision ID: 0eed68eddcdb
|
||||
Revises: 70094ba27e80
|
||||
Create Date: 2025-09-24 13:47:23.282807
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '0eed68eddcdb'
|
||||
down_revision: Union[str, Sequence[str], None] = '70094ba27e80'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_additional_settings', sa.Column('conditional_order_type', sa.String(), nullable=False))
|
||||
op.add_column('user_additional_settings', sa.Column('limit_price', sa.Float(), nullable=False))
|
||||
op.add_column('user_additional_settings', sa.Column('trigger_price', sa.Float(), nullable=False))
|
||||
op.drop_column('user_conditional_settings', 'trigger_price')
|
||||
op.drop_column('user_conditional_settings', 'limit_price')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_conditional_settings', sa.Column('limit_price', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=False))
|
||||
op.add_column('user_conditional_settings', sa.Column('trigger_price', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=False))
|
||||
op.drop_column('user_additional_settings', 'trigger_price')
|
||||
op.drop_column('user_additional_settings', 'limit_price')
|
||||
op.drop_column('user_additional_settings', 'conditional_order_type')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,34 @@
|
||||
"""Added fee for user auto trading
|
||||
|
||||
Revision ID: 10bf073c71f9
|
||||
Revises: 2b9572b49ecd
|
||||
Create Date: 2025-10-02 17:52:05.235523
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '10bf073c71f9'
|
||||
down_revision: Union[str, Sequence[str], None] = '2b9572b49ecd'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_auto_trading', sa.Column('fee', sa.Float(), nullable=True))
|
||||
op.drop_column('user_deals', 'fee')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('fee', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True))
|
||||
op.drop_column('user_auto_trading', 'fee')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,34 @@
|
||||
"""Added side for user auto trading
|
||||
|
||||
Revision ID: 2b9572b49ecd
|
||||
Revises: ef342b38e17b
|
||||
Create Date: 2025-10-02 17:21:20.904797
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '2b9572b49ecd'
|
||||
down_revision: Union[str, Sequence[str], None] = 'ef342b38e17b'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_auto_trading', sa.Column('side', sa.String(), nullable=True))
|
||||
op.drop_constraint(op.f('uq_user_auto_trading_symbol'), 'user_auto_trading', type_='unique')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.create_unique_constraint(op.f('uq_user_auto_trading_symbol'), 'user_auto_trading', ['user_id', 'symbol'], postgresql_nulls_not_distinct=False)
|
||||
op.drop_column('user_auto_trading', 'side')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,32 @@
|
||||
"""update last side the conditional data
|
||||
|
||||
Revision ID: 3534adf891fc
|
||||
Revises: ef38c90eed55
|
||||
Create Date: 2025-09-30 08:39:02.971158
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '3534adf891fc'
|
||||
down_revision: Union[str, Sequence[str], None] = 'ef38c90eed55'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
pass
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
pass
|
||||
# ### end Alembic commands ###
|
38
alembic/versions/42c66cfe8d4e_updated_martingale_factor.py
Normal file
38
alembic/versions/42c66cfe8d4e_updated_martingale_factor.py
Normal file
@@ -0,0 +1,38 @@
|
||||
"""Updated martingale factor
|
||||
|
||||
Revision ID: 42c66cfe8d4e
|
||||
Revises: 45977e9d8558
|
||||
Create Date: 2025-09-22 17:17:39.779979
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '42c66cfe8d4e'
|
||||
down_revision: Union[str, Sequence[str], None] = '45977e9d8558'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.alter_column('user_additional_settings', 'martingale_factor',
|
||||
existing_type=sa.INTEGER(),
|
||||
type_=sa.Float(),
|
||||
existing_nullable=False)
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.alter_column('user_additional_settings', 'martingale_factor',
|
||||
existing_type=sa.Float(),
|
||||
type_=sa.INTEGER(),
|
||||
existing_nullable=False)
|
||||
# ### end Alembic commands ###
|
38
alembic/versions/45977e9d8558_updated_order_quantity.py
Normal file
38
alembic/versions/45977e9d8558_updated_order_quantity.py
Normal file
@@ -0,0 +1,38 @@
|
||||
"""Updated order quantity
|
||||
|
||||
Revision ID: 45977e9d8558
|
||||
Revises: fd8581c0cc87
|
||||
Create Date: 2025-09-22 16:59:40.415398
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '45977e9d8558'
|
||||
down_revision: Union[str, Sequence[str], None] = 'fd8581c0cc87'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.alter_column('user_additional_settings', 'order_quantity',
|
||||
existing_type=sa.INTEGER(),
|
||||
type_=sa.Float(),
|
||||
existing_nullable=False)
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.alter_column('user_additional_settings', 'order_quantity',
|
||||
existing_type=sa.Float(),
|
||||
type_=sa.INTEGER(),
|
||||
existing_nullable=False)
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,40 @@
|
||||
"""Create User Conditional Setting
|
||||
|
||||
Revision ID: 70094ba27e80
|
||||
Revises: 42c66cfe8d4e
|
||||
Create Date: 2025-09-23 16:47:07.161544
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '70094ba27e80'
|
||||
down_revision: Union[str, Sequence[str], None] = '42c66cfe8d4e'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.create_table('user_conditional_settings',
|
||||
sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
|
||||
sa.Column('user_id', sa.Integer(), nullable=False),
|
||||
sa.Column('limit_price', sa.Float(), nullable=False),
|
||||
sa.Column('trigger_price', sa.Float(), nullable=False),
|
||||
sa.ForeignKeyConstraint(['user_id'], ['users.id'], ondelete='CASCADE'),
|
||||
sa.PrimaryKeyConstraint('id'),
|
||||
sa.UniqueConstraint('user_id')
|
||||
)
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_table('user_conditional_settings')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,42 @@
|
||||
"""added user_auto_trading table
|
||||
|
||||
Revision ID: 73a00faa4f7f
|
||||
Revises: 968f8121104f
|
||||
Create Date: 2025-10-01 12:30:21.830851
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '73a00faa4f7f'
|
||||
down_revision: Union[str, Sequence[str], None] = '968f8121104f'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.create_table('user_auto_trading',
|
||||
sa.Column('id', sa.Integer(), autoincrement=True, nullable=False),
|
||||
sa.Column('user_id', sa.Integer(), nullable=False),
|
||||
sa.Column('symbol', sa.String(), nullable=True),
|
||||
sa.Column('auto_trading', sa.Boolean(), nullable=True),
|
||||
sa.ForeignKeyConstraint(['user_id'], ['users.id'], ondelete='CASCADE'),
|
||||
sa.PrimaryKeyConstraint('id'),
|
||||
sa.UniqueConstraint('user_id', 'symbol', name='uq_user_auto_trading_symbol')
|
||||
)
|
||||
op.drop_column('user_conditional_settings', 'auto_trading')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_conditional_settings', sa.Column('auto_trading', sa.BOOLEAN(), autoincrement=False, nullable=True))
|
||||
op.drop_table('user_auto_trading')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,32 @@
|
||||
"""deleted position_idx for user deals table
|
||||
|
||||
Revision ID: 77197715747c
|
||||
Revises: 8f1476c68efa
|
||||
Create Date: 2025-09-29 12:20:18.928995
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '77197715747c'
|
||||
down_revision: Union[str, Sequence[str], None] = '8f1476c68efa'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_column('user_deals', 'position_idx')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('position_idx', sa.INTEGER(), autoincrement=False, nullable=True))
|
||||
# ### end Alembic commands ###
|
32
alembic/versions/863d6215e1eb_updated_deals.py
Normal file
32
alembic/versions/863d6215e1eb_updated_deals.py
Normal file
@@ -0,0 +1,32 @@
|
||||
"""Updated Deals
|
||||
|
||||
Revision ID: 863d6215e1eb
|
||||
Revises: f00a94ccdf01
|
||||
Create Date: 2025-09-28 23:13:39.484468
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '863d6215e1eb'
|
||||
down_revision: Union[str, Sequence[str], None] = 'f00a94ccdf01'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('margin_type', sa.String(), nullable=True))
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_column('user_deals', 'margin_type')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,34 @@
|
||||
"""added position_idx for user deals table
|
||||
|
||||
Revision ID: 8f1476c68efa
|
||||
Revises: 863d6215e1eb
|
||||
Create Date: 2025-09-29 11:40:46.512160
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '8f1476c68efa'
|
||||
down_revision: Union[str, Sequence[str], None] = '863d6215e1eb'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('position_idx', sa.Integer(), nullable=True))
|
||||
op.drop_constraint(op.f('user_deals_user_id_key'), 'user_deals', type_='unique')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.create_unique_constraint(op.f('user_deals_user_id_key'), 'user_deals', ['user_id'], postgresql_nulls_not_distinct=False)
|
||||
op.drop_column('user_deals', 'position_idx')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,36 @@
|
||||
"""updated user_deals and user_conditional_settings
|
||||
|
||||
Revision ID: 968f8121104f
|
||||
Revises: dbffe818030c
|
||||
Create Date: 2025-10-01 11:45:49.073865
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = '968f8121104f'
|
||||
down_revision: Union[str, Sequence[str], None] = 'dbffe818030c'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_conditional_settings', sa.Column('auto_trading', sa.Boolean(), nullable=True))
|
||||
op.drop_column('user_deals', 'commission_fee')
|
||||
op.drop_column('user_deals', 'auto_trading')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('auto_trading', sa.BOOLEAN(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('commission_fee', sa.VARCHAR(), autoincrement=False, nullable=True))
|
||||
op.drop_column('user_conditional_settings', 'auto_trading')
|
||||
# ### end Alembic commands ###
|
60
alembic/versions/acbcc95de48d_updated_userdeals.py
Normal file
60
alembic/versions/acbcc95de48d_updated_userdeals.py
Normal file
@@ -0,0 +1,60 @@
|
||||
"""Updated UserDeals
|
||||
|
||||
Revision ID: acbcc95de48d
|
||||
Revises: ccdc5764eb4f
|
||||
Create Date: 2025-09-28 16:57:28.384116
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'acbcc95de48d'
|
||||
down_revision: Union[str, Sequence[str], None] = 'ccdc5764eb4f'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_conditional_settings', sa.Column('auto_trading', sa.String(), nullable=False))
|
||||
op.add_column('user_deals', sa.Column('trading_type', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('conditional_order_type', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('take_profit_percent', sa.Integer(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('stop_loss_percent', sa.Integer(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('max_risk_percent', sa.Integer(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('commission_fee', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('switch_side_mode', sa.String(), nullable=True))
|
||||
op.drop_index(op.f('ix_user_deals_deal_series_id'), table_name='user_deals')
|
||||
op.drop_column('user_deals', 'take_profit')
|
||||
op.drop_column('user_deals', 'deal_series_id')
|
||||
op.drop_column('user_deals', 'price')
|
||||
op.drop_column('user_deals', 'exec_fee')
|
||||
op.drop_column('user_deals', 'stop_loss')
|
||||
op.drop_column('user_deals', 'closed_size')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('closed_size', sa.VARCHAR(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('stop_loss', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('exec_fee', sa.VARCHAR(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('price', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('deal_series_id', sa.INTEGER(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('take_profit', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True))
|
||||
op.create_index(op.f('ix_user_deals_deal_series_id'), 'user_deals', ['deal_series_id'], unique=False)
|
||||
op.drop_column('user_deals', 'switch_side_mode')
|
||||
op.drop_column('user_deals', 'commission_fee')
|
||||
op.drop_column('user_deals', 'max_risk_percent')
|
||||
op.drop_column('user_deals', 'stop_loss_percent')
|
||||
op.drop_column('user_deals', 'take_profit_percent')
|
||||
op.drop_column('user_deals', 'conditional_order_type')
|
||||
op.drop_column('user_deals', 'trading_type')
|
||||
op.drop_column('user_conditional_settings', 'auto_trading')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,79 @@
|
||||
"""unnecessary data has been deleted
|
||||
|
||||
Revision ID: c710f4e2259c
|
||||
Revises: 10bf073c71f9
|
||||
Create Date: 2025-10-09 14:17:32.632574
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'c710f4e2259c'
|
||||
down_revision: Union[str, Sequence[str], None] = '10bf073c71f9'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_additional_settings',
|
||||
sa.Column('switch_side', sa.Boolean(), nullable=False, server_default=sa.false()))
|
||||
op.drop_column('user_additional_settings', 'leverage_to_buy')
|
||||
op.drop_column('user_additional_settings', 'order_type')
|
||||
op.drop_column('user_additional_settings', 'limit_price')
|
||||
op.drop_column('user_additional_settings', 'leverage_to_sell')
|
||||
op.drop_column('user_additional_settings', 'conditional_order_type')
|
||||
op.add_column('user_auto_trading', sa.Column('total_fee', sa.Float(), nullable=True))
|
||||
op.drop_column('user_auto_trading', 'side')
|
||||
op.drop_column('user_deals', 'switch_side_mode')
|
||||
op.drop_column('user_deals', 'leverage_to_buy')
|
||||
op.drop_column('user_deals', 'order_type')
|
||||
op.drop_column('user_deals', 'limit_price')
|
||||
op.drop_column('user_deals', 'max_risk_percent')
|
||||
op.drop_column('user_deals', 'leverage_to_sell')
|
||||
op.drop_column('user_deals', 'conditional_order_type')
|
||||
op.alter_column('user_risk_management', 'take_profit_percent',
|
||||
existing_type=sa.INTEGER(),
|
||||
type_=sa.Float(),
|
||||
existing_nullable=False)
|
||||
op.alter_column('user_risk_management', 'stop_loss_percent',
|
||||
existing_type=sa.INTEGER(),
|
||||
type_=sa.Float(),
|
||||
existing_nullable=False)
|
||||
op.drop_column('user_risk_management', 'max_risk_percent')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_risk_management', sa.Column('max_risk_percent', sa.INTEGER(), autoincrement=False, nullable=False))
|
||||
op.alter_column('user_risk_management', 'stop_loss_percent',
|
||||
existing_type=sa.Float(),
|
||||
type_=sa.INTEGER(),
|
||||
existing_nullable=False)
|
||||
op.alter_column('user_risk_management', 'take_profit_percent',
|
||||
existing_type=sa.Float(),
|
||||
type_=sa.INTEGER(),
|
||||
existing_nullable=False)
|
||||
op.add_column('user_deals', sa.Column('conditional_order_type', sa.VARCHAR(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('leverage_to_sell', sa.VARCHAR(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('max_risk_percent', sa.INTEGER(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('limit_price', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('order_type', sa.VARCHAR(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('leverage_to_buy', sa.VARCHAR(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_deals', sa.Column('switch_side_mode', sa.BOOLEAN(), autoincrement=False, nullable=True))
|
||||
op.add_column('user_auto_trading', sa.Column('side', sa.VARCHAR(), autoincrement=False, nullable=True))
|
||||
op.drop_column('user_auto_trading', 'total_fee')
|
||||
op.add_column('user_additional_settings', sa.Column('conditional_order_type', sa.VARCHAR(), autoincrement=False, nullable=False))
|
||||
op.add_column('user_additional_settings', sa.Column('leverage_to_sell', sa.VARCHAR(), autoincrement=False, nullable=False))
|
||||
op.add_column('user_additional_settings', sa.Column('limit_price', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=False))
|
||||
op.add_column('user_additional_settings', sa.Column('order_type', sa.VARCHAR(), server_default=sa.text("'Market'::character varying"), autoincrement=False, nullable=False))
|
||||
op.add_column('user_additional_settings', sa.Column('leverage_to_buy', sa.VARCHAR(), autoincrement=False, nullable=False))
|
||||
op.drop_column('user_additional_settings', 'switch_side')
|
||||
# ### end Alembic commands ###
|
38
alembic/versions/c98b9dc36d15_fixed_auto_trade.py
Normal file
38
alembic/versions/c98b9dc36d15_fixed_auto_trade.py
Normal file
@@ -0,0 +1,38 @@
|
||||
"""Fixed auto_trade
|
||||
|
||||
Revision ID: c98b9dc36d15
|
||||
Revises: acbcc95de48d
|
||||
Create Date: 2025-09-28 21:33:08.319232
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'c98b9dc36d15'
|
||||
down_revision: Union[str, Sequence[str], None] = 'acbcc95de48d'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.alter_column('user_conditional_settings', 'auto_trading',
|
||||
existing_type=sa.VARCHAR(),
|
||||
type_=sa.Boolean(),
|
||||
existing_nullable=False)
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.alter_column('user_conditional_settings', 'auto_trading',
|
||||
existing_type=sa.Boolean(),
|
||||
type_=sa.VARCHAR(),
|
||||
existing_nullable=False)
|
||||
# ### end Alembic commands ###
|
50
alembic/versions/ccdc5764eb4f_added_userdeals.py
Normal file
50
alembic/versions/ccdc5764eb4f_added_userdeals.py
Normal file
@@ -0,0 +1,50 @@
|
||||
"""Added UserDeals
|
||||
|
||||
Revision ID: ccdc5764eb4f
|
||||
Revises: 0eed68eddcdb
|
||||
Create Date: 2025-09-25 22:39:17.246594
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'ccdc5764eb4f'
|
||||
down_revision: Union[str, Sequence[str], None] = '0eed68eddcdb'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_conditional_settings', sa.Column('timer_start', sa.Integer(), nullable=False))
|
||||
op.add_column('user_conditional_settings', sa.Column('timer_end', sa.Integer(), nullable=False))
|
||||
op.add_column('user_deals', sa.Column('trade_mode', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('order_type', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('leverage', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('leverage_to_buy', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('leverage_to_sell', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('closed_side', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('martingale_factor', sa.Float(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('max_bets_in_series', sa.Integer(), nullable=True))
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_column('user_deals', 'max_bets_in_series')
|
||||
op.drop_column('user_deals', 'martingale_factor')
|
||||
op.drop_column('user_deals', 'closed_side')
|
||||
op.drop_column('user_deals', 'leverage_to_sell')
|
||||
op.drop_column('user_deals', 'leverage_to_buy')
|
||||
op.drop_column('user_deals', 'leverage')
|
||||
op.drop_column('user_deals', 'order_type')
|
||||
op.drop_column('user_deals', 'trade_mode')
|
||||
op.drop_column('user_conditional_settings', 'timer_end')
|
||||
op.drop_column('user_conditional_settings', 'timer_start')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,34 @@
|
||||
"""added limit and trigger price for user deals
|
||||
|
||||
Revision ID: d3c85bad8c98
|
||||
Revises: 09db71875980
|
||||
Create Date: 2025-09-29 16:50:36.818798
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'd3c85bad8c98'
|
||||
down_revision: Union[str, Sequence[str], None] = '09db71875980'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('limit_price', sa.Float(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('trigger_price', sa.Float(), nullable=True))
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_column('user_deals', 'trigger_price')
|
||||
op.drop_column('user_deals', 'limit_price')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,40 @@
|
||||
"""added last_side and auto_trading for user_deals
|
||||
|
||||
Revision ID: dbffe818030c
|
||||
Revises: 3534adf891fc
|
||||
Create Date: 2025-10-01 09:29:55.554101
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'dbffe818030c'
|
||||
down_revision: Union[str, Sequence[str], None] = '3534adf891fc'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_column('user_conditional_settings', 'last_side')
|
||||
op.drop_column('user_conditional_settings', 'auto_trading')
|
||||
op.add_column('user_deals', sa.Column('last_side', sa.String(), nullable=True))
|
||||
op.add_column('user_deals', sa.Column('auto_trading', sa.Boolean(), nullable=True))
|
||||
op.drop_column('user_deals', 'side')
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('side', sa.VARCHAR(), autoincrement=False, nullable=True))
|
||||
op.drop_column('user_deals', 'auto_trading')
|
||||
op.drop_column('user_deals', 'last_side')
|
||||
op.add_column('user_conditional_settings', sa.Column('auto_trading', sa.BOOLEAN(), server_default=sa.text('false'), autoincrement=False, nullable=False))
|
||||
op.add_column('user_conditional_settings', sa.Column('last_side', sa.VARCHAR(), autoincrement=False, nullable=False))
|
||||
# ### end Alembic commands ###
|
32
alembic/versions/ef342b38e17b_added_fee_user_deals.py
Normal file
32
alembic/versions/ef342b38e17b_added_fee_user_deals.py
Normal file
@@ -0,0 +1,32 @@
|
||||
"""added fee user deals
|
||||
|
||||
Revision ID: ef342b38e17b
|
||||
Revises: 73a00faa4f7f
|
||||
Create Date: 2025-10-02 15:10:25.456983
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'ef342b38e17b'
|
||||
down_revision: Union[str, Sequence[str], None] = '73a00faa4f7f'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user_deals', sa.Column('fee', sa.Float(), nullable=True))
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_column('user_deals', 'fee')
|
||||
# ### end Alembic commands ###
|
@@ -0,0 +1,38 @@
|
||||
"""added last side the conditional data
|
||||
|
||||
Revision ID: ef38c90eed55
|
||||
Revises: d3c85bad8c98
|
||||
Create Date: 2025-09-30 08:33:23.415545
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'ef38c90eed55'
|
||||
down_revision: Union[str, Sequence[str], None] = 'd3c85bad8c98'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
op.add_column('user_conditional_settings', sa.Column('last_side', sa.String(), nullable=True))
|
||||
|
||||
# Обновляем все существующие строки значением по умолчанию
|
||||
op.execute(
|
||||
"UPDATE user_conditional_settings SET last_side = 'default_value' WHERE last_side IS NULL"
|
||||
)
|
||||
|
||||
# Устанавливаем ограничение NOT NULL
|
||||
op.alter_column('user_conditional_settings', 'last_side', nullable=False)
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_column('user_conditional_settings', 'last_side')
|
||||
# ### end Alembic commands ###
|
40
alembic/versions/f00a94ccdf01_updated_deals.py
Normal file
40
alembic/versions/f00a94ccdf01_updated_deals.py
Normal file
@@ -0,0 +1,40 @@
|
||||
"""Updated Deals
|
||||
|
||||
Revision ID: f00a94ccdf01
|
||||
Revises: c98b9dc36d15
|
||||
Create Date: 2025-09-28 22:25:00.092196
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'f00a94ccdf01'
|
||||
down_revision: Union[str, Sequence[str], None] = 'c98b9dc36d15'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.alter_column('user_deals', 'switch_side_mode',
|
||||
existing_type=sa.VARCHAR(),
|
||||
type_=sa.Boolean(),
|
||||
existing_nullable=True)
|
||||
op.create_unique_constraint(None, 'user_deals', ['user_id'])
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_constraint(None, 'user_deals', type_='unique')
|
||||
op.alter_column('user_deals', 'switch_side_mode',
|
||||
existing_type=sa.Boolean(),
|
||||
type_=sa.VARCHAR(),
|
||||
existing_nullable=True)
|
||||
# ### end Alembic commands ###
|
32
alembic/versions/fd8581c0cc87_updated_leverage.py
Normal file
32
alembic/versions/fd8581c0cc87_updated_leverage.py
Normal file
@@ -0,0 +1,32 @@
|
||||
"""Updated leverage
|
||||
|
||||
Revision ID: fd8581c0cc87
|
||||
Revises: bb586fa9bcd2
|
||||
Create Date: 2025-09-22 15:13:21.487402
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'fd8581c0cc87'
|
||||
down_revision: Union[str, Sequence[str], None] = None
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
pass
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
pass
|
||||
# ### end Alembic commands ###
|
Reference in New Issue
Block a user