c语言实现Mysql数据库访问

realtang

2. /*
3.   Name:         MySQLClientTest
4.   Author1:       Kip Warner (kip@zero47.com)
5.   Author2:      Modified By Tang Xu [email]tangxu.sh@gmail.com[/email]
6.   Date:         24/11/03 13:15, 20/05/2005
7.   Description:  Example to show usage of MySQL databases from client end.
8.                 I did not have much time. Sorry...
9. */
11. // Includes...
12. #include <MySQL/mysql.h>
13. #include <stdlib.h>
14. #include <stdio.h>
16. // Database name...
17. char        g_szHost[]          = "localhost";
18. UINT        g_unPort            = MYSQL_PORT;
19. char        g_szUserName[]      = "any";
20. char        g_szPassword[]      = "";
21. char        g_szDatabase[]      = "test";
22. char        g_szSQLStatement[]  = "SELECT * from table1";
24. // Entry point...
25. int main(int nArguments, char *pszArguments[])
26. {
27.     // Variables...
28.     MYSQL          *myDatabase      = NULL;
29.     MYSQL_RES           *myResult        = NULL;
30.     MYSQL_FIELD           *myField         = NULL;
31.     MYSQL_ROW            myRow           = NULL;
32.     UINT            unRecords       = 0;
33.     UINT            unFields        = 0;
34.     UINT            unIndex         = 0;
35.     UINT            unFieldIndex    = 0;
37.     // Initialize MySQL...
38.     myDatabase = mysql_init(NULL);
39.    
40.         // Failed...
41.         if(!myDatabase)
42.         {
43.             // Alert user...
44.             printf("] Error: Unable to initialize MySQL API...\n");
46.             // Cleanup, abort, terminate...
47.             mysql_close(myDatabase);
48.             getch();
49.             return 0;
50.         }
51.    
53.     // Connect to server and check for error...
54.     if(mysql_real_connect(myDatabase, g_szHost, g_szUserName, g_szPassword,
55.                           NULL, g_unPort, NULL, 0) < 0)
56.     {
57.         // Alert user...
58.         printf("] Error: Unable to connect to server...\n");
59.         printf("%s\n",mysql_error(myDatabase));
61.         // Cleanup, abort, terminate...
62.         mysql_close(myDatabase);
63.         getch();
64.         return 0;
65.     }
67.     // Select database in server and check for error...
68.     if(mysql_select_db(myDatabase, g_szDatabase) < 0)
69.     {
70.         // Alert user...
71.         printf("] Error: Unable to select database...\n");
72.         
73.         // Cleanup, abort, terminate...
74.         mysql_close(myDatabase);
75.         getch();
76.         return 0;
77.     }
79.     // Query database and check for error...
80.     if(mysql_query(myDatabase, g_szSQLStatement) != 0)
81.     {
82.         // Alert user...
83.         printf("] Error: Unable to execute query...\n");
84.         
85.         // Cleanup, abort, terminate...
86.         mysql_close(myDatabase);
87.         getch();
88.         return 0;
89.     }
91.     // Retrieve query result from server...
92.     myResult = mysql_store_result(myDatabase);
93.    
94.         // Failed...
95.         if(!myResult)
96.         {
97.             // Alert user...
98.             printf("] Error: Unable to retrieve result...\n");
99.             
100.             // Cleanup, abort, terminate...
101.             mysql_close(myDatabase);
102.             getch();
103.             return 0;        
104.         }
105.   
106.     // How many records were returned in the result set?
107.    
108.         // Calculate...
109.         unRecords = mysql_num_rows(myResult);
110.    
111.         // Alert user...
112.         printf("] Query: %d records found...\n", unRecords);
113.    
114.     // How many fields are present in a record?
115.         
116.         // Calculate...
117.         unFields = mysql_num_fields(myResult);
118.         
119.         // Alert user...
120.         printf("] Query: There are %d fields in each record...", unFields);
121.    
122.     // Output records...
123.     for(unIndex = 0; unIndex < unRecords; unIndex++)
124.     {
125.         // Fetch row from results...
126.         myRow = mysql_fetch_row(myResult);
128.         // Fetch fields from row...
129.         myField = mysql_fetch_fields(myResult);
131.         // Show record...
132.         printf("] Record: %d / %d\n", unIndex, unRecords);
134.         // Output all fields in this row...
135.         for(unFieldIndex = 0; unFieldIndex < unFields; unFieldIndex++)
136.         {
137.             // Output...
138.             printf("\n");
139.             if(unIndex ==0)            
140.                 printf("\t%s", myField[unFieldIndex].name);
141.             printf("\t%s",myRow[unFieldIndex]?(char *)myRow[unFieldIndex]:"");            
142.         }        
143.     }
144.    
145.     // Free result...
146.     mysql_free_result(myResult);
147.    
148.     // Close server connection...
149.     mysql_close(myDatabase);
150.     myDatabase = NULL;
151.    
152.     // Alert user, exit...
153.     printf("\n Done, press any key to exit...\n");
154.     getch();
155.     return 0;
156. }

复制代码

realtang

原先的作者不知什么居心，竟然没提供显示每个字段内容的代码。在这里我加上了。
从这个例子可以看出，mysql返回的所有字段值均转换为了字符串。

惠繪洋

謝謝, 對我在c及mysql的學習上加了一頁呢. thanks.

freesu

楼主的代码里面，是在windows环境吗？
为何还include "windws.h"

realtang

Post by freesu
楼主的代码里面，是在windows环境吗？
为何还include "windws.h"

是我的疏漏,现在已经删掉了windows.h