fix: Executing existing DDL statements on executemany statement execution

google/cloud/spanner_dbapi/cursor.py

@@ -317,6 +317,10 @@ def executemany(self, operation, seq_of_params):
 
         many_result_set = StreamedManyResultSets()
 
+        # For every operation, we've got to ensure that any prior DDL
+        # statements were run.
+        self.connection.run_prior_DDL_statements()
+
         if class_ in (parse_utils.STMT_INSERT, parse_utils.STMT_UPDATING):
             statements = []
 

tests/system/test_dbapi.py

@@ -344,6 +344,50 @@ def test_DDL_autocommit(shared_instance, dbapi_database):
             op.result()
 
 
+def test_ddl_executemany(shared_instance, dbapi_database):
+    """Check that DDLs in autocommit mode are immediately executed."""
+
+    try:
+        conn = Connection(shared_instance, dbapi_database)
+        want_row = (
+            1,
+            "first-name",
+        )
+        cur = conn.cursor()
+        cur.execute(
+            """
+            CREATE TABLE Singers (
+                SingerId     INT64 NOT NULL,
+                Name    STRING(1024),
+            ) PRIMARY KEY (SingerId)
+        """
+        )
+        cur.executemany(
+            """
+    INSERT INTO Singers (SingerId, Name)
+    VALUES (%s, %s)
+    """,
+            [want_row],
+        )
+        conn.commit()
+
+        # read the resulting data from the database
+        cur.execute("SELECT * FROM Singers")
+        got_rows = cur.fetchall()
+
+        assert got_rows == [want_row]
+
+        cur.close()
+        conn.close()
+
+    finally:
+        # Delete table
+        table = dbapi_database.table("Singers")
+        if table.exists():
+            op = dbapi_database.update_ddl(["DROP TABLE Singers"])
+            op.result()
+
+
 @pytest.mark.skipif(_helpers.USE_EMULATOR, reason="Emulator does not support json.")
 def test_autocommit_with_json_data(shared_instance, dbapi_database):
     """