equal
deleted
inserted
replaced
230 |
230 |
231 def get_connection(self): |
231 def get_connection(self): |
232 """open and return a connection to the source""" |
232 """open and return a connection to the source""" |
233 raise NotImplementedError(self) |
233 raise NotImplementedError(self) |
234 |
234 |
235 def check_connection(self, cnx): |
|
236 """Check connection validity, return None if the connection is still |
|
237 valid else a new connection (called when the connections set using the |
|
238 given connection is being attached to a session). Do nothing by default. |
|
239 """ |
|
240 pass |
|
241 |
|
242 def close_source_connections(self): |
235 def close_source_connections(self): |
243 for cnxset in self.repo.cnxsets: |
236 for cnxset in self.repo.cnxsets: |
244 cnxset.cu = None |
237 cnxset.cu = None |
245 cnxset.cnx.close() |
238 cnxset.cnx.close() |
246 |
239 |