Revision e1f09a6e pithos/backends/lib/sqlalchemy/node.py
| b/pithos/backends/lib/sqlalchemy/node.py | ||
|---|---|---|
| 292 | 292 |
self.statistics_update(parent, -nr, size, mtime, cluster) |
| 293 | 293 |
self.statistics_update_ancestors(parent, -nr, size, mtime, cluster) |
| 294 | 294 |
|
| 295 |
s = select([self.versions.c.serial])
|
|
| 295 |
s = select([self.versions.c.hash])
|
|
| 296 | 296 |
s = s.where(where_clause) |
| 297 | 297 |
r = self.conn.execute(s) |
| 298 |
hashes = [row[HASH] for row in r.fetchall()]
|
|
| 298 |
hashes = [row[0] for row in r.fetchall()]
|
|
| 299 | 299 |
r.close() |
| 300 | 300 |
|
| 301 | 301 |
#delete versions |
| ... | ... | |
| 340 | 340 |
mtime = time() |
| 341 | 341 |
self.statistics_update_ancestors(node, -nr, -size, mtime, cluster) |
| 342 | 342 |
|
| 343 |
s = select([self.versions.c.serial])
|
|
| 343 |
s = select([self.versions.c.hash])
|
|
| 344 | 344 |
s = s.where(where_clause) |
| 345 | 345 |
r = self.conn.execute(s) |
| 346 |
hashes = [r[HASH] for r in r.fetchall()]
|
|
| 346 |
hashes = [r[0] for r in r.fetchall()]
|
|
| 347 | 347 |
r.close() |
| 348 | 348 |
|
| 349 | 349 |
#delete versions |
Also available in: Unified diff