Examples of com.datastax.driver.core.RegularStatement

com.datastax.driver.core.RegularStatement
A regular (non-prepared and non batched) CQL statement.
This class represents a query string along with query options (and optionally binary values, see {@code getValues}). It can be extended but {@link SimpleStatement}is provided as a simple implementation to build a {@code RegularStatement} directlyfrom its query string.

        //When
        final IterateFromPartition<String> start = builder.withPartitionComponents("a");


        start.limit(3).iterator();


        final RegularStatement whereClause = start.properties.generateWhereClauseForSelect(select);


        //Then
        assertThat(whereClause.getQueryString()).isEqualTo("SELECT * FROM table WHERE id=:id LIMIT :limitSize;");
        assertThat(start.properties.getBoundValues()).containsSequence("a", 3);
        assertThat(start.properties.fetchSizeO.isPresent()).isFalse();
    }

View Full Code Here

        //When
        final IterateFromPartition<String> start = builder.withPartitionComponents("a");


        start.limit(3).orderByAscending().async().iterator(11);


        final RegularStatement whereClause = start.properties.generateWhereClauseForSelect(select);


        //Then
        assertThat(whereClause.getQueryString()).isEqualTo("SELECT * FROM table WHERE id=:id ORDER BY col1 ASC LIMIT :limitSize;");
        assertThat(start.properties.getBoundValues()).containsSequence("a", 3);
        assertThat(start.properties.fetchSizeO.get()).isEqualTo(11);
    }

View Full Code Here

        //When
        final IterateWithPartition<String> start = builder.withPartitionComponentsIN("a", "b");


        start.fromClusterings("A", "B").limit(3).iterator(10);


        final RegularStatement whereClause = start.properties.generateWhereClauseForSelect(select);


        //Then
        assertThat(whereClause.getQueryString()).isEqualTo("SELECT * FROM table WHERE bucket IN :partitionComponentsIn AND (col1,col2)>=(:col1,:col2) LIMIT :limitSize;");
        assertThat(start.properties.getBoundValues()).containsSequence(asList("a", "b"), "A", "B", 3);
        assertThat(start.properties.fetchSizeO.get()).isEqualTo(10);
    }

View Full Code Here

        //When
        final IterateFromPartition<String> start = builder.withPartitionComponents("a");


        start.limit(3).iterator(120);


        final RegularStatement whereClause = start.properties.generateWhereClauseForSelect(select);


        //Then
        assertThat(whereClause.getQueryString()).isEqualTo("SELECT * FROM table WHERE id=:id LIMIT :limitSize;");
        assertThat(start.properties.getBoundValues()).containsSequence("a", 3);
        assertThat(start.properties.fetchSizeO.get()).isEqualTo(120);
    }

View Full Code Here

        //When
        final IterateFromPartition<String> start = builder.withPartitionComponents("a");


        start.limit(3).async().iterator(120);


        final RegularStatement whereClause = start.properties.generateWhereClauseForSelect(select);


        //Then
        assertThat(whereClause.getQueryString()).isEqualTo("SELECT * FROM table WHERE id=:id LIMIT :limitSize;");
        assertThat(start.properties.getBoundValues()).containsSequence("a", 3);
        assertThat(start.properties.fetchSizeO.get()).isEqualTo(120);
    }

View Full Code Here

        //When
        final IterateFromPartition<String> start = builder.withPartitionComponents("a");


        start.limit(3).iteratorWithMatching("A", "B");


        final RegularStatement whereClause = start.properties.generateWhereClauseForSelect(select);


        //Then
        assertThat(whereClause.getQueryString()).isEqualTo("SELECT * FROM table WHERE id=:id AND col1=:col1 AND col2=:col2 LIMIT :limitSize;");
        assertThat(start.properties.getBoundValues()).containsSequence("a", "A", "B", 3);
        assertThat(start.properties.fetchSizeO.isPresent()).isFalse();
    }

View Full Code Here

        //When
        final IterateFromPartition<String> start = builder.withPartitionComponents("a");


        start.limit(3).async().iteratorWithMatching("A", "B");


        final RegularStatement whereClause = start.properties.generateWhereClauseForSelect(select);


        //Then
        assertThat(whereClause.getQueryString()).isEqualTo("SELECT * FROM table WHERE id=:id AND col1=:col1 AND col2=:col2 LIMIT :limitSize;");
        assertThat(start.properties.getBoundValues()).containsSequence("a", "A", "B", 3);
        assertThat(start.properties.fetchSizeO.isPresent()).isFalse();
    }

View Full Code Here

        //When
        final IterateFromPartition<String> start = builder.withPartitionComponents("a");


        start.limit(3).orderByAscending().iteratorWithMatchingAndBatchSize(123, "A", "B");


        final RegularStatement whereClause = start.properties.generateWhereClauseForSelect(select);


        //Then
        assertThat(whereClause.getQueryString()).isEqualTo("SELECT * FROM table WHERE id=:id AND col1=:col1 AND col2=:col2 ORDER BY col1 ASC LIMIT :limitSize;");
        assertThat(start.properties.getBoundValues()).containsSequence("a", "A", "B", 3);
        assertThat(start.properties.fetchSizeO.get()).isEqualTo(123);
    }

View Full Code Here

        //When
        final IterateFromPartition<String> start = builder.withPartitionComponents("a");


        start.limit(3).orderByDescending().async().iteratorWithMatchingAndBatchSize(123, "A", "B");


        final RegularStatement whereClause = start.properties.generateWhereClauseForSelect(select);


        //Then
        assertThat(whereClause.getQueryString()).isEqualTo("SELECT * FROM table WHERE id=:id AND col1=:col1 AND col2=:col2 ORDER BY col1 DESC LIMIT :limitSize;");
        assertThat(start.properties.getBoundValues()).containsSequence("a", "A", "B", 3);
        assertThat(start.properties.fetchSizeO.get()).isEqualTo(123);
    }

View Full Code Here

        final List<Object> clusteringKeysIN = Arrays.<Object>asList(PropertyType.LIST, PropertyType.SET);


        final Select select = select().from("table");


        //When
        final RegularStatement statement = SliceQueryProperties.builder(meta, ClusteredEntity.class, SliceType.SELECT)
                .partitionKeysName(asList("id", "bucket")).lastPartitionKeyName("year")
                .partitionKeys(partitionKeys).andPartitionKeysIn(partitionKeysIN)
                .withClusteringKeysName(asList("date")).lastClusteringKeyName("type")
                .withClusteringKeys(clusteringKeys).andClusteringKeysIn(clusteringKeysIN)
                .ordering(OrderingMode.DESCENDING)
                .limit(12)
                .generateWhereClauseForSelect(select);


        //Then
        assertThat(statement.getQueryString()).isEqualTo("SELECT * FROM table WHERE id=:id AND bucket=:bucket AND year IN :partitionComponentsIn AND date=:date AND type IN :clusteringKeysIn ORDER BY date DESC LIMIT :limitSize;");
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of com.datastax.driver.core.RegularStatement

com.datastax.driver.core.querybuilder.Batch

com.netflix.astyanax.cql.reads.QueryGenCache

info.archinnov.achilles.internal.context.BatchingFlushContextTest

info.archinnov.achilles.internal.context.DaoContextTest

info.archinnov.achilles.internal.context.ImmediateFlushContextTest

info.archinnov.achilles.internal.metadata.holder.PropertyMetaStatementGeneratorTest

info.archinnov.achilles.internal.persistence.operations.TypedQueryValidatorTest

info.archinnov.achilles.internal.statement.prepared.PreparedStatementGenerator

info.archinnov.achilles.internal.statement.wrapper.NativeStatementWrapperTest

info.archinnov.achilles.internal.statement.wrapper.RegularStatementWrapperTest

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.