Linux下C++/C连接MySQL数据库(二)

--返回数据的SQL

引：

返回数据的SQL是指通过查询语句从数据库中取出满足条件的数据记录

从MySQL数据库值哦功能检索数据有4个步骤：

1）发出查询

2）检索数据

3）处理数据

4）整理所需要的数据

用mysql_query()发出查询，检索数据可以使用mysql_store_result()或mysql_use_result()，取决与怎样检索数据，接着是调用mysql_fetch_row()来处理数据，最后，还必须调用mysql_free_result()以允许MySQL进行必要的整理工作。

1、一次提取所有数据

[cpp] view plaincopyprint?

1. MYSQL_RES *mysql_store_result(MYSQL * connection);
2. //成功返回结构体指针，失败返回NULL
3. my_ulonglong mysql_num_row(MYSQL_RES * result);
4. //减速实际返回的行数
5. MYSQL_ROW mysql_fetch_row(MYSQL_RES * result);
6. //从mysql_store_result()中得到结果的结构体，并从中检索单个行，当没有更多的数据，或者出错时，返回NULL
7. void mysql_free_result(MYSQL_RES * result);
8. //使mySQL数据库整理分配的对象，关闭连接.

MYSQL_RES *mysql_store_result(MYSQL * connection);
//成功返回结构体指针，失败返回NULL
	my_ulonglong mysql_num_row(MYSQL_RES * result);
//减速实际返回的行数
	MYSQL_ROW mysql_fetch_row(MYSQL_RES * result);
//从mysql_store_result()中得到结果的结构体，并从中检索单个行，当没有更多的数据，或者出错时，返回NULL
	void mysql_free_result(MYSQL_RES * result);
//使mySQL数据库整理分配的对象，关闭连接.

示例：

[cpp] view plaincopyprint?

1. #include <iostream>
2. #include <fstream>
3. #include <cstdlib>
4. #include <mysql/mysql.h>
5. using namespace std;
6. void mysql_err_function(MYSQL * connection);
7. int main()
8. {
9. MYSQL * connection;
10. connection = mysql_init(NULL);
11. if (!connection)
12. {
13. mysql_err_function(connection);
14. }
15. connection = mysql_real_connect(connection,"localhost","root","123456","test",0,NULL,0);
16. if (!connection)
17. {
18. mysql_err_function(connection);
19. }
20. cout << "Connection to MySQL Server is Success..." << endl;
21. string query;
22. getline(cin,query);
23. int res = mysql_query(connection,query.c_str());
24. if (res)
25. {
26. mysql_err_function(connection);
27. }
28. MYSQL_RES * my_res = mysql_store_result(connection);
29. cout << "Retrieved " << mysql_num_rows(my_res) << "rows" << endl;
30. MYSQL_ROW sqlrow;
31. while ((sqlrow = mysql_fetch_row(my_res)))
32. {
33. cout << "Fetched data..." << endl;
34. }
35. mysql_free_result(my_res);
36. mysql_close(connection);
37. cout << "Connection to MySQL Server is closed!" << endl;
38. return 0;
39. }
40. void mysql_err_function(MYSQL * connection)
41. {
42. if (mysql_errno(connection))
43. {
44. cout << "Error " << mysql_errno(connection) << " : "
45. << mysql_error(connection) << endl;
46. exit(-1);
47. }
48. }

#include <iostream>
#include <fstream>
#include <cstdlib>
#include <mysql/mysql.h>
using namespace std;

void mysql_err_function(MYSQL * connection);

int main()
{
	MYSQL * connection;
	connection = mysql_init(NULL);

	if (!connection)
	{
		mysql_err_function(connection);
	}

    connection = mysql_real_connect(connection,"localhost","root","123456","test",0,NULL,0);

	if (!connection)
	{
		mysql_err_function(connection);
	}

	cout << "Connection to MySQL Server is Success..." << endl;
	string query;
	getline(cin,query);

	int res = mysql_query(connection,query.c_str());
	if (res)
	{
		mysql_err_function(connection);
	}

    MYSQL_RES * my_res = mysql_store_result(connection);

	cout << "Retrieved " << mysql_num_rows(my_res) << "rows" << endl;

	MYSQL_ROW sqlrow;
	while ((sqlrow = mysql_fetch_row(my_res)))
	{
		cout << "Fetched data..." << endl;
	}
	mysql_free_result(my_res);

	mysql_close(connection);
	cout << "Connection to MySQL Server is closed!" << endl;

	return 0;
}

void mysql_err_function(MYSQL * connection)
{
	if (mysql_errno(connection))
	{
		cout << "Error " << mysql_errno(connection) << " : "
		<< mysql_error(connection) << endl;

		exit(-1);
	}
}

2、一次提取一行数据，用于处理了大量的数据集

[cpp] view plaincopyprint?

1. MYSQL_RES *mysql_use_result(MYSQL * connection);
2. //成功返回结果集，失败返回NULL

MYSQL_RES *mysql_use_result(MYSQL * connection);
//成功返回结果集，失败返回NULL 

一次取全部数据增加了网络负载，增加了时延，但是可以保证数据的完整性。

示例：

[cpp] view plaincopyprint?

1. #include <iostream>
2. #include <cstdlib>
3. #include <mysql/mysql.h>
4. using namespace std;
5. void mysql_err_function(MYSQL * connection);
6. int main()
7. {
8. MYSQL * connection;
9. connection = mysql_init(NULL);
10. if (mysql_real_connect(connection,"localhost","root","123456","test",0,NULL,0))
11. {
12. cout << "Connection to MySQL Server is Succeed..." << endl;
13. string query;
14. getline(cin,query);
15. int res = mysql_query(connection,query.c_str());
16. if (res)
17. {
18. mysql_err_function(connection);//mysql_err_function()实现代码参考上例
19. }
20. else
21. {
22. MYSQL_RES * my_res = mysql_use_result(connection);
23. if (my_res)
24. {
25. MYSQL_ROW sqlrow;
26. while ((sqlrow = mysql_fetch_row(my_res)))
27. {
28. cout << "Fetching the Data..." << endl;
29. }
30. mysql_free_result(my_res);
31. }
32. else
33. {
34. mysql_err_function(connection);
35. }
36. }
37. mysql_close(connection);
38. cout << "Connection to MySQL Server is Closed!" << endl;
39. }
40. else
41. {
42. mysql_err_function(connection);
43. }
44. }