-
Notifications
You must be signed in to change notification settings - Fork 1.9k
/
put_get_example.cpp
125 lines (94 loc) · 3.5 KB
/
put_get_example.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
/*
* 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.
*/
#include <iostream>
#include "ignite/ignite.h"
#include "ignite/ignition.h"
#include "ignite/examples/organization.h"
using namespace ignite;
using namespace cache;
using namespace examples;
/*
* Execute individual Put and Get operations.
*
* @param cache Cache instance.
*/
void PutGet(Cache<int, Organization>& cache)
{
// Create new Organization to store in cache.
Organization org("Microsoft", Address("1096 Eddy Street, San Francisco, CA", 94109));
// Put organization to cache.
cache.Put(1, org);
// Get recently created employee as a strongly-typed fully de-serialized instance.
Organization orgFromCache = cache.Get(1);
std::cout << ">>> Retrieved organization instance from cache: " << std::endl;
std::cout << orgFromCache.ToString() << std::endl;
std::cout << std::endl;
}
/*
* Execute bulk Put and Get operations.
*/
void PutGetAll(Cache<int, Organization>& cache)
{
// Create new Organizations to store in cache.
Organization org1("Microsoft", Address("1096 Eddy Street, San Francisco, CA", 94109));
Organization org2("Red Cross", Address("184 Fidler Drive, San Antonio, TX", 78205));
// Put created data entries to cache.
std::map<int, Organization> vals;
vals[1] = org1;
vals[2] = org2;
cache.PutAll(vals);
// Get recently created organizations as a strongly-typed fully de-serialized instances.
std::set<int> keys;
keys.insert(1);
keys.insert(2);
std::map<int, Organization> valsFromCache = cache.GetAll(keys);
std::cout << ">>> Retrieved organization instances from cache: " << std::endl;
for (std::map<int, Organization>::iterator it = valsFromCache.begin(); it != valsFromCache.end(); ++it)
std::cout << it->second.ToString() << std::endl;
std::cout << std::endl;
}
int main()
{
IgniteConfiguration cfg;
cfg.springCfgPath = "platforms/cpp/examples/put-get-example/config/example-cache.xml";
try
{
// Start a node.
Ignite grid = Ignition::Start(cfg);
std::cout << std::endl;
std::cout << ">>> Cache put-get example started." << std::endl;
std::cout << std::endl;
// Get cache instance.
Cache<int, Organization> cache = grid.GetCache<int, Organization>("atomic");
// Clear cache.
cache.Clear();
PutGet(cache);
PutGetAll(cache);
// Stop node.
Ignition::StopAll(false);
}
catch (IgniteError& err)
{
std::cout << "An error occurred: " << err.GetText() << std::endl;
return err.GetCode();
}
std::cout << std::endl;
std::cout << ">>> Example finished, press 'Enter' to exit ..." << std::endl;
std::cout << std::endl;
std::cin.get();
return 0;
}