Method safe_create_table

pymysql/tests/base.py:89–105

create a table. Ensures any existing version of that table is first dropped. Also adds a cleanup rule to drop the table after the test completes.

(self, connection, tablename, ddl, cleanup=True)

            self._connections = None

    def safe_create_table(self, connection, tablename, ddl, cleanup=True):
        """create a table.

        Ensures any existing version of that table is first dropped.

        Also adds a cleanup rule to drop the table after the test
        completes.
        """
        cursor = connection.cursor()

        with warnings.catch_warnings():
            warnings.simplefilter("ignore")
            cursor.execute(f"drop table if exists `{tablename}`")
        cursor.execute(ddl)
        cursor.close()
        if cleanup:
            self.addCleanup(self.drop_table, connection, tablename)

    def drop_table(self, connection, tablename):
        cursor = connection.cursor()