217 def _get_connection(self): |
217 def _get_connection(self): |
218 """open and return a connection to the source""" |
218 """open and return a connection to the source""" |
219 nshost = self.config.get('pyro-ns-host') or self.repo.config['pyro-ns-host'] |
219 nshost = self.config.get('pyro-ns-host') or self.repo.config['pyro-ns-host'] |
220 nsgroup = self.config.get('pyro-ns-group') or self.repo.config['pyro-ns-group'] |
220 nsgroup = self.config.get('pyro-ns-group') or self.repo.config['pyro-ns-group'] |
221 self.info('connecting to instance :%s.%s for user %s', |
221 self.info('connecting to instance :%s.%s for user %s', |
222 nsgroup, nshost, self.config['cubicweb-user']) |
222 nsgroup, self.config['pyro-ns-id'], self.config['cubicweb-user']) |
223 #cnxprops = ConnectionProperties(cnxtype=self.config['cnx-type']) |
223 #cnxprops = ConnectionProperties(cnxtype=self.config['cnx-type']) |
224 return dbapi.connect(database=self.config['pyro-ns-id'], |
224 return dbapi.connect(database=self.config['pyro-ns-id'], |
225 login=self.config['cubicweb-user'], |
225 login=self.config['cubicweb-user'], |
226 password=self.config['cubicweb-password'], |
226 password=self.config['cubicweb-password'], |
227 host=nshost, group=nsgroup, |
227 host=nshost, group=nsgroup, |