mysqlconnection.cpp

#include "mysqlconnection.h"
#include "stdio.h"
#include <QDebug>

MySQLConnection::MySQLConnection(QString server_, int port_, QString user_,
                                 QString password_, QString database_, QObject *parent) :
    QObject(parent),
    server(server_),
    port(port_),
    user(user_),
    password(password_),
    database(database_)
{

#ifdef USE_LIB_MYSQL_CLIENT
    MYSQL_RES *res;
    MYSQL_ROW row;

    /* Connect to database */
    if (!mysql_real_connect(conn,
                            server.toLocal8Bit().data(),
                            user.toLocal8Bit().data(),
                            password.toLocal8Bit().data(),
                            database.toLocal8Bit().data(),
                            port,
                            NULL,
                            0)
            ) {

        fprintf(stderr, "%s, %s, %s, %s, %d",
                server.toLocal8Bit().data(),
                user.toLocal8Bit().data(),
                password.toLocal8Bit().data(),
                database.toLocal8Bit().data(),
                port,
                NULL
                );
        qDebug() << "MySQL connection error:"<< mysql_error(conn);
       exit(1);
    }
    /* send SQL query */
    if (mysql_query(conn, "select @@datadir")) {
       fprintf(stderr, "%s\n", mysql_error(conn));
       exit(1);
    }
    res = mysql_use_result(conn);
    while ((row = mysql_fetch_row(res)) != NULL)
       datadir = row[0];
    mysql_free_result(res);

    /* send SQL query */
    if (mysql_query(conn, "select @@version")) {
       fprintf(stderr, "%s\n", mysql_error(conn));
       exit(1);
    }
    res = mysql_use_result(conn);
    while ((row = mysql_fetch_row(res)) != NULL)
       version = row[0];
    mysql_free_result(res);

    qDebug() << "Got mysql parameters from connection:" << datadir << version;
#else
    datadir = "/var/lib/mysql";
    version = "5.5.32";
#endif
}


MySQLConnection::~MySQLConnection() {
    /* close connection */
#ifdef USE_LIB_MYSQL_CLIENT
    mysql_close(conn);
#endif
}

void MySQLConnection::lock_all_tables() {
    qDebug() << "Locking all tables";
#ifdef USE_LIB_MYSQL_CLIENT
    if (mysql_query(conn, "FLUSH TABLES WITH READ LOCK")) {
       fprintf(stderr, "%s\n", mysql_error(conn));
       exit(1);
    }
#endif
    emit all_tables_locked();
}


void MySQLConnection::unlock_all_tables() {
    qDebug() << "Unlocking all tables";
#ifdef USE_LIB_MYSQL_CLIENT
    if (mysql_query(conn, "UNLOCK TABLES")) {
       fprintf(stderr, "%s\n", mysql_error(conn));
       exit(1);
    }
#endif
    emit all_tables_unlocked();
}