From bd5b97bf1a052238c5f71b78139b0a55e5cbba25 Mon Sep 17 00:00:00 2001
From: Shlomi Noach <2607934+shlomi-noach@users.noreply.github.com>
Date: Tue, 4 Feb 2025 10:22:59 +0200
Subject: [PATCH] Supporting InnoDBParallelReadThreadsCapability

Signed-off-by: Shlomi Noach <2607934+shlomi-noach@users.noreply.github.com>
---
 go/mysql/capabilities/capability.go      |  3 +++
 go/mysql/capabilities/capability_test.go | 15 +++++++++++++++
 2 files changed, 18 insertions(+)

diff --git a/go/mysql/capabilities/capability.go b/go/mysql/capabilities/capability.go
index eac25585089..1877caf11d6 100644
--- a/go/mysql/capabilities/capability.go
+++ b/go/mysql/capabilities/capability.go
@@ -42,6 +42,7 @@ const (
 	InstantExpandEnumCapability                                           //
 	InstantChangeColumnVisibilityCapability                               //
 	MySQLUpgradeInServerFlavorCapability                                  //
+	InnoDBParallelReadThreadsCapability                                   // Supported in 8.0.14 and above, introducing innodb_parallel_read_threads variable
 	DynamicRedoLogCapacityFlavorCapability                                // supported in MySQL 8.0.30 and above: https://dev.mysql.com/doc/relnotes/mysql/8.0/en/news-8-0-30.html
 	DisableRedoLogFlavorCapability                                        // supported in MySQL 8.0.21 and above: https://dev.mysql.com/doc/relnotes/mysql/8.0/en/news-8-0-21.html
 	CheckConstraintsCapability                                            // supported in MySQL 8.0.16 and above: https://dev.mysql.com/doc/relnotes/mysql/8.0/en/news-8-0-16.html
@@ -100,6 +101,8 @@ func MySQLVersionHasCapability(serverVersion string, capability FlavorCapability
 		return atLeast(8, 0, 1)
 	case PerformanceSchemaMetadataLocksTableCapability:
 		return atLeast(8, 0, 2)
+	case InnoDBParallelReadThreadsCapability:
+		return atLeast(8, 0, 14)
 	case MySQLUpgradeInServerFlavorCapability:
 		return atLeast(8, 0, 16)
 	case CheckConstraintsCapability:
diff --git a/go/mysql/capabilities/capability_test.go b/go/mysql/capabilities/capability_test.go
index cf5e693840e..ea8458ba2ff 100644
--- a/go/mysql/capabilities/capability_test.go
+++ b/go/mysql/capabilities/capability_test.go
@@ -154,6 +154,21 @@ func TestMySQLVersionCapableOf(t *testing.T) {
 			capability: TransactionalGtidExecutedFlavorCapability,
 			isCapable:  false,
 		},
+		{
+			version:    "8.0.13",
+			capability: InnoDBParallelReadThreadsCapability,
+			isCapable:  false,
+		},
+		{
+			version:    "8.0.14",
+			capability: InnoDBParallelReadThreadsCapability,
+			isCapable:  true,
+		},
+		{
+			version:    "8.4.1",
+			capability: InnoDBParallelReadThreadsCapability,
+			isCapable:  true,
+		},
 		{
 			version:    "8.0.30",
 			capability: DynamicRedoLogCapacityFlavorCapability,