diff --git a/connector.py b/connector.py index 2a87fae..3ca65f9 100644 --- a/connector.py +++ b/connector.py @@ -116,6 +116,12 @@ def _send(self, data, settings=None, stream=False): # def connect(*args, **kwargs): + # crude hack to get authentication to work + if 'username' in kwargs: + kwargs['db_url'] = kwargs['db_url'].replace('//','//{username}:{password}@'.format( + username=kwargs['username'] if kwargs['username'] else 'default', + password=kwargs['password'] if kwargs['username'] and 'password' in kwargs else '' + )) return Connection(*args, **kwargs) class Connection(Database):