Revision 991f60ff snf-pithos-app/pithos/api/manage_accounts/__init__.py
| b/snf-pithos-app/pithos/api/manage_accounts/__init__.py | ||
|---|---|---|
| 117 | 117 |
if dest_account not in self.existing_accounts(): |
| 118 | 118 |
raise NameError('%s does not exist' % dest_account)
|
| 119 | 119 |
|
| 120 |
trans = self.backend.wrapper.conn.begin()
|
|
| 120 |
self.backend.wrapper.execute()
|
|
| 121 | 121 |
try: |
| 122 | 122 |
self._copy_object(src_account, src_container, src_name, |
| 123 | 123 |
dest_account, move=True) |
| ... | ... | |
| 125 | 125 |
if dry: |
| 126 | 126 |
if not silent: |
| 127 | 127 |
print "Skipping database commit." |
| 128 |
trans.rollback()
|
|
| 128 |
self.backend.wrapper.rollback()
|
|
| 129 | 129 |
else: |
| 130 |
trans.commit()
|
|
| 130 |
self.backend.wrapper.commit()
|
|
| 131 | 131 |
if not silent: |
| 132 | 132 |
print "%s is deleted." % src_account |
| 133 | 133 |
except: |
| 134 |
trans.rollback()
|
|
| 134 |
self.backend.wrapper.rollback()
|
|
| 135 | 135 |
raise |
| 136 | 136 |
|
| 137 | 137 |
def _copy_object(self, src_account, src_container, src_name, |
| ... | ... | |
| 247 | 247 |
src_account).keys() |
| 248 | 248 |
return |
| 249 | 249 |
|
| 250 |
trans = self.backend.wrapper.conn.begin()
|
|
| 250 |
self.backend.wrapper.execute()
|
|
| 251 | 251 |
try: |
| 252 | 252 |
self._merge_account(src_account, dest_account, delete_src) |
| 253 | 253 |
|
| 254 | 254 |
if dry: |
| 255 | 255 |
if not silent: |
| 256 | 256 |
print "Skipping database commit." |
| 257 |
trans.rollback()
|
|
| 257 |
self.backend.wrapper.rollback()
|
|
| 258 | 258 |
else: |
| 259 |
trans.commit()
|
|
| 259 |
self.backend.wrapper.commit()
|
|
| 260 | 260 |
if not silent: |
| 261 | 261 |
msg = "%s merged into %s." |
| 262 | 262 |
print msg % (src_account, dest_account) |
| 263 | 263 |
except: |
| 264 |
trans.rollback()
|
|
| 264 |
self.backend.wrapper.rollback()
|
|
| 265 | 265 |
raise |
| 266 | 266 |
|
| 267 | 267 |
def delete_container_contents(self, account, container): |
| ... | ... | |
| 287 | 287 |
% self.backend.get_account_groups(account, account).keys() |
| 288 | 288 |
return |
| 289 | 289 |
|
| 290 |
trans = self.backend.wrapper.conn.begin()
|
|
| 290 |
self.backend.wrapper.execute()
|
|
| 291 | 291 |
try: |
| 292 | 292 |
self._delete_account(account) |
| 293 | 293 |
|
| 294 | 294 |
if dry: |
| 295 | 295 |
if not silent: |
| 296 | 296 |
print "Skipping database commit." |
| 297 |
trans.rollback()
|
|
| 297 |
self.backend.wrapper.rollback()
|
|
| 298 | 298 |
else: |
| 299 |
trans.commit()
|
|
| 299 |
self.commit()
|
|
| 300 | 300 |
if not silent: |
| 301 | 301 |
print "%s is deleted." % account |
| 302 | 302 |
except: |
| 303 |
trans.rollback()
|
|
| 303 |
self.rollback()
|
|
| 304 | 304 |
raise |
| 305 | 305 |
|
| 306 | 306 |
def create_account(self, account): |
Also available in: Unified diff