Interrogazione su strutture dati
Le strutture di dati possono essere interrogate nella cache se ne hanno attributi ricercabili ad essi associati durante la creazione della struttura dati. Questi attributi ricercabili includono:
Prerequisiti
- Per conoscere i prerequisiti standard richiesti per lavorare con all NCache Per le funzionalità lato client fare riferimento alla pagina specificata Prerequisiti dell'API lato client.
- Per i dettagli dell'API, fare riferimento a: ICache, QueryCommand, ICacheReader, Servizio di ricerca, Esegui Lettore, Ottieni valore, IDdistributedList, OttieniDatiGruppo, Conteggio dei campi, Dizionario distribuito, OttieniPerTag.
- Per conoscere i prerequisiti standard richiesti per lavorare con all NCache Per le funzionalità lato client fare riferimento alla pagina specificata Prerequisiti dell'API lato client.
- Per i dettagli dell'API, fare riferimento a: Cache, QueryCommand, Lettore di cache, getSearchService, eseguiReader, getCampoConteggio, getValore, Elenco distribuito, getGroupData, Attributi della struttura dati, Mappa distribuita, getPerTag.
- Per conoscere i prerequisiti standard richiesti per lavorare con all NCache Per le funzionalità lato client fare riferimento alla pagina specificata Prerequisiti dell'API lato client.
- Per i dettagli dell'API, fare riferimento a: Cache, QueryCommand, Servizio di ricerca, getSearchService, eseguiReader, getCampoConteggio, getValore, getGroupData, Lettore di cache, Attributi della struttura dati, getPerTag.
- Per conoscere i prerequisiti standard richiesti per lavorare con all NCache Per le funzionalità lato client fare riferimento alla pagina specificata Prerequisiti dell'API lato client.
- Per i dettagli API fare riferimento a: Cache, QueryCommand, Lettore di cache, esegui_lettore, Servizio di ricerca, get_search_service, Attributi della struttura dati, get_field_count, ottieni_valore, get_group_data, get_by_tag.
Cerca strutture dati per gruppi
Query SQL
Il seguente esempio di codice recupera tutti gli elementi dalla cache che sono stati associati a un gruppo specificato, Elettronica. Il Gruppo può essere associato utilizzando DataTypeAttributes
classe durante la creazione della struttura dati.
Consigli
- Se sono presenti più elenchi specificati per il gruppo, verranno restituiti tutti in un unico risultato, a condizione che le loro strutture di dati siano simili.
- Per più elementi della cache, ad esempio, se a
CacheItem
e un elenco appartengono allo stesso gruppo, è necessario assicurarsi che i dati vengano gestiti di conseguenza.
// Preconditions: Cache is already connected
// Items with groups exist in cache
// Custom class is query indexed through the NCache Management Center or config.ncconf
// Search for items with group
// Provide Fully Qualified Name (FQN) of your custom class
string query = "SELECT ProductID FROM FQN.Customer WHERE $Group$ = ?";
/// Use QueryCommand for query execution
var queryCommand = new QueryCommand(query);
// Providing parameters for query
queryCommand.Parameters.Add("$Group$", "Electronics");
// Executing QueryCommand through ICacheReader
ICacheReader reader = cache.SearchService.ExecuteReader(queryCommand);
// Check if the result set is not empty
if (reader.FieldCount > 0)
{
while (reader.Read())
{
string ProductID = reader.GetValue<string>(1);
// Perform operations
}
}
else
{
// Null query result set retrieved
}
// Preconditions: Cache is already connected
// Items with groups exist in cache
// Custom class is query indexed through NCache Management Center or config.ncconf
// Search for items with group
// Provide Fully Qualified Name (FQN) of your custom class
String query = "SELECT productID FROM FQN.Customer WHERE $Group$ = ?";
// Use QueryCommand for query execution
var queryCommand = new QueryCommand(query);
// Providing parameters for query
queryCommand.getParameters().put("$Group$", "Electronics");
// Executing QueryCommand through CacheReader
CacheReader reader = cache.getSearchService().executeReader(queryCommand);
// Check if the result set is not empty
if (reader.getFieldCount() > 0) {
while (reader.read()) {
String productID = reader.getValue(1, String.class);
// Perform operations
}
} else {
// Null query result set retrieved
}
// This is an async method
// Preconditions: Cache is already connected
// Items with groups exist in cache
// Custom class is query indexed through the NCache Management Center or config.ncconf
// Search for items with group
// Provide Fully Qualified Name (FQN) of your custom class
var query = "SELECT productID FROM FQN.Customer WHERE $Group$ = ?";
/// Use QueryCommand for query execution
var queryCommand = new ncache.QueryCommand(query);
// Providing parameters for query
let map = new Map();
var parameters = map.set("$Group$", "Electronics");
queryCommand.setParameters(parameters);
// Executing QueryCommand through CacheReader
var searchService = await this.cache.getSearchService();
var reader = await searchService.executeReader(queryCommand);
// Check if the result set is not empty
if (reader.getFieldCount() > 0) {
while (reader.read()) {
var productID = reader.getValue(1, Number());
// Perform operations
}
} else {
// Null query result set retrieved
}
# Preconditions: Cache is already connected
# Items with groups exist in cache
# Custom class is query indexed through NCache Management Center or config.ncconf
# Search for items with group
# Provide Fully Qualified Name (FQN) of your custom class
query = "SELECT product_id FROM FQN.Customer WHERE $Group$ = ?"
# Use QueryCommand for query execution
query_command = ncache.QueryCommand(query)
# Providing parameters for query
parameters = {"$Group$": "Electronics"}
query_command.set_parameters(parameters)
# Executing QueryCommand through CacheReader
search_service = cache.get_search_service()
reader = search_service.execute_reader(query_command)
# Check if the result set is not empty
if reader.get_field_count() > 0:
while reader.read():
product_id = reader.get_value(str, 1)
# Perform operations
else:
# None query result set retrieved
print("Query result is None")
API di gruppo
Il seguente esempio di codice recupera tutti gli elenchi dalla cache che sono stati associati a un gruppo specificato, Elettronica. Il gruppo può essere associato utilizzando DataTypeAttributes
classe durante la creazione della struttura dati.
// List with this group already exists in cache
string groupName = "Electronics";
IDictionary<string, IDistributedList<Product>> result = cache.SearchService.GetGroupData<IDistributedList<Product>>(groupName);
if (result != null && result.Count > 0)
{
// Iterate over list
foreach (var item in result)
{
foreach (var i in item.Value)
{
// Perform operations
}
}
}
else
{
// No data against the group found
}
// Precondition: Cache is already connected
// List with this group already exists in the cache
String groupName = "Electronics";
Map<String, DistributedList<Product>> result = cache.getSearchService().getGroupData(groupName);
if (result != null && result.size() > 0) {
// Iterate over list
for (var item : result.entrySet()) {
// Perform operations
}
} else {
// No data against the group found
}
// This is an async method
// Precondition: Cache is already connected
// List with this group already exists in the cache
var groupName = "Electronics";
var result = await (
await this.cache.getSearchService()
).getGroupData(groupName);
if (result != null && result.size() > 0) {
// Iterate over list
for (var item in result.entrySet()) {
// Perform operations
}
} else {
// No data against the group found
}
# Precondition: Cache is already connected
# List with this group already exists in the cache
group_name = "Electronics"
result = cache.get_search_service().get_group_data(group_name)
if result is not None and len(result) > 0:
# Iterate over list
for item in result:
# Perform operations
print(item)
else:
# No data against the group found
print("No data found")
Note:
Per garantire che l'operazione sia a prova di errore, si consiglia di gestire eventuali potenziali eccezioni all'interno dell'applicazione, come spiegato in Gestione dei guasti.
Query SQL
Il seguente esempio di codice recupera gli elementi dalla cache che sono stati associati a un tag specificato, Acciaio inossidabile. Il tag può essere associato utilizzando DataTypeAttributes
classe durante la creazione della struttura dati.
// Items are already present in the cache with tags
// Custom class is query indexed through NCache Management Center or config.ncconf
// Search for items with tags
// Use the Fully Qualified Name (FQN) of your own custom class
string query = "Select $Value$ FROM FQN.Product WHERE $Tag$ = ?";
// Use QueryCommand for query execution
var queryCommand = new QueryCommand(query);
queryCommand.Parameters.Add("$Tag$", "Stainless Steel");
// Executing query
ICacheReader reader = cache.SearchService.ExecuteReader(queryCommand);
// Check if result set is not empty
if (reader.FieldCount > 0)
{
while (reader.Read())
{
// Get the value of the result set
Product result = reader.GetValue<Product>(1);
}
}
else
{
// Null query result set retrieved
}
// Pre-conditions: Cache is already connected
// Items are already present in the cache with tags
// Custom class is query indexed through NCache Management Center or config.ncconf
// Search for items with tags
// Use the Fully Qualified Name (FQN) of your own custom class
String query = "Select $Value$ FROM FQN.Product WHERE $Tag$ = ?";
// Use QueryCommand for query execution
var queryCommand = new QueryCommand(query);
queryCommand.getParameters().put("$Tag$", "Stainless Steel");
// Executing query
CacheReader reader = cache.getSearchService().executeReader(queryCommand);
// Check if result set is not empty
if (reader.getFieldCount() > 0) {
while (reader.read()) {
// Get the value of the result set
Product result = reader.getValue(1, Product.class);
}
} else {
// Null query result set retrieved
}
// This is an async method
// Pre-conditions: Cache is already connected
// Items are already present in the cache with tags
// Custom class is query indexed through NCache Management Center or config.ncconf
// Search for items with tags
// Use the Fully Qualified Name (FQN) of your own custom class
var query = "Select $Value$ FROM FQN.Product WHERE $Tag$ = ?";
// Use QueryCommand for query execution
var queryCommand = new ncache.QueryCommand(query);
var map = new Map();
var parameters = map.set("$Tag$", "Stainless Steel");
queryCommand.setParameters(parameters);
// Executing query
var searchService = await this.cache.getSearchService();
var reader = await searchService.executeReader(queryCommand);
// Check if result set is not empty
if (reader.getFieldCount() > 0) {
while (reader.read()) {
// Get the value of the result set
var result = reader.getValue(1, ncache.JsonDataType.Object);
// Perform operations
}
} else {
// Null query result set retrieved
}
# Pre-conditions: Cache is already connected
# Items are already present in the cache with tags
# Custom class is query indexed through NCache Management Center or config.ncconf
# Search for items with tags
# Use the Fully Qualified Name (FQN) of your own custom class
query = "Select $Value$ FROM FQN.Product WHERE $Tag$ = ?"
# Use QueryCommand for query execution
query_command = ncache.QueryCommand(query)
parameters = {"$Tag$": "Stainless Steel"}
query_command.set_parameters(parameters)
# Executing query
search_service = cache.get_search_service()
reader = search_service.execute_reader(query_command)
# Check if result set is not empty
if reader.get_field_count() > 0:
while reader.read():
# Get the value of the result set
result = reader.get_value(Product, 1)
# Perform operations
else:
# Null query result set retrieved
print("Query result is None")
API dei tag
Il seguente esempio di codice recupera tutte le istanze del dizionario dalla cache che sono state associate a un tag specificato, Acciaio inossidabile. Il tag può essere associato utilizzando il DataTypeAttributes
classe durante la creazione della struttura dati.
// Items against this tag exist in cache
Tag tag = new Tag("Stainless Steel");
// Get dictionary against tag
IDictionary<string, IDistributedDictionary<string, Product>> result = cache.SearchService.GetByTag<IDistributedDictionary<string, Product>>(tag);
if (result != null && result.Count > 0)
{
foreach (var item in result)
{
// Perform operations
}
}
else
{
// Dictionary does not exist against tag
}
// Precondition: Cache is already connected
// Items against this tag already exist in the cache
Tag tag = new Tag("Stainless steel");
// Get map against tag
Map<String, DistributedMap<String, Product>> result = cache.getSearchService().getByTag(tag);
if (result != null && result.size() > 0) {
for (var item : result.entrySet()) {
// Perform operations
}
} else {
// Dictionary does not exist against tag
}
// This is an async method
// Precondition: Cache is already connected
// Items against this tag already exist in the cache
var tag = [new ncache.Tag("Stainless steel")];
// Get map against tag
var result = await (await this.cache.getSearchService()).getByTag(tag);
if (result != null && result.size() > 0) {
for (var item in result.entrySet()) {
// Perform operations
}
} else {
// Dictionary does not exist against tag
}
# Precondition: Cache is already connected
# Items against this tag already exist in the cache
tag = ncache.Tag("Stainless steel")
# Get map against tag
result = cache.get_search_service().get_by_tag(tag)
if result is not None and len(result) > 0:
for item in result:
# Perform operations
print(item)
else:
# Dictionary does not exist against tag
print("Dictionary not found")
NCache utilizza l' $DataType$
parola chiave che recupererà tutte le strutture di dati con il tag denominato specificato. Il codice seguente presuppone che sia stato aggiunto un elenco con Named Tag Codice Sconto con un valore 0.4 e lo recupera usando le query.
// Data Structures exist with NamedTag Discount and value 0.4
// Create query
string query = "SELECT * FROM $DataType$ WHERE Discount = 0.4";
// Use QueryCommand for query execution
var queryCommand = new QueryCommand(query);
// Execute Query to search cache
ICacheReader queryResult = cache.SearchService.ExecuteReader(queryCommand);
// queryResult contains all the keys and metadata of result
if (queryResult.FieldCount > 0)
{
while (queryResult.Read())
{
// Key of list can be fetched through
queryResult.GetValue<DistributedList>(1);
}
}
else
{
// Null query result set retrieved
}
// Pre-conditions: Cache is already connected
// Data Structures exist with NamedTag "Discount" and value 0.4
// Create query
String query = "SELECT * FROM $DataType$ WHERE Discount = 0.4";
// Use QueryCommand for query execution
var queryCommand = new QueryCommand(query);
// Execute Query to search cache
CacheReader queryResult = cache.getSearchService().executeReader(queryCommand);
// queryResult contains all the keys and metadata of result
if (queryResult.getFieldCount() > 0) {
while (queryResult.read()) {
// Key of list can be fetched through
queryResult.getValue(0, DistributedList.class);
// Perform operations
}
} else {
// Null query result set retrieved
}
// This is an async method
// Pre-conditions: Cache is already connected
// Data Structures exist with NamedTag "Discount" and value 0.4
// Create query
var query = "SELECT * FROM $DataType$ WHERE Discount = 0.4";
// Use QueryCommand for query execution
var queryCommand = new ncache.QueryCommand(query);
// Execute Query to search cache
var searchService = await this.cache.getSearchService();
var queryResult = await searchService.executeReader(queryCommand);
// queryResult contains all the keys and metadata of result
if (queryResult.getFieldCount() > 0) {
while (queryResult.read()) {
// Key of list can be fetched through
queryResult.getValue(0, Number());
// Perform operations
}
} else {
// Null query result set retrieved
}
# Pre-conditions: Cache is already connected
# Data Structures exist with NamedTag "Discount" and value 0.4
# Create query
query = "SELECT * FROM $DataType$ WHERE discount = 0.4"
query_command = ncache.QueryCommand(query)
# Execute Query to search cache
search_service = cache.get_search_service()
query_result = search_service.execute_reader(query_command)
# queryResult contains all the keys and metadata of result
if query_result.get_field_count() > 0:
while query_result.read():
# Key of list can be fetched through
query_result.get_value(int, 1)
# Perform operations
else:
# No data containing the named tag(s) exist
print("Data not found")
Risorse addizionali
NCache fornisce un'applicazione di esempio per eseguire query su strutture di dati GitHub.
Vedere anche
.NETTO: Alachisoft.NCache.Tipi.dati.client spazio dei nomi.
Giava: com.alachisoft.ncache.strutture.dati.client spazio dei nomi.
Node.js: Gestore struttura dati classe.
Pitone: ncache.strutture.dati.client classe.