VPF::QSqlDatabase::addDatabase + Mysql = не thread safe - Форум программистов

null56

Дата 15.9.2009, 12:01 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 721
Регистрация: 19.3.2008

Репутация: 6
Всего: 12

В чем суть:
Если судить по ассистенту, то функция добавления нового подключения функцией addDatabase

Цитата

QSqlDatabase QSqlDatabase::addDatabase ( const QString & type, const QString & connectionName = QLatin1String( defaultConnection ) ) [static]
................
Note: This function is thread-safe.

Что имею:
при использовании небезопасных (моих) оберток, при многонитевом обращении иногда получаю от мускула

Цитата

Can't connect to MySQL server on '127.0.0.1' (111)

Я использую 4 потока, три из которых идут через обертку, и одна без неё.... вот при использовании 4 потока, такое иногда происходит...
Раньше у меня были три потока идущие без оберток, подобная ошибка появлялась, пока не засунул эту функцию в статическую нитебезопасную обертку

Вопрос: Почему так получается, если функция треадсейфная? или же это зависит от настроек мускула?

Заранее спасибо

Добавлено @ 12:04
сейчас буду пробовать засунуть всё в общую нитебезопасную обертку

Код


    /** уникальное имя соединения с бд */
    QByteArray
    uniqueConnectionName(bool * pOk, int tryNum)
    {
        unsigned int thread_id = (unsigned int)QThread ::currentThreadId();
        QByteArray connection_name;
        *pOk = false;
        do {
            connection_name += QString :: number(thread_id++);
            qDebug("Connection name: %s", connection_name.constData());
            if (!QSqlDatabase :: contains(connection_name)) { *pOk = true; break; }
        } while (tryNum--);
        return connection_name;
    }

    /** создать новое подключение к базе */
    QSqlDatabase
    createSqlConnection(bool * pOk, int tryNum, const QString & rDriverName)
    {
        /* extern QMutex g_SqlAccess; - глобальная в соответсвующем пространстве*/
        QMutexLocker lock(&g_SqlAccess);
        QByteArray connection_name = uniqueConnectionName(pOk, tryNum);
        QSqlDatabase data_base;
        if (*pOk)
            { data_base = QSqlDatabase :: addDatabase(rDriverName, connection_name); }
        return data_base;
    }

Это сообщение отредактировал(а) null56 - 15.9.2009, 15:20

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| С/С++: Кроссплатформенное программирование, Qt/Gtk+/wxWidgets \| Следующая тема »