importccl: adds an import tenant test with multiple SQL pods

The test validates that an import can be distributed across two SQL pods
in a single tenant.

Release note: None

pkg/ccl/importccl/import_stmt_test.go

@@ -1851,7 +1851,7 @@ func TestImportRowLimit(t *testing.T) {
 
 	t.Run("row limit multiple csv", func(t *testing.T) {
 		sqlDB.Exec(t, `CREATE DATABASE test; USE test`)
-		defer sqlDB.Exec(t, (`DROP DATABASE test`))
+		defer sqlDB.Exec(t, `DROP DATABASE test`)
 
 		data = "pear\navocado\nwatermelon\nsugar"
 		sqlDB.Exec(t, `CREATE TABLE t (s STRING)`)
@@ -6867,7 +6867,6 @@ func TestDisallowsInvalidFormatOptions(t *testing.T) {
 		}
 	}
 }
-
 func TestImportInTenant(t *testing.T) {
 	defer leaktest.AfterTest(t)()
 	defer log.Scope(t).Close(t)
@@ -6912,6 +6911,41 @@ func TestImportInTenant(t *testing.T) {
 	t11.CheckQueryResults(t, "SELECT * FROM foo", [][]string{{"11", "22"}, {"33", "44"}, {"55", "66"}})
 }
 
+func TestImportInMultiServerTenant(t *testing.T) {
+	defer leaktest.AfterTest(t)()
+	defer log.Scope(t).Close(t)
+
+	ctx := context.Background()
+	baseDir := testutils.TestDataPath(t)
+	args := base.TestServerArgs{ExternalIODir: baseDir}
+	tc := testcluster.StartTestCluster(t, 1, base.TestClusterArgs{ServerArgs: args})
+	defer tc.Stopper().Stop(ctx)
+
+	// Setup a SQL server on a tenant.
+	_, conn1 := serverutils.StartTenant(t, tc.Server(0), base.TestTenantArgs{TenantID: roachpb.MakeTenantID(10)})
+	defer conn1.Close()
+	t1 := sqlutils.MakeSQLRunner(conn1)
+
+	// Setup another SQL server on the same tenant.
+	_, conn2 := serverutils.StartTenant(t, tc.Server(0), base.TestTenantArgs{TenantID: roachpb.MakeTenantID(10), Existing: true})
+	defer conn2.Close()
+	t2 := sqlutils.MakeSQLRunner(conn2)
+
+	const userfileURI = "userfile://defaultdb.public.root/test.csv"
+	const userfile2URI = "userfile://defaultdb.public.root/test2.csv"
+	const createStmt = "CREATE TABLE foo (k INT PRIMARY KEY, v INT)"
+	const importStmt = "IMPORT INTO foo CSV DATA ($1, $2)"
+
+	// Upload files.
+	require.NoError(t, putUserfile(ctx, conn1, security.RootUserName(), userfileURI, []byte("10,2")))
+	require.NoError(t, putUserfile(ctx, conn2, security.RootUserName(), userfile2URI, []byte("11,22\n33,44\n55,66")))
+
+	t1.Exec(t, createStmt)
+	t1.Exec(t, importStmt, userfileURI, userfile2URI)
+	t1.CheckQueryResults(t, "SELECT * FROM foo", [][]string{{"10", "2"}, {"11", "22"}, {"33", "44"}, {"55", "66"}})
+	t2.CheckQueryResults(t, "SELECT * FROM foo", [][]string{{"10", "2"}, {"11", "22"}, {"33", "44"}, {"55", "66"}})
+}
+
 func putUserfile(
 	ctx context.Context, conn *gosql.DB, user security.SQLUsername, uri string, content []byte,
 ) error {