问：在unix上编程，如何屏蔽数据库间的差异

ningth

如何屏蔽数据库间的差异

unixODBC没用过，不知道怎么样

lenovo

推荐你用otl。

mengwg

原帖由 ningth 于 2006-11-29 16:01 发表
如何屏蔽数据库间的差异

unixODBC没用过，不知道怎么样

如果不想自己封装，unixodbc应该是个不错的选择。
以前做过类似的工作，连接里有个文档你可参考。 http://www.onlyit.cn/bbs/doc/over_db.rar
不过那个是很早的版本了。现在在用的版本做了些改进，多了对多线程和连接池的支持。贴上和连接打交道的头文件供参考。

1. 
   
2. #ifndef itf_db_h
   
3. #define itf_db_h
   
4. 
   
5. #include <system.h>
   
6. #include <dbdatamgr.h>
   
7. #include <dbdatamgr_itf.h>
   
8. #include <memlist.h>
   
9. #include <stdio.h>
   
10. #include <thread_ext.h>
    
11. 
    
12. //这个是后台数据库，决定了sql语句的适用性
    
13. #define  Db_Serv_Undef             0
    
14. #define  Db_Serv_Oracle            1
    
15. #define  Db_Serv_Access            2
    
16. #define  Db_Serv_Sybase            3
    
17. #define  Db_Serv_Mysql             4
    
18. #define  Db_Serv_Informix          5
    
19. #define  Db_Serv_Odb               6
    
20. 
    
21. //这个是客户端连接用的，不用于决定sql语句
    
22. #define  Db_Type_Oracle            1      //oracle
    
23. #define  Db_Type_Bde               2      //bde
    
24. #define  Db_Type_Exp_Oracle        3      //exp_oracle
    
25. #define  Db_Type_Exp_Mssql         4      //exp_mssql
    
26. #define  Db_Type_Vc                5      //vc_odbc
    
27. #define  Db_Type_Ado_Access        6      //ado_access
    
28. #define  Db_Type_Itf_Sql           7      //itf_sql
    
29. #define  Db_Type_Mysql             8      //itf_mysql
    
30. 
    
31. #define  Db_Type_Odb_V01           10     //odb
    
32. 
    
33. class TDb_Connect
    
34. {
    
35. protected:
    
36.   int  mServ_Type;
    
37. 
    
38. public:
    
39.   int  mDb_Type;
    
40.   char mDb_Name[60];
    
41.   char mUser_Name[60];
    
42.   char mPassword[60];
    
43.   char mGrp_Name[60];
    
44.   char mHost[60];
    
45.   int  mPort;
    
46.   int  mInitlized;
    
47.   int  mTid;
    
48.   int  mCreate_Tid;
    
49.   void  * mAss_Ptr;
    
50.         void (* mRelease_Obj_Handle)(void * conn);
    
51.   DBDataMgr_Itf_Stru mData_Oper_Funcs;
    
52. 
    
53. protected:
    
54.   int  (* _Set_Data_Oper_Handle)(DBDataMgr_Itf_Stru * oper_ptr);
    
55.   int  (* _Connect_Handle)(void * ddm,int db_type,char * db_name,char * user_name,
    
56.                       char * password,char * host,int port);
    
57.   int  (* _Disconnect_Handle)(void * ddm);
    
58.   int  (* _Commit_Handle)(void * ddm);
    
59.   int  (* _Rollback_Handle)(void * ddm);
    
60.   int  (* _ExecuteSql_Handle)(void * ddm,char * sqlcmd);
    
61.   int  (* _ExecuteProc_Handle)(void * ddm,char * sqlcmd);
    
62.   int  (* _SelectRow_Handle)(void * ddm,char * sqlcmd,int (* data_handle)(void *,void *),
    
63.                       void * dbioptr,void * assptr);
    
64.   int  (* _BatchInsert_Handle)(void * ddm);
    
65. 
    
66. public:
    
67.   TDb_Connect();
    
68.   ~TDb_Connect();
    
69. 
    
70.   virtual int Set_Serv_Type(int db_serv_type);
    
71.   virtual int Get_Serv_Type();
    
72. 
    
73.           int SetLocalTid();
    
74.   virtual int Load_Handle(char * lib_file);
    
75. 
    
76.   virtual int Connect(int db_type,char * db_name, char * user_name,char * password,
    
77.                       char * host=NULL,int port=0);
    
78.   virtual int Disconnect();
    
79.   virtual int Commit(DBDataMgr * ddm);
    
80.   virtual int Rollback(DBDataMgr * ddm);
    
81.   virtual int ExecuteSql(DBDataMgr * ddm,char * sqlcmd);
    
82.   virtual int ExecuteProc(DBDataMgr * ddm,char * sqlcmd);
    
83.   virtual int SelectRow(DBDataMgr * ddm,char * sqlcmd,int (* data_handle)(void *,void *),
    
84.                       void * dbioptr,void * assptr);
    
85.   virtual int BatchInsert(DBDataMgr * ddm);
    
86.   virtual int Get_Sequence_Id(DBDataMgr * ddm,char * seq_name,int * seq_val);
    
87.   virtual int Get_Sequence_Cur_Val(DBDataMgr * ddm,char * seq_name,int * seq_val);
    
88.   virtual int Set_Sequence_Id(DBDataMgr * ddm,char * seq_name,int seq_val);
    
89. };
    
90. 
    
91. class TDb_Connect_Mgr
    
92. {
    
93. public:
    
94.   TMemList mConn_Lst;
    
95.   TThread_Lock * mLock;
    
96. 
    
97. protected:
    
98.   int Check_Lock();
    
99. 
    
100. public:
     
101.   TDb_Connect_Mgr();
     
102.   ~TDb_Connect_Mgr();
     
103. 
     
104.   int Add_Connect(TDb_Connect * conn);
     
105.   int Remove_Connect(TDb_Connect * conn);
     
106.   int End_Session(char * grp_name=NULL);
     
107.   int Get_Free_Count(char * grp_name=NULL);
     
108.   int Get_Count(char * grp_name=NULL);
     
109.   TDb_Connect * Get_Session(char * grp_name=NULL);
     
110.   int Disconnect(char * grp_name=NULL);             //关闭一个数据库连接
     
111.   int Disconnect(TDb_Connect * conn);               //关闭一个数据库连接
     
112.   int Disconnect_Self_Thread();                     //关闭本线程创建的数据库连接
     
113. };
     
114. 
     
115. //建立数据库连接
     
116. 
     
117. //无需指定后台
     
118. extern int Mts_Ora(char * dbname,
     
119.                    char * username,
     
120.                    char * passwd,
     
121.                    int connnum=1,
     
122.                    char * grp_name=NULL);
     
123. 
     
124. //最后一个参数指定后台
     
125. extern int Mts_Bde(char * dbname,
     
126.                    char * username,
     
127.                    char * passwd,
     
128.                    int connnum=1,
     
129.                    char * grp_name=NULL,
     
130.                    int db_serv_type=0);
     
131. 
     
132. //无需指定后台
     
133. extern int Mts_Exp_Oracle(char * dbname,
     
134.                    char * username,
     
135.                    char * passwd,
     
136.                    int connnum=1,
     
137.                    char * grp_name=NULL);
     
138. 
     
139. //无需指定后台
     
140. extern int Mts_Exp_Mssql(char * hostname,
     
141.                    char * dbname,
     
142.                    char * username,
     
143.                    char * passwd,
     
144.                    int connnum=1,
     
145.                    char * grp_name=NULL);
     
146. 
     
147. //无需指定后台
     
148. extern int Mts_Odb(char * dbname,
     
149.                    char * username,
     
150.                    char * passwd,
     
151.                    int connnum,
     
152.                    char * grpname,
     
153.                    char * host,
     
154.                    int port);
     
155. 
     
156. //无需指定后台
     
157. extern int Mts_Ado_Access(
     
158.                    char * dbname,
     
159.                    char * username,
     
160.                    char * passwd,
     
161.                    int connnum=1,
     
162.                    char * grp_name=NULL);
     
163. 
     
164. //无需指定后台
     
165. extern int Mts_Mysql(char * dbname,
     
166.                    char * username,
     
167.                    char * passwd,
     
168.                    char * host=NULL,
     
169.                    int port=0,
     
170.                    int connnum=1,
     
171.                    char * grpname=NULL);
     
172. 
     
173. 
     
174. //最后一个参数指定后台
     
175. extern int Mts_Vc(char * dbname,
     
176.                    char * username,
     
177.                    char * passwd,
     
178.                    int connnum=1,
     
179.                    char * grp_name=NULL,
     
180.                    int db_serv_type=0);
     
181. 
     
182. 
     
183. extern int Mts_Get_Free_Count(char * grp_name=NULL);         //获得未被占用的连接数量
     
184. extern int Mts_Get_Count(char * grp_name=NULL);              //获得连接数量
     
185. 
     
186. extern TDb_Connect * Mts_Get_Session(char * grp_name=NULL);  //获得一个未被占用的连接,或者是本线程正在使用的连接
     
187. extern int Mts_End_Session(char * grp_name=NULL);            //释放一个数据库会话
     
188. 
     
189. extern int Mts_Disconnect(char * grp_name=NULL);             //关闭一个数据库连接
     
190. extern int Mts_Disconnect(TDb_Connect * conn);                                                         //关闭一个数据库连接
     
191. extern int Mts_Disconnect_Self_Thread();
     
192. 
     
193. extern TDb_Connect * New_Bde_Connect();
     
194. extern TDb_Connect * New_Ora_Connect();
     
195. extern TDb_Connect * New_Net_Connect();
     
196. extern TDb_Connect * New_Odb_Connect();
     
197. extern TDb_Connect * New_Exp_Connect();
     
198. extern TDb_Connect * New_Mysql_Connect();
     
199. 
     
200. //下面2个函数被各数据库驱动程序调用，应用程序不应该调用
     
201. extern int Mts_Add_Connect(TDb_Connect * conn);
     
202. extern int Mts_Remove_Connect(TDb_Connect * conn);
     
203. 
     
204. extern TDb_Connect_Mgr * Db_Connect_Mgr;
     
205. 
     
206. extern int    Global_Init_Db_Connect_Mgr();
     
207. extern int    Init_Db_Connect_Mgr();
     
208. extern void * Mts_Get_Mgr_Ptr();
     
209. extern int    Mts_Set_Mgr_Ptr(void * ptr);
     
210. 
     
211. #endif
     
212. 
     

复制代码

zengjin8310

odbc很多情况下出问题都查不出原因， 不能自己＋数据库软件提供上完全来控制。
有时候稍微麻烦点是必要的，数据库访问相关的拉出接口来就行了， 不同的数据库搞个不同实现。