Hello! I can see that you only define data source locally. It needs to be defined on all server nodes participating in cache load.
Please take a look at https://apacheignite-mix.readme.io/docs/examples Regards, -- Ilya Kasnacheev пн, 27 янв. 2020 г. в 17:45, nithin91 < nithinbharadwaj.govindar...@franklintempleton.com>: > Hi Belyakov, > > Thank you so much. This is very helpful. > > I am facing the following error when i am using this approach > > Failed to start component: class org.apache.ignite.IgniteException: Failed > to initialize cache store (data source is not provided). > > Below is the code used for implementation.I have configured the data source > property correctly but not sure why this error pops up.Can you please help > me on this. > > package ignite.example.ignite_read; > > import java.sql.SQLException; > import java.util.ArrayList; > import java.util.HashSet; > import java.util.LinkedHashMap; > import java.util.Set; > > //import javax.activation.DataSource; > import javax.cache.configuration.Factory; > import javax.cache.integration.CacheLoaderException; > import javax.sql.DataSource; > > import org.apache.ignite.Ignite; > import org.apache.ignite.IgniteCache; > import org.apache.ignite.IgniteException; > import org.apache.ignite.Ignition; > import org.apache.ignite.cache.CacheAtomicityMode; > import org.apache.ignite.cache.CacheMode; > import org.apache.ignite.cache.QueryEntity; > import org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory; > import org.apache.ignite.cache.store.jdbc.JdbcType; > import org.apache.ignite.cache.store.jdbc.JdbcTypeField; > import org.apache.ignite.cache.store.jdbc.dialect.OracleDialect; > import org.apache.ignite.configuration.CacheConfiguration; > import org.apache.ignite.configuration.IgniteConfiguration; > import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; > import > org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; > > import oracle.jdbc.pool.OracleDataSource; > > public class IgniteCacheload { > > @SuppressWarnings("unchecked") > public static void main(String[] args) throws IgniteException, > SQLException > { > > > > > IgniteConfiguration config = new IgniteConfiguration(); > /* > // config code > * > > try (Ignite ignite = Ignition.start(config)){ > > CacheConfiguration<ProductKey,Products> prdCacheCfg = new > CacheConfiguration<>(); > > prdCacheCfg.setName("ProdCache"); > prdCacheCfg.setCacheMode(CacheMode.PARTITIONED); > prdCacheCfg.setAtomicityMode(CacheAtomicityMode.ATOMIC); > > //personCacheCfg.setReadThrough(true); > //personCacheCfg.setWriteThrough(true); > > CacheJdbcPojoStoreFactory<ProductKey,Products> factory = > new > CacheJdbcPojoStoreFactory<>(); > > > factory.setDialect(new OracleDialect()); > //factory.setDataSource(dsdetails()); > factory.setDataSourceFactory(dsdetails()); > > JdbcType productType = new JdbcType(); > productType.setCacheName("ProdCache"); > productType.setKeyType(ProductKey.class); > productType.setValueType(Products.class); > // Specify the schema if applicable > > productType.setDatabaseTable("table"); > > productType.setKeyFields(new > JdbcTypeField(java.sql.Types.VARCHAR, "fid", > ProductKey.class, "FID")); > productType.setValueFields(new > JdbcTypeField(java.sql.Types.VARCHAR, > "scode", Products.class, "scode")); > > > factory.setTypes(productType); > > prdCacheCfg.setCacheStoreFactory(factory); > > > config.setCacheConfiguration(prdCacheCfg); > > > > IgniteCache<ProductKey, Products> cache = > ignite.getOrCreateCache(prdCacheCfg); > > cache.clear(); > > // Load cache on all data nodes with default SQL statement. > System.out.println(">>> Load ALL data to cache from DB..."); > cache.loadCache(null); > > > System.out.println(">>> Loaded cache entries: " + > cache.size()); > > } > catch (Exception e) { > throw new CacheLoaderException("Failed to load the cache"+ > e.getMessage()); > > } > > > } > > public static Factory<DataSource> dsdetails() throws SQLException{ > //public static DataSource dsdetails() throws SQLException{ > OracleDataSource oraDataSrc = new OracleDataSource(); > oraDataSrc.setURL("url"); > oraDataSrc.setUser("username"); > oraDataSrc.setPassword("pswd"); > //return oraDataSrc; > return (Factory<DataSource>)oraDataSrc; > > } > > } > > > > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >
