| Total Complexity | 6 |
| Total Lines | 23 |
| Duplicated Lines | 0 % |
| 1 | import _mssql |
||
| 10 | class MSSQLAction(Action): |
||
| 11 | |||
| 12 | def __init__(self, config): |
||
| 13 | super(MSSQLAction, self).__init__(config=config) |
||
| 14 | self.config = config |
||
| 15 | |||
| 16 | def connect(self, database=None, server=None, user=None, password=None): |
||
| 17 | # pylint: disable=no-member |
||
| 18 | return _mssql.connect(**self._connect_params(database, server, user, password)) |
||
| 19 | |||
| 20 | def _connect_params(self, database=None, server=None, user=None, password=None): |
||
| 21 | database = database or self.config.get('default') |
||
| 22 | db_config = self.config.get(database, {}) |
||
| 23 | params = { |
||
| 24 | 'database': db_config.get('database') or database, |
||
| 25 | 'server': server or db_config.get('server'), |
||
| 26 | 'user': user or db_config.get('user'), |
||
| 27 | 'password': password or db_config.get('password') |
||
| 28 | } |
||
| 29 | unspecified = [param for param, value in params.iteritems() if value is None] |
||
| 30 | if unspecified: |
||
| 31 | raise Exception("Must specify or configure in config.yaml: %s" % ', '.join(unspecified)) |
||
| 32 | return params |
||
| 33 |