source versioning: fix failing tests

Author: bobbyiliev

docs/resources/source_table_postgres.md

@@ -47,6 +47,7 @@ resource "materialize_source_table_postgres" "postgres_table_from_source" {
 
 - `comment` (String) Comment on an object in the database.
 - `database_name` (String) The identifier for the table database in Materialize. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set.
+- `exclude_columns` (List of String) Exclude specific columns when reading data from PostgreSQL.
 - `ownership_role` (String) The owernship role of the object.
 - `region` (String) The region to use for the resource connection. If not set, the default region is used.
 - `schema_name` (String) The identifier for the table schema in Materialize. Defaults to `public`.

integration/sqlserver.tf

@@ -54,7 +54,7 @@ resource "materialize_source_sqlserver" "sqlserver_source_all" {
     database_name = materialize_connection_sqlserver.sqlserver_connection.database_name
   }
 
-  exclude_columns = ["dbo.table3.data", "dbo.table1.about", "dbo.table2.about", "dbo.table5.large_text", "dbo.table5.image_data", "dbo.table5.xml_data", "dbo.table5.json_data", "dbo.table10.text_col", "dbo.table10.nvarchar_max"]
+  exclude_columns = ["dbo.table3.data", "dbo.table1.about", "dbo.table2.about", "dbo.table5.large_text", "dbo.table5.image_data", "dbo.table5.xml_data", "dbo.table5.json_data", "dbo.table6.description", "dbo.table10.text_col", "dbo.table10.nvarchar_max"]
 }
 
 # SQL Server Source Table

pkg/provider/acceptance_source_table_mysql_test.go

@@ -341,14 +341,6 @@ func testAccSourceTableMySQLWithENUMResource(nameSpace string) string {
 		mysql_connection {
 			name = materialize_connection_mysql.mysql_connection.name
 		}
-
-		table {
-			upstream_name        = "mysql_table6"
-			upstream_schema_name = "shop"
-			name                 = "mysql_table6_local"
-		}
-
-		text_columns = ["shop.mysql_table6.tags", "shop.mysql_table6.status"]
 	}
 
 	resource "materialize_source_table_mysql" "test_enum" {
@@ -446,14 +438,6 @@ func testAccSourceTableMySQLWithDateTimeTypesResource(nameSpace string) string {
 		mysql_connection {
 			name = materialize_connection_mysql.mysql_connection.name
 		}
-
-		table {
-			upstream_name        = "mysql_table10"
-			upstream_schema_name = "shop"
-			name                 = "mysql_table10_local"
-		}
-
-		ignore_columns = ["shop.mysql_table10.year_col"]
 	}
 
 	resource "materialize_source_table_mysql" "test_datetime" {
@@ -467,6 +451,8 @@ func testAccSourceTableMySQLWithDateTimeTypesResource(nameSpace string) string {
 
 		upstream_name         = "mysql_table10"
 		upstream_schema_name  = "shop"
+
+		exclude_columns = ["year_col"]
 	}
 	`, nameSpace)
 }

pkg/provider/acceptance_source_table_sqlserver_test.go

@@ -282,7 +282,7 @@ func TestAccSourceTableSQLServer_withUnsupportedTypes(t *testing.T) {
 					testAccCheckSourceTableSQLServerExists("materialize_source_table_sqlserver.test_unsupported"),
 					resource.TestCheckResourceAttr("materialize_source_table_sqlserver.test_unsupported", "name", nameSpace+"_table_unsupported"),
 					resource.TestCheckResourceAttr("materialize_source_table_sqlserver.test_unsupported", "upstream_name", "table5"),
-					resource.TestCheckResourceAttr("materialize_source_table_sqlserver.test_unsupported", "exclude_columns.#", "2"),
+					resource.TestCheckResourceAttr("materialize_source_table_sqlserver.test_unsupported", "exclude_columns.#", "4"),
 				),
 			},
 		},
@@ -375,11 +375,6 @@ func testAccSourceTableSQLServerWithUnsupportedTypesResource(nameSpace string) s
 		sqlserver_connection {
 			name = materialize_connection_sqlserver.sqlserver_connection.name
 		}
-		table {
-			upstream_name  = "table5"
-			upstream_schema_name = "dbo"
-		}
-		exclude_columns = ["dbo.table5.large_text", "dbo.table5.image_data", "dbo.table5.xml_data", "dbo.table5.json_data"]
 	}
 
 	resource "materialize_source_table_sqlserver" "test_unsupported" {
@@ -396,7 +391,9 @@ func testAccSourceTableSQLServerWithUnsupportedTypesResource(nameSpace string) s
 
 		exclude_columns = [
 			"large_text",
-			"image_data"
+			"image_data",
+			"xml_data",
+			"json_data"
 		]
 	}
 	`, nameSpace)