def upgrade():
op.add_column('package', sa.Column('downloads', sa.Integer(), nullable=False, server_default="0"))
- bind = op.get_bind()
- session = orm.Session(bind=bind)
-
- for package in session.query(Package).all():
- downloads_result = session.query(func.sum(PackageRelease.downloads)).filter_by(package_id=package.id).one_or_none()
- downloads = 0 if not downloads_result or not downloads_result[0] else downloads_result[0]
- package.downloads = downloads
-
- session.commit()
-
def downgrade():
# ### commands auto generated by Alembic - please adjust! ###