Sybase批量操作的实现

Sybase批量操作应该如何实现呢？下面就为您详细介绍Sybase批量操作的事项方法，如果您对Sybase批量操作方面感兴趣的话，不妨一看。

创新互联建站是一家专业提供德惠企业网站建设,专注与成都网站设计、成都做网站、H5建站、小程序制作等业务。10年已为德惠众多企业、政府机构等服务。创新互联专业网站设计公司优惠进行中。

一、前言

在项目研发过程中，需要开发一个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); 
    2.

在动态链接库中定义了两个类：CInteriorGlobal和CSYBBCP。CInteriorGlobal完成全局的初始化操作，CSYBBCP实现数据库的批量操作。
在调用Sybase数据库的DB LIBRARY API函数进行数据库的相关操作时，首先需要调用dbsetversion函数设置版本信息，这个函数只能调用一次，如果再次调用则会报错。而类CSYBBCP在BCP_Transfer_2函数中动态创建和释放，如果在CSYBBCP中直接调用dbsetversion会导致多次调用出错。因此需要采用一种机制让dbsetversion只能调用一次，这里使用了设计模式中的SingleTom模式，SingleTom模式就是确保实例唯一，本人利用该类仅做一次实例化操作来初始化Sybase客户端版本信息。

下面是CInteriorGlobal的定义：

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

CInteriorGlobal的实现，在构造函数中设置版本信息：

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

为了完成批量操作，定义类CSYBBCP，具体定义如下：

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

在类CSYBBCP中，主要是函数BCP_Transfer_db进行数据库大批量数据的导入和导出，要完成数据传输操作，需要如下几个步骤：

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

在使用Sybase12.5客户端之前，程序未调用bcp_control函数，在执行bcp_exec函数时不是使用while，而是使用if判断，代码如下：

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

程序能正常完成功能，当使用Sybase12.5客户端后，在执行时发现程序突然退出，异常处理也未能记录日志，后跟踪发现程序是在执行bcp_exec时退出，但是未能查出原因，咨询Sybase公司技术人员，也没能解决问题。后来在一次测试中偶然发现有时能导入数据，于是测试数据文件在什么情况下能导入，实验其临界点，多次测试后发现文件1000条记录为临界点，超过则出现问题。于是本人在程序中调用bcp_control函数，设置批量记录为1000，如果数据文件记录多于1000，则需要bcp_exec执行多次才能完成，所以采用while，而不是if，这样问题解决。

三、结束

在上面的论述中，还仅仅涉及DB LIBRARY，对于Sybase客户端编程，还有CT LIBRARY方式，目前CT已经支持导出，但不支持导入。

网站题目：Sybase批量操作的实现
标题链接：http://www.csdahua.cn/qtweb/news10/275210.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

python知识

同城分类信息

tpbzx.cn　　 　四川胜锦安防　　 　成都网站推广　　 　宇仓仓储　　 　响应式网站建设方案　　 　bgp多线机房托管　　 　小谭网创广告　　 　温江服务器托管　　 　软文推广公司　　 　温江网站设计　　 　成都移动服务器托管　　 　网上商城开发　　 　重庆网站设计　　 　成都能净科技　　 　成都包装设计公司　　 　响应式网站　　 　定制网站设计　　 　成都网络公司　　 　成都微信小程序　　 　四川鸿达