diff --git a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/client.rpt b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/client.rpt index 183c87362f..9d1c65d806 100644 --- a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/client.rpt +++ b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/client.rpt @@ -42,7 +42,7 @@ read advised zilla:flush ${pgsql:flushEx() .name("name") .tableOid(0) .index(0) - .typeOid(701) + .typeOid(1043) .length(8) .modifier(-1) .format("TEXT") @@ -51,7 +51,7 @@ read advised zilla:flush ${pgsql:flushEx() .name("sql") .tableOid(0) .index(0) - .typeOid(20) + .typeOid(1043) .length(8) .modifier(-1) .format("TEXT") diff --git a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/server.rpt b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/server.rpt index c407fc66ee..2d4a096a97 100644 --- a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/server.rpt +++ b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/server.rpt @@ -44,7 +44,7 @@ write advise zilla:flush ${pgsql:flushEx() .name("name") .tableOid(0) .index(0) - .typeOid(701) + .typeOid(1043) .length(8) .modifier(-1) .format("TEXT") @@ -53,7 +53,7 @@ write advise zilla:flush ${pgsql:flushEx() .name("sql") .tableOid(0) .index(0) - .typeOid(20) + .typeOid(1043) .length(8) .modifier(-1) .format("TEXT") diff --git a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/client.rpt b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/client.rpt index a87203a830..6eddc691a8 100644 --- a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/client.rpt +++ b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/client.rpt @@ -42,7 +42,7 @@ read advised zilla:flush ${pgsql:flushEx() .name("name") .tableOid(0) .index(0) - .typeOid(701) + .typeOid(1043) .length(8) .modifier(-1) .format("TEXT") @@ -51,7 +51,7 @@ read advised zilla:flush ${pgsql:flushEx() .name("sql") .tableOid(0) .index(0) - .typeOid(20) + .typeOid(1043) .length(8) .modifier(-1) .format("TEXT") diff --git a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/server.rpt b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/server.rpt index 1d6af65ec3..9349a45b7e 100644 --- a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/server.rpt +++ b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/server.rpt @@ -44,7 +44,7 @@ write advise zilla:flush ${pgsql:flushEx() .name("name") .tableOid(0) .index(0) - .typeOid(701) + .typeOid(1043) .length(8) .modifier(-1) .format("TEXT") @@ -53,7 +53,7 @@ write advise zilla:flush ${pgsql:flushEx() .name("sql") .tableOid(0) .index(0) - .typeOid(20) + .typeOid(1043) .length(8) .modifier(-1) .format("TEXT") diff --git a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/client.rpt b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/client.rpt index ee41dddaf1..d7aa0fd77d 100644 --- a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/client.rpt +++ b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/client.rpt @@ -43,7 +43,7 @@ read advised zilla:flush ${pgsql:flushEx() .name("Name") .tableOid(0) .index(0) - .typeOid(701) + .typeOid(1043) .length(4) .modifier(-1) .format("TEXT") diff --git a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/server.rpt b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/server.rpt index 9ac7e754f2..cbed6e429e 100644 --- a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/server.rpt +++ b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/server.rpt @@ -46,7 +46,7 @@ write advise zilla:flush ${pgsql:flushEx() .name("Name") .tableOid(0) .index(0) - .typeOid(701) + .typeOid(1043) .length(4) .modifier(-1) .format("TEXT") diff --git a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/client.rpt b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/client.rpt index 4f701af13b..2c0f03233d 100644 --- a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/client.rpt +++ b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/client.rpt @@ -43,7 +43,7 @@ read advised zilla:flush ${pgsql:flushEx() .name("Name") .tableOid(0) .index(0) - .typeOid(701) + .typeOid(1043) .length(4) .modifier(-1) .format("TEXT") diff --git a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/server.rpt b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/server.rpt index 5f42c02f56..130d587f70 100644 --- a/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/server.rpt +++ b/incubator/binding-risingwave.spec/src/main/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/server.rpt @@ -46,7 +46,7 @@ write advise zilla:flush ${pgsql:flushEx() .name("Name") .tableOid(0) .index(0) - .typeOid(701) + .typeOid(1043) .length(4) .modifier(-1) .format("TEXT") diff --git a/incubator/binding-risingwave/src/main/java/io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java b/incubator/binding-risingwave/src/main/java/io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java index bae6ceb81f..c42985b4f4 100644 --- a/incubator/binding-risingwave/src/main/java/io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java +++ b/incubator/binding-risingwave/src/main/java/io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java @@ -97,6 +97,8 @@ public final class RisingwaveProxyFactory implements RisingwaveStreamFactory private static final String SEVERITY_WARNING = "WARNING\u0000"; private static final String CODE_XX000 = "XX000\u0000"; + private static final int STRING_TYPE_OID = 1043; + private static final String POSTGRES_USER = "postgres\u0000"; private static final String DEFAULT_USER = "default\u0000"; @@ -828,7 +830,7 @@ public void doDescription( .name("%s\u0000".formatted(name)) .tableOid(0) .index((short) 0) - .typeOid(701) + .typeOid(STRING_TYPE_OID) .length((short) name.length()) .modifier(-1) .format(f -> f.set(PgsqlFormat.TEXT))