官方文档
机器配置
机器环境：mac 10.14
mysql版本：8.0.4-rc，自行编译，编译步骤
mysql 存放路径：/Users/shiyibo/LNMP/mysql
IDE: CLion
目录划分：
| - main.cpp
| - myDb.h
| - MyDb.cpp
代码
/**
* file MyDb.h
*
* Created by shiyibo on 2018/12/21.
*/
#ifndef DB_MYDB_H
#define DB_MYDB_H
#include <string>
#include "/Users/shiyibo/LNMP/mysql/include/mysql.h"
using namespace std;
class MyDb {
public:
MyDb();
~MyDb();
/**
* 连接mysql
*
* @param host
* @param user
* @param pwd
* @param db_name
* @param port
* @return
*/
bool initDB(string host, string user,string pwd,string db_name, int port);
/**
* 执行sql语句
*
* @param sql
* @return
*/
bool exeSQL(string sql);
private:
/**
* 连接mysql句柄指针
*/
MYSQL *mysql;
/**
* 指向查询结果的指针
*/
MYSQL_RES *result;
/**
* 按行返回的查询信息
*/
MYSQL_ROW row;
};
#endif //DB_MYDB_H
/**
* file MyDb.cpp
* Created by shiyibo on 2018/12/21.
*/
#include <iostream>
#include <string>
#include "MyDb.h"
using namespace std;
/**
* 初始化数据库连接变量
*/
MyDb::MyDb()
{
mysql = mysql_init(NULL);
if(!mysql) {
cout<<"Error:"<<mysql_error(mysql);
exit(1);
}
}
/**
* 释放资源
*/
MyDb::~MyDb()
{
if(mysql) {
mysql_close(mysql);
}
}
/**
*
* @param host
* @param user
* @param passwd
* @param db_name
* @oaram port
* @return
*/
bool MyDb::initDB(std::string host, std::string user, std::string passwd, std::string db_name, int port = 3306)
{
mysql = mysql_real_connect(mysql, host.c_str(), user.c_str(), passwd.c_str(), db_name.c_str(), port, NULL, 0);
if(!mysql) {
cout << "Error: " << mysql_error(mysql);
exit(1);
}
return true;
}
/**
* 执行sql 语句
* @param sql
* @return
*/
bool MyDb::exeSQL(std::string sql)
{
//mysql_query()执行成功返回0,执行失败返回非0值。
if (mysql_query(mysql,sql.c_str())) {
cout<<"Query Error: "<<mysql_error(mysql);
return false;
}
result = mysql_store_result(mysql);
if (result) {
//获取结果集中总共的字段数，即列数
int num_fields = mysql_num_fields(result);
unsigned long long num_rows = mysql_num_rows(result);
for(unsigned long long i = 0; i < num_rows; i++) {
row = mysql_fetch_row(result);
if(!row) {
break;
}
for(int j=0;j<num_fields;j++) {
cout<<row[j]<<"\t\t";
}
cout<<endl;
}
} else {
//代表执行的是update,insert,delete类的非查询语句
if (mysql_field_count(mysql) == 0) {
// 返回update,insert,delete影响的行数
unsigned long long num_rows = mysql_affected_rows(mysql);
return num_rows;
} else {
cout << "Get result error: " << mysql_error(mysql);
return false;
}
}
return true;
}
#include <iostream>
#include "MyDb.h"
int main() {
// std::cout << "Hello, World!" << std::endl;
MyDb db;
string host = "127.0.0.1";
string user = "root";
string passwd = "password";
string dbName = "test";
int port = 3307;
cout<<"start\n";
//连接数据库
bool conn = db.initDB(host, user, passwd, dbName, port);
if (!conn) {
cout<<"connect fails\n";
}
cout<<"ok" <<endl;
//将用户信息添加到数据库
string sql = "INSERT account values(1, 'fengxin');";
db.exeSQL(sql);
sql = "INSERT account values(2, 'axin');";
db.exeSQL(sql);
//将所有用户信息读出，并输出。
sql = "SELECT * from account;";
db.exeSQL(sql);
return 0;
}
编译
g++ main.cpp MyDB.cpp -o main `mysql_config --cflags --libs`
运行
image.png
数据表
CREATE TABLE `account` (
`id` int(10) unsigned NOT NULL AUTO_INCREMENT,
`name` varchar(25) NOT NULL DEFAULT '',
PRIMARY KEY (`id`)
)
image.png
问题
- 运行时遇到如下报错
./main
dyld: Library not loaded: @rpath/libmysqlclient.21.dylib
Referenced from: /Users/shiyibo/CLionProjects/db/./main
Reason: image not found
Abort trap: 6
解决方案：
- 方案1，来源
1、关闭csrutil
2、找到mysql安装路径，建立软连接
sudo ln -s /usr/local/mysql/lib/libmysqlclient.21.dylib /usr/lib/libmysqlclient.21.dylib
效果: 原意是，建立一个从
/usr/lib/libmysqlclient.21.dylib到/usr/local/mysql/lib/libmysqlclient.21.dylib的软连；
环境中编译的地址为/Users/shiyibo/LNMP/mysql，默认的按照路径/usr/local/mysql/lib/libmysqlclient.21.dylib中没有这个目录；
换成了
sudo ln -s /Users/shiyibo/LNMP/mysql/lib/libmysqlclient.21.dylib /usr/lib/libmysqlclient21.dylib，重试，不管用；
- 方案2，来源
sudo ln -s /usr/local/mysql/lib/libmysqlclient.18.dylib/usr/lib/libmysqlclient.18.dylib
或
export DYLD_LIBRARY_PATH="$DYLD_LIBRARY_PATH:/usr/local/mysql/lib/"
使用第二种方案，可以成功编译，当然，路径也得换为
/Users/shiyibo/LNMP/mysql/lib
最后
好多年不写C系列，代码丑陋，生疏，敬请谅解！
