Skip to content

Commit f12e6ed

Browse files
committed
fixes
1 parent ebf741e commit f12e6ed

File tree

1 file changed

+3
-1
lines changed
  • cassandra-driver/src/main/java/org/jnosql/diana/cassandra/column

1 file changed

+3
-1
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818

1919
import com.datastax.driver.core.CodecRegistry;
20+
import com.datastax.driver.core.DataType;
2021
import com.datastax.driver.core.Session;
2122
import com.datastax.driver.core.TypeCodec;
2223
import com.datastax.driver.core.UDTValue;
@@ -97,7 +98,8 @@ private static Object getUdtValue(UserType userType, Iterable elements) {
9798
if (Column.class.isInstance(object)) {
9899
Column column = Column.class.cast(object);
99100
Object convert = ValueUtil.convert(column.getValue());
100-
TypeCodec<Object> objectTypeCodec = CodecRegistry.DEFAULT_INSTANCE.codecFor(convert);
101+
DataType fieldType = userType.getFieldType(column.getName());
102+
TypeCodec<Object> objectTypeCodec = CodecRegistry.DEFAULT_INSTANCE.codecFor(fieldType);
101103
udtValue.set(getName(column), convert, objectTypeCodec);
102104

103105
} else if (Iterable.class.isInstance(object)) {

0 commit comments

Comments
 (0)