Mercurial > libervia-backend
annotate sat/memory/migration/versions/8974efc51d22_create_tables_for_pubsub_caching.py @ 3893:045af0eeda3f
core, CLI (base), tools (common/data_format): typing/core readability
author | Goffi <goffi@goffi.org> |
---|---|
date | Wed, 21 Sep 2022 22:20:43 +0200 |
parents | d5116197e403 |
children |
rev | line source |
---|---|
3594
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
1 """create tables for Pubsub caching |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
2 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
3 Revision ID: 8974efc51d22 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
4 Revises: 602caf848068 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
5 Create Date: 2021-07-27 16:38:54.658212 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
6 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
7 """ |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
8 from alembic import op |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
9 import sqlalchemy as sa |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
10 from sat.memory.sqla_mapping import JID, Xml |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
11 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
12 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
13 # revision identifiers, used by Alembic. |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
14 revision = '8974efc51d22' |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
15 down_revision = '602caf848068' |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
16 branch_labels = None |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
17 depends_on = None |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
18 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
19 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
20 def upgrade(): |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
21 # ### commands auto generated by Alembic - please adjust! ### |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
22 op.create_table('pubsub_nodes', |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
23 sa.Column('id', sa.Integer(), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
24 sa.Column('profile_id', sa.Integer(), nullable=True), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
25 sa.Column('service', JID(), nullable=True), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
26 sa.Column('name', sa.Text(), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
27 sa.Column('subscribed', sa.Boolean(create_constraint=True, name='subscribed_bool'), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
28 sa.Column('analyser', sa.Text(), nullable=True), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
29 sa.Column('sync_state', sa.Enum('IN_PROGRESS', 'COMPLETED', 'ERROR', 'NO_SYNC', name='sync_state', create_constraint=True), nullable=True), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
30 sa.Column('sync_state_updated', sa.Float(), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
31 sa.Column('type', sa.Text(), nullable=True), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
32 sa.Column('subtype', sa.Text(), nullable=True), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
33 sa.Column('extra', sa.JSON(), nullable=True), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
34 sa.ForeignKeyConstraint(['profile_id'], ['profiles.id'], name=op.f('fk_pubsub_nodes_profile_id_profiles'), ondelete='CASCADE'), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
35 sa.PrimaryKeyConstraint('id', name=op.f('pk_pubsub_nodes')), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
36 sa.UniqueConstraint('profile_id', 'service', 'name', name=op.f('uq_pubsub_nodes_profile_id')) |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
37 ) |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
38 op.create_table('pubsub_items', |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
39 sa.Column('id', sa.Integer(), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
40 sa.Column('node_id', sa.Integer(), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
41 sa.Column('name', sa.Text(), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
42 sa.Column('data', Xml(), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
43 sa.Column('created', sa.DateTime(), server_default=sa.text('(CURRENT_TIMESTAMP)'), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
44 sa.Column('updated', sa.DateTime(), server_default=sa.text('(CURRENT_TIMESTAMP)'), nullable=False), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
45 sa.Column('parsed', sa.JSON(), nullable=True), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
46 sa.ForeignKeyConstraint(['node_id'], ['pubsub_nodes.id'], name=op.f('fk_pubsub_items_node_id_pubsub_nodes'), ondelete='CASCADE'), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
47 sa.PrimaryKeyConstraint('id', name=op.f('pk_pubsub_items')), |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
48 sa.UniqueConstraint('node_id', 'name', name=op.f('uq_pubsub_items_node_id')) |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
49 ) |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
50 # ### end Alembic commands ### |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
51 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
52 |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
53 def downgrade(): |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
54 # ### commands auto generated by Alembic - please adjust! ### |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
55 op.drop_table('pubsub_items') |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
56 op.drop_table('pubsub_nodes') |
d5116197e403
migration: script to create pubsub caching tables
Goffi <goffi@goffi.org>
parents:
diff
changeset
|
57 # ### end Alembic commands ### |