Connection.cpp

#include "Connection.h"
#include "public.h"
#include <iostream>

Connection::Connection()
{
    _conn = mysql_init(nullptr);
    if (_conn == nullptr)
    {
        std::cerr << "mysql_init() failed\n";
        exit(EXIT_FAILURE);
    }
}

Connection::~Connection()
{
    if (_conn != nullptr)
        mysql_close(_conn);
}

bool Connection::connect(std::string ip, unsigned short port, std::string user, std::string password,
                         std::string dbname)
{
    MYSQL *p = mysql_real_connect(_conn, ip.c_str(), user.c_str(),
                                  password.c_str(), dbname.c_str(), port, nullptr, 0);
    return p != nullptr;
}
// 更新操作 insert、delete、update
bool Connection::update(std::string sql)
{
    if (mysql_query(_conn, sql.c_str()))
    {
        LOG("更新失败:" + sql);
        return false;
    }
    return true;
}
// 查询操作 select
MYSQL_RES *Connection::query(std::string sql)
{
    if (mysql_query(_conn, sql.c_str()))
    {
        LOG("查询失败:" + sql);
        return nullptr;
    }
    return mysql_use_result(_conn);
}

void Connection::refreshAliveTime(){
    _alivetime=clock();
}

clock_t Connection::getAliveTime() const
{
    return clock()-_alivetime;
}