Skip to content

Commit 9178101

Browse files
committed
fixes in
1 parent 7f92be4 commit 9178101

File tree

3 files changed

+6
-8
lines changed

3 files changed

+6
-8
lines changed

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,6 @@
3030
import java.util.concurrent.ExecutorService;
3131
import java.util.concurrent.Executors;
3232

33-
import static java.lang.Boolean.FALSE;
34-
3533
class CassandraProperties {
3634

3735
private static final int DEFAULT_PORT = 9042;

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,12 +17,9 @@
1717
import com.datastax.oss.driver.api.core.ConsistencyLevel;
1818
import com.datastax.oss.driver.api.core.cql.ResultSet;
1919
import com.datastax.oss.driver.api.core.cql.SimpleStatement;
20-
import com.datastax.oss.driver.api.querybuilder.select.Select;
2120
import jakarta.nosql.column.ColumnEntity;
2221
import jakarta.nosql.column.ColumnQuery;
2322

24-
import java.util.ArrayList;
25-
import java.util.List;
2623
import java.util.Objects;
2724
import java.util.stream.Stream;
2825

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

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,8 @@
1414
*/
1515
package org.eclipse.jnosql.diana.cassandra.column;
1616

17+
import com.datastax.oss.driver.api.querybuilder.Literal;
18+
import com.datastax.oss.driver.api.querybuilder.QueryBuilder;
1719
import com.datastax.oss.driver.api.querybuilder.relation.Relation;
1820
import com.datastax.oss.driver.api.querybuilder.term.Term;
1921
import jakarta.nosql.Condition;
@@ -27,6 +29,7 @@
2729
import java.util.Collections;
2830
import java.util.List;
2931
import java.util.Objects;
32+
import java.util.stream.Collectors;
3033

3134
import static com.datastax.oss.driver.api.querybuilder.QueryBuilder.literal;
3235

@@ -67,7 +70,7 @@ private static void load(ColumnCondition columnCondition, List<Relation> relatio
6770
relations.add(Relation.column(QueryUtils.getName(column)).isLessThanOrEqualTo(getTerm(column)));
6871
return;
6972
case IN:
70-
relations.add(Relation.column(QueryUtils.getName(column)).in(literal(getIinValue(column.getValue()))));
73+
relations.add(Relation.column(QueryUtils.getName(column)).in(getIinValue(column.getValue())));
7174
return;
7275
case LIKE:
7376
relations.add(Relation.column(QueryUtils.getName(column)).like(getTerm(column)));
@@ -86,7 +89,7 @@ private static Term getTerm(Column column) {
8689
return literal(ValueUtil.convert(column.getValue()));
8790
}
8891

89-
private static Object[] getIinValue(Value value) {
90-
return ValueUtil.convertToList(value).toArray();
92+
private static Term[] getIinValue(Value value) {
93+
return ValueUtil.convertToList(value).stream().map(QueryBuilder::literal).toArray(Term[]::new);
9194
}
9295
}

0 commit comments

Comments
 (0)