| 34 | class MySQLDatabase(Database): |
| 35 | |
| 36 | def __init__(self, env_controller: EnvironmentController): |
| 37 | super().__init__(TYPE_MYSQL) |
| 38 | |
| 39 | self.env_controller = env_controller |
| 40 | assert isinstance(self.env_controller.delegation, DBBenchEnvironmentDelegation) |
| 41 | self.session_id: Optional[str] = None |
| 42 | self.container_id: Optional[str] = None |
| 43 | self.container_ip: Optional[str] = None |
| 44 | |
| 45 | self._conn: Optional[mysql_connector.MySQLConnectionAbstract] = None |
| 46 | self.password = self.env_controller.delegation.password |
| 47 | self.database: Optional[str] = None |
| 48 | |
| 49 | async def initialize(self): |
| 50 | session_id, container_ids, container_ips = await self.env_controller.start_session(self.type) |