Revision d50ed8d4 snf-pithos-backend/pithos/backends/lib/sqlalchemy/alembic/versions/3dd56e750a3_fix_latest_version.py
| b/snf-pithos-backend/pithos/backends/lib/sqlalchemy/alembic/versions/3dd56e750a3_fix_latest_version.py | ||
|---|---|---|
| 15 | 15 |
from sqlalchemy.sql import table, column |
| 16 | 16 |
from sqlalchemy.sql.expression import desc |
| 17 | 17 |
|
| 18 |
|
|
| 18 | 19 |
def upgrade(): |
| 19 |
n = table('nodes',
|
|
| 20 |
column('node', sa.Integer),
|
|
| 21 |
column('latest_version', sa.Integer)
|
|
| 22 |
) |
|
| 23 |
v = table('versions',
|
|
| 24 |
column('node', sa.Integer),
|
|
| 25 |
column('mtime', sa.Integer),
|
|
| 26 |
column('serial', sa.Integer),
|
|
| 27 |
) |
|
| 28 |
|
|
| 29 |
s = sa.select([v.c.serial]).where(n.c.node == v.c.node).order_by(desc(v.c.mtime)).limit(1) |
|
| 20 |
n = table('nodes',
|
|
| 21 |
column('node', sa.Integer),
|
|
| 22 |
column('latest_version', sa.Integer)
|
|
| 23 |
) |
|
| 24 |
v = table('versions',
|
|
| 25 |
column('node', sa.Integer),
|
|
| 26 |
column('mtime', sa.Integer),
|
|
| 27 |
column('serial', sa.Integer),
|
|
| 28 |
) |
|
| 29 |
|
|
| 30 |
s = sa.select([v.c.serial]).where( |
|
| 31 |
n.c.node == v.c.node).order_by(desc(v.c.mtime)).limit(1) |
|
| 30 | 32 |
op.execute( |
| 31 |
n.update().\
|
|
| 32 |
values({'latest_version':s})
|
|
| 33 |
)
|
|
| 33 |
n.update(). |
|
| 34 |
values({'latest_version': s})
|
|
| 35 |
) |
|
| 34 | 36 |
|
| 35 | 37 |
|
| 36 | 38 |
def downgrade(): |
Also available in: Unified diff