MT7688学习笔记（5）——OpenWrt下MySQL的使用

一、安装mysql

1.1 准备资源

下载tar包到目录dl/

mysql-5.1.73.tar.gz

链接：https://pan.baidu.com/s/1HEAotvd_8SM4IEr03-DeRw 密码：1yd5

ncurses-5.9.tar.gz

链接：https://pan.baidu.com/s/1rLgoKY9BLGEplIeI8rCjuQ 密码：c7wp

1.2 编译安装

1.cd /work/openwrt-hiwooya-stable-master/

2.make menuconfig

搜索mysql，找到后打上“*”号

mysql-server的附属包有：

• libmysqlclient
• libncursesw
• mysql-server
• uclibcxx
• libreadline

打上“*”之后开始编译。

编译成功后烧进路由器，运行路由器看到/usr/bin下有mysqld这个服务，说明我们已经成功编译mysql进去了。

1.3 编译报错

Package mysql-server is missing dependencies for the following libraries:
libncurses.so.5

未解决。。。

二、配置mysql

2.1 修改存放位置

修改配置文件/etc/my.conf，找到

datadir            =/mnt/data/mysql
tmpdir             =/mnt/data/tmp

更改为你想存放数据库的地方：

datadir             =/mnt/sda3/data/mysql     #将数据库放置到U盘对应分区上存储
tmpdir              =/mnt/sda3/data/tmp       #将数据库临时文件夹存放到U盘对应分区上

2.2 修改数据库的绑定地址

找到bind-address属性

bind-address        =127.0.0.1

更改为：

bind-address        =0.0.0.0

修改的目的：允许远程访问。

三、初始化及启动mysql

3.1 初始化mysql

mysql_install_db  --force

3.2 启动mysql

/etc/init.d/mysqld start

3.3 更改root密码

mysqladmin -u root password "1234"

3.4 关闭mysqld服务

killall mysqld

四、登录mysql

mysql -u root -p

五、调用mysql API

官方文档：https://dev.mysql.com/doc/refman/5.7/en/c-api.html

5.1 头文件

#include <mysql/mysql.h>

5.1 登录MySQL

5.1.1 mysql_init

MYSQL *mysql_init(MYSQL * mysql);

• 用途：获取或初始化MYSQL结构
• 参数：mysql：为NULL，则分配一个（返回其指针）。或按照传入的结构指针进行初始化。
• 结果：若为NULL表示出错。

5.1.2 mysql_options

int mysql_options(MYSQL *mysql, enum mysql_option option, const char *arg);

• 用途：可用于设置额外的连接选项，并影响连接的行为。一次设置一个，可多次调用该函数来设置数个选项。
  应在mysql_init()之后、以及mysql_connect()或mysql_real_connect()之前调用mysql_options()。
• 结果：该函数成功时返回0。如果使用了未知选项，返回非0值。

5.1.3 mysql_real_connect

MYSQL * STDCALL mysql_real_connect(MYSQL *mysql, 
                                const char *host,   //MySQL的IP，远程登录输入远程登录的IP地址
                                const char *user,   //登录用户
                                const char *passwd, //登录密码
                                const char *db,     //使用的数据库名称
                                unsigned int port,  //MySQL端口
                                const char *unix_socket,    //是否使用socket机制登录，NULL：否
                                unsigned long clientflag);  //连接标志，通常为0

• 用途：与数据库建立连接
• 参数：host：该值必须是主机名或IP地址。如果“host”是NULL或字符串"localhost"，连接将被视为与本地主机的连接。
  user：参数包含用户的MySQL登录ID。如果“user”是NULL或空字符串""，用户将被视为当前用户。在UNIX环境下，它是当前的登录名。
  passwd：参数包含用户的密码。如果“passwd”是NULL，仅会对该用户的（拥有1个空密码字段的）用户表中的条目进行匹配检查。
  db：是数据库名称。如果db为NULL，连接会将默认的数据库设为该值。
  port：若不是0，其值将用作TCP/IP连接的端口号。
  unix_socket：若不是NULL，该字符串描述了应使用的套接字或命名管道。
  client_flag：的值通常为0。
• 结果：成功返回*mysql指针，失败返回NULL。

5.1.4 登录数据库代码示例

/**************** 
*SQLBase.h 
*****************/  
class CSQLBase
{
public:
	CSQLBase(string strHost = "127.0.0.1", string strUser = "root", string strPwd = "1234", string strDb = "project");
	virtual ~CSQLBase();

	bool connect(string strHost = "127.0.0.1", string strUser = "root", string strPwd = "1234", string strDb = "project");
	void close(void) ;
	bool query(string strSql) const;
	bool fetchRow(void (*func)(char *row[], void *pAgr), void *pAgr) const;
	
protected:

private:
	MYSQL *m_pMysql;
	string m_strHost;
	string m_strUser;
	string m_strPassword;
	string m_strDatabase;
};

/**************** 
*SQLBase.cpp
*****************/  
#include "SQLBase.h"

CSQLBase::CSQLBase(string strHost, string strUser, string strPwd, string strDb)
{
	this->m_pMysql = mysql_init(nullptr);

	if(this->m_pMysql)
	{
		this->connect(strHost, strUser, strPwd, strDb);
	}
}
CSQLBase::~CSQLBase()
{
	this->close();
}
bool CSQLBase::connect(string strHost, string strUser, string strPwd, string strDb)
{
	this->m_strHost = strHost;
	this->m_strUser = strUser;
	this->m_strPassword = strPwd;
	this->m_strDatabase = strDb;
	if(mysql_real_connect(this->m_pMysql, strHost.c_str(), strUser.c_str(), strPwd.c_str(), strDb.c_str(), 0, nullptr, 0) == nullptr)
	{
		return false;
	}
	mysql_set_character_set(this->m_pMysql, "utf8");
	return true;
}
void CSQLBase::close(void)
{
	if(this->m_pMysql)
	{
		mysql_close(this->m_pMysql);
	}
}

5.2 操作MySQL

5.2.1 mysql_query

int STDCALL mysql_query(MYSQL *mysql,   //MySQL操作结构体
                        const char *q); //操作命令

• 用途：执行由“Null终结的字符串”查询指向的SQL查询。正常情况下，字符串必须包含1条SQL语句，而且不应为语句添加终结分号（‘;’）或“\g”。如果允许多语句执行，字符串可包含多条由分号隔开的语句。
• 结果：成功返回0，失败返回1。

5.2.2 mysql_error

const char *mysql_error(MYSQL *mysql);

• 用途：返回上次调用的MySQL函数的错误消息。

5.2.3 mysql_affected_rows

int mysql_affected_rows(MYSQL *mysql);

• 用途：返回上次UPDATE更改的行数，上次DELETE删除的行数，或上次INSERT语句插入的行数。对于UPDATE、DELETE或INSERT语句，可在mysql_query()后立刻调用。对于SELECT语句，mysql_affected_rows()的工作方式与mysql_num_rows()类似。
• 结果：大于0的整数表明受影响或检索的行数。“0”表示UPDATE语句未更新记录，在查询中没有与WHERE匹配的行，或未执行查询。“-1”表示查询返回错误。

5.2.4 操作数据库代码示例

try
    {
        …………………

        string sql = "SELECT * from zx_users;";
        if (mysql_query(&mysql, sql.c_str()))
        {   
            string err_string = mysql_error(&mysql);

            if(err_string.empty())
                throw string("MySQL query is error!");
            else
                throw err_string;
        }
        ………………
    }
    catch (string &error_msg)
    {
        cout << error_msg << endl;
    }
    catch (...)
    {
        cout << "MySQL operation is error!" << endl;
    }

    mysql_close(&mysql);

5.3 关闭MySQL

5.3.1 mysql_close

void mysql_close(MYSQL *connection);

• 用途：关闭MySQL数据库。

5.4 读取MySQL数据

5.4.1 mysql_use_result

MYSQL_RES *mysql_use_result(MYSQL *mysql);

• 用途：对于成功检索数据的每个查询（SELECT、SHOW、DESCRIBE、EXPLAIN），必须调用mysql_store_result()或mysql_use_result()。
  mysql_use_result()将初始化结果集检索，但并不像mysql_store_result()那样将结果集实际读取到客户端。它必须通过对mysql_fetch_row()的调用，对每一行分别进行检索。这将直接从服务器读取结果，而不会将其保存在临时表或本地缓冲区内，与mysql_store_result()相比，速度更快而且使用的内存也更少。客户端仅为当前行和通信缓冲区分配内存，分配的内存可增加到max_allowed_packet字节。
  使用mysql_use_result()时，必须执行mysql_fetch_row()，直至返回NULL值，否则，未获取的行将作为下一个检索的一部分返回。

5.4.2 mysql_store_result（获取命令结果）

MYSQL_RES *mysql_store_result(MYSQL *mysql);

• 用途：mysql_store_result()将查询的全部结果读取到客户端，分配1个MYSQL_RES结构，并将结果置于该结构中。
  如果查询未返回结果集，mysql_store_result()将返回Null指针（例如，如果查询是INSERT语句）。
  如果读取结果集失败，mysql_store_result()还会返回Null指针。通过检查mysql_error()是否返回非空字符串，mysql_errno()是否返回非0值，或mysql_field_count()是否返回0，可以检查是否出现了错误。
  如果未返回行，将返回空的结果集。（空结果集设置不同于作为返回值的空指针）。
  一旦调用了mysql_store_result()并获得了不是Null指针的结果，可调用mysql_num_rows()来找出结果集中的行数。
  可以调用mysql_fetch_row()来获取结果集中的行，或调用mysql_row_seek()和mysql_row_tell()来获取或设置结果集中的当前行位置。
  一旦完成了对结果集的操作，必须调用mysql_free_result()。

5.4.3 mysql_fetch_row（读取数据函数）

MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);

• 用途：检索结果集的下一行。在mysql_store_result()之后使用时，如果没有要检索的行，mysql_fetch_row()返回NULL。在mysql_use_result()之后使用时，如果没有要检索的行或出现了错误，mysql_fetch_row()返回NULL。

5.4.4 mysql_free_result（释放结果函数）

MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);

• 用途：仅需要在考虑到返回很大的结果集时会占用多少内存时调用。在脚本结束后所有关联的内存都会被自动释放。

5.4.5 读取数据库数据代码示例

try
    {       
…………………………………

//MySQL命令
        string sql = "SELECT * from zx_users;";
        if (mysql_query(&mysql, sql.c_str()))
        {   
            string err_string = mysql_error(&mysql);

            if(err_string.empty())
                throw string("MySQL query is error!");
            else
                throw err_string;
        }
        cout << "MySQL : " << sql << endl;

        MYSQL_RES *result = mysql_store_result(&mysql);
        if (!result)
            throw string("MySQL not result!");
        //获取字段数量
        int num_fields = mysql_num_fields(result);
        if(0 == num_fields)
            throw string("MySQL fields number is 0!");
        //获取字段名
        MYSQL_FIELD *fields = mysql_fetch_fields(result);
        if (!fields)
            throw string("MySQL fields fetch is error!");

        for (int i = 0; i < num_fields; i++)
        {
            cout << " " << fields[i].name;
        }
        cout << endl;

        while (MYSQL_ROW row = mysql_fetch_row(result)) //获取整条数据内容
        {
            for (int i = 0; i < num_fields; i++)
            {
                if (NULL == row[i])
                {
                    cout << " NULL";
                }
                else
                {
                    cout << " " << row[i];
                }   
            }
            cout << endl;
        }

        mysql_free_result(result);

        cout << "MySQL is OK." << endl;
    }
    catch (string &error_msg)
    {
        cout << error_msg << endl;
    }
    catch (...)
    {
        cout << "MySQL operation is error!" << endl;
    }

---