通过

用 SQLSetPos 更新行集中的行

SQLSetPos 的更新操作使数据源能够使用应用程序缓冲区中每个绑定列的数据更新表中所选的一行或多行（除非长度/指示器缓冲区中的值为 SQL_COLUMN_IGNORE）。 不会更新未绑定的列。

若要使用 SQLSetPos 更新行，应用程序将执行以下作：

  1. 将新数据值放在行集缓冲区中。 有关如何使用 SQLSetPos 发送长数据的信息，请参阅 Long Data 和 SQLSetPos 和 SQLBulkOperations。

  2. 根据需要设置每个列的长度/指示器缓冲区中的值。 这是绑定到字符串缓冲区的列的字节长度或SQL_NTS，绑定到二进制缓冲区的列的字节长度，对于需要设置为NULL的任何列，则为SQL_NULL_DATA。

  3. 设置不更新列的长度/指示器缓冲区中的值为SQL_COLUMN_IGNORE。 尽管应用程序可以跳过此步骤并重新发送现有数据，但这效率低下，并有可能将值发送到读取时截断的数据源。

  4. 调用 SQLSetPos 并将 Operation 设置为 SQL_UPDATE，RowNumber 设置为要更新的行号。 如果 RowNumber 为 0，则会更新行集中的所有行。

SQLSetPos 返回后，当前行将设置为更新的行。

更新行集的所有行（RowNumber 等于 0）时，应用程序可以通过将行作数组的相应元素（SQL_ATTR_ROW_OPERATION_PTR 语句属性指向）设置为SQL_ROW_IGNORE来禁用某些行的更新。 行作数组的大小和元素数对应于行状态数组（SQL_ATTR_ROW_STATUS_PTR语句属性指向）。 若要仅更新已成功提取且尚未从结果集中删除的那些行，应用程序使用从提取行集的函数得到的行状态数组作为 SQLSetPos 的行操作数组。

对于作为更新发送到数据源的每一行，应用程序缓冲区应具有有效的行数据。 如果通过提取数据来填充应用程序缓冲区，并且维护了行状态数组，那么这些数组中每个行位置的值都不应是 SQL_ROW_DELETED、SQL_ROW_ERROR 或 SQL_ROW_NOROW。

例如，以下代码允许用户滚动浏览 Customers 表并更新、删除或添加新行。 它会在调用 SQLSetPos 更新或添加新行之前，将新数据放在行集缓冲区中。 在行集缓冲区的末尾分配一个额外的行，用于保存新行;这样可以防止在缓冲区中放置新行的数据时覆盖现有数据。

#define UPDATE_ROW   100  
#define DELETE_ROW   101  
#define ADD_ROW      102  
  
SQLUINTEGER    CustIDArray[11];  
SQLCHAR        NameArray[11][51], AddressArray[11][51],   
               PhoneArray[11][11];  
SQLINTEGER     CustIDIndArray[11], NameLenOrIndArray[11],   
               AddressLenOrIndArray[11],  
               PhoneLenOrIndArray[11];  
SQLUSMALLINT   RowStatusArray[10], Action, RowNum;  
SQLRETURN      rc;  
SQLHSTMT       hstmt;  
  
// Set the SQL_ATTR_ROW_BIND_TYPE statement attribute to use column-wise   
// binding. Declare the rowset size with the SQL_ATTR_ROW_ARRAY_SIZE   
// statement attribute. Set the SQL_ATTR_ROW_STATUS_PTR statement   
// attribute to point to the row status array.  
SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, SQL_CURSOR_KEYSET_DRIVEN, 0);  
SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_BIND_TYPE, SQL_BIND_BY_COLUMN, 0);  
SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, 10, 0);  
SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_STATUS_PTR, RowStatusArray, 0);  
  
// Bind arrays to the CustID, Name, Address, and Phone columns.  
SQLBindCol(hstmt, 1, SQL_C_ULONG, CustIDArray, 0, CustIDIndArray);  
SQLBindCol(hstmt, 2, SQL_C_CHAR, NameArray, sizeof(NameArray[0]), NameLenOrIndArray);  
SQLBindCol(hstmt, 3, SQL_C_CHAR, AddressArray, sizeof(AddressArray[0]),  
            AddressLenOrIndArray);  
SQLBindCol(hstmt, 4, SQL_C_CHAR, PhoneArray, sizeof(PhoneArray[0]),  
            PhoneLenOrIndArray);  
  
// Execute a statement to retrieve rows from the Customers table.  
SQLExecDirect(hstmt, "SELECT CustID, Name, Address, Phone FROM Customers", SQL_NTS);  
  
// Fetch and display the first 10 rows.  
rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0);  
DisplayData(CustIDArray, CustIDIndArray, NameArray, NameLenOrIndArray, AddressArray,  
            AddressLenOrIndArray, PhoneArray, PhoneLenOrIndArray, RowStatusArray);  
  
// Call GetAction to get an action and a row number from the user.  
while (GetAction(&Action, &RowNum)) {  
   switch (Action) {  
  
      case SQL_FETCH_NEXT:  
      case SQL_FETCH_PRIOR:  
      case SQL_FETCH_FIRST:  
      case SQL_FETCH_LAST:  
      case SQL_FETCH_ABSOLUTE:  
      case SQL_FETCH_RELATIVE:  
         // Fetch and display the requested data.  
         SQLFetchScroll(hstmt, Action, RowNum);  
         DisplayData(CustIDArray, CustIDIndArray,  
                     NameArray, NameLenOrIndArray,  
                     AddressArray, AddressLenOrIndArray,  
                     PhoneArray, PhoneLenOrIndArray, RowStatusArray);  
         break;  
  
      case UPDATE_ROW:  
         // Place the new data in the rowset buffers and update the   
         // specified row.  
         GetNewData(&CustIDArray[RowNum - 1], &CustIDIndArray[RowNum - 1],  
                  NameArray[RowNum - 1], &NameLenOrIndArray[RowNum - 1],  
                  AddressArray[RowNum - 1], &AddressLenOrIndArray[RowNum - 1],  
                  PhoneArray[RowNum - 1], &PhoneLenOrIndArray[RowNum - 1]);  
         SQLSetPos(hstmt, RowNum, SQL_UPDATE, SQL_LOCK_NO_CHANGE);  
         break;  
  
      case DELETE_ROW:  
         // Delete the specified row.  
         SQLSetPos(hstmt, RowNum, SQL_DELETE, SQL_LOCK_NO_CHANGE);  
         break;  
  
      case ADD_ROW:  
         // Place the new data in the rowset buffers at index 10.   
         // This is an extra element for new rows so rowset data is   
         // not overwritten. Insert the new row. Row 11 corresponds   
         // to index 10.  
         GetNewData(&CustIDArray[10], &CustIDIndArray[10],  
                     NameArray[10], &NameLenOrIndArray[10],  
                     AddressArray[10], &AddressLenOrIndArray[10],  
                     PhoneArray[10], &PhoneLenOrIndArray[10]);  
         SQLSetPos(hstmt, 11, SQL_ADD, SQL_LOCK_NO_CHANGE);  
         break;  
   }  
}  
  
// Close the cursor.  
SQLCloseCursor(hstmt);
  • Last updated on