iartamonov/mautrix-telegram
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Fix edit index upgrade on postgres

Browse Source
This commit is contained in:
Tulir Asokan
2019-05-29 16:37:13 +03:00
parent 47243334f4
commit ff257fcd77
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
alembic/versions/9e9c89b0b877_add_edit_index_to_messages.py
+2 -4
View File
@@ -8,7 +8,6 @@ Create Date: 2019-05-29 15:28:23.128377
from alembic import op from alembic import op
import sqlalchemy as sa import sqlalchemy as sa
# revision identifiers, used by Alembic. # revision identifiers, used by Alembic.
revision = '9e9c89b0b877' revision = '9e9c89b0b877'
down_revision = '17574c57f3f8' down_revision = '17574c57f3f8'
@@ -24,7 +23,7 @@ def upgrade():
sa.Column('tg_space', sa.Integer), sa.Column('tg_space', sa.Integer),
sa.Column('edit_index', sa.Integer), sa.Column('edit_index', sa.Integer),
sa.PrimaryKeyConstraint('tgid', 'tg_space', 'edit_index'), sa.PrimaryKeyConstraint('tgid', 'tg_space', 'edit_index'),
sa.UniqueConstraint("mxid", "mx_room", "tg_space", name="_mx_id_room")) sa.UniqueConstraint("mxid", "mx_room", "tg_space", name="_mx_id_room_2"))
c = op.get_bind() c = op.get_bind()
c.execute("INSERT INTO _message_temp (mxid, mx_room, tgid, tg_space, edit_index) " c.execute("INSERT INTO _message_temp (mxid, mx_room, tgid, tg_space, edit_index) "
"SELECT message.mxid, message.mx_room, message.tgid, message.tg_space, 0 " "SELECT message.mxid, message.mx_room, message.tgid, message.tg_space, 0 "
@@ -33,7 +32,6 @@ def upgrade():
c.execute("ALTER TABLE _message_temp RENAME TO message") c.execute("ALTER TABLE _message_temp RENAME TO message")
def downgrade(): def downgrade():
op.create_table('_message_temp', op.create_table('_message_temp',
sa.Column('mxid', sa.String), sa.Column('mxid', sa.String),
@@ -45,6 +43,6 @@ def downgrade():
c = op.get_bind() c = op.get_bind()
c.execute("INSERT INTO _message_temp (mxid, mx_room, tgid, tg_space) " c.execute("INSERT INTO _message_temp (mxid, mx_room, tgid, tg_space) "
"SELECT message.mxid, message.mx_room, message.tgid, message.tg_space " "SELECT message.mxid, message.mx_room, message.tgid, message.tg_space "
"FROM portal") "FROM message")
c.execute("DROP TABLE message") c.execute("DROP TABLE message")
c.execute("ALTER TABLE _message_temp RENAME TO message") c.execute("ALTER TABLE _message_temp RENAME TO message")