# IGNITE-330 Fixed Demo logic.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/46d054d2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/46d054d2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/46d054d2 Branch: refs/heads/ignite-45-gridcache Commit: 46d054d2920657f7854520e4eb2cd7ce36798de4 Parents: a34d786 Author: AKuznetsov <[email protected]> Authored: Mon Mar 23 22:02:02 2015 +0700 Committer: AKuznetsov <[email protected]> Committed: Mon Mar 23 22:02:02 2015 +0700 ---------------------------------------------------------------------- .../main/java/org/apache/ignite/schema/Demo.java | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/46d054d2/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java ---------------------------------------------------------------------- diff --git a/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java b/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java index fdeffab..7e0ed72 100644 --- a/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java +++ b/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java @@ -18,8 +18,10 @@ package org.apache.ignite.schema; import org.apache.ignite.*; +import org.apache.ignite.cache.store.*; import org.apache.ignite.configuration.*; +import javax.cache.*; import javax.cache.configuration.*; /** @@ -34,7 +36,12 @@ public class Demo { CacheConfiguration ccfg = new CacheConfiguration<>(); // Configure cache store. - ccfg.setCacheStoreFactory(new FactoryBuilder.SingletonFactory(CacheConfig.store())); + ccfg.setCacheStoreFactory(new Factory<CacheStore>() { + @Override public CacheStore create() { + return CacheConfig.store(); + } + }); + ccfg.setReadThrough(true); ccfg.setWriteThrough(true); @@ -51,10 +58,11 @@ public class Demo { IgniteCache<PersonKey, Person> cache = ignite.jcache(null); // Demo for load cache with custom SQL. - cache.loadCache(null, "org.apache.ignite.examples.demo.PersonKey", - "select * from PERSON where ID = 3"); + cache.loadCache(null, "org.apache.ignite.schema.PersonKey", + "select * from PERSON where ID <= 3"); - System.out.println(">>> Loaded Person: " + cache.get(new PersonKey(3))); + for (Cache.Entry<PersonKey, Person> aCache : cache) + System.out.println(">>> Loaded Person: " + aCache); } } }
