Revision 42ea7e66
| b/snf-pithos-backend/pithos/backends/lib/sqlalchemy/alembic/versions/165ba3fbfe53_update_path_account.py | ||
|---|---|---|
| 59 | 59 |
column('path', sa.String(2048))
|
| 60 | 60 |
) |
| 61 | 61 |
|
| 62 |
v = table( |
|
| 63 |
'versions', |
|
| 64 |
column('node', sa.Integer),
|
|
| 65 |
column('muser', sa.String(2048))
|
|
| 66 |
) |
|
| 67 |
|
|
| 62 | 68 |
p = table( |
| 63 | 69 |
'public', |
| 64 | 70 |
column('public_id', sa.Integer),
|
| ... | ... | |
| 99 | 105 |
u = n.update().where(n.c.node == node).values({'path':path})
|
| 100 | 106 |
connection.execute(u) |
| 101 | 107 |
|
| 108 |
s = sa.select([v.c.node, v.c.muser]) |
|
| 109 |
versions = connection.execute(s).fetchall() |
|
| 110 |
for node, muser in versions: |
|
| 111 |
uuid = get_uuid(muser) |
|
| 112 |
if not uuid: |
|
| 113 |
continue |
|
| 114 |
u = v.update().where(v.c.node == node).values({'muser':uuid})
|
|
| 115 |
connection.execute(u) |
|
| 116 |
|
|
| 102 | 117 |
s = sa.select([p.c.public_id, p.c.path]) |
| 103 | 118 |
public = connection.execute(s).fetchall() |
| 104 | 119 |
for id, path in public: |
| ... | ... | |
| 171 | 186 |
u = n.update().where(n.c.node == node).values({'path':path})
|
| 172 | 187 |
connection.execute(u) |
| 173 | 188 |
|
| 189 |
s = sa.select([v.c.node, v.c.muser]) |
|
| 190 |
versions = connection.execute(s).fetchall() |
|
| 191 |
for node, muser in versions: |
|
| 192 |
displayname = get_displayname(muser) |
|
| 193 |
if not displayname: |
|
| 194 |
continue |
|
| 195 |
u = v.update().where(v.c.node == node).values({'muser':displayname})
|
|
| 196 |
connection.execute(u) |
|
| 197 |
|
|
| 174 | 198 |
s = sa.select([p.c.public_id, p.c.path]) |
| 175 | 199 |
public = connection.execute(s).fetchall() |
| 176 | 200 |
for id, path in public: |
Also available in: Unified diff