ODBC设置超时时遇到的非常奇怪的问题

stavck

我在项目中使用ODBC API 进行数据库操作，实际开发中遇到一个非常郁闷的问题：无法取得连接超时和设置查询超时！为了进行验证，我特意写了一个测试程序。（后面的帖子中我会贴出代码）
下面时测试程序执行的结果：

连接Mysql数据库的执行的结果是：
ODBC Version is: 3               //查询ODBC 版本的结果
Login Timeout is: 3              //查询登录超时的结果
Error Get Connection timeout -1  //设置连接超时为3秒时，出错信息
Error [Microsoft][ODBC 驱动程序管理器] 选项类型越界 (45)
State HY092
Connected !                     //已经连接到数据库
Query Timeout is 0              //设置完查询超时为3秒后，查看查询超时的结果。

连接access数据库的执行的结果是：
ODBC Version is: 3               //查询ODBC 版本的结果
Login Timeout is: 3              //查询登录超时的结果
Error Get Connection timeout -1  //设置连接超时为3秒时， 出错信息
Error [Microsoft][ODBC 驱动程序管理器] 选项类型越界 (45)
State HY092
Connected !                     //已经连接到数据库
Error Set Query Timeout -1      //设置 查询超时为3秒时，出错信息
Error [Microsoft][ODBC 驱动程序管理器] 选项类型越界 (45)
State HY092

是我的程序问题，还是驱动不支持？

stavck

1. 
   
2. 
   
3. // TimeoutTest.cpp : Defines the entry point for the console application.
   
4. //
   
5. 
   
6. #include "stdafx.h"
   
7. 
   
8. #include "windows.h"
   
9. 
   
10. //ODBC API
    
11. #include <sql.h>
    
12. #include <sqlext.h>
    
13. #include <odbcinst.h>
    
14. 
    
15. #pragma comment(lib,"odbc32.lib")
    
16. #pragma comment(lib,"OdbcCP32.Lib")
    
17. 
    
18. int main(int argc, char* argv[])
    
19. {
    
20.         SQLHENV                         hEnv;                        // Handle ODBC environment
    
21.         SQLRETURN                 nRet;                        // result of functions
    
22.         SQLHDBC                         hDBC;                        // Handle connection
    
23.         SQLHSTMT                 hStmt;                        // Handle Statement
    
24. 
    
25.         SQLUINTEGER                 nTimeout = 3;        // Timeout
    
26.         SQLCHAR                 nVersion = 0;
    
27. 
    
28.         SQLCHAR pszSqlState[SQL_MAX_MESSAGE_LENGTH] = "";
    
29.         SQLCHAR pszErrorMsg[SQL_MAX_MESSAGE_LENGTH] = "";
    
30. 
    
31. 
    
32.         SQLINTEGER nNativeError = 0L;
    
33.         SQLSMALLINT nErrorMsg = 0;
    
34.        
    
35. 
    
36. 
    
37.         // 1. allocate Environment handle and register version
    
38.         nRet = SQLAllocHandle(SQL_HANDLE_ENV,SQL_NULL_HANDLE,&hEnv);
    
39. 
    
40.         if ((nRet != SQL_SUCCESS) && (nRet != SQL_SUCCESS_WITH_INFO))
    
41.         {
    
42.                 printf("Error AllocHandlen");
    
43.                 return 0;
    
44.         }
    
45. 
    
46.         nRet = SQLSetEnvAttr(hEnv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, SQL_IS_UINTEGER);
    
47.         if ((nRet != SQL_SUCCESS) && (nRet != SQL_SUCCESS_WITH_INFO))
    
48.         {
    
49.                 printf("Error SetEnvn");
    
50.                 SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
    
51.                 return 0;
    
52.         }
    
53. 
    
54. 
    
55.         nRet = SQLGetEnvAttr(hEnv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)&nVersion, SQL_IS_INTEGER, NULL);
    
56.         if ((nRet == SQL_SUCCESS) || (nRet == SQL_SUCCESS_WITH_INFO))
    
57.         {
    
58.                 printf("ODBC Version is: %ldn", nVersion);
    
59.         }
    
60.         else
    
61.         {
    
62.                 printf("Error Get ODBC Version %dn", nRet);
    
63.                 SQLGetDiagRec(SQL_HANDLE_DBC, hEnv, 1,  pszSqlState, &nNativeError,
    
64.                                                 pszErrorMsg, SQL_MAX_MESSAGE_LENGTH - 1, &nErrorMsg);
    
65.                 printf("Error %s (%d)n State %s n", pszErrorMsg, nErrorMsg, pszSqlState);
    
66.         }
    
67.        
    
68. 
    
69.         // 2. allocate connection handle, set timeout
    
70.         nRet = SQLAllocHandle(SQL_HANDLE_DBC, hEnv, &hDBC);
    
71.         if ((nRet != SQL_SUCCESS) && (nRet != SQL_SUCCESS_WITH_INFO))
    
72.         {
    
73.                 printf("Error AllocHDB %dn", nRet);
    
74.                 SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
    
75.                 return 0;
    
76.         }
    
77. 
    
78.         nRet = SQLSetConnectAttr(hDBC, SQL_ATTR_LOGIN_TIMEOUT, (SQLPOINTER)nTimeout, SQL_IS_INTEGER);
    
79.         if ((nRet != SQL_SUCCESS) && (nRet != SQL_SUCCESS_WITH_INFO))
    
80.         {
    
81.                 printf("Error SetConnectAttr %dn", nRet);
    
82.         }
    
83. 
    
84.         nRet = SQLGetConnectAttr(hDBC, SQL_ATTR_LOGIN_TIMEOUT, (SQLPOINTER)&nTimeout, SQL_IS_INTEGER, NULL);
    
85.         if ((nRet == SQL_SUCCESS) || (nRet == SQL_SUCCESS_WITH_INFO))
    
86.         {
    
87.                 printf("Login Timeout is: %ldn", nTimeout);
    
88.         }
    
89.         else
    
90.         {
    
91.                 printf("Error Get Login Timeout %dn", nRet);
    
92.                 SQLGetDiagRec(SQL_HANDLE_DBC, hDBC, 1,  pszSqlState, &nNativeError,
    
93.                                                 pszErrorMsg, SQL_MAX_MESSAGE_LENGTH - 1, &nErrorMsg);
    
94.                 printf("Error %s (%d)n State %s n", pszErrorMsg, nErrorMsg, pszSqlState);
    
95.         }
    
96. 
    
97.         nRet = SQLSetConnectAttr(hDBC, SQL_ATTR_CONNECTION_TIMEOUT, (SQLPOINTER)nTimeout, SQL_IS_INTEGER);
    
98.         if ((nRet != SQL_SUCCESS) && (nRet != SQL_SUCCESS_WITH_INFO))
    
99.         {
    
100.                 printf("Error SetConnectAttr %dn", nRet);
     
101.         }
     
102. 
     
103.         nRet = SQLGetConnectAttr(hDBC, SQL_ATTR_CONNECTION_TIMEOUT, (SQLPOINTER)&nTimeout, SQL_IS_INTEGER, NULL);
     
104.         if ((nRet == SQL_SUCCESS) || (nRet == SQL_SUCCESS_WITH_INFO))
     
105.         {
     
106.                 printf("Connection timeout is: %ldn", nTimeout);
     
107.         }
     
108.         else
     
109.         {
     
110.                 printf("Error Get Connection timeout %dn", nRet);
     
111.                 SQLGetDiagRec(SQL_HANDLE_DBC, hDBC, 1,  pszSqlState, &nNativeError,
     
112.                                                 pszErrorMsg, SQL_MAX_MESSAGE_LENGTH - 1, &nErrorMsg);
     
113.                 printf("Error %s (%d)n State %s n", pszErrorMsg, nErrorMsg, pszSqlState);
     
114.         }
     
115.        
     
116.         // 3. Connect to the datasource "test"
     
117.         nRet = SQLConnect(hDBC, (SQLCHAR*) "mysql", SQL_NTS,
     
118.                                                                          (SQLCHAR*) "inumen", SQL_NTS,
     
119.                                                                          (SQLCHAR*) "inumen", SQL_NTS);
     
120. /*        nRet = SQLConnect(hDBC, (SQLCHAR*) "test", SQL_NTS,
     
121.                                                                          (SQLCHAR*) "Admin", SQL_NTS,
     
122.                                                                          (SQLCHAR*) "", SQL_NTS);*/
     
123.         if ((nRet != SQL_SUCCESS) && (nRet != SQL_SUCCESS_WITH_INFO))
     
124.         {
     
125.                 printf("Error SQLConnect %dn", nRet);
     
126.                 SQLGetDiagRec(SQL_HANDLE_DBC, hDBC, 1,  pszSqlState, &nNativeError,
     
127.                                                 pszErrorMsg, SQL_MAX_MESSAGE_LENGTH - 1, &nErrorMsg);
     
128.                 printf("%s (%d)n", pszErrorMsg, nErrorMsg);
     
129.                 SQLFreeHandle(SQL_HANDLE_DBC, hDBC);
     
130.                 SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
     
131.                 return 0;
     
132.         }
     
133. 
     
134.         printf("Connected !n");
     
135. 
     
136.         nRet = SQLAllocHandle(SQL_HANDLE_STMT, hDBC, &hStmt);
     
137.         if ((nRet != SQL_SUCCESS) && (nRet != SQL_SUCCESS_WITH_INFO))
     
138.         {
     
139.                 printf("Error AllocStatement %dn", nRet);
     
140.                 SQLGetDiagRec(SQL_HANDLE_DBC, hDBC, 1,  pszSqlState, &nNativeError,
     
141.                                                 pszErrorMsg, SQL_MAX_MESSAGE_LENGTH - 1, &nErrorMsg);
     
142.                 printf("%s (%d)n", pszErrorMsg, nErrorMsg);
     
143.                 SQLFreeHandle(SQL_HANDLE_DBC, hDBC);
     
144.                 SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
     
145.                 return 0;
     
146.         }
     
147. 
     
148. 
     
149.         nRet = SQLSetStmtAttr(hStmt, SQL_ATTR_QUERY_TIMEOUT, (SQLPOINTER)nTimeout, SQL_IS_UINTEGER);
     
150.         if ((nRet != SQL_SUCCESS) && (nRet != SQL_SUCCESS_WITH_INFO))
     
151.         {
     
152.                 printf("Error Set Query Timeout %dn", nRet);
     
153.                 SQLGetDiagRec(SQL_HANDLE_DBC, hDBC, 1,  pszSqlState, &nNativeError,
     
154.                                                 pszErrorMsg, SQL_MAX_MESSAGE_LENGTH - 1, &nErrorMsg);
     
155.                 printf("Error %s (%d)n State %s n", pszErrorMsg, nErrorMsg, pszSqlState);
     
156.                 SQLFreeHandle(SQL_HANDLE_DBC, hDBC);
     
157.                 SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
     
158.                 SQLFreeHandle(SQL_HANDLE_STMT, hStmt);
     
159.                
     
160.                 return 0;
     
161.         }
     
162. 
     
163.         nRet = SQLGetStmtAttr(hStmt, SQL_ATTR_QUERY_TIMEOUT, (SQLPOINTER)&nTimeout, SQL_IS_UINTEGER, NULL);
     
164.         if ((nRet != SQL_SUCCESS) && (nRet != SQL_SUCCESS_WITH_INFO))
     
165.         {
     
166.                 printf("Error Get Query Timeout %dn", nRet);
     
167.                 SQLGetDiagRec(SQL_HANDLE_DBC, hDBC, 1,  pszSqlState, &nNativeError,
     
168.                                                 pszErrorMsg, SQL_MAX_MESSAGE_LENGTH - 1, &nErrorMsg);
     
169.                 printf("Error %s (%d)n State %s n", pszErrorMsg, nErrorMsg, pszSqlState);
     
170.         }
     
171.         else
     
172.         {
     
173.                 printf("Query Timeout is %dn", nTimeout);       
     
174.         }
     
175. 
     
176.         //.............................
     
177. 
     
178.         SQLFreeHandle(SQL_HANDLE_STMT, hStmt);
     
179. 
     
180.         SQLDisconnect(hDBC);
     
181. 
     
182.         SQLFreeHandle(SQL_HANDLE_DBC, hDBC);
     
183.         SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
     
184.        
     
185.         return 0;
     
186. }
     

复制代码

[ 本帖最后由 stavck 于 2005-11-23 15:46 编辑 ]

renstone921

To lz:

以后发代码,麻烦用code标记，这样大家也好看一些。

对你的问题，我有几个疑问，希望你能讲清楚。

odbc大概有3个版本。每个版本支持的api是不一样的，所以，你首先要确定的是，你所使用的odbc驱动是否支持该api的调用，印象里SQLGetConnectAttr这个api，myODBC2.5就不支持。所以，你首先要做的是确定你所使用的odbc是哪一家的，他所提供的api属于odbc哪个版本的。

State HY092

这个就是它的状态信息，表示api不支持，你需要一本微软的odbc的手册。一般在mdac的文档里面就有，或者msdn里面也有。

stavck

不好意思，我没有说清楚。
我使用的mysql的odbc驱动时3.51版，我到mysql的主页上查过，他们是支持这些函数的。
令我奇怪的是，access 的驱动竟然也连设置查询超时都不支持，以前写过ADO的代码，里面是可以设置查询超时的，所以很怀疑我的程序有问题。

我的代码是可以直接编译的，如果有兴趣，大家可以测试一下。

renstone921

你把
nRet = SQLGetConnectAttr(hDBC, SQL_ATTR_CONNECTION_TIMEOUT, (SQLPOINTER)&nTimeout, SQL_IS_INTEGER, NULL);
放到建立连接的SQLConnect后面去做，
我只记得当设置语句属性时，Set和Get的先后顺序有影响，连接超时这个属性对于连接是否建立的要求应当是可以在连接建立前后都可以的。但不知道这里为什么不行，你还是找个sql server试一下。

[ 本帖最后由 renstone921 于 2005-11-23 16:41 编辑 ]

stavck

谢谢renstone921！
昨天，我在一台ms sql server 7的机器上试了一下，发现程序运行基本正常，只是取连接超时时会出错。
今天我改了一下，在连接到数据库后取连接超时，结果mysql取的结果是：31536000，查询超时依然是0。而access就不支持改属性，返回的状态是：HYC00。
看样不是我程序的问题了。
难得mysql不支持设置连接超时和查询超时？

stavck

我在mysql网站的bug列表中查到了，他们说只能等到5.1版的mysql出来之后才能解决这个问题。真是郁闷！