Connection.cpp

#include"Public.h"
#include"Connection.h"
#include<iostream>
#include<string>
#include<cstdio>
#include<mysql.h>
using namespace std;
Connection::Connection()
{
	_conn = mysql_init(nullptr);
}
Connection::~Connection()
{
	if (_conn != nullptr)
		mysql_close(_conn);
}
bool Connection::connect(string ip, unsigned short port, string username, string password, string dbname)
{
	MYSQL * P = mysql_real_connect(_conn, ip.c_str(), username.c_str(), password.c_str(), dbname.c_str(),
	port,nullptr,0);
	return P != nullptr;
}
bool Connection::update(string sql)
{
	if (mysql_query(_conn, sql.c_str()))
	{
		cout<<"error"<< mysql_error(_conn)<<"\n";
		LOG("¸üÐÂʧ°Ü£º"+ sql);
		mysql_error(_conn);
		return false;
	}
	return true;
}
MYSQL_RES* Connection::query(string sql)
{
	if (mysql_query(_conn, sql.c_str()))
	{
		LOG("¸üÐÂʧ°Ü£º" + sql);
		return nullptr;
	}
	return mysql_use_result(_conn);
}