Fix postgres compatibility
This commit is contained in:
@@ -19,31 +19,31 @@ depends_on = None
|
|||||||
|
|
||||||
def upgrade():
|
def upgrade():
|
||||||
Session = op.create_table('telethon_sessions',
|
Session = op.create_table('telethon_sessions',
|
||||||
sa.Column('session_id', sa.VARCHAR(), nullable=False),
|
sa.Column('session_id', sa.String, nullable=False),
|
||||||
sa.Column('dc_id', sa.INTEGER(), nullable=False),
|
sa.Column('dc_id', sa.Integer, nullable=False),
|
||||||
sa.Column('server_address', sa.VARCHAR(), nullable=True),
|
sa.Column('server_address', sa.String, nullable=True),
|
||||||
sa.Column('port', sa.INTEGER(), nullable=True),
|
sa.Column('port', sa.Integer, nullable=True),
|
||||||
sa.Column('auth_key', sa.BLOB(), nullable=True),
|
sa.Column('auth_key', sa.LargeBinary, nullable=True),
|
||||||
sa.PrimaryKeyConstraint('session_id', 'dc_id'))
|
sa.PrimaryKeyConstraint('session_id', 'dc_id'))
|
||||||
SentFile = op.create_table('telethon_sent_files',
|
SentFile = op.create_table('telethon_sent_files',
|
||||||
sa.Column('session_id', sa.VARCHAR(), nullable=False),
|
sa.Column('session_id', sa.String, nullable=False),
|
||||||
sa.Column('md5_digest', sa.BLOB(), nullable=False),
|
sa.Column('md5_digest', sa.LargeBinary, nullable=False),
|
||||||
sa.Column('file_size', sa.INTEGER(), nullable=False),
|
sa.Column('file_size', sa.Integer, nullable=False),
|
||||||
sa.Column('type', sa.INTEGER(), nullable=False),
|
sa.Column('type', sa.Integer, nullable=False),
|
||||||
sa.Column('id', sa.INTEGER(), nullable=True),
|
sa.Column('id', sa.BigInteger, nullable=True),
|
||||||
sa.Column('hash', sa.INTEGER(), nullable=True),
|
sa.Column('hash', sa.BigInteger, nullable=True),
|
||||||
sa.PrimaryKeyConstraint('session_id', 'md5_digest', 'file_size',
|
sa.PrimaryKeyConstraint('session_id', 'md5_digest', 'file_size',
|
||||||
'type'))
|
'type'))
|
||||||
Entity = op.create_table('telethon_entities',
|
Entity = op.create_table('telethon_entities',
|
||||||
sa.Column('session_id', sa.VARCHAR(), nullable=False),
|
sa.Column('session_id', sa.String, nullable=False),
|
||||||
sa.Column('id', sa.INTEGER(), nullable=False),
|
sa.Column('id', sa.Integer, nullable=False),
|
||||||
sa.Column('hash', sa.INTEGER(), nullable=False),
|
sa.Column('hash', sa.Integer, nullable=False),
|
||||||
sa.Column('username', sa.VARCHAR(), nullable=True),
|
sa.Column('username', sa.String, nullable=True),
|
||||||
sa.Column('phone', sa.INTEGER(), nullable=True),
|
sa.Column('phone', sa.Integer, nullable=True),
|
||||||
sa.Column('name', sa.VARCHAR(), nullable=True),
|
sa.Column('name', sa.String, nullable=True),
|
||||||
sa.PrimaryKeyConstraint('session_id', 'id'))
|
sa.PrimaryKeyConstraint('session_id', 'id'))
|
||||||
Version = op.create_table('telethon_version',
|
Version = op.create_table('telethon_version',
|
||||||
sa.Column('version', sa.INTEGER(), nullable=False),
|
sa.Column('version', sa.Integer, nullable=False),
|
||||||
sa.PrimaryKeyConstraint('version'))
|
sa.PrimaryKeyConstraint('version'))
|
||||||
conn = op.get_bind()
|
conn = op.get_bind()
|
||||||
sessions = [os.path.basename(f) for f in os.listdir(".") if f.endswith(".session")]
|
sessions = [os.path.basename(f) for f in os.listdir(".") if f.endswith(".session")]
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ depends_on = None
|
|||||||
def upgrade():
|
def upgrade():
|
||||||
op.add_column('telegram_file',
|
op.add_column('telegram_file',
|
||||||
sa.Column('timestamp', sa.BigInteger(), nullable=False, default=0,
|
sa.Column('timestamp', sa.BigInteger(), nullable=False, default=0,
|
||||||
server_default="true"))
|
server_default="0"))
|
||||||
|
|
||||||
|
|
||||||
def downgrade():
|
def downgrade():
|
||||||
|
|||||||
@@ -29,7 +29,7 @@ def upgrade():
|
|||||||
sa.UniqueConstraint('mxid'))
|
sa.UniqueConstraint('mxid'))
|
||||||
op.create_table('user',
|
op.create_table('user',
|
||||||
sa.Column('mxid', sa.String),
|
sa.Column('mxid', sa.String),
|
||||||
sa.Column('tgid', sa.Integer, nullable=True),
|
sa.Column('tgid', sa.Integer, nullable=True, unique=True),
|
||||||
sa.Column('tg_username', sa.String, nullable=True),
|
sa.Column('tg_username', sa.String, nullable=True),
|
||||||
sa.Column('saved_contacts', sa.Integer, nullable=False, default=0),
|
sa.Column('saved_contacts', sa.Integer, nullable=False, default=0),
|
||||||
sa.PrimaryKeyConstraint('mxid'))
|
sa.PrimaryKeyConstraint('mxid'))
|
||||||
|
|||||||
@@ -70,7 +70,7 @@ class User(Base):
|
|||||||
__tablename__ = "user"
|
__tablename__ = "user"
|
||||||
|
|
||||||
mxid = Column(String, primary_key=True)
|
mxid = Column(String, primary_key=True)
|
||||||
tgid = Column(Integer, nullable=True)
|
tgid = Column(Integer, nullable=True, unique=True)
|
||||||
tg_username = Column(String, nullable=True)
|
tg_username = Column(String, nullable=True)
|
||||||
saved_contacts = Column(Integer, default=0)
|
saved_contacts = Column(Integer, default=0)
|
||||||
contacts = relationship("Contact", uselist=True,
|
contacts = relationship("Contact", uselist=True,
|
||||||
|
|||||||
Reference in New Issue
Block a user