Methode RegisterCQ
RegisterCQ (Kontinuierliche Abfrage)
Registriert die angegebene kontinuierliche Abfrage beim Cache-Server. Sie können diese Methode in Ihrer Anwendung mehrmals verwenden, je nachdem, ob Sie Benachrichtigungen über eine Änderung im Datensatz Ihrer Abfrage erhalten möchten. Diese Methode verwendet als Argument ein Objekt von ContinuousQuery, für das die Abfrage und die Rückrufe registriert sind.
Erklärung
void RegisterCQ(ContinuousQuery query)
Parameter
Typ | Name und Vorname | Beschreibung |
---|---|---|
ContinuousQuery | query | SQL-ähnliche Abfrage, die im Cache ausgeführt werden soll. |
Beispiele
Das folgende Beispiel zeigt, wie eine kontinuierliche Abfrage mit Rückrufen zum Hinzufügen, Aktualisieren und Entfernen von Elementen registriert wird.
ICache cache = CacheManager.GetCache("demoCache");
string queryString = "SELECT MyApplication.Employee WHERE this.Salary > ?";
QueryCommand queryCommand = new QueryCommand(queryString);
queryCommand.Parameters.Add("Salary", 50000);
ContinuousQuery continuousQuery = new ContinuousQuery(queryCommand);
continuousQuery.RegisterNotification(new QueryDataNotificationCallback(query_ItemAdded), EventType.ItemAdded, EventDataFilter.None);
continuousQuery.RegisterNotification(new QueryDataNotificationCallback(query_ItemUpdated), EventType.ItemUpdated, EventDataFilter.DataWithMetadata);
continuousQuery.RegisterNotification(new QueryDataNotificationCallback(query_ItemRemoved), EventType.ItemRemoved, EventDataFilter.None);
cache.MessagingService.RegisterCQ(continuousQuery);