Вставка в Cassandra через Thrift-клиент не работает после удаления строки через Cassandra-Cli - PullRequest
Новая
       0

Вставка в Cassandra через Thrift-клиент не работает после удаления строки через Cassandra-Cli

1 голос
/ 24 октября 2010

Я написал тест simpe, чтобы проверить мое собственное понимание экономичного интерфейса для Cassandra. Он просто вставляет строку в базу данных (используя пространство ключей и семейство столбцов, предварительно настроенное для установки cassandra), затем считывает ее из базы данных и сравнивает результаты. 

public class CassandraAPITest {
    @Test
    public void testCassandraAPI() throws Exception {
        TTransport tr = new TSocket("localhost", 9160);
        tr.open();
        Client client = new Cassandra.Client(new TBinaryProtocol(tr));
        String key = "123";
        byte[] value = { 52, 53, 54 };
        ColumnPath columnPath = new ColumnPath("Standard1");
        columnPath.setColumn("abc".getBytes("UTF8"));
        long timestamp = System.currentTimeMillis();

       client.insert("Keyspace1", key, columnPath, value, timestamp, ConsistencyLevel.ONE);

        SlicePredicate predicate = new SlicePredicate();
        SliceRange sliceRange = new SliceRange();
        sliceRange.setStart(new byte[0]);
        sliceRange.setFinish(new byte[0]);
        predicate.setSlice_range(sliceRange);

        List<ColumnOrSuperColumn> result = client.get_slice("Keyspace1", key, new ColumnParent("Standard1"), predicate, ConsistencyLevel.ONE);

        assertEquals(1, result.size());
        byte[] actual = result.get(0).column.value;
        assertArrayEquals(value, actual);

        // client.remove("Keyspace1", key, columnPath, System.currentTimeMillis(), ConsistencyLevel.ONE);

        tr.close();
    }
}

Этот тест работает нормально. Конечно, это оставляет ряд в базе данных. Я мог бы удалить строку в конце теста, раскомментировав приведенный выше оператор client.remove (это также работает нормально). Но вместо этого я попытался удалить строку через интерфейс командной строки: 

cassandra> connect localhost/9160                   
Connected to: "Test Cluster" on localhost/9160
cassandra> get Keyspace1.Standard1['123']
=> (column=616263, value=456, timestamp=1287909211506)
Returned 1 results.
cassandra> del Keyspace1.Standard1['123']   
row removed.
cassandra> get Keyspace1.Standard1['123']
Returned 0 results.

После этого тест не пройден. Кажется, что вставка строки в базу данных больше не действует, поэтому строка assertEquals (1, result.size ()) завершается ошибкой: 

java.lang.AssertionError: expected:<1> but was:<0>
    at org.junit.Assert.fail(Assert.java:91)
    at org.junit.Assert.failNotEquals(Assert.java:618)
    at org.junit.Assert.assertEquals(Assert.java:126)
    at org.junit.Assert.assertEquals(Assert.java:443)
    at org.junit.Assert.assertEquals(Assert.java:427)
    at test.package.CassandraAPITest.testCassandraAPI(CassandraAPITest.java:48)

Я не получаю никаких сообщений об ошибках (ни на клиенте, ни на сервере), и я понятия не имею, что может быть причиной проблемы.

1 Ответ

2 голосов
/ 24 октября 2010

Вы вставляете с разрешением в миллисекунды, но CLI (и другие клиенты высокого уровня) используют микросекунды.Итак, ваша вторая вставка в прошлом, по сравнению с удалением, поэтому Кассандра правильно ее игнорирует.

...