Skip to content

Commit 141786c

Browse files
committed
adds query condition
1 parent b69ebd7 commit 141786c

File tree

1 file changed

+6
-1
lines changed
  • cassandra-driver/src/main/java/org/eclipse/jnosql/communication/cassandra/column

1 file changed

+6
-1
lines changed

cassandra-driver/src/main/java/org/eclipse/jnosql/communication/cassandra/column/QueryUtils.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import com.datastax.oss.driver.api.core.metadata.schema.KeyspaceMetadata;
2525
import com.datastax.oss.driver.api.core.metadata.schema.TableMetadata;
2626
import com.datastax.oss.driver.api.core.type.DataType;
27+
import com.datastax.oss.driver.api.core.type.SetType;
2728
import com.datastax.oss.driver.api.core.type.UserDefinedType;
2829
import com.datastax.oss.driver.api.core.type.codec.CodecNotFoundException;
2930
import com.datastax.oss.driver.api.core.type.codec.TypeCodec;
@@ -145,7 +146,11 @@ private static Object getUdtValue(UserDefinedType userType, Iterable elements, D
145146
}
146147
DataType fieldType = userType.getFieldTypes().get(index);
147148
TypeCodec<Object> objectTypeCodec = CodecRegistry.DEFAULT.codecFor(fieldType);
148-
udtValue.set(getName(column), convert, objectTypeCodec);
149+
if (fieldType instanceof SetType) {
150+
udtValue.set(getName(column), new HashSet<Object>((Collection<?>) convert), objectTypeCodec);
151+
} else {
152+
udtValue.set(getName(column), convert, objectTypeCodec);
153+
}
149154

150155
} else if (Iterable.class.isInstance(object)) {
151156
udtValues.add(getUdtValue(userType, Iterable.class.cast(Iterable.class.cast(object)), type));

0 commit comments

Comments
 (0)