Second, review the information on the Driver implementation found here:

The Driver

Has a static main method that executes all the Contacts examples in the following order:

• LoaderExample
• QueryExample
• ObserverExample
• BasicExample
• ProcessorExample

Is implemented in each of the three programming languages supported by Coherence:

Please refer to this example set's source code for more details on each of the examples outlined below.

Basic Data Access Example

This example shows the most basic data access features of Coherence including getting, putting and removing data.

cache.put(contactId, contact);

contact = (Contact) cache.get(contactId);

cache.remove(contactId);

cache.Add(contactId, contact);

contact = (Contact)cache[contactId];

cache.Remove(contactId);

hCache->put(vContactId, vContact);

vContact = cast<Managed<Contact>::View>(hCache->get(vContactId));

hCache->remove(vContactId);

The example Output (due to Observer Example):

entry inserted:
John Nocyefqgqo
Addresses
Home: 1500 Boylston St.
null
Obopnof, NM 88824
US
Work: 8 Yawkey Way
null
Ssedhvmdeq, OR 84217
US
Phone Numbers
work: +11 0 707 3776578
Birth Date: 1971-12-31
entry deleted:
John Nocyefqgqo
Addresses
Home: 1500 Boylston St.
null
Obopnof, NM 88824
US
Work: 8 Yawkey Way
null
Ssedhvmdeq, OR 84217
US
Phone Numbers
work: +11 0 707 3776578
Birth Date: 1971-12-31

Loader Example

This example loads contacts into the cache from a file or stream.

It demonstrates the most effective way of inserting data into a cache using bulk inserts. This will allow for minimizing the number of network roundtrips between the application and the cache.

cache.putAll(mapBatch);

cache.InsertAll(dictBatch);

hCache->putAll(hMapBatch);

Example output:

.........Added 10000 entries to cache

Query Example

QueryExample runs sample queries for contacts.

The purpose of this example is to show how to create Extractors on cache data and how to create a KeyExtractor for the cache keys. It also illustrates how to use the indexes to filter the dataset in order to efficiently create a matching set. Finally, the example demonstrates how to use some of the built-in cache aggregators to do simple computational tasks on the cache data. A subset of the code is shown below.

cache.addIndex(new ChainedExtractor("getHomeAddress.getState"), /*fOrdered*/ false, /*comparator*/ null);

Set setResults = cache.entrySet(new EqualsFilter("getHomeAddress.getState", "MA"));

System.out.println("count > " + nAge + ": " + cache.aggregate(new GreaterFilter("getAge", nAge), new Count()));

cache.AddIndex(new ChainedExtractor("getHomeAddress.getState"),/*fOrdered*/ false, /*comparator*/ null);

ICacheEntry[] aCacheEntry = cache.GetEntries(new EqualsFilter("getHomeAddress.getState", "MA"));

Console.WriteLine("count > " + nAge + ": "+ cache.Aggregate(new GreaterFilter("getAge", nAge), new Count()));

ValueExtractor::View vHomeStateExtractor = ChainedExtractor::create(
   ChainedExtractor::createExtractors("getHomeAddress.getState"));

Object::View voStateName = String::create("MA");
Set::View setResults = hCache->entrySet(
      EqualsFilter::create(vHomeStateExtractor, voStateName));

Integer32::View nAge = Integer32::valueOf(58);
Object::View vResult = hCache->aggregate(
      (Filter::View) GreaterFilter::create(vAgeExtractor, nAge),
         Count::create());
std::cout << "count > " << nAge->getValue() << ": " << vResult << std::endl;

The example output is large due to 10,000 contacts and several queries. A sample of the query for Massachusetts residents:

MA Residents
ConverterEntry{Key="John Scqngqda", Value="John Scqngqda
Addresses
Home: 265 Beacon St.

Oaskxm, MA 88259
US
Work: Yoyodyne Propulsion Systems
330 Lectroid Rd.
Grover's Mill, OK 95744
US
Phone Numbers
work: +11 88 903 8991283
home: +11 98 553 5878221
Birth Date: 1960-01-03"}

Observer Example

ObserverExample demonstrates how to use a MapListener to monitor cache events such as when cache data has been inserted, updated, and removed. A subset of the code is shown below.

cache.addMapListener(new ContactChangeListener());

cache.AddCacheListener(new ContactChangeListener());

ContactChangeListener::Handle hListener = ContactChangeListener::create();
hCache->addFilterListener(hListener);

class ContactChangeListener
   : public class_spec<ContactChangeListener,
         extends <MapListener> >

There is no immediate output when this example is run. The registered listener outputs the entry when it is inserted, updated, and deleted. For an update, it outputs both the old value and the new value. The changes to entries are caused by running the Basic Data Access Example and the Processor Example, so the output happens when those examples are run.

Processor Example

ProcessorExample demonstrates how to use a processor to modify a set of data in the cache. In the code sample that follows, all Contacts who live in MA will have their work address updated.

cache.invokeAll(new EqualsFilter("getHomeAddress.getState", "MA"), new OfficeUpdater(addrWork));

cache.InvokeAll(new EqualsFilter("getHomeAddress.getState", "MA"), new OfficeUpdater(addrWork));

class OfficeUpdater
   : public class_spec<OfficeUpdater,
      extends<UpdaterProcessor>,
      implements<PortableObject> >

Filter::View vEqualsFilter = EqualsFilter::create(
            ChainedExtractor::create(ChainedExtractor::createExtractors(
                    "getHomeAddress.getState")),
                    String::create("MA"));
InvocableMap::EntryProcessor::Handle hOffice = OfficeUpdater::create(addrWork);
Map::View vMap = hCache->invokeAll(vEqualsFilter, hOffice);

The example Output (due to Observer Example) is large due to the number of contacts. A sample of output:

entry updated
old value:
John Keau
Addresses
Home: 443 Beacon St.

Ophvowvw, MA 06539
US
Work: Yoyodyne Propulsion Systems
330 Lectroid Rd.
Grover's Mill, FL 86812
US
Phone Numbers
work: +11 8 919 9456102
home: +11 25 759 588823
Birth Date: 1968-12-31
new value:
John Keau
Addresses
Home: 443 Beacon St.

Ophvowvw, MA 06539
US
Work: 200 Newbury St.
Yoyodyne, Ltd.
Boston, MA 02116
US
Phone Numbers
work: +11 8 919 9456102
home: +11 25 759 588823
entry updated
old value:
John Lbggblkd
Addresses
Home: 929 Beacon St.

Trwylbmf, MA 50358
US
Work: Yoyodyne Propulsion Systems
330 Lectroid Rd.
Grover's Mill, AZ 19164
US
Phone Numbers
work: +11 60 699 203810
home: +11 34 149 5018157
Birth Date: 1964-01-02
new value:
John Lbggblkd
Addresses
Home: 929 Beacon St.

Trwylbmf, MA 50358
US
Work: 200 Newbury St.
Yoyodyne, Ltd.
Boston, MA 02116
US
Phone Numbers
work: +11 60 699 203810
home: +11 34 149 5018157
Birth Date: 1964-01-02

Birth Date: 1968-12-31

Data Generator

The DataGenerator has a static main method that generates random Contact information and stores the results in a
comma separated value file. This class was used to generate the contacts.csv that is packaged with the contacts examples and is included in case more sample data is needed.

It is implemented only in Java.