К основному контенту

WiredTiger. Просто взгляд.[update]

Открыл для себя  WiredTiger. Говорят это очень крутой NoSql мотор, который начали использовать в MongoDb. Решил попробовать и я, для чего прям из примера написал программку.


    WT_CONNECTION *Volume1Connection;
    //    WT_CONNECTION *Volume2Connection;
    WT_CURSOR *cursor;
    WT_SESSION *session;
    const char *key, *value;
    int ret;

    if ((ret = wiredtiger_open("./Volume", NULL, "create", &Volume1Connection)) != 0 ||
            (ret = Volume1Connection->open_session(Volume1Connection, NULL, NULL, &session)) != 0)
    {
        fprintf(stderr, "Error connecting to %s: %s\n",
                ".", wiredtiger_strerror(ret));
    }

    ret = session->create(session, "table:access", "key_format=S,value_format=S");
    qDebug()<<ret;
    ret = session->open_cursor(session, "table:access", NULL, NULL, &cursor);

    QHash<QUuid, QUuid> TempArray;
    for(int i=0; i<10; i++)
        TempArray.insert(QUuid::createUuid(), QUuid::createUuid());


    QHashIterator<QUuid, QUuid> i(TempArray);
    while (i.hasNext())
    {
        i.next();
        qDebug()<< i.key() << ": " << i.value();

        cursor->set_key(cursor,  i.key().toString().remove('{').remove('}').toLocal8Bit().data());        /* Insert a record. */
        cursor->set_value(cursor,i.value().toString().remove('{').remove('}').toLocal8Bit().data());
        ret = cursor->insert(cursor);
    }

    ret = cursor->reset(cursor);            /* Restart the scan. */
    while ((ret = cursor->next(cursor)) == 0)
    {
        cursor->get_key(cursor, &key);
        cursor->get_value(cursor, &value);
        printf("Got record: %s : %s\n", key, value);
    }

    i.toFront();
    while (i.hasNext())
    {
        i.next();
        qDebug()<< i.key() << ": " << i.value();
        cursor->set_key(cursor, i.key().toString().remove('{').remove('}').toLocal8Bit().data());
        const char* val;
        if(cursor->search(cursor)==0)
        {
            cursor->get_value(cursor, &val);
            qDebug()<<"---- key"<<i.key()<<"value from base"<<val;
        }
        else
            qDebug()<<"key not found";
        //cursor->search()
    }

    cursor->close(cursor);
    ret = Volume1Connection->close(Volume1Connection, NULL);


    quit();

В результате прогона программки получаем в базе мусор. Я как-то к этому не привык. Да и не хочется верить в то, что мотор не работает.
Конечно это я где-то что-то делаю не так.
Кто знает! Кто пробовал! Подсобите!
_______________
Разобрался. Строки для передачи курсору надо много тщательней готовить принимая во внимание особенности api.
Должен отметить, что это очень интересный инструмент. И хоть я и готов даже говорить о замене существующего (пусть и неспешного) комфорта постгреса, но явно использовать в некоторых местах буду.
Ну а там, видно будет.

Популярные сообщения из этого блога

Надежды юношей питают.

Всем хорошо известна эта фраза. Считается, что она являет собой аналог известного афоризма Ф. Бекона: "Надежда - хороший завтрак, но плохой ужин".
История появления этой фразы в русском языке проследить не удается. Известно только, что она появилась в стихотворении Глеба Глинки.

Надежд сомнителен приют.
«Надежды юношей питают,
Отраду старцам подают»,
Но все же постепенно тают.

И, наконец, на склоне дней
Вдруг понимает человече
Тщету надежд, тщету идей...
«Иных уж нет, а те далече»,
Интересно отметить, что рассматриваемая фраза взята в кавычки. Конечно Глинка не мог не знать знаменитой оды Ломоносова "На день восшествия на престол Елисаветы".
Науки юношей питают,
Отраду старым подают,
В счастливой жизни украшают,
В несчастной случай берегут;
В домашних трудностях утеха
И в дальних странствах не помеха.
Науки пользуют везде,
Среди народов и в пустыне,
В градском шуму и наедине,
В покое сладки и в труде.
Но здесь вовсе не надежды, но науки. Искажение, результат творческой переработки, заб…

К вопросу об организации оркестратора кластера в деле бесшовного ввода новых версий Kalpa-системы.

Страшное дело - организация взаимодействия в большой системе взаимодействующих узлов.
Первое и основное дело, с каким придется столкнуться - реализация плавного, бесшовного обновления всей системы на новые версии. Причем делать это надо не дергая пользователей. Пусть они спокойно доработают свою сессию на старой версии. Для обеспечения такой плавности необходима одновременная работа как всего серверного хозяйства в старой версии, так и плавный ввод в работу версии новой.
Итак. В системе существует служба "SystemControl". Она отвечает:

За контроль топологии системы. Знает какие узлы существуют в системе и какие службы эти узлы обслуживают.Мониторит отказ отдельных узлов и перебалансировку топологии системы.Осуществляет плавное обновление системы.  Каждая служба (кроме слоя сервера приложений) имеет свой набор сетевых портов ожидания. Каждая версия использует только один из трех портов. SystemControl всегда знает расписание портов текущей и прошлой версии. Таким образом можно о…

Новости госмессенджеров.

«Развитие IT-технологий является приоритетом работы правительства Республики Крым. Наш президент в своём послании Федеральному собранию назвал развитие цифровой экономики вопросом национальной безопасности и технологической независимости России. Глава государства обратил особое внимание на риски, связанные с цифровыми технологиями, и необходимость защиты от киберугроз», — отметил Сергей Аксёнов.
Андрей Назаров уточнил, что свои разработки программисты могут представить на третьем ялтинском форуме в апреле следующего года. Отметим, что Назаров также занимает пост председателя правления Ялтинского международного экономического форума.
Госконтрактом с крымским правительством уже заинтересовались разработчики российского мессенджера Dialog, которые участвуют в конкурсе Института развития интернета на создание государственного мессенджера для федеральных чиновников.

«Мы готовы принять участие и в разработке закрытого безопасного мессенджера для крымских чиновников, в свете чего планируем про…