c++ - 将结果存储在 C++ 中的 Map 中，然后对其进行迭代，然后打印出来？

Question

我已经开始为 Cassandra 使用 C++ libcql 库。我正在尝试使用 C++ 和 libcql 库从 Cassandra 检索数据。

每当我使用 cqlsh 进入命令行并像这样选择时 -

 select records from profile_user where user_id = '1';

我总是在 cql 命令行上得到以下输出，其中 records 列实际上是一个 map，其中键是 e1 并且值为 HELLO。同样，键是 e2，值是 HELLO。当我在 CQL 中创建表时，我创建了记录作为 map ，因为我使用了 CQL 的集合功能..

 records
--------------------------------
 {'e1': 'HELLO', 'e2': 'HELLO'}

现在来到 C++ 世界-

现在我正尝试从 C++ libcql 库中检索相同的东西...我将在 C++ 中运行上面相同的选择查询，我想返回一个包含 的 map >e1, e2 作为键 和 HELLO 作为映射中的值...可以用 C++ 实现吗？

/**
 * This method will retrieve the data from Cassandra..
 * And then call print_rows method to print it out on the console
 */
void get_attributes(string id){
    try{

        // some code

        //Connection open
        connection_open();

        execute_query("USE testks;");

        //this will give me the result back of the select query
        cql_result_t& result = execute_query("select * from profile_user where key ='"+id+"';");

        // and this is printing it out on the console
        print_rows(result);

        // some code
    } catch (int e){
        // some code here
    }
}

下面是运行我的 C++ 程序后在控制台上打印结果的方法 -

/**
 * This method prints out the result on the console..    *
 *
 */
void print_rows(cql::cql_result_t& result) {
    while (result.next()) {
        for (size_t i = 0; i < result.column_count(); ++i) {
            cql::cql_byte_t* data = NULL;
            cql::cql_int_t size = 0;
            result.get_data(i, &data, size);
            std::cout.write(reinterpret_cast<char*>(data), size);
            std::cout << " | ";
        }
        std::cout << std::endl;
    }
}

运行上述 C++ 程序后，我在控制台上看到的结果是这样的 -

e1HELLOe2HELLO |

但我正在寻找的是 - 将结果存储在 C++ 的 Map 中，这样键应该是 Map 中的 e1 和 e2.. 以及值因为它们应该是 HELLO 在同一个 Map 中...然后迭代 Map 并在 C++ 中打印出结果？这可能与我当前的代码有关吗？

如果是，任何人都可以提供一个简单的例子吗？谢谢...

我想这基本上是一个 C++ 问题..只需检索数据并将其放入 map ...但我面临的问题是我的背景完全是 Java，所以很难弄清楚如何这样做...

Answer 1

我不知道 libcql 并且找不到任何文档。查看 cql_result_t 的 header 表示有函数可以确定有多少列以及如何访问它们。看样子，你只是复制了demo example，似乎不是一个特别好的demo。我将从改进 print_result() 函数开始，使其看起来像下面这样，然后看看我会得到什么。我的猜测 是您从查询中获得了一个“ map ”类型，您将需要了解如何通过挖掘它们的 header 来提取和使用相应的表示(除非某处有一些文档)。下面的代码仅提取了一些类型，并且主要打印了它需要处理相应类型的处理(假设它实际编译):

void print_result(cql::cql_result_t& result)
{
    std::size_t const columns(result.column_count());
    while (result.next()) {
        for (std::size_t column(0); column != columns; ++column) {
            cql::cql_column_type_enum type;
            if (result.column_type(column, type)) {
                switch (type) {
                case cql::CQL_COLUMN_TYPE_CUSTOM:
                    std::cout << "todo: process custom type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_ASCII:
                    std::cout << "todo: process ascii type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_BIGINT:
                    std::cout << "todo: process bigint type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_BLOB:
                    std::cout << "todo: process blob type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_BOOLEAN:
                    std::cout << "todo: process boolean type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_COUNTER:
                    std::cout << "todo: process counter type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_DECIMAL:
                    std::cout << "todo: process decimal type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_DOUBLE: {
                    double value;
                    if (result.get_double(column, value)) {
                        std::cout << "column=" << column << " "
                                  << "double=" << value << "\n";
                    }
                    else {
                        std::cout << "failed to extract double for column "
                                  << column << "\n";
                    }
                    break;
                case cql::CQL_COLUMN_TYPE_FLOAT: {
                    float value;
                    if (result.get_float(column, value)) {
                        std::cout << "column=" << column << " "
                                  << "float=" << value << "\n";
                    }
                    else {
                        std::cout << "failed to extract float for column "
                                  << column << "\n";
                    }
                    break;
                case cql::CQL_COLUMN_TYPE_INT: {
                    int value;
                    if (result.get_int(column, value)) {
                        std::cout << "column=" << column << " "
                                  << "int=" << value << "\n";
                    }
                    else {
                        std::cout << "failed to extract int for column "
                                  << column << "\n";
                    }
                    break;
                case cql::CQL_COLUMN_TYPE_TEXT: {
                    std::string value;
                    if (result.get_string(column, value)) {
                        std::cout << "column=" << column << " "
                                  << "text='" << value << "'\n";
                    }
                    else {
                        std::cout << "failed to extract text for column "
                                  << column << "\n";
                    }
                    break;
                case cql::CQL_COLUMN_TYPE_TIMESTAMP:
                    std::cout << "todo: process timestamp type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_UUID:
                    std::cout << "todo: process uiid type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_VARCHAR:
                    std::cout << "todo: process varchar type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_VARINT:
                    std::cout << "todo: process varint type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_TIMEUUID:
                    std::cout << "todo: process timeuuid type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_INET:
                    std::cout << "todo: process inet type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_LIST:
                    std::cout << "todo: process list type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_MAP:
                    std::cout << "todo: process map type\n";
                    break;
                case cql::CQL_COLUMN_TYPE_SET:
                    std::cout << "todo: process set type\n";
                    break;
                }
            }
        }
    }
}