无题

__BlueGuy__

1. // Connecting_with_SQLConnect.cpp
   
2. // compile with: user32.lib odbc32.lib
   
3. #include <windows.h>
   
4. #include <sqlext.h>
   
5. #include <mbstring.h>
   
6. #include <stdio.h>
   
7. #include <sqltypes.h>
   
8. 
   
9. #define MAX_DATA 100
   
10. #define MYSQLSUCCESS(rc) ((rc == SQL_SUCCESS) || (rc == SQL_SUCCESS_WITH_INFO) )
    
11. 
    
12. class direxec {
    
13.    RETCODE rc; // ODBC return code
    
14.    HENV henv; // Environment   
    
15.    HDBC hdbc; // Connection handle
    
16.    HSTMT hstmt; // Statement handle
    
17. 
    
18.    unsigned char szData[MAX_DATA]; // Returned data storage
    
19.    SDWORD cbData; // Output length of data
    
20.    unsigned char chr_ds_name[SQL_MAX_DSN_LENGTH]; // Data source name
    
21. 
    
22. public:
    
23.    direxec(); // Constructor
    
24.    void sqlconn(); // Allocate env, stat, and conn
    
25.    void sqlexec(); // Execute SQL statement
    
26.    void sqldisconn(); // Free pointers to env, stat, conn, and disconnect
    
27.    void error_out(); // Displays errors
    
28. };
    
29. 
    
30. // Constructor initializes the string chr_ds_name with the data source name.
    
31. // "Northwind" is an ODBC data source (odbcad32.exe) name whose default is the Northwind database
    
32. direxec::direxec() {
    
33.    _mbscpy_s(chr_ds_name, SQL_MAX_DSN_LENGTH, (const unsigned char *)"helloworld");
    
34. }
    
35. 
    
36. // Allocate environment handle and connection handle, connect to data source, and allocate statement handle.
    
37. void direxec::sqlconn() {
    
38.    SQLAllocEnv(&henv);
    
39.    SQLAllocConnect(henv, &hdbc);
    
40.    rc = SQLConnect(hdbc, chr_ds_name, SQL_NTS, NULL, 0, NULL, 0);
    
41. 
    
42.    // Deallocate handles, display error message, and exit.
    
43.    if (!MYSQLSUCCESS(rc)) {
    
44.       SQLFreeConnect(henv);
    
45.       SQLFreeEnv(henv);
    
46.       SQLFreeConnect(hdbc);
    
47.       if (hstmt)
    
48.          error_out();
    
49.       exit(-1);
    
50.    }
    
51. 
    
52.    rc = SQLAllocStmt(hdbc, &hstmt);
    
53. }
    
54. 
    
55. // Execute SQL command with SQLExecDirect() ODBC API.
    
56. void direxec::sqlexec() {
    
57. 
    
58.         SQLLEN mAffectCount;
    
59.         SQLSMALLINT mColCount;
    
60. 
    
61.         rc = SQLExecDirect(hstmt, (SQLCHAR*)"INSERT INTO city values (1, 'HeFei', 'IDN', 'AnHui', 10001)", SQL_NTS);
    
62.         rc = SQLExecDirect(hstmt, (SQLCHAR*)"INSERT INTO city values (2, 'BengBu', 'IDN', 'AnHui', 10002)", SQL_NTS);
    
63.         rc = SQLExecDirect(hstmt, (SQLCHAR*)"INSERT INTO city values (3, 'SuZhou', 'IDN', 'AnHui', 10003)", SQL_NTS);
    
64.         rc = SQLExecDirect(hstmt, (SQLCHAR*)"UPDATE  city SET Name = 'HuaiNan' WHERE Name = 'HeFei'", SQL_NTS);
    
65.         rc = SQLExecDirect(hstmt, (SQLCHAR*)"DELETE FROM city WHERE Name = 'HuaiNan'", SQL_NTS);
    
66. 
    
67.         SQLRowCount(hstmt,&mAffectCount);
    
68.         SQLNumResultCols(hstmt,&mColCount);
    
69.         SQLCloseCursor(hstmt);
    
70.         SQLFreeStmt(hstmt, SQL_UNBIND);
    
71. 
    
72.         rc = SQLExecDirect(hstmt, (SQLCHAR*)"SELECT * FROM city", SQL_NTS);
    
73.         SQLRowCount(hstmt,&mAffectCount);
    
74.         SQLNumResultCols(hstmt,&mColCount);
    
75. 
    
76.         int ColIndex;
    
77.         char Col[100][2048] = {0};
    
78.         SQLCHAR        ColName[100][2048] = {0};
    
79.         SQLLEN mCollocate[100] = {0};
    
80. 
    
81.         for (ColIndex=0;ColIndex<mColCount;ColIndex++)
    
82.         {
    
83.                 SQLBindCol(hstmt,ColIndex+1,SQL_C_CHAR,Col[ColIndex],2048,&mCollocate[ColIndex]);
    
84.                 SQLDescribeCol(hstmt,ColIndex+1,ColName[ColIndex],30,NULL,NULL,NULL,NULL,NULL);
    
85.         }
    
86. 
    
87.         puts("SQLFetch");
    
88. 
    
89.         while ((rc = SQLFetch(hstmt)) != SQL_NO_DATA)
    
90.         {
    
91.                 printf("%s %s %s %s %s\n", Col[0], Col[1], Col[2], Col[3], Col[4]);
    
92.         }
    
93. 
    
94.         SQLCloseCursor(hstmt);
    
95.         SQLFreeStmt(hstmt, SQL_UNBIND);
    
96. 
    
97.         rc = SQLExecDirect(hstmt, (SQLCHAR*)"SELECT * FROM city", SQL_NTS);
    
98.         SQLRowCount(hstmt,&mAffectCount);
    
99.         SQLNumResultCols(hstmt,&mColCount);
    
100. 
     
101.         puts("\nSQLGetData");
     
102.         memset(Col, 0, 100*2048*sizeof(char));
     
103. 
     
104.         for (int RowIndex=0;RowIndex<mAffectCount;RowIndex++)
     
105.         {
     
106.                 SQLFetch(hstmt);
     
107. 
     
108.                 for (int ColIndex=0;ColIndex<mColCount;ColIndex++)
     
109.                 {
     
110.                         int        TotalGet = 0;
     
111.                         SQLLEN LenData = 0;
     
112.                         int        Ret        = 0;
     
113. 
     
114.                         while(Ret=SQLGetData(hstmt, ColIndex+1, SQL_C_CHAR,Col[ColIndex]+TotalGet,200000,&LenData)!=SQL_NO_DATA)
     
115.                         {
     
116.                                 break;
     
117.                         }
     
118.                 }
     
119. 
     
120.                 printf("%s %s %s %s %s\n", Col[0], Col[1], Col[2], Col[3], Col[4]);
     
121.         }
     
122. }
     
123. 
     
124. // Free the statement handle, disconnect, free the connection handle, and free the environment handle.
     
125. void direxec::sqldisconn() {
     
126.    SQLFreeStmt(hstmt,SQL_DROP);
     
127.    SQLDisconnect(hdbc);
     
128.    SQLFreeConnect(hdbc);
     
129.    SQLFreeEnv(henv);
     
130. }
     
131. 
     
132. // Display error message in a message box that has an OK button.
     
133. void direxec::error_out() {
     
134.    unsigned char szSQLSTATE[10];
     
135.    SDWORD nErr;
     
136.    unsigned char msg[SQL_MAX_MESSAGE_LENGTH + 1];
     
137.    SWORD cbmsg;
     
138. 
     
139.    while (SQLError(0, 0, hstmt, szSQLSTATE, &nErr, msg, sizeof(msg), &cbmsg) == SQL_SUCCESS) {
     
140.       sprintf_s((char *)szData, sizeof(szData), "Error:\nSQLSTATE=%s, Native error=%ld, msg='%s'", szSQLSTATE, nErr, msg);
     
141.       MessageBox(NULL, (const char *)szData, "ODBC Error", MB_OK);
     
142.    }
     
143. }
     
144. 
     
145. int main () {
     
146.    direxec x;   // Declare an instance of the direxec object.
     
147.    x.sqlconn();   // Allocate handles, and connect.
     
148.    x.sqlexec();   // Execute SQL command
     
149.    x.sqldisconn();   // Free handles and disconnect
     
150.    getchar();
     
151. }

复制代码

__BlueGuy__

给个主页推荐一下呗