Using Java to Operate GridGain
GridGain is a memory based Distributed database and computing platform that provides distributed computing, caching, data grid, data access and other functions. Using Java to operate GridGain requires the use of its provided Java API.
Firstly, it is necessary to add the dependency of GridGain in the Maven project:
<dependency>
<groupId>org.gridgain</groupId>
<artifactId>gridgain-core</artifactId>
<version>8.8.27-M6</version>
</dependency>
Next, the following Java code samples can be used to implement data insertion, modification, query, and deletion:
import javax.cache.Cache;
import javax.cache.CacheException;
import javax.cache.CacheManager;
import javax.cache.configuration.FactoryBuilder;
import javax.cache.configuration.MutableConfiguration;
import org.apache.ignite.Ignite;
import org.apache.ignite.Ignition;
import org.apache.ignite.cache.query.ScanQuery;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.lang.IgniteBiPredicate;
public class GridGainExample {
public static void main(String[] args) {
//Starting the GridGain cluster
try (Ignite ignite = Ignition.start()) {
//Create cache configuration
CacheConfiguration<String, String> cacheCfg = new CacheConfiguration<>("myCache");
cacheCfg.setIndexedTypes(String.class, String.class);
//Create cache
Cache<String, String> cache = ignite.getOrCreateCache(cacheCfg);
//Insert Data
cache.put("key1", "value1");
cache.put("key2", "value2");
//Modify data
cache.put("key2", "updatedValue");
//Query data
String value1 = cache.get("key1");
String value2 = cache.get("key2");
System.out.println("Value1: " + value1);
System.out.println("Value2: " + value2);
//Delete data
cache.remove("key1");
//Query all data
ScanQuery<String, String> scanQuery = new ScanQuery<>(
(IgniteBiPredicate<String, String>) (key, value) -> true
);
try (CacheManager cacheManager = ignite.cache().getCacheManager()) {
Cache<String, String> allEntries = cacheManager.createCache(
"allEntries",
new MutableConfiguration<>()
.setTypes(String.class, String.class)
.setStoreByValue(false)
.setIndexedTypes(String.class, String.class)
.setCacheLoaderFactory(FactoryBuilder
.factoryOf(GridGainCacheLoader.class))
);
for (Cache.Entry<String, String> entry : cache.query(scanQuery).getAll()) {
allEntries.put(entry.getKey(), entry.getValue());
}
//Print all data
System.out.println("All Entries:");
allEntries.forEach(entry -> {
System.out.println(entry.getKey() + ": " + entry.getValue());
});
} catch (CacheException e) {
e.printStackTrace();
}
}
}
}
In the above code, the GridGain cluster was started using the 'Ignition. start()' method and a cache named 'myCache' was created. Then insert the data using the 'cache. put()' method, query the data using the 'cache. get()' method, modify the data using the 'cache. put()' method, and delete the data using the 'cache. remove()' method.
Finally, use 'ScanQuery' to query all data and store it in another cache called 'allEntries', and then print all data by traversing the cache.
It should be noted that the above code is only used to demonstrate the basic usage of GridGain, and more configuration and optimization may be required during actual use. In addition, other APIs provided by GridGain can also be used to achieve more complex operations, such as distributed computing and distributed transactions.
