(name)
| 228 | |
| 229 | |
| 230 | def set_default_connection(name): |
| 231 | global cluster, session |
| 232 | |
| 233 | if name not in _connections: |
| 234 | raise CQLEngineException("Connection '{0}' doesn't exist.".format(name)) |
| 235 | |
| 236 | log.debug("Connection '{0}' has been set as default.".format(name)) |
| 237 | _connections[DEFAULT_CONNECTION] = _connections[name] |
| 238 | cluster = _connections[name].cluster |
| 239 | session = _connections[name].session |
| 240 | |
| 241 | |
| 242 | def get_connection(name=None): |
no test coverage detected