Revision 7a65e284
| b/snf-pithos-backend/pithos/backends/lib/sqlalchemy/public.py | ||
|---|---|---|
| 95 | 95 |
s = s.values(path=path, active=True, url=url) |
| 96 | 96 |
r = self.conn.execute(s) |
| 97 | 97 |
r.close() |
| 98 |
logger.info('Public url: %s set for path: %s' % (url, path))
|
|
| 98 |
logger.info('Public url set for path: %s' % path)
|
|
| 99 | 99 |
|
| 100 | 100 |
def public_unset(self, path): |
| 101 | 101 |
s = self.public.delete() |
| 102 | 102 |
s = s.where(self.public.c.path == path) |
| 103 |
self.conn.execute(s).close() |
|
| 104 |
logger.info('Public url unset for path: %s' % (path))
|
|
| 103 |
r = self.conn.execute(s) |
|
| 104 |
if r.rowcount != 0: |
|
| 105 |
logger.info('Public url unset for path: %s' % path)
|
|
| 106 |
r.close() |
|
| 105 | 107 |
|
| 106 | 108 |
def public_unset_bulk(self, paths): |
| 107 | 109 |
if not paths: |
| b/snf-pithos-backend/pithos/backends/lib/sqlite/public.py | ||
|---|---|---|
| 75 | 75 |
) |
| 76 | 76 |
q = "insert into public(path, active, url) values(?, 1, ?)" |
| 77 | 77 |
self.execute(q, (path, url)) |
| 78 |
logger.info('Public url: %s set for path: %s' % (url, path))
|
|
| 78 |
if sqlite3_changes() != 0: |
|
| 79 |
logger.info('Public url set for path: %s' % path)
|
|
| 79 | 80 |
|
| 80 | 81 |
def public_unset(self, path): |
| 81 | 82 |
q = "delete from public where path = ?" |
| 82 |
self.execute(q, (path,)) |
|
| 83 |
logger.info('Public url unset for path: %s' % (path))
|
|
| 83 |
c = self.execute(q, (path,)) |
|
| 84 |
if c.rowcount != 0: |
|
| 85 |
logger.info('Public url unset for path: %s' % path)
|
|
| 84 | 86 |
|
| 85 | 87 |
def public_unset_bulk(self, paths): |
| 86 | 88 |
placeholders = ','.join('?' for path in paths)
|
Also available in: Unified diff