Hi, I have used Ignite version 1.9 and gridgain version 7.8.6. So i don't have to declare any datastore/jdbc connection details as well as cache configuration details in spring XML.
On Wed, May 24, 2017 at 12:15 AM, Andrey Gura <[email protected]> wrote: > Hi, > > Make sure that you have cache store configuration on server and client > nodes. > > Also use only one type of node configuration: declarative (Spring XML) > or programmatically configuration. > > What version of Ignite do you use? I need it for applying provided > stack trace to proper version of code. > > > On Tue, May 23, 2017 at 2:16 PM, debasish pradhan <[email protected]> > wrote: > > hi , > > > > > > Please find the config file for client . > > > > import com.mchange.v2.c3p0.ComboPooledDataSource; > > import java.io.InputStream; > > import java.math.BigDecimal; > > import java.sql.Types; > > import java.util.ArrayList; > > import java.util.Arrays; > > import java.util.LinkedHashMap; > > import java.util.Properties; > > import javax.cache.configuration.Factory; > > import javax.sql.DataSource; > > 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.BasicJdbcDialect; > > import org.apache.ignite.configuration.BinaryConfiguration; > > import org.apache.ignite.configuration.CacheConfiguration; > > import org.apache.ignite.configuration.IgniteConfiguration; > > import org.apache.ignite.configuration.OdbcConfiguration; > > import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; > > import > > org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; > > //import com.timesten.jdbc.JdbcOdbcConnection; > > //import com.timesten.jdbc.TimesTenDataSource; > > > > public class ClientConfigurationFactory { > > /** Secret properties loading. **/ > > private static final Properties props = new Properties(); > > > > static { > > try (InputStream in = > > IgniteConfiguration.class.getClassLoader().getResourceAsStream("secret. > properties")) > > { > > props.load(in); > > } > > catch (Exception ignored) { > > // No-op. > > } > > } > > > > /** Helper class for datasource creation. **/ > > public static class DataSources { > > public static final ComboPooledDataSource INSTANCE_dataStore = > > createdataStore(); > > > > private static ComboPooledDataSource createdataStore() { > > ComboPooledDataSource dataStore = new > ComboPooledDataSource(); > > > > > > dataStore.setJdbcUrl("jdbc:timesten:client:TTC_Server= > localhost;TCP_PORT=53397;TTC_Server_DSN=EMSDSN;UID=test; > PWD=test;TTC_Timeout=180"); > > dataStore.setUser("kodiak"); > > dataStore.setPassword("kodiak"); > > > > return dataStore; > > } > > } > > > > > > /** > > * Configure grid. > > * > > * @return Ignite configuration. > > * @throws Exception If failed to construct Ignite configuration > > instance. > > **/ > > public static IgniteConfiguration createConfiguration() throws > Exception > > { > > IgniteConfiguration cfg = new IgniteConfiguration(); > > > > cfg.setClientMode(true); > > cfg.setGridName("TestDB1"); > > > > TcpDiscoverySpi discovery = new TcpDiscoverySpi(); > > > > TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder(); > > > > ipFinder.setAddresses(Arrays.asList("127.0.0.1:47500..47510")); > > > > discovery.setIpFinder(ipFinder); > > > > cfg.setDiscoverySpi(discovery); > > > > BinaryConfiguration binaryCfg = new BinaryConfiguration(); > > > > binaryCfg.setCompactFooter(false); > > > > cfg.setBinaryConfiguration(binaryCfg); > > > > cfg.setOdbcConfiguration(new OdbcConfiguration()); > > > > cfg.setCacheConfiguration(cacheEmployeeCache()); > > > > return cfg; > > } > > > > /** > > * Create configuration for cache "EmployeeCache". > > * > > * @return Configured cache. > > * @throws Exception if failed to create cache configuration. > > **/ > > public static CacheConfiguration cacheEmployeeCache() throws > Exception { > > CacheConfiguration ccfg = new CacheConfiguration(); > > > > ccfg.setName("EmployeeCache"); > > ccfg.setCacheMode(CacheMode.PARTITIONED); > > ccfg.setAtomicityMode(CacheAtomicityMode.ATOMIC); > > > > CacheJdbcPojoStoreFactory cacheStoreFactory = new > > CacheJdbcPojoStoreFactory(); > > > > cacheStoreFactory.setDataSourceFactory(new > Factory<DataSource>() { > > /** {@inheritDoc} **/ > > @Override public DataSource create() { > > return DataSources.INSTANCE_dataStore; > > }; > > }); > > > > cacheStoreFactory.setDialect(new BasicJdbcDialect()); > > > > cacheStoreFactory.setTypes(jdbcTypeEmployee(ccfg.getName())); > > > > ccfg.setCacheStoreFactory(cacheStoreFactory); > > > > ccfg.setReadThrough(true); > > ccfg.setWriteThrough(true); > > > > ArrayList<QueryEntity> qryEntities = new ArrayList<>(); > > > > QueryEntity qryEntity = new QueryEntity(); > > > > qryEntity.setKeyType("com.gmail.orl.debasis.model.EmployeeKey"); > > qryEntity.setValueType("com.gmail.orl.debasis.model.Employee"); > > > > LinkedHashMap<String, String> fields = new LinkedHashMap<>(); > > > > fields.put("id", "java.math.BigDecimal"); > > fields.put("firstname", "java.lang.String"); > > fields.put("lastname", "java.lang.String"); > > > > qryEntity.setFields(fields); > > qryEntities.add(qryEntity); > > > > ccfg.setQueryEntities(qryEntities); > > > > return ccfg; > > } > > > > /** > > * Create JDBC type for "jdbcTypeEmployee". > > * > > * @param cacheName Cache name. > > * @return Configured JDBC type. > > **/ > > private static JdbcType jdbcTypeEmployee(String cacheName) { > > JdbcType type = new JdbcType(); > > > > type.setCacheName(cacheName); > > type.setKeyType("com.gmail.orl.debasis.model.EmployeeKey"); > > type.setValueType("com.gmail.orl.debasis.model.Employee"); > > type.setDatabaseSchema("DG"); > > type.setDatabaseTable("EMPLOYEE"); > > > > type.setValueFields( > > new JdbcTypeField(Types.DECIMAL, "ID", BigDecimal.class, > "id"), > > new JdbcTypeField(Types.VARCHAR, "FIRSTNAME", String.class, > > "firstname"), > > new JdbcTypeField(Types.VARCHAR, "LASTNAME", String.class, > > "lastname") > > ); > > > > return type; > > } > > } > > > > ****************** > > client-config.xml > > > > <?xml version="1.0" encoding="UTF-8"?> > > > > <beans xmlns="http://www.springframework.org/schema/beans"; > > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > > xmlns:util="http://www.springframework.org/schema/util"; > > xsi:schemaLocation="http://www.springframework.org/schema/beans > > > > http://www.springframework.org/schema/beans/spring-beans.xsd > > http://www.springframework.org/schema/util > > > > http://www.springframework.org/schema/util/spring-util.xsd";> > > <!-- Load external properties file. --> > > <bean id="placeholderConfig" > > class="org.springframework.beans.factory.config. > PropertyPlaceholderConfigurer"> > > <property name="location" value="classpath:secret.properties"/> > > </bean> > > > > <!-- Data source beans will be initialized from external properties > > file. --> > > <bean id="dataStore" class="com.mchange.v2.c3p0. > ComboPooledDataSource"> > > <property name="jdbcUrl" value="${dataStore.jdbc.url}"/> > > <property name="user" value="${dataStore.jdbc.username}"/> > > <property name="password" value="${dataStore.jdbc.password}"/> > > </bean> > > > > <!-- Data source beans will be initialized from external properties > > file. --> > > <!-- <bean id="dataStore" class="com.timesten.jdbc. > TimesTenDataSource"> > > <property name="jdbcUrl" > > value="jdbc:timesten:client:TTC_Server=localhost;TCP_PORT= > 53397;TTC_Server_DSN=emsdsn;UID=kodiak;PWD=kodiak;TTC_Timeout=180"/> > > <property name="user" value="kodiak"/> > > <property name="password" value="kodiak"/> > > </bean>--> > > > > <bean class="org.apache.ignite.configuration.IgniteConfiguration"> > > <property name="clientMode" value="false"/> > > <property name="gridName" value="TestDB1"/> > > > > <property name="discoverySpi"> > > <bean > > class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> > > <property name="ipFinder"> > > <bean > > class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm. > TcpDiscoveryVmIpFinder"> > > <property name="addresses"> > > <list> > > <value>127.0.0.1:47500..47510</value> > > </list> > > </property> > > </bean> > > </property> > > </bean> > > </property> > > > > <property name="binaryConfiguration"> > > <bean > > class="org.apache.ignite.configuration.BinaryConfiguration"> > > <property name="compactFooter" value="false"/> > > </bean> > > </property> > > > > <property name="odbcConfiguration"> > > <bean class="org.apache.ignite.configuration. > OdbcConfiguration"> > > </bean> > > </property> > > > > <property name="cacheConfiguration"> > > <list> > > <bean > > class="org.apache.ignite.configuration.CacheConfiguration"> > > <property name="name" value="EmployeeCache"/> > > <property name="cacheMode" value="PARTITIONED"/> > > <property name="atomicityMode" value="ATOMIC"/> > > > > <property name="cacheStoreFactory"> > > <bean > > class="org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory"> > > <property name="dataSourceBean" > > value="dataStore"/> > > <property name="dialect"> > > <bean > > class="org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect"> > > </bean> > > </property> > > > > <property name="types"> > > <list> > > <bean > > class="org.apache.ignite.cache.store.jdbc.JdbcType"> > > <property name="cacheName" > > value="EmployeeCache"/> > > <property name="keyType" > > value="com.gmail.orl.debasis.model.EmployeeKey"/> > > <property name="valueType" > > value="com.gmail.orl.debasis.model.Employee"/> > > <property name="databaseSchema" > > value="DG"/> > > <property name="databaseTable" > > value="EMPLOYEE"/> > > > > <property name="valueFields"> > > <list> > > <bean > > class="org.apache.ignite.cache.store.jdbc.JdbcTypeField"> > > <constructor-arg> > > <util:constant > > static-field="java.sql.Types.DECIMAL"/> > > </constructor-arg> > > <constructor-arg > > value="ID"/> > > <constructor-arg > > value="java.math.BigDecimal"/> > > <constructor-arg > > value="id"/> > > </bean> > > > > <bean > > class="org.apache.ignite.cache.store.jdbc.JdbcTypeField"> > > <constructor-arg> > > <util:constant > > static-field="java.sql.Types.VARCHAR"/> > > </constructor-arg> > > <constructor-arg > > value="FIRSTNAME"/> > > <constructor-arg > > value="java.lang.String"/> > > <constructor-arg > > value="firstname"/> > > </bean> > > > > <bean > > class="org.apache.ignite.cache.store.jdbc.JdbcTypeField"> > > <constructor-arg> > > <util:constant > > static-field="java.sql.Types.VARCHAR"/> > > </constructor-arg> > > <constructor-arg > > value="LASTNAME"/> > > <constructor-arg > > value="java.lang.String"/> > > <constructor-arg > > value="lastname"/> > > </bean> > > </list> > > </property> > > </bean> > > </list> > > </property> > > </bean> > > </property> > > > > <property name="readThrough" value="true"/> > > <property name="writeThrough" value="true"/> > > > > <property name="queryEntities"> > > <list> > > <bean > > class="org.apache.ignite.cache.QueryEntity"> > > <property name="keyType" > > value="com.gmail.orl.debasis.model.EmployeeKey"/> > > <property name="valueType" > > value="com.gmail.orl.debasis.model.Employee"/> > > > > <property name="fields"> > > <map> > > <entry key="id" > > value="java.math.BigDecimal"/> > > <entry key="firstname" > > value="java.lang.String"/> > > <entry key="lastname" > > value="java.lang.String"/> > > </map> > > </property> > > </bean> > > </list> > > </property> > > </bean> > > </list> > > </property> > > </bean> > > </beans> > > > > On Tue, May 23, 2017 at 4:34 PM, Evgenii Zhuravlev > > <[email protected]> wrote: > >> > >> Hi, > >> > >> Could you provide your full config file? > >> > >> 2017-05-22 15:00 GMT+03:00 debasish pradhan <[email protected]>: > >>> > >>> Hi , > >>> > >>> I am new to apache ignite. I was trying to connect Timesten DB to fetch > >>> data , but its failing . I downloaded the project from web console . > As per > >>> instruction I started the server node . After that I am trying to run > >>> loadcache . but its failing with following error. > >>> > >>> cache load code: > >>> ========= > >>> > >>> try (Ignite ignite = Ignition.start("TestDB1-client.xml")) { > >>> > >>> System.out.println(">>> Loading caches..."); > >>> > >>> System.out.println(">>> Loading cache:...EmployeeCache"); > >>> > >>> //ignite.cache("EmployeeCache").loadCache(null); > >>> > >>> ignite.cache("EmployeeCache").loadCache(null, > Employee.class.getName(), > >>> "select * from DG.Employee"); > >>> > >>> > >>> configuration:jdbc driver : > >>> > >>> public static class DataSources { > >>> public static final TimesTenDataSource INSTANCE_dataStore = > >>> createdataStore(); > >>> private static TimesTenDataSource createdataStore() { > >>> TimesTenDataSource dataStore = new TimesTenDataSource(); > >>> > >>> dataStore.setUrl("jdbc:timesten:client:TTC_Server= > localhost;TCP_PORT=53397;TTC_Server_DSN=TESTDSN;UID=test; > PWD=test;TTC_Timeout=180"); > >>> dataStore.setUser("test"); > >>> dataStore.setPassword("test"); > >>> return dataStore; > >>> } > >>> } > >>> > >>> > >>> TestDB1-client.xml--> > >>> > >>> <bean id="dataSource" class="com.timesten.jdbc.TimesTenDataSource"> > >>> <property name="url" > >>> value="jdbc:timesten:client:TTC_Server=localhost;TCP_PORT= > 53397;TTC_Server_DSN=TestDSN;UID=test;PWD=test;TTC_Timeout=180" > >>> /> > >>> <property name="username" value="kodiak" /> > >>> <property name="password" value="kodiak" /> > >>> </bean> > >>> > >>> > >>> [17:04:12,860][SEVERE][main][GridJobWorker] Failed to execute job > >>> [jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b, > >>> ses=GridJobSessionImpl [ses=GridTaskSessionImpl > >>> [taskName=o.a.i.i.processors.cache.GridCacheAdapter$LoadCacheJobV2, > >>> dep=LocalDeployment [super=GridDeployment [ts=1495452846874, > depMode=SHARED, > >>> clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a, > >>> clsLdrId=6608fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b, userVer=0, > >>> loc=true, sampleClsName=java.lang.String, pendingUndeploy=false, > >>> undeployed=false, usage=0]], > >>> taskClsName=o.a.i.i.processors.cache.GridCacheAdapter$LoadCacheJobV2, > >>> sesId=0a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b, > >>> startTime=1495452852829, endTime=9223372036854775807, > >>> taskNodeId=8b249f71-34cd-4ec7-8056-c32a3e61034b, > >>> clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a, closed=false, > cpSpi=null, > >>> failSpi=null, loadSpi=null, usage=1, fullSup=false, internal=true, > >>> subjId=8b249f71-34cd-4ec7-8056-c32a3e61034b, mapFut=IgniteFuture > >>> [orig=GridFutureAdapter [resFlag=0, res=null, startTime=1495452852839, > >>> endTime=0, ignoreInterrupts=false, state=INIT]]], > >>> jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b]] > >>> > >>> class org.apache.ignite.IgniteException: > java.lang.NullPointerException > >>> > >>> at > >>> org.apache.ignite.internal.processors.closure. > GridClosureProcessor$C2V2.execute(GridClosureProcessor.java:2059) > >>> > >>> at > >>> org.apache.ignite.internal.processors.job.GridJobWorker$ > 2.call(GridJobWorker.java:560) > >>> > >>> at > >>> org.apache.ignite.internal.util.IgniteUtils. > wrapThreadLoader(IgniteUtils.java:6620) > >>> > >>> at > >>> org.apache.ignite.internal.processors.job.GridJobWorker. > execute0(GridJobWorker.java:554) > >>> > >>> at > >>> org.apache.ignite.internal.processors.job.GridJobWorker. > body(GridJobWorker.java:483) > >>> > >>> at > >>> org.apache.ignite.internal.util.worker.GridWorker.run( > GridWorker.java:110) > >>> > >>> at > >>> org.apache.ignite.internal.processors.job.GridJobProcessor. > processJobExecuteRequest(GridJobProcessor.java:1114) > >>> > >>> at > >>> org.apache.ignite.internal.processors.task.GridTaskWorker.sendRequest( > GridTaskWorker.java:1383) > >>> > >>> at > >>> org.apache.ignite.internal.processors.task.GridTaskWorker. > processMappedJobs(GridTaskWorker.java:645) > >>> > >>> at > >>> org.apache.ignite.internal.processors.task.GridTaskWorker.body( > GridTaskWorker.java:537) > >>> > >>> at > >>> org.apache.ignite.internal.util.worker.GridWorker.run( > GridWorker.java:110) > >>> > >>> at > >>> org.apache.ignite.internal.processors.task. > GridTaskProcessor.startTask(GridTaskProcessor.java:679) > >>> > >>> at > >>> org.apache.ignite.internal.processors.task.GridTaskProcessor.execute( > GridTaskProcessor.java:403) > >>> > >>> at > >>> org.apache.ignite.internal.processors.closure.GridClosureProcessor. > callAsync(GridClosureProcessor.java:418) > >>> > >>> at > >>> org.apache.ignite.internal.processors.closure.GridClosureProcessor. > callAsync(GridClosureProcessor.java:391) > >>> > >>> at > >>> org.apache.ignite.internal.processors.cache.GridCacheAdapter. > globalLoadCacheAsync(GridCacheAdapter.java:3718) > >>> > >>> at > >>> org.apache.ignite.internal.processors.cache.GridCacheAdapter. > globalLoadCache(GridCacheAdapter.java:3657) > >>> > >>> at > >>> org.apache.ignite.internal.processors.cache. > IgniteCacheProxy.loadCache(IgniteCacheProxy.java:390) > >>> > >>> at load.LoadCaches.main(LoadCaches.java:28) > >>> > >>> > >>> > >> > > >
