Function run

src/tests/test_database_driver.py:106–202

(selenium, host, port, user, password, db)

    @run_in_pyodide(packages=["micropip"])
    async def run(selenium, host, port, user, password, db):
        import contextlib

        import micropip

        await micropip.install("pymysql==1.1.0")

        import pymysql

        def connect(**kwargs):
            conn = pymysql.connect(
                host=host,
                port=port,
                user=user,
                password=password,
                database=db,
                unix_socket=False,
                **kwargs,
            )
            return contextlib.closing(conn)

        # 1) Basic DDL/DML
        with connect(autocommit=True) as conn:
            with conn.cursor() as cur:
                cur.execute("DROP TABLE IF EXISTS pyodide_mysql_test")
                cur.execute(
                    """
                    CREATE TABLE pyodide_mysql_test (
                        id INT PRIMARY KEY AUTO_INCREMENT,
                        name VARCHAR(255) NOT NULL,
                        value INT NOT NULL
                    )
                    """
                )
                cur.execute(
                    "INSERT INTO pyodide_mysql_test (name, value) VALUES (%s, %s)",
                    ("alpha", 1),
                )
                cur.execute(
                    "INSERT INTO pyodide_mysql_test (name, value) VALUES (%s, %s)",
                    ("beta", 2),
                )
                cur.execute(
                    "UPDATE pyodide_mysql_test SET value = value + 10 WHERE name = %s",
                    ("alpha",),
                )
                cur.execute("SELECT name, value FROM pyodide_mysql_test ORDER BY id")
                result = cur.fetchall()

            assert result == (("alpha", 11), ("beta", 2))

        # 2) Transactions + savepoints
        with connect(autocommit=False) as conn:
            with conn.cursor() as cur:
                cur.execute("DROP TABLE IF EXISTS tx_test")
                cur.execute(
                    "CREATE TABLE tx_test (id INT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(50) NOT NULL)"
                )