|
38 | 38 |
|
39 | 39 | from .dbtool import Array |
40 | 40 |
|
41 | | -from .unotool import checkVersion |
42 | 41 | from .unotool import generateUuid |
43 | | -from .unotool import getSimpleFile |
44 | 42 |
|
45 | 43 | from .dbqueries import getSqlQuery |
46 | 44 |
|
|
50 | 48 | from .dbtool import getDataSourceCall |
51 | 49 | from .dbtool import getDataFromResult |
52 | 50 |
|
53 | | -from .dbinit import createDataBase |
54 | | -from .dbinit import getDataBaseConnection |
55 | | - |
56 | | -from .helper import checkConnection |
57 | | -from .helper import checkDatabaseVersion |
| 51 | +from .logger import getLogger |
58 | 52 |
|
59 | 53 | from .dbconfig import g_role |
60 | 54 |
|
| 55 | +from .configuration import g_defaultlog |
| 56 | + |
61 | 57 | import os |
62 | 58 | import traceback |
63 | 59 |
|
64 | 60 |
|
65 | 61 | class DataBase(): |
66 | | - def __init__(self, ctx, source, logger, url, user='', pwd=''): |
67 | | - cls, mtd = 'DataBase', '__init__' |
68 | | - logger.logprb(INFO, cls, mtd, 401) |
| 62 | + def __init__(self, ctx, connection, url): |
69 | 63 | self._ctx = ctx |
70 | 64 | self._url = url |
71 | | - odb = url + '.odb' |
72 | | - new = not getSimpleFile(ctx).exists(odb) |
73 | | - connection = getDataBaseConnection(ctx, url, user, pwd, new) |
74 | | - checkConnection(ctx, source, connection, logger, new) |
75 | | - version = connection.getMetaData().getDriverVersion() |
76 | | - if new: |
77 | | - logger.logprb(INFO, cls, mtd, 402, version) |
78 | | - createDataBase(ctx, connection, odb) |
79 | | - logger.logprb(INFO, cls, mtd, 403) |
| 65 | + print("DataBase.__init__() url: %s" % self._url) |
80 | 66 | self._statement = connection.createStatement() |
81 | | - self._version = version |
82 | | - self._logger = logger |
83 | | - logger.logprb(INFO, cls, mtd, 404) |
84 | 67 |
|
85 | 68 | @property |
86 | 69 | def Url(self): |
87 | 70 | return self._url |
88 | | - @property |
89 | | - def Version(self): |
90 | | - return self._version |
91 | 71 |
|
92 | 72 | @property |
93 | 73 | def Connection(self): |
94 | 74 | return self._statement.getConnection() |
95 | 75 |
|
96 | | - def isUptoDate(self): |
97 | | - return checkDatabaseVersion(self._version) |
98 | | - |
99 | 76 | # Procedures called by the DataSource |
100 | 77 | def addCloseListener(self, listener): |
101 | 78 | self.Connection.getParent().DatabaseDocument.addCloseListener(listener) |
@@ -472,7 +449,7 @@ def _mergeItem(self, call, item): |
472 | 449 | mx = 2 ** 32 / 2 -1 |
473 | 450 | if size > mx: |
474 | 451 | size = min(size, mx) |
475 | | - self._logger.logprb(SEVERE, 'DataBase', '_mergeItem', 451, size, item.get('Size')) |
| 452 | + getLogger(self._ctx, g_defaultlog).logprb(SEVERE, 'DataBase', '_mergeItem', 401, os.name, item.get('Size'), size) |
476 | 453 | call.setLong(10, size) |
477 | 454 | call.setString(11, item.get('Link')) |
478 | 455 | call.setBoolean(12, item.get('Trashed')) |
|
0 commit comments