Skip to content

Commit 84e65fc

Browse files
committed
wip - fix failures
1 parent 664ab7f commit 84e65fc

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

client/trino-jdbc/src/main/java/io/trino/jdbc/AbstractTrinoResultSet.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -704,7 +704,7 @@ private static Object convertFromClientRepresentation(ClientTypeSignature column
704704
for (int i = 0; i < fields.size(); i++) {
705705
io.trino.client.RowField field = fields.get(i);
706706
ClientTypeSignatureParameter clientTypeSignatureParameter = typeArguments.get(i);
707-
verify(clientTypeSignatureParameter.getKind() == ClientTypeSignatureParameter.ParameterKind.NAMED_TYPE || clientTypeSignatureParameter.getKind() == ClientTypeSignatureParameter.ParameterKind.TYPE, "Not a NAMED_TYPE or TYPE: %s", clientTypeSignatureParameter);
707+
verify(clientTypeSignatureParameter.getKind() == ClientTypeSignatureParameter.ParameterKind.NAMED_TYPE, "Not a NAMED_TYPE or TYPE: %s", clientTypeSignatureParameter);
708708
verify(field.getName().equals(clientTypeSignatureParameter.getName()), "Name mismatch: %s, %s", field, clientTypeSignatureParameter);
709709
Object converted = convertFromClientRepresentation(clientTypeSignatureParameter.getTypeSignature(), field.getValue());
710710
builder.addField(field.getName(), converted);

core/trino-main/src/main/java/io/trino/server/protocol/ProtocolUtil.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -144,15 +144,15 @@ private static ClientTypeSignature toClientTypeSignature(TypeSignature signature
144144
}
145145

146146
return new ClientTypeSignature(signature.getBase(), signature.getParameters().stream()
147-
.map(parameter -> toClientTypeSignatureParameter(parameter, supportsParametricDateTime))
147+
.map(parameter -> toClientTypeSignatureParameter(signature.getBase(), parameter, supportsParametricDateTime))
148148
.collect(toImmutableList()));
149149
}
150150

151-
private static ClientTypeSignatureParameter toClientTypeSignatureParameter(TypeParameter parameter, boolean supportsParametricDateTime)
151+
private static ClientTypeSignatureParameter toClientTypeSignatureParameter(String base, TypeParameter parameter, boolean supportsParametricDateTime)
152152
{
153153
return switch (parameter) {
154154
case TypeParameter.Type(Optional<String> name, TypeSignature type) -> {
155-
if (name.isPresent()) {
155+
if (base.equalsIgnoreCase(ROW)) { // for backward compatibility with old clients,which expect NAMED_TYPE for row fields
156156
yield ClientTypeSignatureParameter.ofNamedType(new NamedClientTypeSignature(
157157
name.map(RowFieldName::new),
158158
toClientTypeSignature(type, supportsParametricDateTime)));

0 commit comments

Comments
 (0)