Clean class LOBase
This commit is contained in:
parent
01b6c0315e
commit
8df0641cf5
|
@ -65,82 +65,6 @@ class LOBase(object):
|
|||
error(str(e))
|
||||
return None
|
||||
|
||||
@property
|
||||
def obj(self):
|
||||
return self._obj
|
||||
|
||||
@property
|
||||
def name(self):
|
||||
return self._name
|
||||
|
||||
@property
|
||||
def connection(self):
|
||||
return self._con
|
||||
|
||||
@property
|
||||
def path(self):
|
||||
return self._path
|
||||
@path.setter
|
||||
def path(self, value):
|
||||
self._path = value
|
||||
|
||||
@property
|
||||
def exists(self):
|
||||
return self._dbc.hasRegisteredDatabase(self.name)
|
||||
|
||||
@classmethod
|
||||
def register(self, path, name):
|
||||
if not self._dbc.hasRegisteredDatabase(name):
|
||||
self._dbc.registerDatabaseLocation(name, _path_url(path))
|
||||
return
|
||||
|
||||
def revoke(self, name):
|
||||
self._dbc.revokeDatabaseLocation(name)
|
||||
return True
|
||||
|
||||
def save(self):
|
||||
# ~ self._db.connection.commit()
|
||||
# ~ self._db.connection.getTables().refresh()
|
||||
# ~ oDisp.executeDispatch(oFrame,".uno:DBRefreshTables", "", 0, Array())
|
||||
self._obj.DatabaseDocument.store()
|
||||
self.refresh()
|
||||
return
|
||||
|
||||
def close(self):
|
||||
self._con.close()
|
||||
return
|
||||
|
||||
def refresh(self):
|
||||
self._con.getTables().refresh()
|
||||
return
|
||||
|
||||
def get_tables(self):
|
||||
tables = self._con.getTables()
|
||||
tables = [tables.getByIndex(i) for i in range(tables.Count)]
|
||||
return tables
|
||||
|
||||
def cursor(self, sql, params):
|
||||
cursor = self._con.prepareStatement(sql)
|
||||
for i, v in enumerate(params, 1):
|
||||
if not type(v) in self.TYPES:
|
||||
error('Type not support')
|
||||
debug((i, type(v), v, self.TYPES[type(v)]))
|
||||
getattr(cursor, self.TYPES[type(v)])(i, v)
|
||||
return cursor
|
||||
|
||||
def execute(self, sql, params):
|
||||
debug(sql)
|
||||
if params:
|
||||
cursor = self.cursor(sql, params)
|
||||
cursor.execute()
|
||||
else:
|
||||
cursor = self._con.createStatement()
|
||||
cursor.execute(sql)
|
||||
# ~ resulset = cursor.executeQuery(sql)
|
||||
# ~ rows = cursor.executeUpdate(sql)
|
||||
self.save()
|
||||
return cursor
|
||||
|
||||
|
||||
class WriterTableRange(ObjectBase):
|
||||
|
||||
|
|
Loading…
Reference in New Issue