| Total Complexity | 4 |
| Total Lines | 28 |
| Duplicated Lines | 0 % |
| Changes | 0 | ||
| 1 | # # Package # # |
||
| 2 | from pymongo import MongoClient |
||
| 3 | from pymongo.database import Database |
||
| 4 | |||
| 5 | __all__ = ["MongomanticClient"] |
||
| 6 | |||
| 7 | |||
| 8 | class MongomanticClient: |
||
| 9 | client: MongoClient = None |
||
| 10 | db: Database = None |
||
| 11 | |||
| 12 | |||
| 13 | def connect(uri: str, database: str, mock: bool = False) -> None: |
||
| 14 | if mock: |
||
| 15 | try: |
||
| 16 | import mongomock |
||
| 17 | except ImportError: |
||
| 18 | raise RuntimeError("Mongomock needs to be installed for mocking a connection") |
||
| 19 | MongomanticClient.client = mongomock.MongoClient(uri) |
||
| 20 | else: |
||
| 21 | MongomanticClient.client = MongoClient(uri) |
||
| 22 | |||
| 23 | MongomanticClient.db = MongomanticClient.client.__getattr__(database) |
||
| 24 | |||
| 25 | |||
| 26 | def disconnect() -> None: |
||
| 27 | MongomanticClient.client.close() |
||
| 28 |