程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> SyBase數據庫 >> SyBase教程 >> Sybase批量操作的實現

Sybase批量操作的實現

編輯:SyBase教程

Sybase批量操作應該如何實現呢?下面就為您詳細介紹Sybase批量操作的事項方法,如果您對Sybase批量操作方面感興趣的話,不妨一看。

一、前言

在項目研發過程中,需要開發一個Sybase批量操作的動態鏈接庫DLL),以前的實現主要是程序中直接調用bcp.exe,這種方式由應用程序創建子進程,不好控制批量操作過程,失敗跟蹤難度比較大,因此想利用bcp.exe調用的函數來實現操作過程。本人通過分析bcp.exe程序,得到了批量操作的DB LIBRARY API函數,再查閱API函數的資料得以實現該動態鏈接庫。

二、實現

批量操作動態鏈接庫只實現了一個輸出函數, 應用程序通過動態加載DLL,再獲取函數地址,便可調用函數實現Sybase批量操作。

輸出函數定義如下:

  1. LIBBCP_API BOOL BCP_Transfer_2(const char *task, const char *step, const char *config, long *copiedrow);  

在動態鏈接庫中定義了兩個類:CInteriorGlobal和CSYBBCP。CInteriorGlobal完成全局的初始化操作,CSYBBCP實現數據庫的批量操作。
在調用Sybase數據庫的DB LIBRARY API函數進行數據庫的相關操作時,首先需要調用dbsetversion函數設置版本信息,這個函數只能調用一次,如果再次調用則會報錯。而類CSYBBCP在BCP_Transfer_2函數中動態創建和釋放,如果在CSYBBCP中直接調用dbsetversion會導致多次調用出錯。因此需要采用一種機制讓dbsetversion只能調用一次,這裡使用了設計模式中的SingleTom模式,SingleTom模式就是確保實例唯一,本人利用該類僅做一次實例化操作來初始化Sybase客戶端版本信息。

下面是CInteriorGlobal的定義:

  1. class CInteriorGlobal  
  2. {  
  3. public:  
  4. static CInteriorGlobal *Instance();  
  5. private:  
  6. CInteriorGlobal();  
  7. private:  
  8. static CInteriorGlobal *_instance;  
  9. };  

CInteriorGlobal的實現,在構造函數中設置版本信息:

  1. CInteriorGlobal::CInteriorGlobal()  
  2. {  
  3. dbsetversion(DBVERSION_100);  
  4. }  
  5. CInteriorGlobal    *CInteriorGlobal::_instance  = 0;  
  6. CInteriorGlobal * CInteriorGlobal::Instance()  
  7. {  
  8. if(0 == _instance)  
  9. _instance = new CInteriorGlobal;  
  10. return _instance;  
  11. }  

為了完成批量操作,定義類CSYBBCP,具體定義如下:

  1. class CSYBBCP  
  2. {  
  3. public:  
  4. CSYBBCP();  
  5. ~CSYBBCP();  
  6. BOOL        DoConnect(int taskindex, int stepindex, char *server, char *database, char *username,  
  7. char *password, char *charset, char *language);  
  8. BOOL        DoQuery(char *sql, char **buf, int *rowcount, int *fieldcount);  
  9. BOOL        DoUpdate(char *sql, char *database = NULL);  
  10. BOOL        BCP_Connect(int taskindex, int stepindex, char *server, char *database,  
  11. char *username, char *password, char *charset, char *language);  
  12. BOOL        BCP_Transfer_db(char *sql, char *fldterminator, char *rowterminator, int direction,  
  13. char *datafile, char *errfile, long *copiedrow);  
  14. private:  
  15. BOOL        m_isbcpout;  
  16. int         m_stepindex;  
  17. int         m_taskindex;  
  18. char        m_viewname[MAX_STRING_NUM];  
  19. char        m_database[MAX_STRING_NUM];  
  20. DBPROCESS  *m_dbproc;  
  21. private:  
  22. int         GetTableFieldNums(char *table);  
  23. BOOL        DoDisconnect();  
  24. };  

在類CSYBBCP中,主要是函數BCP_Transfer_db進行數據庫大批量數據的導入和導出,要完成數據傳輸操作,需要如下幾個步驟:

  1. // 初始化:指定表明和數據文件  
  2. if(bcp_init(m_dbproc, tablename, datafile, NULL, direction) == FAIL)  
  3. {  
  4. return FALSE;  
  5. }  
  6. // 設置批量操作的控制參數,這裡設置的每批記錄數  
  7. if(bcp_control(m_dbproc, BCPBATCH, (DBINT) 1000) == FAIL)  
  8. {  
  9. return FALSE;  
  10. }  
  11. // 設置列數  
  12. if(bcp_columns(m_dbproc, cCols) == FAIL)  
  13. {  
  14. return FALSE;  
  15. }  
  16. // 設置列格式  
  17. for(ii = 1; ii < cCols; ii++)  
  18. {  
  19. if(bcp_colfmt(m_dbproc, ii, SYBCHAR, 0, -1, (UINT8 *) fldterminator, _strlen(fldterminator), ii) == FAIL)  
  20. {  
  21. return FALSE;  
  22. }  
  23. }  
  24. if(bcp_colfmt(m_dbproc, ii, SYBCHAR, 0, -1, (UINT8 *) rowterminator, _strlen(rowterminator), ii) == FAIL)  
  25. {  
  26. return FALSE;  
  27. }  
  28. // 執行批量操作  
  29. while(bcp_exec(m_dbproc, & cRows) == FAIL)  
  30. {  
  31. return FALSE;  
  32. }  
  33. // 批量操作結束  
  34. retcode = bcp_done(m_dbproc);  

在使用Sybase12.5客戶端之前,程序未調用bcp_control函數,在執行bcp_exec函數時不是使用while,而是使用if判斷,代碼如下:

  1. if(bcp_exec(m_dbproc, & cRows) == FAIL)  
  2. {  
  3. return FALSE;  
  4. }  

程序能正常完成功能,當使用Sybase12.5客戶端後,在執行時發現程序突然退出,異常處理也未能記錄日志,後跟蹤發現程序是在執行bcp_exec時退出,但是未能查出原因,咨詢Sybase公司技術人員,也沒能解決問題。後來在一次測試中偶然發現有時能導入數據,於是測試數據文件在什麼情況下能導入,實驗其臨界點,多次測試後發現文件1000條記錄為臨界點,超過則出現問題。於是本人在程序中調用bcp_control函數,設置批量記錄為1000,如果數據文件記錄多於1000,則需要bcp_exec執行多次才能完成,所以采用while,而不是if,這樣問題解決。

三、結束

在上面的論述中,還僅僅涉及DB LIBRARY,對於Sybase客戶端編程,還有CT LIBRARY方式,目前CT已經支持導出,但不支持導入。


編輯推薦】

設置SYBASE用戶口令為空

深入探究SYBASE數據庫日志

Sybase日期函數應用示例

Sybase建立索引的原則

Sybase分頁顯示存儲過程

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved