Add tests for streams

Author: littleK0i

test/_config/step1/db1/sc1/external_table/str005_ext1.yaml

@@ -0,0 +1,19 @@
+columns:
+  dt:
+    type: DATE
+    expr: "to_date(split_part(metadata$filename, '/', 2))::date"
+    comment: "Date of ingestion"
+
+  id:
+    type: NUMBER(38,0) NOT NULL
+    expr: "$1:id::number(38,0)"
+
+  name:
+    type: VARCHAR(255) NOT NULL
+    expr: "$1:name::varchar(255)"
+
+location:
+  stage: str005_st1
+  file_format: str005_ff1
+
+partition_by: [dt]

test/_config/step1/db1/sc1/file_format/str005_ff1.yaml

@@ -0,0 +1 @@
+type: CSV

test/_config/step1/db1/sc1/stage/str005_st1.yaml

@@ -0,0 +1,2 @@
+url: gcs://test-bucket1
+storage_integration: test_storage_integration_gcp

test/_config/step1/db1/sc1/stream/str005_str1.yaml

@@ -0,0 +1,4 @@
+object_type: EXTERNAL_TABLE
+object_name: str005_ext1
+
+insert_only: true

test/_config/step2/db1/sc1/stage/str005_st1.yaml

@@ -0,0 +1,2 @@
+directory:
+  enable: true

test/_config/step2/db1/sc1/stream/str005_str1.yaml

@@ -0,0 +1,2 @@
+object_type: STAGE
+object_name: str005_st1

test/stream/str005.py

@@ -0,0 +1,20 @@
+def test_step1(helper):
+    stream_show = helper.show_stream("db1", "sc1", "str005_str1")
+
+    assert stream_show["source_type"] == "External Table"
+    assert stream_show["table_name"].endswith(".STR005_EXT1")
+    assert stream_show["mode"] == "INSERT_ONLY"
+
+
+def test_step2(helper):
+    stream_show = helper.show_stream("db1", "sc1", "str005_str1")
+
+    assert stream_show["source_type"] == "Stage"
+    assert stream_show["table_name"] == "STR005_ST1"  # Snowflake bug: streams for stages return not fully qualified name
+    assert stream_show["mode"] == "DEFAULT"
+
+
+def test_step3(helper):
+    stream_show = helper.show_stream("db1", "sc1", "str005_str1")
+
+    assert stream_show is None