WIP

incubator/binding-pgsql.spec/src/main/scripts/io/aklivity/zilla/specs/binding/pgsql/streams/application/select.table/server.rpt

@@ -78,12 +78,12 @@ write zilla:data.ext ${pgsql:dataEx()
                                 .build()
                               .build()}
 write [0x00 0x03]                                                 # Field Count
-        [0x00 0x00 0x00 0x04]                                       # Length
-        [0x31 0x39 0x36 0x34]                                       # Data
-        [0x00 0x00 0x00 0x0a]                                       # Length
-        [0x31 0x37 0x32 0x33 0x35 0x39 0x33 0x31 0x31 0x33]         # Data
-        [0x00 0x00 0x00 0x04]                                       # Length
-        [0x5c 0x78 0x33 0x31]                                       # Data
+      [0x00 0x00 0x00 0x04]                                       # Length
+      [0x31 0x39 0x36 0x34]                                       # Data
+      [0x00 0x00 0x00 0x0a]                                       # Length
+      [0x31 0x37 0x32 0x33 0x35 0x39 0x33 0x31 0x31 0x33]         # Data
+      [0x00 0x00 0x00 0x04]                                       # Length
+      [0x5c 0x78 0x33 0x31]                                       # Data
 
 write advise zilla:flush ${pgsql:flushEx()
                               .typeId(zilla:id("pgsql"))

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/client.rpt

@@ -0,0 +1,101 @@
+#
+# Copyright 2021-2024 Aklivity Inc
+#
+# Licensed under the Aklivity Community License (the "License"); you may not use
+# this file except in compliance with the License.  You may obtain a copy of the
+# License at
+#
+#   https://www.aklivity.io/aklivity-community-license/
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OF ANY KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations under the License.
+#
+
+connect "zilla://streams/app1"
+    option zilla:window 8192
+    option zilla:transmission "duplex"
+
+write zilla:begin.ext ${pgsql:beginEx()
+                              .typeId(zilla:id("pgsql"))
+                              .parameter("user", "zillabase")
+                              .parameter("database", "dev")
+                              .parameter("application_name", "psql")
+                              .parameter("client_encoding", "UTF8")
+                              .build()}
+
+connected
+
+write zilla:data.ext ${pgsql:dataEx()
+                              .typeId(zilla:id("pgsql"))
+                              .query()
+                                .build()
+                              .build()}
+write "SELECT * FROM zb_catalog.zviews;"
+      [0x00]
+
+read advised zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .type()
+                                .column()
+                                    .name("name")
+                                    .tableOid(0)
+                                    .index(0)
+                                    .typeOid(701)
+                                    .length(8)
+                                    .modifier(-1)
+                                    .format("TEXT")
+                                    .build()
+                                .column()
+                                    .name("sql")
+                                    .tableOid(0)
+                                    .index(0)
+                                    .typeOid(20)
+                                    .length(8)
+                                    .modifier(-1)
+                                    .format("TEXT")
+                                    .build()
+                                .build()
+                              .build()}
+
+read zilla:data.ext ${pgsql:dataEx()
+                              .typeId(zilla:id("pgsql"))
+                              .row()
+                                .build()
+                              .build()}
+read  [0x00 0x02]                                                 # Field Count
+      [0x00 0x00 0x00 0x04]                                       # Length
+      [0x31 0x39 0x36 0x34]                                       # Data
+      [0x00 0x00 0x00 0x65]                                       # Length
+      "CREATE MATERIALIZED VIEW IF NOT EXISTS distinct_cities AS" # Data
+      " SELECT id, city FROM weather GROUP BY city;"
+
+
+read advised zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .completion()
+                                .tag("SELECT 1")
+                                .build()
+                              .build()}
+
+read advised zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .ready()
+                                .status("IDLE")
+                                .build()
+                              .build()}
+
+connect "zilla://streams/app1"
+    option zilla:window 8192
+    option zilla:transmission "duplex"
+
+write zilla:begin.ext ${pgsql:beginEx()
+                              .typeId(zilla:id("pgsql"))
+                              .parameter("user", "app")
+                              .parameter("database", "dev")
+                              .parameter("application_name", "psql")
+                              .parameter("client_encoding", "UTF8")
+                              .build()}
+
+connected

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/server.rpt

@@ -0,0 +1,103 @@
+#
+# Copyright 2021-2024 Aklivity Inc
+#
+# Licensed under the Aklivity Community License (the "License"); you may not use
+# this file except in compliance with the License.  You may obtain a copy of the
+# License at
+#
+#   https://www.aklivity.io/aklivity-community-license/
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OF ANY KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations under the License.
+#
+
+accept "zilla://streams/app1"
+    option zilla:window 8192
+    option zilla:transmission "duplex"
+
+accepted
+
+read zilla:begin.ext ${pgsql:beginEx()
+                              .typeId(zilla:id("pgsql"))
+                              .parameter("user", "zillabase")
+                              .parameter("database", "dev")
+                              .parameter("application_name", "psql")
+                              .parameter("client_encoding", "UTF8")
+                              .build()}
+
+connected
+
+read zilla:data.ext ${pgsql:dataEx()
+                              .typeId(zilla:id("pgsql"))
+                              .query()
+                                .build()
+                              .build()}
+read "SELECT * FROM zb_catalog.zviews;"
+read [0x00]
+
+write advise zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .type()
+                                .column()
+                                    .name("name")
+                                    .tableOid(0)
+                                    .index(0)
+                                    .typeOid(701)
+                                    .length(8)
+                                    .modifier(-1)
+                                    .format("TEXT")
+                                    .build()
+                                .column()
+                                    .name("sql")
+                                    .tableOid(0)
+                                    .index(0)
+                                    .typeOid(20)
+                                    .length(8)
+                                    .modifier(-1)
+                                    .format("TEXT")
+                                    .build()
+                                .build()
+                              .build()}
+
+write zilla:data.ext ${pgsql:dataEx()
+                              .typeId(zilla:id("pgsql"))
+                              .row()
+                                .build()
+                              .build()}
+write [0x00 0x02]                                                 # Field Count
+      [0x00 0x00 0x00 0x04]                                       # Length
+      [0x31 0x39 0x36 0x34]                                       # Data
+      [0x00 0x00 0x00 0x65]                                       # Length
+      "CREATE MATERIALIZED VIEW IF NOT EXISTS distinct_cities AS" # Data
+      " SELECT id, city FROM weather GROUP BY city;"
+write flush
+
+
+write advise zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .completion()
+                                .tag("SELECT 1")
+                                .build()
+                              .build()}
+
+write advise zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .ready()
+                                .status("IDLE")
+                                .build()
+                              .build()}
+
+accepted
+
+read zilla:begin.ext ${pgsql:beginEx()
+                              .typeId(zilla:id("pgsql"))
+                              .parameter("user", "app")
+                              .parameter("database", "dev")
+                              .parameter("application_name", "psql")
+                              .parameter("client_encoding", "UTF8")
+                              .build()}
+
+connected
+

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/client.rpt

@@ -0,0 +1,77 @@
+#
+# Copyright 2021-2024 Aklivity Inc
+#
+# Licensed under the Aklivity Community License (the "License"); you may not use
+# this file except in compliance with the License.  You may obtain a copy of the
+# License at
+#
+#   https://www.aklivity.io/aklivity-community-license/
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OF ANY KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations under the License.
+#
+
+connect "zilla://streams/app0"
+    option zilla:window 8192
+    option zilla:transmission "duplex"
+
+write zilla:begin.ext ${pgsql:beginEx()
+                              .typeId(zilla:id("pgsql"))
+                              .parameter("user", "app")
+                              .parameter("database", "dev")
+                              .parameter("application_name", "psql")
+                              .parameter("client_encoding", "UTF8")
+                              .build()}
+
+connected
+
+write zilla:data.ext ${pgsql:dataEx()
+                              .typeId(zilla:id("pgsql"))
+                              .query()
+                                .build()
+                              .build()}
+write "SHOW ZVIEWS;"
+      [0x00]
+
+write flush
+
+read advised zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .type()
+                                .column()
+                                    .name("Name")
+                                    .tableOid(0)
+                                    .index(0)
+                                    .typeOid(701)
+                                    .length(8)
+                                    .modifier(-1)
+                                    .format("TEXT")
+                                    .build()
+                                .build()
+                              .build()}
+
+read zilla:data.ext ${pgsql:dataEx()
+                              .typeId(zilla:id("pgsql"))
+                              .row()
+                                .build()
+                              .build()}
+read  [0x00 0x01]                                                 # Field Count
+      [0x00 0x00 0x00 0x04]                                       # Length
+      [0x31 0x39 0x36 0x34]                                       # Data
+
+read advised zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .completion()
+                                .tag("SHOW_COMMAND")
+                                .build()
+                              .build()}
+
+read advised zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .ready()
+                                .status("IDLE")
+                                .build()
+                              .build()}
+

incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/server.rpt

@@ -0,0 +1,79 @@
+#
+# Copyright 2021-2024 Aklivity Inc
+#
+# Licensed under the Aklivity Community License (the "License"); you may not use
+# this file except in compliance with the License.  You may obtain a copy of the
+# License at
+#
+#   https://www.aklivity.io/aklivity-community-license/
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OF ANY KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations under the License.
+#
+
+property serverAddress "zilla://streams/app0"
+
+accept ${serverAddress}
+    option zilla:window 8192
+    option zilla:transmission "duplex"
+
+accepted
+
+read zilla:begin.ext ${pgsql:beginEx()
+                              .typeId(zilla:id("pgsql"))
+                              .parameter("user", "app")
+                              .parameter("database", "dev")
+                              .parameter("application_name", "psql")
+                              .parameter("client_encoding", "UTF8")
+                              .build()}
+
+connected
+
+read zilla:data.ext ${pgsql:dataEx()
+                              .typeId(zilla:id("pgsql"))
+                              .query()
+                                .build()
+                              .build()}
+read "SHOW ZVIEWS;"
+      [0x00]
+
+write advise zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .type()
+                                .column()
+                                    .name("Name")
+                                    .tableOid(0)
+                                    .index(0)
+                                    .typeOid(701)
+                                    .length(8)
+                                    .modifier(-1)
+                                    .format("TEXT")
+                                    .build()
+                                .build()
+                              .build()}
+write flush
+
+write zilla:data.ext ${pgsql:dataEx()
+                              .typeId(zilla:id("pgsql"))
+                              .row()
+                                .build()
+                              .build()}
+write [0x00 0x01]                                                 # Field Count
+      [0x00 0x00 0x00 0x04]                                       # Length
+      [0x31 0x39 0x36 0x34]                                       # Data
+
+write advise zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .completion()
+                                .tag("SHOW_COMMAND")
+                                .build()
+                              .build()}
+
+write advise zilla:flush ${pgsql:flushEx()
+                              .typeId(zilla:id("pgsql"))
+                              .ready()
+                                .status("IDLE")
+                                .build()
+                              .build()}

incubator/binding-risingwave.spec/src/test/java/io/aklivity/zilla/specs/binding/risingwave/streams/EffectiveIT.java

@@ -235,4 +235,13 @@ public void shouldAlterStreamAddColumn() throws Exception
     {
         k3po.finish();
     }
+
+    @Test
+    @Specification({
+        "${app}/show.zviews/client",
+        "${app}/show.zviews/server" })
+    public void shouldShowZviews() throws Exception
+    {
+        k3po.finish();
+    }
 }