conn.close()
return encoding
+ def _get_conn_kwargs(self, forced_client_encoding):
+ '''
+ Return a dict with additional conninfo values from the settings.
+ '''
+ registry = self.uh.request.registry
+ if forced_client_encoding is not None:
+ return {'client_encoding': forced_client_encoding}
+ client_encoding = registry.settings['pgwui'].get('client_encoding')
+ if client_encoding == '':
+ return {}
+ return {'client_encoding': client_encoding}
+
def call_with_connection(self, func):
'''
Validate input, connect to the db, and do something with
user=self.user,
password=self.password,
host=registry.settings['pgwui'].get('pg_host'),
+ port=registry.settings['pgwui'].get('pg_port'),
+ **self._get_conn_kwargs(client_encoding))
except psycopg.OperationalError:
errors = [self.authfailerror_factory()]
havecreds = False