test version check

Author: patrickwwbutler

test/mysql-cdc/mysql-version-compat/version-check.td

@@ -0,0 +1,34 @@
+# Copyright Materialize, Inc. and contributors. All rights reserved.
+#
+# Use of this software is governed by the Business Source License
+# included in the LICENSE file at the root of this repository.
+#
+# As of the Change Date specified in that file, in accordance with
+# the Business Source License, use of this software will be governed
+# by the Apache License, Version 2.0.
+
+# Verify that CREATE TABLE FROM SOURCE fails when connected to a MySQL server
+# older than version 8.0.1, which does not support the binlog_row_metadata
+# system variable required for full row metadata in the binlog.
+
+$ mysql-connect name=mysql url=mysql://root@mysql password=${arg.mysql-root-password}
+
+$ mysql-execute name=mysql
+DROP DATABASE IF EXISTS public;
+CREATE DATABASE public;
+USE public;
+CREATE TABLE t1 (id INT PRIMARY KEY, val TEXT);
+INSERT INTO t1 VALUES (1, 'hello');
+
+> CREATE SECRET mysqlpass AS '${arg.mysql-root-password}'
+
+> CREATE CONNECTION mysql_conn TO MYSQL (
+    HOST mysql,
+    USER root,
+    PASSWORD SECRET mysqlpass
+  )
+
+> CREATE SOURCE mz_source FROM MYSQL CONNECTION mysql_conn;
+
+! CREATE TABLE t1 FROM SOURCE mz_source (REFERENCE public.t1);
+contains: 8.0.1

test/mysql-cdc/mzcompose.py

@@ -37,6 +37,26 @@ def create_mysql(mysql_version: str) -> MySql:
     return MySql(version=mysql_version)
 
 
+def create_mysql_pre_8_0_1(version: str = "5.7.44") -> MySql:
+    """
+    Create a MySQL instance for a version older than 8.0.1.
+    The --binlog-row-metadata flag did not exist before 8.0.1, so it must be
+    omitted from the server args.
+    """
+    return MySql(
+        version=version,
+        additional_args=[
+            "--log-bin=mysql-bin",
+            "--gtid_mode=ON",
+            "--enforce_gtid_consistency=ON",
+            "--binlog-format=row",
+            "--binlog-row-image=full",
+            "--server-id=1",
+            "--max-connections=500",
+        ],
+    )
+
+
 def create_mysql_replica(mysql_version: str) -> MySql:
     return MySql(
         name="mysql-replica",
@@ -368,3 +388,19 @@ def workflow_source_timeouts(c: Composition, parser: WorkflowArgumentParser) ->
             f"--var=mysql-root-password={MySql.DEFAULT_ROOT_PASSWORD}",
             "proxied/*.td",
         )
+
+
+def workflow_mysql_version_compat(
+    c: Composition, _parser: WorkflowArgumentParser
+) -> None:
+    """
+    Validates that CREATE TABLE FROM SOURCE fails when connected to a MySQL
+    server older than version 8.0.1, which does not support the
+    binlog_row_metadata system variable required for full row metadata.
+    """
+    with c.override(create_mysql_pre_8_0_1()):
+        c.up("materialized", "mysql")
+        c.run_testdrive_files(
+            f"--var=mysql-root-password={MySql.DEFAULT_ROOT_PASSWORD}",
+            "mysql-version-compat/version-check.td",
+        )