Merge pull request #137 from nktks/feature/skip-create-change-stream

[v2]change unsupported DDL behavior
cloudspannerecosystem · Feb 13, 2024 · 783883b · 783883b
2 parents 675211a + d9bf80b
commit 783883b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/v2/loader/schema_parser_source.go b/v2/loader/schema_parser_source.go
@@ -62,9 +62,7 @@ func NewSchemaParserSource(fpath string) (SchemaSource, error) {
 			if isAlterTableAddFK(val) {
 				continue
 			}
-			return nil, fmt.Errorf("stmt should be CreateTable, CreateIndex or AlterTableAddForeignKey, but got '%s'", ddlstmt.SQL())
-		default:
-			return nil, fmt.Errorf("stmt should be CreateTable, CreateIndex or AlterTableAddForeignKey, but got '%s'", ddlstmt.SQL())
+			return nil, fmt.Errorf("unknown statement is specified: %s", ddlstmt.SQL())
 		}
 	}
 

diff --git a/v2/loader/source_test.go b/v2/loader/source_test.go
@@ -38,6 +38,8 @@ CREATE TABLE Simple (
 ) PRIMARY KEY(Id);
 CREATE INDEX SimpleIndex ON Simple(Value);
 CREATE UNIQUE INDEX SimpleIndex2 ON Simple(Id, Value);
+CREATE CHANGE STREAM EverythingStream
+  FOR ALL;
 `
 	testSchema2 = `
 CREATE TABLE MaxLengths (