Aktualisieren von Rowsets
Aktualisiert: November 2007
Eine der grundlegenden Datenbankoperationen stellt das Aktualisieren des Datenspeichers bzw. das Schreiben von Daten in den Datenspeicher dar. In OLE DB ist der Aktualisierungsmechanismus einfach: Die Consumeranwendung legt die Werte gebundener Datenmember fest und schreibt diese Werte anschließend in das Rowset. Anschließend fordert der Consumer den Anbieter auf, den Datenspeicher zu aktualisieren.
Consumer können Rowsetdaten mithilfe folgender Aktualisierungsmethoden aktualisieren: Festlegen von Spaltenwerten innerhalb einer Zeile, Einfügen einer Zeile und Löschen einer Zeile. Um diese Operationen vornehmen zu können, implementiert die OLE DB-Vorlagenklasse CRowset die IRowsetChange-Schnittstelle und überschreibt die folgenden Schnittstellenmethoden:
SetData ändert Spaltenwerte in einer Zeile eines Rowsets. Dies entspricht dem SQL-Befehl UPDATE.
Insert fügt eine Zeile in ein Rowset ein. Dies entspricht dem SQL-Befehl INSERT.
Delete löscht Zeilen aus einem Rowset. Dies entspricht dem SQL-Befehl DELETE.
Unterstützen von Aktualisierungsoperationen
Wenn Sie einen Consumer mit dem ATL-OLE DB-Consumer-Assistenten erstellen, können Sie die Aktualisierungsoperationen unterstützen, indem Sie eines oder mehrere der drei Kontrollkästchen Ändern, Einfügen und Löschen aktivieren. Wenn Sie diese Kontrollkästchen aktivieren, ändert der Assistent den Code dahingehend, dass die von Ihnen gewünschten Änderungen unterstützt werden. Wenn Sie den Assistenten nicht verwenden, müssen Sie jedoch die folgenden Rowseteigenschaften auf VARIANT_TRUE festlegen, damit Aktualisierungen unterstützt werden:
DBPROPVAL_UP_CHANGE ermöglicht die Änderung von Datenwerten in einer Zeile.
DBPROPVAL_UP_INSERT ermöglicht das Einfügen einer Zeile.
DBPROPVAL_UP_DELETE ermöglicht das Löschen einer Zeile.
Legen Sie die Eigenschaften wie folgt fest:
CDBPropSet ps(DBPROPSET_ROWSET);
ps.AddProperty(DBPROP_IRowsetChange, true)
ps.AddProperty(DBPROP_UPDATABILITY, DBPROPVAL_UP_CHANGE | DBPROPVAL_UP_INSERT | DBPROPVAL_UP_DELETE)
Die Operationen zum Ändern, Einfügen oder Löschen können fehlschlagen, wenn das Schreiben in eine oder mehrere Spalten nicht möglich ist. Ändern Sie die Cursorzuordnung, um diesen Fehler zu beheben.
Festlegen von Daten in Zeilen
CRowset::SetData legt Datenwerte in einer oder mehreren Spalten der aktuellen Zeile fest. Der folgende Code legt die Werte von Datenmembern fest, die an die Spalten Name und Units in Stock der Tabelle Products gebunden sind. Anschließend wird SetData aufgerufen, um diese Werte in die hundertste Zeile des Rowsets zu schreiben:
// Instantiate a rowset based on the user record class
CTable<CAccessor<CProductAccessor> > product;
CSession session;
// Open the rowset and move to the 100th row
product.Open(session, "Product", &ps, 1); // ps is the property set
product.MoveToBookmark(&bookmark, 0); // Assume that bookmark is set to 100th row
// Change the values of columns "Name" and "Units in Stock" in the current row of the Product table
_tcscpy_s( product.m_ProductName, product.m_sizeOfProductName,
_T( "Candle" ) );
product.m_UnitsInStock = 10000;
// Set the data
HRESULT hr = product.SetData( );
Einfügen von Zeilen in Rowsets
CRowset::Insert erstellt und initialisiert eine neue Zeile unter Verwendung von Daten aus dem Accessor. Insert erstellt eine vollständig neue Zeile nach der aktuellen Zeile. Sie müssen angeben, ob die aktuelle Zeile unverändert bleiben soll oder zur neuen Zeile inkrementiert werden soll. Hierzu müssen Sie den Parameter bGetRow festlegen:
HRESULT Insert(int nAccessor = 0, bool bGetRow = false)
false (der Standardwert) gibt an, dass die aktuelle Zeile zur nächsten Zeile inkrementiert wird. (In diesem Fall wird auf die eingefügte Zeile verwiesen.)
true gibt an, dass die Position der aktuellen Zeile unverändert bleibt.
Der unten stehende Code legt die Werte von Datenmembern fest, die an die Spalten der Tabelle Products gebunden sind. Anschließend wird Insert aufgerufen, damit eine neue Zeile mit diesen Werten nach der hundertsten Zeile des Rowsets eingefügt wird. Es wird empfohlen, alle Spaltenwerte festzulegen um zu verhindern, dass in der neuen Zeile nicht definierte Daten auftreten:
// Instantiate a rowset based on the user record class
CTable<CAccessor<CProductAccessor> > product;
CSession session;
// Open the rowset and move to the 100th row
product.Open(session, "Product", &ps, 1); // ps is the property set
product.MoveToBookmark(&bookmark, 0); // Assume that bookmark is set to 100th row
// Set the column values for a row of the Product table, then insert the row
product.m_ProductID = 101;
_tcscpy_s( product.m_ProductName, product.m_sizeOfProductName,
_T( "Candle" ) );
product.m_SupplierID = 27857;
product.m_CategoryID = 372;
_tcscpy_s( product.m_QuantityPerUnit, product.m_sizeOfQuantityPerUnit,
_T( "Pack of 10" ) );
product.m_UnitPrice = 20;
product.m_UnitsInStock = 10000;
product.m_UnitsOnOrder = 5201;
product.m_ReorderLevel = 5000;
product.m_Discontinued = false;
// You must also initialize the status and length fields before setting/inserting data
// Set the column status values
m_dwProductIDStatus = DBSTATUS_S_OK;
m_dwProductNameStatus = DBSTATUS_S_OK;
m_dwSupplierIDStatus = DBSTATUS_S_OK;
m_dwCategoryIDStatus = DBSTATUS_S_OK;
m_dwQuantityPerUnitStatus = DBSTATUS_S_OK;
m_dwUnitPriceStatus = DBSTATUS_S_OK;
m_dwUnitsInStockStatus = DBSTATUS_S_OK;
m_dwUnitsOnOrderStatus = DBSTATUS_S_OK;
m_dwReorderLevelStatus = DBSTATUS_S_OK;
m_dwDiscontinuedStatus = DBSTATUS_S_OK;
// Set the column length value for column data members that are not fixed-length types.
// The value should be the length of the string that you are setting.
m_dwProductNameLength = 6; // "Candle" has 6 characters
m_dwQuantityPerUnitLength = 10; // "Pack of 10" has 10 characters
// Insert the data
HRESULT hr = product.Insert( );
Ein ausführlicheres Beispiel finden Sie unter CRowset::Insert.
Weitere Informationen zum Festlegen der Datenmember für Status und Länge finden Sie unter Feldstatus-Datenmember in vom Assistenten generierten Accessoren.
Löschen von Zeilen aus Rowsets
CRowset::Delete löscht die aktuelle Zeile aus dem Rowset. Der folgende Code ruft Delete auf, um die hundertste Zeile des Rowsets zu entfernen:
// Instantiate a rowset based on the user record class
CTable<CAccessor<CProductAccessor> > product;
CSession session;
// Open the rowset and move to the 100th row
product.Open(session, "Product", &ps, 1); // ps is the property set
product.MoveToBookmark(&bookmark, 0); // Assume that bookmark is set to 100th row
// Delete the row
HRESULT hr = product.Delete( );
Unverzügliche und verzögerte Aktualisierungen
Wenn nicht anders festgelegt, bewirkt das Aufrufen der SetData-Methode, der Insert-Methode und der Delete-Methode eine unverzügliche Aktualisierung des Datenspeichers. Sie können Aktualisierungen jedoch verzögern. Der Consumer speichert hierbei alle Änderungen in einem lokalen Cache und überträgt sie dann an den Datenspeicher, wenn eine der folgenden Aktualisierungsmethoden aufgerufen wird:
CRowset::Update überträgt Änderungen, die seit dem letzten Sammeln oder dem letzten Update-Aufruf an der aktuellen Zeile vorgenommen wurden.
CRowset::Update überträgt Änderungen, die seit dem letzten Sammeln oder dem letzten Update-Aufruf an allen Zeilen vorgenommen wurden.
Beachten Sie, dass der Begriff Aktualisieren für die Aktualisierungsmethoden mit der spezifischen Bedeutung Änderungen auf Befehl vornehmen verwendet wird und nicht mit dem SQL-Befehl UPDATE verwechselt werden darf. (SetData entspricht dem SQL-Befehl UPDATE.)
In bestimmten Situationen sind verzögerte Aktualisierungen sinnvoll. Wenn Sie beispielsweise eine Reihe von Geldtransaktionen vornehmen und eine der Transaktionen abgebrochen wird, können Sie die Änderung rückgängig machen, da die Änderungen erst nach der Ausführung der letzten Änderung übermittelt werden. Der Anbieter kann die Änderungen auch in einem Netzwerkaufruf bündeln. Dies ist eine noch effizientere Methode.
Um verzögerte Aktualisierungen zu unterstützen, müssen Sie zusätzlich zu den unter "Unterstützen von Aktualisierungsoperationen" beschriebenen Eigenschaften die DBPROP_IRowsetChange-Eigenschaft festlegen:
pPropSet->AddProperty(DBPROP_IRowsetUpdate, true);
Wenn Sie Update oder UpdateAll aufrufen, übertragen die Methoden Änderungen vom lokalen Cache in den Datenspeicher. Anschließend wird der lokale Cache bereinigt. Mithilfe von Update werden lediglich Änderungen für die aktuelle Zeile übertragen. Deshalb ist es wichtig, dass die Anwendung stets "weiß", welche Zeile wann aktualisiert werden soll. Im folgenden Beispiel wird das Aktualisieren von zwei aufeinander folgenden Zeilen demonstriert:
// Instantiate a rowset based on the user record class
CTable<CAccessor<CProductAccessor> > product;
CSession session;
// Open the rowset and move to the 100th row
product.Open(session, "Product", &ps, 1); // ps is the property set
product.MoveToBookmark(&bookmark, 0); // Assume that bookmark is set to 100th row
// Change the values of columns "Name" and "Units in Stock" in the 100th row of the Product table
_tcscpy_s( product.m_ProductName, product.m_sizeOfProductName,
_T( "Wick" ) );
product.m_UnitsInStock = 10000;
HRESULT hr = product.SetData( ); // No changes made to row 100 yet
product.Update(); // Update row 100 now
// Change the values of columns "Name" and "Units in Stock" in the 101st row of the Product table
product.MoveNext( );
_tcscpy_s( product.m_ProductName, product.m_sizeOfProductName
_T( "Wax" ) );
product.m_UnitsInStock = 500;
HRESULT hr = product.SetData( ); // No changes made to row 101 yet
product.Update(); // Update row 101 now
Um sicherzustellen, dass vorgenommene Änderungen übertragen werden, sollten Sie Update aufrufen, bevor Sie zu einer anderen Zeile wechseln. Erscheint es Ihnen jedoch als zu aufwendig oder ineffizient, wenn die Anwendung beispielsweise Hunderte von Zeilen aktualisieren muss, können Sie mithilfe von UpdateAll alle Zeilen auf einmal aktualisieren.
Wenn beispielsweise der erste Update-Aufruf im oben stehenden Code fehlen würde, bliebe Zeile 100 unverändert, während Zeile 101 geändert werden würde. Nach diesem Punkt müsste die Anwendung entweder UpdateAll aufrufen oder zu Zeile 100 zurückgehen und Update aufrufen, damit diese Zeile aktualisiert werden könnte.
Und schließlich ist einer der Hauptgründe für die Verwendung verzögerter Aktualisierungen die Möglichkeit, sie rückgängig machen zu können. Wenn Sie CRowset::Undo aufrufen, wird der Zustand des lokalen Änderungscaches dem Status des Datenspeichers vor dem Ausführen der Änderungen entsprechend wiederhergestellt. Dabei müssen Sie beachten, dass Undo den Status des lokalen Cache nicht um einen einzelnen Schritt (also auf den Zustand vor der letzten Änderung) zurücksetzt, sondern den lokalen Cache für die ganze Zeile bereinigt. Darüber hinaus wirkt sich Undo nur auf die aktuelle Zeile aus.