[entropy.db] add MySQL connector (barely tested !!!)

This commit is contained in:
Fabio Erculiani
2012-08-08 18:45:41 +02:00
parent a1e7d92bfb
commit ad74ade00c
4 changed files with 5266 additions and 9 deletions
+2 -1
View File
@@ -24,5 +24,6 @@
"""
from entropy.db.sqlite import EntropyRepository
from entropy.db.mysql import EntropyMySQLRepository
__all__ = ["EntropyRepository"]
__all__ = ["EntropyRepository", "EntropyMySQLRepository"]
File diff suppressed because it is too large Load Diff
+8 -6
View File
@@ -3743,15 +3743,17 @@ class EntropyRepositoryBase(TextInterface, EntropyRepositoryPluginStore):
raise NotImplementedError()
@staticmethod
def importRepository(dumpfile, dbfile):
def importRepository(dumpfile, db, data = None):
"""
Import SQLite3 dump file to this database.
Import dump file to this database.
@param dumpfile: SQLite3 dump file to read
@param dumpfile: dump file to read
@type dumpfile: string
@param dbfile: database file to write to
@param dbfile: database file path or reference name
@type dbfile: string
@return: sqlite3 import return code
@keyword data: connection data (dict object)
@type data: dict or None
@return: import return code (0 = OK)
@rtype: int
@raise AttributeError: if given paths are invalid
"""
@@ -3759,7 +3761,7 @@ class EntropyRepositoryBase(TextInterface, EntropyRepositoryPluginStore):
def exportRepository(self, dumpfile):
"""
Export running SQLite3 database to file.
Export running database to file.
@param dumpfile: dump file object to write to
@type dumpfile: file object (hint: open())
+2 -2
View File
@@ -5247,12 +5247,12 @@ class EntropyRepository(EntropyRepositoryBase):
return 0
@staticmethod
def importRepository(dumpfile, dbfile):
def importRepository(dumpfile, db, data = None):
"""
Reimplemented from EntropyRepositoryBase.
@todo: remove /usr/bin/sqlite3 dependency
"""
dbfile = os.path.realpath(dbfile)
dbfile = os.path.realpath(db)
tmp_dbfile = dbfile + ".import_repository"
dumpfile = os.path.realpath(dumpfile)
if not entropy.tools.is_valid_path_string(dbfile):