Positionierte Aktualisierung und DELETE-Anweisungen

Anwendungen können die aktuelle Zeile in einem Resultset mit einer positionierten Aktualisierungs- oder Löschausweisung aktualisieren oder löschen. Positionierte Aktualisierungs- und Löschanweisungen werden von einigen Datenquellen unterstützt, aber nicht von allen. Um festzustellen, ob eine Datenquelle positionierte Aktualisierungs- und Löschanweisungen unterstützt, ruft eine Anwendung SQLGetInfo mit dem SQL_DYNAMIC_CURSOR_ATTRIBUTES1, SQL_FORWARD_ONLY_CURSOR_ATTRIBUTES1, SQL_KEYSET_CURSOR_ATTRIBUTES1 oder SQL_STATIC_CURSOR_ATTRIBUTES1 InfoType (abhängig vom Cursortyp) auf. Beachten Sie, dass die ODBC-Cursorbibliothek positionierte Aktualisierungs- und Löschanweisungen simuliert.

Um eine positionierte Aktualisierungs- oder Lösch-Anweisung zu verwenden, muss die Anwendung ein Resultset mit einer SELECT FOR UPDATE-Anweisung erstellen. Die Syntax dieser Anweisung lautet:

SELECT [ALL | DISTINCT] Select-List

FROM-Tabellenverweisliste

[WHERE-Suchbedingung]

FOR UPDATE OF [column-name [,column-name]...]

Die Anwendung positioniert dann den Cursor auf der Zeile, die aktualisiert oder gelöscht werden soll. Dazu kann SQLFetchScroll aufgerufen werden, um ein Rowset abzurufen, das die erforderliche Zeile enthält, und SQLSetPos aufruft, um den Rowsetcursor in dieser Zeile zu positionieren. Die Anwendung führt dann die positionierte Aktualisierungs- oder Lösch-Anweisung für eine andere Anweisung als die Anweisung aus, die vom Resultset verwendet wird. Die Syntax dieser Anweisungen lautet:

UPDATE-Tabellenname

SET-Spaltenbezeichner= {Ausdruck | NULL}

[,Spaltenbezeichner= {Ausdruck | NULL}]...

WHERE CURRENT OFcursor-name

DELETE FROMtable-nameWHERE CURRENT OFcursor-name

Beachten Sie, dass für diese Anweisungen ein Cursorname erforderlich ist. Die Anwendung kann entweder einen Cursornamen mit SQLSetCursorName angeben, bevor die Anweisung ausgeführt wird, die das Resultset erstellt, oder die Datenquelle beim Erstellen des Cursors automatisch einen Cursornamen generieren lassen. Im letzteren Fall ruft die Anwendung diesen Cursornamen für die Verwendung in positionierten Aktualisierungs- und Löschanweisungen durch Aufrufen von SQLGetCursorName ab.

Mit dem folgenden Code kann ein Benutzer beispielsweise durch die Tabelle "Kunden" scrollen und Kundendatensätze löschen oder seine Adressen und Telefonnummern aktualisieren. Es ruft SQLSetCursorName auf, um einen Cursornamen anzugeben, bevor er den Resultset von Kunden erstellt und drei Anweisungshandles verwendet: hstmtCust für das Resultset, hstmtUpdate für eine positionierte Updateanweisung und hstmtDelete für eine positionierte Delete-Anweisung. Obwohl der Code separate Variablen an die Parameter in der positionierten Update-Anweisung binden kann, aktualisiert er die Rowsetpuffer und bindet die Elemente dieser Puffer. Dadurch werden die Rowsetpuffer mit den aktualisierten Daten synchronisiert.

#define POSITIONED_UPDATE 100  
#define POSITIONED_DELETE 101  
  
SQLUINTEGER    CustIDArray[10];  
SQLCHAR        NameArray[10][51], AddressArray[10][51],   
               PhoneArray[10][11];  
SQLINTEGER     CustIDIndArray[10], NameLenOrIndArray[10],   
               AddressLenOrIndArray[10],  
               PhoneLenOrIndArray[10];  
SQLUSMALLINT   RowStatusArray[10], Action, RowNum;  
SQLHSTMT       hstmtCust, hstmtUpdate, hstmtDelete;  
  
// Set the SQL_ATTR_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(hstmtCust, SQL_ATTR_ROW_BIND_TYPE, SQL_BIND_BY_COLUMN, 0);  
SQLSetStmtAttr(hstmtCust, SQL_ATTR_ROW_ARRAY_SIZE, 10, 0);  
SQLSetStmtAttr(hstmtCust, SQL_ATTR_ROW_STATUS_PTR, RowStatusArray, 0);  
  
// Bind arrays to the CustID, Name, Address, and Phone columns.  
SQLBindCol(hstmtCust, 1, SQL_C_ULONG, CustIDArray, 0, CustIDIndArray);  
SQLBindCol(hstmtCust, 2, SQL_C_CHAR, NameArray, sizeof(NameArray[0]),  
            NameLenOrIndArray);  
SQLBindCol(hstmtCust, 3, SQL_C_CHAR, AddressArray, sizeof(AddressArray[0]),  
         AddressLenOrIndArray);  
SQLBindCol(hstmtCust, 4, SQL_C_CHAR, PhoneArray, sizeof(PhoneArray[0]),  
            PhoneLenOrIndArray);  
  
// Set the cursor name to Cust.  
SQLSetCursorName(hstmtCust, "Cust", SQL_NTS);  
  
// Prepare positioned update and delete statements.  
SQLPrepare(hstmtUpdate,  
   "UPDATE Customers SET Address = ?, Phone = ? WHERE CURRENT OF Cust",  
   SQL_NTS);  
SQLPrepare(hstmtDelete, "DELETE FROM Customers WHERE CURRENT OF Cust", SQL_NTS);  
  
// Execute a statement to retrieve rows from the Customers table.  
SQLExecDirect(hstmtCust,  
   "SELECT CustID, Name, Address, Phone FROM Customers FOR UPDATE OF Address, Phone",  
   SQL_NTS);  
  
// Fetch and display the first 10 rows.  
SQLFetchScroll(hstmtCust, 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(hstmtCust, Action, RowNum);  
         DisplayData(CustIDArray, CustIDIndArray, NameArray, NameLenOrIndArray,  
                     AddressArray, AddressLenOrIndArray, PhoneArray,  
                     PhoneLenOrIndArray, RowStatusArray);  
         break;  
  
      case POSITIONED_UPDATE:  
         // Get the new data and place it in the rowset buffers.  
         GetNewData(AddressArray[RowNum - 1], &AddressLenOrIndArray[RowNum - 1],  
                     PhoneArray[RowNum - 1], &PhoneLenOrIndArray[RowNum - 1]);  
  
         // Bind the elements of the arrays at position RowNum-1 to the   
         // parameters of the positioned update statement.  
         SQLBindParameter(hstmtUpdate, 1, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR,  
                           50, 0, AddressArray[RowNum - 1], sizeof(AddressArray[0]),  
                           &AddressLenOrIndArray[RowNum - 1]);  
         SQLBindParameter(hstmtUpdate, 2, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR,  
                           10, 0, PhoneArray[RowNum - 1], sizeof(PhoneArray[0]),  
                           &PhoneLenOrIndArray[RowNum - 1]);  
  
         // Position the rowset cursor. The rowset is 1-based.  
         SQLSetPos(hstmtCust, RowNum, SQL_POSITION, SQL_LOCK_NO_CHANGE);  
  
         // Execute the positioned update statement to update the row.  
         SQLExecute(hstmtUpdate);  
         break;  
  
      case POSITIONED_DELETE:  
         // Position the rowset cursor. The rowset is 1-based.  
         SQLSetPos(hstmtCust, RowNum, SQL_POSITION, SQL_LOCK_NO_CHANGE);  
  
         // Execute the positioned delete statement to delete the row.  
         SQLExecute(hstmtDelete);  
         break;  
   }  
}  
  
// Close the cursor.  
SQLCloseCursor(hstmtCust);