server/sources/__init__.py
changeset 9463 d62e13eba033
parent 9452 5308b3fe03c9
child 9465 86d4b41ae339
--- a/server/sources/__init__.py	Thu Jun 27 08:52:15 2013 +0200
+++ b/server/sources/__init__.py	Wed Jan 22 15:49:32 2014 +0100
@@ -241,12 +241,13 @@
 
     def close_source_connections(self):
         for cnxset in self.repo.cnxsets:
-            cnxset._cursors.pop(self.uri, None)
-            cnxset.source_cnxs[self.uri][1].close()
+            cnxset.cu = None
+            cnxset.cnx.close()
 
     def open_source_connections(self):
         for cnxset in self.repo.cnxsets:
-            cnxset.source_cnxs[self.uri] = (self, self.get_connection())
+            cnxset.cnx = self.get_connection()
+            cnxset.cu = cnxset.cnx.cursor()
 
     def cnxset_freed(self, cnx):
         """the connections set holding the given connection is being reseted
@@ -386,7 +387,7 @@
         .executemany().
         """
         res = self.syntax_tree_search(session, union, args, varmap=varmap)
-        session.cnxset.source('system').manual_insert(res, table, session)
+        session.repo.system_source.manual_insert(res, table, session)
 
     # write modification api ###################################################
     # read-only sources don't have to implement methods below