update sqlite3 storage
This commit is contained in:
parent
05404e89bc
commit
e0cab0063e
@ -70,8 +70,9 @@ class Properties(Sqlite3DB):
|
||||
return ret
|
||||
|
||||
def importation(self, properties):
|
||||
self._storage.execute("DELETE FROM property", commit=False)
|
||||
self._storage.execute("DELETE FROM property WHERE session_id = ?", (self._session_id,), commit=False)
|
||||
for path, property_ in properties.items():
|
||||
path = self._sqlite_encode_path(path)
|
||||
self._storage.execute("INSERT INTO property(path, properties, session_id) "
|
||||
"VALUES (?, ?, ?)", (path,
|
||||
self._sqlite_encode(property_),
|
||||
@ -84,7 +85,7 @@ class Permissives(Sqlite3DB):
|
||||
__slots__ = tuple()
|
||||
|
||||
# permissive
|
||||
def setpermissive(self, path, permissive):
|
||||
def setpermissives(self, path, permissive):
|
||||
path = self._sqlite_encode_path(path)
|
||||
if DEBUG: # pragma: no cover
|
||||
print('setpermissive', path, permissive, id(self))
|
||||
@ -96,7 +97,7 @@ class Permissives(Sqlite3DB):
|
||||
self._sqlite_encode(permissive),
|
||||
self._session_id))
|
||||
|
||||
def getpermissive(self, path='_none'):
|
||||
def getpermissives(self, path='_none'):
|
||||
path = self._sqlite_encode_path(path)
|
||||
permissives = self._storage.select("SELECT permissives FROM "
|
||||
"permissive WHERE path = ? AND session_id = ? LIMIT 1",
|
||||
@ -123,8 +124,10 @@ class Permissives(Sqlite3DB):
|
||||
return ret
|
||||
|
||||
def importation(self, permissives):
|
||||
self._storage.execute("DELETE FROM permissive", commit=False)
|
||||
self._storage.execute("DELETE FROM permissive WHERE session_id = ?", (self._session_id,),
|
||||
commit=False)
|
||||
for path, permissive in permissives.items():
|
||||
path = self._sqlite_encode_path(path)
|
||||
self._storage.execute("INSERT INTO permissive(path, permissives, session_id) "
|
||||
"VALUES (?, ?, ?)", (path,
|
||||
self._sqlite_encode(permissive),
|
||||
|
||||
@ -16,10 +16,12 @@
|
||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
# ____________________________________________________________
|
||||
|
||||
from ...i18n import _
|
||||
from os import unlink
|
||||
from os.path import basename, splitext, join, isfile
|
||||
import sqlite3
|
||||
from glob import glob
|
||||
from ...error import ConflictError
|
||||
|
||||
|
||||
class Setting(object):
|
||||
@ -40,32 +42,34 @@ def _gen_filename():
|
||||
|
||||
def list_sessions():
|
||||
cursor = CONN.cursor()
|
||||
names = [row[0] for row in cursor.execute("SELECT DISTINCT session_id FROM value").fetchall()]
|
||||
names = [row[0] for row in cursor.execute("SELECT session FROM session").fetchall()]
|
||||
return names
|
||||
|
||||
|
||||
def delete_session(session_id, session):
|
||||
def delete_session(session_id, _session_id=None):
|
||||
cursor = CONN.cursor()
|
||||
cursor.execute("DELETE FROM property WHERE session_id = ?",
|
||||
(session_id,))
|
||||
cursor.execute("DELETE FROM permissive WHERE session_id = ?",
|
||||
(session_id,))
|
||||
cursor.execute("DELETE FROM value WHERE session_id = ?",
|
||||
(session_id,))
|
||||
cursor.execute("DELETE FROM information WHERE session_id = ?",
|
||||
(session_id,))
|
||||
CONN.commit()
|
||||
if _session_id is None:
|
||||
_session_id = cursor.execute("SELECT session_id FROM session WHERE session = ?",
|
||||
(session_id,)).fetchone()
|
||||
if _session_id is not None:
|
||||
_session_id = _session_id[0]
|
||||
if _session_id is not None:
|
||||
cursor.execute("DELETE FROM property WHERE session_id = ?", (_session_id,))
|
||||
cursor.execute("DELETE FROM permissive WHERE session_id = ?", (_session_id,))
|
||||
cursor.execute("DELETE FROM value WHERE session_id = ?", (_session_id,))
|
||||
cursor.execute("DELETE FROM information WHERE session_id = ?", (_session_id,))
|
||||
cursor.execute("DELETE FROM session WHERE session_id = ?", (_session_id,))
|
||||
CONN.commit()
|
||||
|
||||
global CONN
|
||||
CONN = None
|
||||
|
||||
class Storage(object):
|
||||
__slots__ = ('_conn', '_cursor', 'persistent', 'session_id')
|
||||
__slots__ = ('_conn', '_cursor', 'persistent', 'session_id', 'session_name')
|
||||
storage = 'sqlite3'
|
||||
|
||||
def __init__(self, session_id, persistent, test=False):
|
||||
self.persistent = persistent
|
||||
self.session_id = session_id
|
||||
global CONN
|
||||
init = False
|
||||
if CONN is None:
|
||||
@ -74,21 +78,33 @@ class Storage(object):
|
||||
CONN.text_factory = str
|
||||
self._conn = CONN
|
||||
self._cursor = self._conn.cursor()
|
||||
self.session_name = session_id
|
||||
if init:
|
||||
session_table = 'CREATE TABLE IF NOT EXISTS session(session_id INTEGER, session TEXT UNIQUE, PRIMARY KEY(session_id))'
|
||||
settings_table = 'CREATE TABLE IF NOT EXISTS property(path TEXT,'
|
||||
settings_table += 'properties text, session_id TEXT, PRIMARY KEY(path, session_id))'
|
||||
settings_table += 'properties text, session_id INTEGER, PRIMARY KEY(path, session_id), '
|
||||
settings_table += 'FOREIGN KEY(session_id) REFERENCES session(session_id))'
|
||||
permissives_table = 'CREATE TABLE IF NOT EXISTS permissive(path TEXT,'
|
||||
permissives_table += 'permissives TEXT, session_id TEXT, PRIMARY KEY(path, session_id))'
|
||||
permissives_table += 'permissives TEXT, session_id INTEGER, PRIMARY KEY(path, session_id), '
|
||||
permissives_table += 'FOREIGN KEY(session_id) REFERENCES session(session_id))'
|
||||
values_table = 'CREATE TABLE IF NOT EXISTS value(path TEXT, '
|
||||
values_table += 'value TEXT, owner TEXT, idx INTEGER, session_id TEXT NOT NULL, '\
|
||||
'PRIMARY KEY (path, idx, session_id))'
|
||||
values_table += 'value TEXT, owner TEXT, idx INTEGER, session_id INTEGER, '\
|
||||
'PRIMARY KEY (path, idx, session_id), '
|
||||
values_table += 'FOREIGN KEY(session_id) REFERENCES session(session_id))'
|
||||
informations_table = 'CREATE TABLE IF NOT EXISTS information(key TEXT,'
|
||||
informations_table += 'value TEXT, session_id TEXT NOT NULL, '
|
||||
informations_table += 'PRIMARY KEY (key, session_id))'
|
||||
informations_table += 'value TEXT, session_id INTEGER, '
|
||||
informations_table += 'PRIMARY KEY (key, session_id), '
|
||||
informations_table += 'FOREIGN KEY(session_id) REFERENCES session(session_id))'
|
||||
self.execute(session_table, commit=False)
|
||||
self.execute(values_table, commit=False)
|
||||
self.execute(informations_table, commit=False)
|
||||
self.execute(settings_table, commit=False)
|
||||
self.execute(permissives_table)
|
||||
self.execute(permissives_table, commit=False)
|
||||
try:
|
||||
self.execute('INSERT INTO session(session) VALUES (?)', (session_id,))
|
||||
except sqlite3.IntegrityError:
|
||||
raise ConflictError(_('session "{}" already used').format(session_id))
|
||||
self.session_id = self._cursor.lastrowid
|
||||
|
||||
def commit(self):
|
||||
self._conn.commit()
|
||||
@ -113,9 +129,10 @@ class Storage(object):
|
||||
#FIXME
|
||||
#self._conn.close()
|
||||
if not self.persistent:
|
||||
session = None
|
||||
if delete_session is not None:
|
||||
delete_session(self.session_id, session)
|
||||
session_id = getattr(self, 'session_id', None)
|
||||
delete_session(self.session_name,
|
||||
session_id)
|
||||
|
||||
|
||||
def getsession():
|
||||
|
||||
@ -263,6 +263,7 @@ class Values(Sqlite3DB):
|
||||
self._storage.execute("DELETE FROM value WHERE session_id = ?", (self._session_id,),
|
||||
commit=False)
|
||||
for idx, path in enumerate(export[0]):
|
||||
path = self._sqlite_encode_path(path)
|
||||
index = export[1][idx]
|
||||
value = export[2][idx]
|
||||
owner = export[3][idx]
|
||||
|
||||
@ -16,7 +16,7 @@
|
||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
# ____________________________________________________________
|
||||
from time import time
|
||||
from .dictionary.cache import Cache as DictCache
|
||||
from .cache.dictionary import Cache as DictCache
|
||||
|
||||
|
||||
def _display_classname(obj):
|
||||
|
||||
Loading…
Reference in New Issue
Block a user