title: Mysql++ 使用
date: 2017-07-26 20:42
tags: [Mysql++]
categories: C++
原文地址 soundblog.top
Mysql++ 使用記錄
前言
最近因為要使用mysql 的c接口厉熟，查了好多資料發(fā)現(xiàn)網(wǎng)上關(guān)于mysql的c 資料是真的不多衡创。不過還好查到了一個Mysql++這個庫铭腕，可以方便我更好的進(jìn)行開發(fā)蜒程。但是即使這樣，其使用難度也比一般的Java和python接口要難得多目溉，因此非常有必要記錄一下這幾天查到的資料护戳，做一個簡單的總結(jié)看成。
Mysql ++ 連接
安裝
# http://tangentsoft.net/mysql++/，從官網(wǎng)下載穩(wěn)定版本mysql++-3.2.3.tar.gz
tar -zxvf mysql++-3.2.3.tar.gz
cd mysql++-3.2.3
./configure --prefix=/your/install/path
make
make install
原始連接方式
我們可以采取最原始的連接方式鹏秋，也比較簡單尊蚁。
include <mysql++.h>
#include <stdlib.h>
#include <stdio.h>
#include <string>
#include <iostream>
#include <typeinfo>
using namespace std;
using namespace mysqlpp;
#define DATEBASE_NAME "search"
#define DATEBASE_IP "localhost:3306"
#define DATEBASE_USERNAME "root"
#define DATEBASE_PWD "DeepLearning"
int main()
{
Connection conn(false);
if(conn.connect(DATEBASE_NAME, DATEBASE_IP, DATEBASE_USERNAME, DATEBASE_PWD))
cout << "connect success !!!" << endl;
Query query = conn.query();
char* sql = "select * from test";
query << sql;
return 0;
}
連接池使用
連接池這個概念在數(shù)據(jù)庫使用中常常會用到，對于一般的使用侣夷，對于數(shù)據(jù)庫的訪問不是太頻繁我們可以每次建立連接横朋，使用完就釋放連接。但是對于一個復(fù)雜的數(shù)據(jù)庫應(yīng)用百拓，情況就完全不同了琴锭，頻繁的建立、關(guān)閉連接衙传，會極大的減低系統(tǒng)的性能决帖，因為對于連接的使用成了系統(tǒng)性能的瓶頸。連接池的原理是先在內(nèi)部建立好很多連接粪牲，用戶使用的時候直接從連接池中獲取連接即可古瓤，用戶使用完再歸還連接，但是連接并沒有別斷開腺阳，而是為下一次使用做準(zhǔn)備落君。
- mysql++ 內(nèi)部已經(jīng)實現(xiàn)好連接池
mysql++-3.2.3/lib/cpool.cpp 這是源碼文件
virtual Connection* exchange(const Connection* pc); //將當(dāng)前連接斷開重新開啟一個連接
virtual Connection* grab(); //從連接池獲取一個連接，如果沒有創(chuàng)建一個
Connection* safe_grab(); //從連接池獲取一個可用的連接
virtual void release(const Connection* pc); //將一個連接置為未使用狀態(tài)
void shrink() //從連接池刪除未使用的連接
void remove(const Connection* pc) //從連接池中刪除指定連接
- 繼承mysqlpp::ConnectionPool 實現(xiàn)自己的連接池
class MysqlConnectPool : public mysqlpp::ConnectionPool
{
public:
MysqlConnectPool(std::string dbname,
std::string serverip,
std::string user,
std::string passwd,
int port,
std::string charset,
int max_size)
:m_dbname(dbname)
,m_server_ip(serverip)
,m_user(user)
,m_password(passwd)
,m_charset(charset)
,m_port(port)
{
m_max_size = max_size;
conns_in_use_ = 0;
m_max_idle_time = 300;
}
······
·····
//代碼太多亭引，暫時就不貼了绎速。。焙蚓。https://github.com/yqyao/MyGit/tree/master/mysql_c%2B%2B
這個github有
}
mysql++ API調(diào)用方式
- 輸入處理
#include <memory>
#include <iostream>
#include <fstream>
#include <vector>
# include "unistd.h"
#include "MysqlConnectPool.h"
std::shared_ptr<MysqlConnectPool> db_pool = nullptr;
std::string db_name = "search";
std::string db_ip = "localhost";
std::string db_user = "root";
std::string db_passwd = "DeepLearning";
int db_port = 3306;
std::string db_charset = "utf8";
int max_size = 10;
int BUFF_SIZE = 1024;
char buff[1024];
char* createTableFormat = "create table %s ;";
std::string getCreateString()
{
memset(buff, 0, BUFF_SIZE);
char* temp = "Student(id int, name varchar(20), status varchar(10))";
snprintf(buff, sizeof(buff), createTableFormat, temp);
std::string buffAsStdStr = buff;
return buffAsStdStr;
}
int main()
{
db_pool = std::make_shared<MysqlConnectPool>(db_name, db_ip, db_user, db_passwd, db_port, db_charset, max_size);
std::string createTablesql = getCreateString();
std::cout << "createTableFormat: " << createTablesql << std::endl;
//out:createTableFormat: create table Student(id int, name varchar(20), status varchar(10))
}
- 實際執(zhí)行過程
void createTable(std::string sql)
{
mysqlpp::ScopedConnection conn(*db_pool, false);
mysqlpp::Query query = conn->query();
query << sql;
mysqlpp::SimpleResult res = query.execute();
std::cout << res.info() << std::endl;
}
int main()
{
db_pool = std::make_shared<MysqlConnectPool>(db_name, db_ip, db_user, db_passwd, db_port, db_charset, max_size);
std::string createTablesql = getCreateString();
std::cout << "createTableFormat: " << createTablesql << std::endl;
createTablesql(createTablesql);
//out:createTableFormat: create table Student(id int, name varchar(20), status varchar(10))
}
因為select 操作涉及到數(shù)據(jù)取出纹冤，因此需要重點介紹
- search操作
表結(jié)構(gòu)為上一步介紹create所創(chuàng)建的結(jié)構(gòu)
std::string getSearchString()
{
memset(buff, 0, BUFF_SIZE);
char* status = "false";
snprintf(buff, sizeof(buff), searchFormat, status);
std::string buffAsStdStr = buff;
return buffAsStdStr;
}
void search(std::string sql)
{
//this scopedConnection will get the connection and release the connection to the connection pool after ~scopedConnection
mysqlpp::ScopedConnection conn(*db_pool, false);
mysqlpp::Query query = conn->query();
query << sql;
mysqlpp::StoreQueryResult ares = query.store();
std::cout << "ares.num_rows() = " << ares.num_rows() << std::endl;
for (size_t i = 0; i < ares.num_rows(); i++)
{
std::cout << "your data" << std::endl;
std::cout << "name: " << ares[i]["name"] << "\tid: " << ares[i]["id"] << "\tstatus: " << ares[i]["status"] << std::endl;
}
}
int main()
{
db_pool = std::make_shared<MysqlConnectPool>(db_name, db_ip, db_user, db_passwd, db_port, db_charset, max_size);
std::string searchSql = getSearchString();
std::cout << "searchFormat: " << searchSql << std::endl;
search(searchSql);
return 0;
}
注意事項
我們這里的使用的是Mysql++ 官方使用的scopedConnection 類自動獲取conn，同時利用析構(gòu)函數(shù)去release conn购公。我們也可以直接使用原始api去使用這個連接萌京。
int main()
{
db_pool = std::make_shared<MysqlConnectPool>(db_name, db_ip, db_user, db_passwd, db_port, db_charset, max_size);
const char* search = "select * from yyq";
mysqlpp::Connection* conn;
conn = db_pool->grab();
db_pool->release(conn); //將conn放回連接池
db_pool->remove(conn); //將conn從連接池去除
std::cout << db_pool->getSize() << std::endl; //當(dāng)前連接池連接個數(shù)
}
這種方式調(diào)用連接池的時候需要注意，每次使用完conn連接后需要手動的去release這個連接宏浩，不然連接池會重復(fù)的建立新連接知残，達(dá)不到我們需要的效果。
