Revision cf53943b
| b/snf-pithos-backend/pithos/backends/lib/sqlite/dbworker.py | ||
|---|---|---|
| 37 | 37 |
|
| 38 | 38 |
def __init__(self, **params): |
| 39 | 39 |
self.params = params |
| 40 |
conn = params['wrapper'].conn |
|
| 41 |
cur = params['wrapper'].conn.cursor() |
|
| 40 |
wrapper = params['wrapper'] |
|
| 41 |
self.wrapper = wrapper |
|
| 42 |
conn = wrapper.conn |
|
| 43 |
cur = wrapper.conn.cursor() |
|
| 42 | 44 |
self.execute = cur.execute |
| 43 | 45 |
self.executemany = cur.executemany |
| 44 | 46 |
self.fetchone = cur.fetchone |
| b/snf-pithos-backend/pithos/backends/lib/sqlite/node.py | ||
|---|---|---|
| 181 | 181 |
on update cascade |
| 182 | 182 |
on delete cascade ) """) |
| 183 | 183 |
|
| 184 |
q = "insert or ignore into nodes(node, parent) values (?, ?)" |
|
| 185 |
execute(q, (ROOTNODE, ROOTNODE)) |
|
| 184 |
wrapper = self.wrapper |
|
| 185 |
wrapper.execute() |
|
| 186 |
try: |
|
| 187 |
q = "insert or ignore into nodes(node, parent) values (?, ?)" |
|
| 188 |
execute(q, (ROOTNODE, ROOTNODE)) |
|
| 189 |
finally: |
|
| 190 |
wrapper.commit() |
|
| 186 | 191 |
|
| 187 | 192 |
def node_create(self, parent, path): |
| 188 | 193 |
"""Create a new node from the given properties. |
Also available in: Unified diff