57c599a3cb57_add_channel_table.py 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. """Add channel table
  2. Revision ID: 57c599a3cb57
  3. Revises: 922e7a387820
  4. Create Date: 2024-12-22 03:00:00.000000
  5. """
  6. from alembic import op
  7. import sqlalchemy as sa
  8. revision = "57c599a3cb57"
  9. down_revision = "922e7a387820"
  10. branch_labels = None
  11. depends_on = None
  12. def upgrade():
  13. op.create_table(
  14. "channel",
  15. sa.Column("id", sa.Text(), nullable=False, primary_key=True, unique=True),
  16. sa.Column("user_id", sa.Text()),
  17. sa.Column("name", sa.Text()),
  18. sa.Column("data", sa.JSON(), nullable=True),
  19. sa.Column("meta", sa.JSON(), nullable=True),
  20. sa.Column("access_control", sa.JSON(), nullable=True),
  21. sa.Column("created_at", sa.BigInteger(), nullable=True),
  22. sa.Column("updated_at", sa.BigInteger(), nullable=True),
  23. )
  24. op.create_table(
  25. "message",
  26. sa.Column("id", sa.Text(), nullable=False, primary_key=True, unique=True),
  27. sa.Column("user_id", sa.Text()),
  28. sa.Column("channel_id", sa.Text(), nullable=True),
  29. sa.Column("content", sa.Text()),
  30. sa.Column("data", sa.JSON(), nullable=True),
  31. sa.Column("meta", sa.JSON(), nullable=True),
  32. sa.Column("created_at", sa.BigInteger(), nullable=True),
  33. sa.Column("updated_at", sa.BigInteger(), nullable=True),
  34. )
  35. def downgrade():
  36. op.drop_table("channel")
  37. op.drop_table("message")