bcp_exec

在数据库表和用户文件之间执行数据的完整大容量副本。

语法

  
RETCODE bcp_exec (  
HDBC   
hdbc  
,  
LPDBINT   
pnRowsProcessed  
);  
  

论据

hdbc
已启用大容量复制的 ODBC 连接句柄。

pnRowsProcessed
指向 DBINT 的指针。 bcp_exec函数用已成功复制的行数填充此 DBINT。 如果 pnRowsProcessed 为 NULL, 则bcp_exec将忽略它。

退货

SUCCEED、SUCCEED_ASYNC 或 FAIL。 如果复制了所有行, bcp_exec 函数将返回 SUCCEED。 如果 异步大容量复制作仍然未完成,bcp_exec将返回SUCCEED_ASYNC。 如果 发生完全失败,或者生成错误的行数达到使用 bcp_control 为 BCPMAXERRS 指定的值,bcp_exec将返回 FAIL。 BCPMAXERRS 默认为 10。 BCPMAXERRS 选项仅影响提供程序在读取数据文件中的行时检测到的语法错误(而不是发送到服务器的行)。 服务器在检测到行错误时中止批处理。 检查 pnRowsProcessed 参数,了解已成功复制的行数。

注解

此函数根据bcp_init中的 eDirection 参数的值,将数据从用户文件复制到数据库表,反之亦然。

在调用 bcp_exec之前,请使用有效的用户名调用 bcp_init 。 否则会导致错误。

bcp_exec 是唯一一个长时间可能未完成的大容量复制函数。 因此,它是唯一支持异步模式的大容量复制函数。 若要设置异步模式,请使用 SQLSetConnectAttr 在调用bcp_exec之前将SQL_ATTR_ASYNC_ENABLE设置为 SQL_ASYNC_ENABLE_ON。 若要测试完成,请使用相同的参数调用 bcp_exec 。 如果大容量复制尚未完成, bcp_exec 返回SUCCEED_ASYNC。 它还在 pnRowsProcessed 中返回已发送到服务器的行数的状态计数。 在到达批处理结束之前,不会提交发送到服务器的行。

有关从 SQL Server 2005 开始的大容量复制中断性变更的信息,请参阅执行大容量复制作(ODBC)。

示例:

以下示例演示如何使用 bcp_exec

// Variables like henv not specified.  
HDBC      hdbc;  
DBINT      nRowsProcessed;  
  
// Application initiation, get an ODBC environment handle, allocate the  
// hdbc, and so on.  
...   
  
// Enable bulk copy prior to connecting on allocated hdbc.  
SQLSetConnectAttr(hdbc, SQL_COPT_SS_BCP, (SQLPOINTER) SQL_BCP_ON,  
   SQL_IS_INTEGER);  
  
// Connect to the data source, return on error.  
if (!SQL_SUCCEEDED(SQLConnect(hdbc, _T("myDSN"), SQL_NTS,  
   _T("myUser"), SQL_NTS, _T("myPwd"), SQL_NTS)))  
   {  
   // Raise error and return.  
   return;  
   }  
  
// Initialize bulk copy.   
if (bcp_init(hdbc, _T("pubs..authors"), _T("authors.sav"), NULL, DB_OUT)  
   == FAIL)  
   {  
   // Raise error and return.  
   return;  
   }  
  
// Now, execute the bulk copy.   
if (bcp_exec(hdbc, &nRowsProcessed) == FAIL)  
   {  
   if (nRowsProcessed == -1)  
      {  
      printf_s("No rows processed on bulk copy execution.\n");  
      }  
   else  
      {  
      printf_s("Incomplete bulk copy.   Only %ld row%s copied.\n",  
         nRowsProcessed, (nRowsProcessed == 1) ? "": "s");  
      }  
   return;  
   }  
  
printf_s("%ld rows processed.\n", nRowsProcessed);  
  
// Carry on.  

另请参阅

大容量复制函数