1 #ifndef __MYMYSQL_H__
 2 #define __MYMYSQL_H__
 3 #include <WinSock2.h>
 4 #include <mysql.h>
 5 #pragma comment(lib,"libmysql.lib")
 6 #define SZCHARSIZE 100
 7 typedef struct _tagMysqlInfo
 8 {
 9     char host[SZCHARSIZE];    //主机
10      char user[SZCHARSIZE];    //用户名
11      char passwd[SZCHARSIZE];    //密码
12      char db[SZCHARSIZE];    //数据库
13      UINT port;            //端口号
14      char unix_socket[SZCHARSIZE];    //如果unix_socket不是NULL，该字符串描述了应使用的套接字或命名管道。注意，“host”参数决定了连接的类型。
15      DWORD client_flag;    // client_flag的值通常为0
16 }MYSQLINFO,*PMYSQLINFO;
17 class CMyMysql
18 {
19 public:
20     CMyMysql(void);
21     BOOL connect(const MYSQLINFO);    //连接成功返回true 失败返回false
22     BOOL query(const char*);            //查询mysql语句
23     my_ulonglong GetresultLine();                //获取查询到的行数
24     MYSQL* GetMysqlPtr();            //获取mysql指针
25     MYSQL_RES* GetMysqlresPtr();    //获取mysqlres指针
26     ~CMyMysql(void);
27 private:
28     MYSQL* m_mYsqlPtr;    //mysql 指针
29     MYSQL_RES* m_mYsqlres;    //mysql 结果集指针
30 };
31 #endif //__MYMYSQL_H__

 1 #include "MyMysql.h"
 2
 3 CMyMysql::CMyMysql(void)
 4     :m_mYsqlPtr(NULL)
 5 {
 6     m_mYsqlPtr = mysql_init(NULL);
 7 }
 8
 9
10 CMyMysql::~CMyMysql(void)
11 {
12     if (m_mYsqlPtr)
13         mysql_close(m_mYsqlPtr);
14     if (m_mYsqlres)
15         mysql_free_result(m_mYsqlres);
16 }
17 BOOL CMyMysql::connect(const MYSQLINFO mysqlInfo)
18 {
19     if(!mysql_real_connect(m_mYsqlPtr,mysqlInfo.host,mysqlInfo.user,mysqlInfo.passwd,mysqlInfo.db,mysqlInfo.port,mysqlInfo.unix_socket,mysqlInfo.client_flag))
20         return FALSE;
21     else
22         return TRUE;
23 }
24 BOOL CMyMysql::query(const char* szSql)
25 {
26     if(!strlen(szSql))return FALSE;
27     if(mysql_query(m_mYsqlPtr,szSql))
28         return FALSE;
29     else
30         return TRUE;
31 }
32 my_ulonglong CMyMysql::GetresultLine()
33 {
34     m_mYsqlres = mysql_store_result(m_mYsqlPtr);
35     if(!m_mYsqlres)return NULL;
36     return mysql_num_rows(m_mYsqlres);
37 }
38 MYSQL* CMyMysql::GetMysqlPtr()
39 {
40     return m_mYsqlPtr;
41 }
42 MYSQL_RES* CMyMysql::GetMysqlresPtr()
43 {
44     return m_mYsqlres;
45 }

 1 void CMysqlDemoDlg::OnBnClickedButton1()
 2 {
 3     CMyMysql * mYSQL = new CMyMysql();
 4     MYSQLINFO mysqlInfo;
 5     ZeroMemory(&mysqlInfo,sizeof(MYSQLINFO));
 6     CopyMemory(mysqlInfo.host,"localhost",_tcslen("localhost"));
 7     CopyMemory(mysqlInfo.user,"root",_tcslen("root"));
 8     CopyMemory(mysqlInfo.passwd,"123456",_tcslen("123456"));
 9     mysqlInfo.port =3306;
10     if (!mYSQL->connect(mysqlInfo))
11     {
12         AfxMessageBox("连接数据库失败！\r\n");
13         delete mYSQL;
14         return ;
15     }
16     if (mysql_set_character_set(mYSQL->GetMysqlPtr(),"gbk"))
17     {
18         AfxMessageBox("设置默认字符失败！\r\n");
19         delete mYSQL;
20
21     }
22     if (mysql_select_db(mYSQL->GetMysqlPtr(),"ecshop"))
23     {
24         AfxMessageBox("选择数据库失败！\r\n");
25         delete mYSQL;
26     }
27     if(!mYSQL->query("select * from ecs_admin_user;"))
28     {
29         AfxMessageBox("查询失败！\r\n");
30         delete mYSQL;
31     }
32     my_ulonglong Line = mYSQL->GetresultLine();
33     MYSQL_FIELD* fd = NULL;
34     CString str;
35     while (fd = mysql_fetch_field(mYSQL->GetMysqlresPtr()))
36     {
37         str+= fd->name;
38         str+="\r\n";
39     }
40     SetDlgItemText(IDC_EDIT1,str);
41     MYSQL_ROW  rows;
42     str = "";
43     UINT  listSize = mysql_num_fields(mYSQL->GetMysqlresPtr());
44     while(rows = mysql_fetch_row(mYSQL->GetMysqlresPtr()))
45     {
46         for (UINT i = 0;i<listSize;i++)
47         {
48             str+= rows[i];
49         }
50         str+="\r\n";
51     }
52     SetDlgItemText(IDC_EDIT2,str);
53     delete mYSQL;
54 }