测试HectorSpringCassandra连接

Question

ERROR connection.HConnectionManager: Could not start connection pool for host <myhost:myport>

当然可以。但是我如何测试这种连接呢？

如果我以实用的方式（而不是通过spring上下文）定义连接，那么它就很清楚了，但是通过spring上下文就不太清楚如何测试它。

你能想出个主意吗？

Answer 1

由于我无法找到令人满意的答案，我决定务实地定义我的连接，并使用一个简单的查询：

private ColumnFamilyResult<String, String> readFromDb(Keyspace keyspace) {
ColumnFamilyTemplate<String, String> template = new ThriftColumnFamilyTemplate<String, String>(keyspace, tableName, StringSerializer.get(),
    StringSerializer.get());
// It doesn't matter if the column actually exists or not since we only check the
// connection. In case of connection failure an exception is thrown,
// else something comes back.
return template.queryColumns("some_column");
}

我的测试检查返回的对象是否为not null。

另一种有效的方法是：

public boolean isConnected() {
List<KeyspaceDefinition> keyspaces = null;
try {
    keyspaces = cluster.describeKeyspaces();
} catch (HectorException e) {
    return false;
}
return (!CollectionUtils.isEmpty(keyspaces));
}