用c/c++编写一个封装链接mysql并查询返回结果的dll，供c#使用，现在就差返回了，求高手指导怎么返回结果
发布网友
发布时间：2022-04-08 20:50
共4个回答
懂视网
时间：2022-04-09 01:11
头文件 my_sql.h
1 #ifndef MY_SQL_H
2 #define MY_SQL_H
3
4 #include <mysql.h>
5 #include <iostream>
6 #include <string>
7 #include <iomanip>
8
9 class My_sql
10 {
11 public:
12 My_sql(); //初始化API、初始化结构、设置字符集、连接数据库
13 ~My_sql(); //释放内存、关闭服务器连接、结束服务器库、结束API库
14 unsigned row_count(); //返回集中的行数
15 unsigned field_count(); //返回集中的列数
16 friend std::ostream & operator <<(std::ostream &out, My_sql &sql);
17 //通过std::ostream输出列名、结果集
18 friend std::istream & operator >>(std::istream &in, My_sql &sql);
19 //通过std::istream输入执行SQL语句，并保存结果集地址至成员变量result
20 // friend My_sql & operator >>(const std::string &q, My_sql &sql);
21 //通过std::string输入执行SQL语句 ，并保存结果集地址至成员变量result
22 friend My_sql & operator <<(My_sql &sql, const std::string &q);
23 //通过std::string输入执行SQL语句 ，并保存结果集地址至成员变量result
24
25 protected:
26 bool query(const std::string &q); //执行SQL语句，保存完整的结果集地址至成员变量result
27 My_sql & display_field_name(std::ostream &out = std::cout, int setw_n = 16); //输出列名
28 My_sql & display_result(std::ostream &out = std::cout, int setw_n = 16); //输出结果集
29 MYSQL mysql; //对象
30 MYSQL_RES *result = NULL; //结果集
31 MYSQL_FIELD *field = NULL; //列
32 MYSQL_ROW row; //行
33 };
34
35 #endif
实现文件 my_sql.cpp
1 #include "my_sql.h"
2
3 My_sql::My_sql()
4 {
5 mysql_library_init( NULL, 0, 0 ); //初始化MySQL C API库
6 mysql_init( &mysql ); //获取或初始化MYSQL结构。
7 mysql_options( &mysql, MYSQL_SET_CHARSET_NAME, "utf8" ); //设置字符集
8 mysql_real_connect( &mysql, "localhost", "root", "password", "my_sql", 0, NULL, CLIENT_MULTI_STATEMENTS );
9 //连接数据库
10 }
11 My_sql::~My_sql()
12 {
13 mysql_free_result( result ); //释放结果集使用的内存
14 mysql_close( &mysql ); //关闭服务器连接
15 mysql_server_end(); //最终确定嵌入式服务器库
16 mysql_library_end(); //最终确定MySQL C API库
17 }
18 bool My_sql::query(const std::string &q)
19 {
20 result = NULL;
21 mysql_query( &mysql, q.c_str() ); //执行指定为“以Null终结的字符串”的SQL查询。
22 result = mysql_store_result( &mysql ); //检索完整的结果集至客户端
23 if ( NULL == result ) {
24 std::cerr << "Query Error!";
25 return false;
26 }
27 return true;
28 }
29
30 unsigned My_sql::row_count()
31 {
32 return mysql_num_rows( result ); //返回集中的行数
33 }
34 unsigned My_sql::field_count()
35 {
36 return mysql_num_fields( result ); //返回集中的列数
37 }
38
39 My_sql & My_sql::display_field_name(std::ostream &out, int setw_n)
40 {
41 for ( unsigned int i = 0; i < field_count(); ++i ) {
42 out << std::setw(setw_n) << ( mysql_fetch_field_direct( result, i ) -> name );
43 //给定字段编号，返回表字段的类型。输出列名
44 }
45 out << std::endl;
46 return *this;
47 }
48
49 My_sql & My_sql::display_result(std::ostream &out, int setw_n)
50 {
51 while( row = mysql_fetch_row( result ) ) //从结果集中获取下一行
52 {
53 for(int i = 0; i < field_count(); ++i )
54 {
55 if ( NULL == row[i]) {
56 out << std::setw(setw_n) << "(NULL)";
57 }
58 else {
59 out << std::setw(setw_n) << row[i];
60 }
61 }
62 out << std::endl;
63 }
64 return *this;
65 }
66
67 std::ostream & operator <<(std::ostream &out, My_sql &sql)
68 {
69 sql.display_field_name(out).display_result(out);
70 //输出列名和结果集
71
72 return out;
73 }
74
75 std::istream & operator >>(std::istream &in, My_sql &sql)
76 {
77 std::string q;
78 std::getline(in, q); //输入整行
79 if ( !sql.query(q) ) {
80 exit(1);
81 }
82 return in;
83 }
84
85 //My_sql & operator >>(const std::string &q, My_sql &sql)
86 //{
87 // if ( !sql.query(q) ) {
88 // exit(1);
89 // }
90 // return sql;
91 //}
92
93 My_sql & operator <<(My_sql &sql, const std::string &q)
94 {
95 if ( !sql.query(q) ) {
96 exit(1);
97 }
98 return sql;
99 }
调用实例 main.cpp
1 #include <iostream>
2 #include "my_sql.h"
3
4 using std::cin;
5 using std::cout;
6
7 int main(int argc, char* argv[])
8 {
9 My_sql sql;
10 sql << "SELECT * FROM my_table";
11 cout << sql;
12 cin >> sql;
13 cout << sql;
14 return 0;
15 }
MySQL的C++简单封装
标签：
热心网友
时间：2022-04-08 22:19
热心网友
时间：2022-04-08 23:37
追答在C#中调用查询的结果就行了
热心网友
时间：2022-04-09 01:12
追答1、几十万条数据，建议分页查询，每次返回一定数量的数据，不然速度会很慢
2、返回数组没有什么问题
3、直接在c#中操作数据库，更方便，建议linq;
