310 dbport = port and int(port) or None |
310 dbport = port and int(port) or None |
311 dbuser = source_config.get('db-user') |
311 dbuser = source_config.get('db-user') |
312 dbpassword = source_config.get('db-password') |
312 dbpassword = source_config.get('db-password') |
313 dbencoding = source_config.get('db-encoding', 'UTF-8') |
313 dbencoding = source_config.get('db-encoding', 'UTF-8') |
314 dbextraargs = source_config.get('db-extra-arguments') |
314 dbextraargs = source_config.get('db-extra-arguments') |
|
315 dbnamespace = source_config.get('db-namespace') |
315 self.dbhelper = db.get_db_helper(self.dbdriver) |
316 self.dbhelper = db.get_db_helper(self.dbdriver) |
316 self.dbhelper.record_connection_info(dbname, dbhost, dbport, dbuser, |
317 self.dbhelper.record_connection_info(dbname, dbhost, dbport, dbuser, |
317 dbpassword, dbextraargs, |
318 dbpassword, dbextraargs, |
318 dbencoding) |
319 dbencoding, dbnamespace) |
319 self.sqlgen = SQLGenerator() |
320 self.sqlgen = SQLGenerator() |
320 # copy back some commonly accessed attributes |
321 # copy back some commonly accessed attributes |
321 dbapi_module = self.dbhelper.dbapi_module |
322 dbapi_module = self.dbhelper.dbapi_module |
322 self.OperationalError = dbapi_module.OperationalError |
323 self.OperationalError = dbapi_module.OperationalError |
323 self.InterfaceError = dbapi_module.InterfaceError |
324 self.InterfaceError = dbapi_module.InterfaceError |