Method _create_database

src/server/tasks/dbbench/interaction.py:128–134

(self)

            raise e

    async def _create_database(self):
        database = f'dbbench_{self.session_id.replace("-", "_")}'
        conn = await self._get_conn()
        async with await conn.cursor() as cursor:
            await cursor.execute(f'CREATE DATABASE {database}')
        self.database = database
        await self._get_conn()

    async def _get_conn(self) -> mysql_connector.MySQLConnectionAbstract:
        if self._conn: