src/quickstart/cpp/PutAllGetAllOperations.cpp

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

/*
 * The PutAllGetAllOperations QuickStart Example.
 *
 * This example takes the following steps:
 *
 * 1. Create a Geode Cache using CacheFactory. By default it will connect to
 * "localhost" at port 40404".
 * 2. Create a Example Region.
 * 3. PutAll Entries (Key and Value pairs) into the Region.
 * 4. GetAll Entries from the Region.
 * 5. Close the Cache.
 *
 */

// Include the Geode library.
#include <gfcpp/GeodeCppCache.hpp>

// Use the "geode" namespace.
using namespace apache::geode::client;

// The PutAllGetAllOperations QuickStart example.
int main(int argc, char** argv) {
  try {
    // Create a Geode Cache using CacheFactory. By default it will connect to
    // "localhost" at port 40404".
    CachePtr cachePtr = CacheFactory::createCacheFactory()->create();

    LOGINFO("Created the Geode Cache");

    // Set Attributes for the region.
    RegionFactoryPtr regionFactory =
        cachePtr->createRegionFactory(CACHING_PROXY);

    // Create exampleRegion.
    RegionPtr regionPtr = regionFactory->create("exampleRegion");

    LOGINFO("Created the Region");

    // Put bulk Entries (Key and Value pairs) into the Region.
    HashMapOfCacheable entryMap;
    char key[2048];
    char value[2048];
    for (int32_t item = 0; item < 100; item++) {
      sprintf(key, "key-%d", item);
      sprintf(value, "%d", item);
      entryMap.insert(CacheableKey::create(key),
                      CacheableString::create(value));
    }
    regionPtr->putAll(entryMap);

    LOGINFO("PutAll 100 entries into the Region");

    // GetAll Entries back out of the Region
    VectorOfCacheableKey keys;
    for (int32_t item = 0; item < 100; item++) {
      sprintf(key, "key-%d", item);
      keys.push_back(CacheableKey::create(key));
    }

    HashMapOfCacheablePtr values(new HashMapOfCacheable());
    regionPtr->getAll(keys, values, NULLPTR, true);

    LOGINFO("Obtained 100 entries from the Region");

    // Close the Geode Cache.
    cachePtr->close();

    LOGINFO("Closed the Geode Cache");

    return 0;

  }
  // An exception should not occur
  catch (const Exception& geodeExcp) {
    LOGERROR("PutAllGetAllOperations Geode Exception: %s",
             geodeExcp.getMessage());

    return 1;
  }
}