Skip to content

Commit

Permalink
Update show commands type oid (#1357)
Browse files Browse the repository at this point in the history
  • Loading branch information
@akrambek
akrambek authored Dec 20, 2024
1 parent 3d9e10e commit 67b81e4
Show file tree
Hide file tree
Showing 13 changed files with 19 additions and 17 deletions.
2 changes: 1 addition & 1 deletion ...vity/zilla/specs/binding/risingwave/streams/effective/show.tables.with.newline/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ read advised zilla:flush ${pgsql:flushEx()
.name("Name")
.tableOid(0)
.index(0)
.typeOid(701)
.typeOid(1043)
.length(8)
.modifier(-1)
.format("TEXT")
Expand Down
2 changes: 1 addition & 1 deletion ...vity/zilla/specs/binding/risingwave/streams/effective/show.tables.with.newline/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ write advise zilla:flush ${pgsql:flushEx()
.name("Name")
.tableOid(0)
.index(0)
.typeOid(701)
.typeOid(1043)
.length(8)
.modifier(-1)
.format("TEXT")
Expand Down
4 changes: 2 additions & 2 deletions ...ipts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand All @@ -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")
Expand Down
4 changes: 2 additions & 2 deletions ...ipts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.ztables/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand All @@ -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")
Expand Down
4 changes: 2 additions & 2 deletions ...ripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand All @@ -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")
Expand Down
4 changes: 2 additions & 2 deletions ...ripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/show.zviews/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand All @@ -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")
Expand Down
2 changes: 1 addition & 1 deletion ...aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.tables.with.newline/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ read advised zilla:flush ${pgsql:flushEx()
.name("Name")
.tableOid(0)
.index(0)
.typeOid(701)
.typeOid(1043)
.length(8)
.modifier(-1)
.format("TEXT")
Expand Down
2 changes: 1 addition & 1 deletion ...aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.tables.with.newline/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ write advise zilla:flush ${pgsql:flushEx()
.name("Name")
.tableOid(0)
.index(0)
.typeOid(701)
.typeOid(1043)
.length(8)
.modifier(-1)
.format("TEXT")
Expand Down
2 changes: 1 addition & 1 deletion .../scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down
2 changes: 1 addition & 1 deletion .../scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.ztables/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down
2 changes: 1 addition & 1 deletion ...n/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down
2 changes: 1 addition & 1 deletion ...n/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/show.zviews/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down
4 changes: 3 additions & 1 deletion .../io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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 VARCHAR_TYPE_OID = 1043;

private static final String POSTGRES_USER = "postgres\u0000";
private static final String DEFAULT_USER = "default\u0000";

Expand Down Expand Up @@ -828,7 +830,7 @@ public void doDescription(
.name("%s\u0000".formatted(name))
.tableOid(0)
.index((short) 0)
.typeOid(701)
.typeOid(VARCHAR_TYPE_OID)
.length((short) name.length())
.modifier(-1)
.format(f -> f.set(PgsqlFormat.TEXT))
Expand Down

0 comments on commit 67b81e4

Please sign in to comment.