C API 連接MySQL及批量插入

CMySQLMgr.h：

#ifndef _CMYSQLMGR_H_
#define _CMYSQLMGR_H_

#include <iostream>
#include "mysql.h"

using namespace std;

class CMySQLMgr
{
public:
        CMySQLMgr();
        ~CMySQLMgr();

        bool Connect(const char * sHost, const char * sUser, const char * sPwd, const char * sDbName, const char * sPort);
        void CloseConnect();

        bool excute(const char * sQuery);

        MYSQL * GetpMysql();

private:
        MYSQL * m_pMysql;
};

#endif

　　

CMySQLMgr.cpp：

#include "CMySQLMgr.h"

CMySQLMgr::CMySQLMgr()
{
        m_pMysql = NULL;
}

CMySQLMgr::~CMySQLMgr()
{

}

bool CMySQLMgr::Connect( const char * sHost, const char * sUser, const char * sPwd, const char * sDbName, const char * sPort )
{
        bool bReturn = true;
        do
        {
                CloseConnect();
                m_pMysql = mysql_init(NULL);
                if (!m_pMysql)
                {
                        bReturn = false;
                        //can write log
                        break;
                }
				
				//參數設置
				char optvalue = 6;
				mysql_options(m_pMysql, MYSQL_OPT_CONNECT_TIMEOUT, (char*)&optvalue);
				optvalue = 1;
				mysql_options(m_pMysql, MYSQL_OPT_RECONNECT, (char*)&optvalue);
				optvalue = 2;
				mysql_options(m_pMysql, MYSQL_OPT_READ_TIMEOUT, (char*)&optvalue);
				
                if (!mysql_real_connect(m_pMysql, sHost, sUser, sPwd, sDbName, atoi(sPort), NULL, 0) )
                {
                        bReturn = false;
                        //can write log
                        cout << "mysql error:" << mysql_error(m_pMysql);
                        break;
                }
        } while (0);

        return bReturn;
}

void CMySQLMgr::CloseConnect()
{
        if (m_pMysql)
        {
                mysql_close(m_pMysql);
        }
}

bool CMySQLMgr::excute( const char * sQuery )
{
        bool bReturn = true;
        try
        {
                if (0 != mysql_query(m_pMysql, sQuery))
                {
                        bReturn = false;
                        cout << "mysql error:" << mysql_error(m_pMysql);
                        //can write log
                }
        }
        catch (std::exception &e)
        {
                cout << "exception:" << e.what() << endl;
        }
        catch (...)
        {
                cout << "Unknown exception." << endl;
        }

        return bReturn;
}

MYSQL * CMySQLMgr::GetpMysql()
{
        if (m_pMysql)
        {
                return m_pMysql;
        }
}

 

main.cpp：

#include <iostream>
#include <stdio.h>
#include "CMySQLMgr.h"
using namespace std;

int main()
{
	CMySQLMgr mysql;
	bool bRet = mysql.Connect("172.16.8.110", "root", "123456", "scistock", "3306");

	char buf[1024*2] = {0};

	const char * sSql = "select * from calcgsdataflash where gscode = 'ZTJB' ";
	bRet = mysql.excute(sSql);
	if (!bRet)
	{
		cout << "sSql:" << sSql << " excute error" << endl;
	}

	MYSQL_RES *res;
	MYSQL_ROW row;
	MYSQL_FIELD *fields;
	res = mysql_store_result(mysql.GetpMysql());
	if (res)
	{
		int nFields = mysql_num_fields(res);
		fields = mysql_fetch_fields(res);
	
		while ((row = mysql_fetch_row(res)))
		{
			string gpcode;
			int ymd = 0;
			int hms = 0;
			float f10 = 0;
			for (int j = 0; j < nFields; j++)
			{
				if (row[j])
				{
					if (strncmp(fields[j].name, "gpcode", strlen("gpcode")) == 0)
					{
						gpcode = row[j];
					}	
					else if (strncmp(fields[j].name, "ymd", strlen("ymd")) == 0)
					{
						ymd = atoi(row[j]);
					}
					else if (strncmp(fields[j].name, "hms", strlen("hms")) == 0)
					{
						hms = atoi(row[j]);
						int hour = hms / 3600;
						int minute = hms / 60 % 60;
						int second = hms % 60;
						hms = hour * 10000 + minute * 100 + second;
					}
					else if (strncmp(fields[j].name, "f10", strlen("f10")) == 0)
					{
						f10 = atoi(row[j]);
					}
				}
			}

			sprintf(buf, "update calcgsdataflash set hms = %d WHERE gscode = 'ZTJB' AND ymd = %d AND gpcode = '%s' AND f10 = %f", hms, ymd, gpcode.c_str(), f10);
			cout << "sSql:" << buf << endl;
			bool bRet = mysql.excute(buf);
			if (!bRet)
			{
				cout << "sSql:" << buf << " excute error" << endl;
			}
		}
		mysql_free_result(res);
	}
	mysql.CloseConnect();
	return 0;
}

　

MySQL官網（https://www.mysql.com/）

Api 連接庫下載地址（https://dev.mysql.com/downloads/connector/c/）

 

Windows ：

　　1.從官網下載Windows的對應版本的連接庫。

　　　　

 

　　2.解壓 1 中下載的壓縮包

　　　　　

　　3.vs 項目中加入 2 中庫文件目錄下的 include文件夾、lib文件夾下的 libmysql.lib。

　　　　（將 libmysql.dll 拷貝至可執行程序目錄下）

　　　　項目配置（Debug or Release、Win32 or x64）要與下載的庫版本保持一致。

　　　　若 Release 模式下需要斷點調試，參見：http://www.cnblogs.com/SZxiaochun/p/6928854.html

 　　　　

 

Linux：

　　1.從官網下載 Linux 對應版本的連接庫

　　　　

　　2.安裝庫

　　　　1.如果下載的是壓縮包

　　　　　　

　　　　　　解壓之后

　　　　　　　　sudo cp -r include/ /usr/include/mysql/ 

　　　　　　　　sudo cp -r lib/ /usr/lib64/mysql/

　　　　2.如果下載的是 .rpm 文件，直接安裝

　　　　　　　　sudo rpm -ivh mysql-connector-c-devel-6.1.11-1.el7.x86_64.rpm （rpm 命令的用法參見：http://www.cnblogs.com/SZxiaochun/p/7718606.html）

　　　　3.makefile 引用安裝的庫

　　　　　　1.靜態庫 libmysqlclient.a

　　　　　　　　　

　　　　　　2.動態庫 libmysqlclient.so （如果安裝之后沒有 libmysqlclient.so ，只有 libmysqlclient.so.18.0.0，就鏈接一下 ln libmysqlclient.so.18.0.0 libmysqlclient.so ，或者重命名也行）

　　　　　　　　　

 

 

批量插入：

//InnoDB表引擎下關閉mysql自動事務提交可以大大提高數據插入的效率，這是因為如果需要插入1000條數據，    mysql會自動發起（提交）1000次的數據寫入請求，如果把autocommit關閉掉，通過程序來控制，只要一 次commit就可以搞定。

#define WRITE_ONCE_COUNT  1000  //設一個宏，表示多少條數據提交一次

int count = 0;            //設一個計數值

mysql_autocommit(mysql,0);//關閉自動提交

sprintf(buf,"insert into dxjl_infobase(Date,gpcode,Type) values(%d,'%s',%d)",nDate,codes,1);

ASC2UTF8(buf,buf,sizeof(buf));//轉編碼，將ASC轉為UTF8  以便數據庫可以識別sql語句

int iSuccess = mysql_query(mysql,buf);
if(iSuccess !=0)
{
    printf("mysql_query:%s\r\n",mysql_error(mysql));
}
else
{
    count ++;
}
if(WRITE_ONCE_COUNT == count)//每WRITE_ONCE_COUNT條數據提交一次
{
    mysql_commit(mysql);
    count = 0;
}
出了循環之后加個判斷，避免最后一次循環數據未達到WRITE_ONCE_COUNT，無法commit提交寫庫：
    if（0 < count）
    {
        mysql_commit(mysql);
    }

autocommit是事務，==1時是立即提交，==0之后遇到commit或rollback才提交。