58 |
self._updateFlag = 0 |
self._updateFlag = 0 |
59 |
self._insertFlag = 0 |
self._insertFlag = 0 |
60 |
self._deleteFlag = 0 |
self._deleteFlag = 0 |
61 |
|
|
62 |
|
# this function calls a per entry function on server side |
63 |
|
def callFunc(self,name,params): |
64 |
|
if hasattr(self,"_instance"): |
65 |
|
self._instance.call(name,params) |
66 |
|
else: |
67 |
|
print ("BUG: Function %s could not be called on a newly created and not"+ |
68 |
|
"commited object (this has to be fixed)") % name |
69 |
|
# at the moment newly created objects are just created localy and |
70 |
|
# not created on appserver too. So there is no way to call a function |
71 |
|
# off a newly created object/recordset at the moment. |
72 |
|
# this has to be changed. |
73 |
|
|
74 |
|
|
75 |
# GEASv2_ResultSet |
# GEASv2_ResultSet |
247 |
# self._session.close() |
# self._session.close() |
248 |
raise GDataObjects.ConnectionError, "Error loging into appserver" |
raise GDataObjects.ConnectionError, "Error loging into appserver" |
249 |
|
|
250 |
# self.triggerExtensions = TriggerExtensions(self._dataConnection) |
self.triggerExtensions = GEASv2_TriggerExtensions(self._session) |
|
self.triggerExtensions = TriggerExtensions(self._session) |
|
251 |
|
|
252 |
except: |
except: |
253 |
raise GDataObjects.ConnectionError, "Error loging into appserver" |
raise GDataObjects.ConnectionError, "Error loging into appserver" |
384 |
} |
} |
385 |
|
|
386 |
|
|
387 |
class TriggerExtensions: |
# |
388 |
|
# Extensions to Trigger Namespaces |
389 |
|
# |
390 |
|
class GEASv2_TriggerExtensions: |
391 |
|
|
392 |
|
def __init__(self, session): |
393 |
|
self.__session = session |
394 |
|
|
395 |
|
# Return a sequence number from sequence 'name' |
396 |
|
# def getSequence(self, name): |
397 |
|
# !!! has to be emulated !!! |
398 |
|
# return self.__singleQuery("select nextval('%s')" % name) |
399 |
|
|
400 |
|
# Run the SQL statement 'statement' |
401 |
|
#def sql(self, statement): |
402 |
|
# !!! has to be emulated !!! |
403 |
|
# cursor = self.__connection.cursor() |
404 |
|
# try: |
405 |
|
# cursor.execute(statement) |
406 |
|
# cursor.close() |
407 |
|
# except: |
408 |
|
# cursor.close() |
409 |
|
# raise |
410 |
|
|
411 |
|
|
|
def __init__(self, connection): |
|
|
pass |
|