I'm getting an "argument type mismatch" for my Oracle CLOB when trying to
call "loadCache". I ran into similar situation like this before with Oracle
Timestamp when using version 1.6 of the ignite fabric and had to upgrade to
the 1.7.0 version of the ignite fabric to fix that defect. This looks very
similar. I have an Oracle CLOB column that I'm trying to load into a
java.lang.String field and am consistently getting the error below. It
works if I remove the CLOB field from my JdbcType configuration, but that's
not going to work for us because most of our tables use CLOBs.
This code is just basic test code to see if the data-caching will work with
our Oracle datastore.
*-----------------------------
/EXCEPTION/
-----------------------------*
Caused by: javax.cache.integration.CacheLoaderException: Failed to set
property in POJO class [type=com.gm.ignite.HistoryResult, prop=results,
col=5, dbName=RESULTS]
at
org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore.buildPojoObject(CacheJdbcPojoStore.java:210)
... 7 more
Caused by: java.lang.IllegalArgumentException: argument type mismatch
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore$ClassProperty.set(CacheJdbcPojoStore.java:397)
at
org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore$ClassProperty.access$300(CacheJdbcPojoStore.java:339)
at
org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore.buildPojoObject(CacheJdbcPojoStore.java:207)
... 7 more
*-----------------------------
/HISTORYRESULT TABLE/
-----------------------------*
COLUMN_NAME, DATA_TYPE, NULLABLE
USER_ID, VARCHAR2(20 BYTE), No
SESSION_ID, VARCHAR2(50 BYTE), No
SESSION_TIME, DATE, Yes
SESSION_NAME, VARCHAR2(50 BYTE), No
RESULTS, CLOB, Yes
CREATED_DT, DATE, No
CREATED_BY, VARCHAR2(20 BYTE), No
MODIFIED_DT, DATE, No
MODIFIED_BY, VARCHAR2(20 BYTE), No
*-------------------------------
/HISTORYRESULTKEY CLASS/
-------------------------------*
public class HistoryResultKey {
private String userId;
private String sessionId;
private String sessionName;
...
*-----------------------------
/HISTORYRESULT CLASS/
-----------------------------*
public class HistoryResult {
private String userId;
private String sessionId;
private Timestamp sessionTime;
private String sessionName;
private String results;
private Timestamp createdDate;
private String createdBy;
private Timestamp modifiedDate;
private String modifiedBy;
...
*-----------------------------
/DEMO CLASS/
-----------------------------*
public static void main(String[] args) throws IgniteException {
System.out.println(">>> Start demo...");
// Start Ignite node.
try (Ignite ignite = Ignition.start("examples/config/example-ignite
- client-only.xml")) {
CacheJdbcPojoStoreFactory<HistoryResultKey, HistoryResult>
pojoStoreFactory = new CacheJdbcPojoStoreFactory<>();
pojoStoreFactory.setDataSourceFactory(new
OracleDataSourceFactory2());
// Configure cache store.
String cacheName = "HistoryResultCache";
CacheConfiguration<HistoryResultKey, HistoryResult> cfg =
HistoryResultsCacheConfig
.cache(cacheName, pojoStoreFactory);
try (IgniteCache<HistoryResultKey, HistoryResult> cache =
ignite.getOrCreateCache(cfg)) {
// Preload cache from database.
preload(cache);
...
private static void preload(IgniteCache<HistoryResultKey, HistoryResult>
cache) {
System.out.println();
System.out.println(">>> Loading entries from database.");
cache.loadCache(null, HistoryResultKey.class.getName(), "SELECT *
FROM HISTORY_RESULTS WHERE SESSION_NAME = 'name2'");
...
*-----------------------------
/JAVA CACHECONFIG/
-----------------------------*
public class HistoryResultsCacheConfig {
private static JdbcType jdbcTypeHistoryResults(String cacheName) {
JdbcType jdbcType = new JdbcType();
jdbcType.setCacheName(cacheName);
jdbcType.setDatabaseSchema("SCHEMA_A");
jdbcType.setDatabaseTable("HISTORY_RESULTS");
jdbcType.setKeyType("com.gm.ignite.HistoryResultKey");
jdbcType.setValueType("com.gm.ignite.HistoryResult");
// Key fields for HISTORY_RESULTS.
Collection<JdbcTypeField> keys = new ArrayList<>();
keys.add(new JdbcTypeField(Types.VARCHAR, "USER_ID", String.class,
"userId"));
keys.add(new JdbcTypeField(Types.VARCHAR, "SESSION_ID",
String.class, "sessionId"));
keys.add(new JdbcTypeField(Types.VARCHAR, "SESSION_NAME",
String.class, "sessionName"));
jdbcType.setKeyFields(keys.toArray(new JdbcTypeField[keys.size()]));
// Value fields for MATLAB_HISTORY_RESULTS.
Collection<JdbcTypeField> vals = new ArrayList<>();
vals.add(new JdbcTypeField(Types.VARCHAR, "USER_ID", String.class,
"userId"));
vals.add(new JdbcTypeField(Types.VARCHAR, "SESSION_ID",
String.class, "sessionId"));
vals.add(new JdbcTypeField(Types.TIMESTAMP, "SESSION_TIME",
Timestamp.class, "sessionTime"));
vals.add(new JdbcTypeField(Types.VARCHAR, "SESSION_NAME",
String.class, "sessionName"));
vals.add(new JdbcTypeField(Types.CLOB, "RESULTS", String.class,
"results"));
vals.add(new JdbcTypeField(Types.TIMESTAMP, "CREATED_DT",
Timestamp.class, "createdDate"));
vals.add(new JdbcTypeField(Types.VARCHAR, "CREATED_BY",
String.class, "createdBy"));
vals.add(new JdbcTypeField(Types.TIMESTAMP, "MODIFIED_DT",
Timestamp.class, "modifiedDate"));
vals.add(new JdbcTypeField(Types.VARCHAR, "MODIFIED_BY",
String.class, "modifiedBy"));
jdbcType.setValueFields(vals.toArray(new
JdbcTypeField[vals.size()]));
return jdbcType;
}
private static QueryEntity queryEntityHistoryResults() {
QueryEntity qryEntity = new QueryEntity();
qryEntity.setKeyType("com.gm.ignite.HistoryResultKey");
qryEntity.setValueType("com.gm.ignite.HistoryResult");
// Query fields for HISTORY_RESULTS.
LinkedHashMap<String, String> fields = new LinkedHashMap<>();
fields.put("userId", "java.lang.String");
fields.put("sessionId", "java.lang.String");
fields.put("sessionTime", "java.sql.Timestamp");
fields.put("sessionName", "java.lang.String");
fields.put("results", "java.lang.String");
fields.put("createdDate", "java.sql.Timestamp");
fields.put("createdBy", "java.lang.String");
fields.put("modifiedDate", "java.sql.Timestamp");
fields.put("modifiedBy", "java.lang.String");
qryEntity.setFields(fields);
// Aliases for fields.
Map<String, String> aliases = new HashMap<>();
aliases.put("userId", "USER_ID");
aliases.put("sessionId", "SESSION_ID");
aliases.put("sessionTime", "SESSION_TIME");
aliases.put("sessionName", "SESSION_NAME");
aliases.put("results", "RESULTS");
aliases.put("createdDate", "CREATED_DT");
aliases.put("createdBy", "CREATED_BY");
aliases.put("modifiedDate", "MODIFIED_DT");
aliases.put("modifiedBy", "MODIFIED_BY");
qryEntity.setAliases(aliases);
// Indexes for HISTORY_RESULTS.
Collection<QueryIndex> idxs = new ArrayList<>();
QueryIndex idx = new QueryIndex();
idx.setName("PK_HISTORY_RESULTS_V_A_ID");
LinkedHashMap<String, Boolean> idxFlds = new LinkedHashMap<>();
idxFlds.put("userId", true);
idxFlds.put("sessionId", true);
idxFlds.put("algorithmName", true);
idx.setFields(idxFlds);
idxs.add(idx);
qryEntity.setIndexes(idxs);
return qryEntity;
}
public static <K, V> CacheConfiguration<K, V> cache(String cacheName,
CacheJdbcPojoStoreFactory<K, V> storeFactory) {
if (storeFactory == null)
throw new IllegalArgumentException("Cache store factory cannot
be null.");
CacheConfiguration<K, V> ccfg = new CacheConfiguration<>(cacheName);
ccfg.setCacheStoreFactory(storeFactory);
ccfg.setReadThrough(true);
ccfg.setWriteThrough(true);
// Configure JDBC types.
Collection<JdbcType> jdbcTypes = new ArrayList<>();
jdbcTypes.add(jdbcTypeHistoryResults(cacheName));
storeFactory.setTypes(jdbcTypes.toArray(new
JdbcType[jdbcTypes.size()]));
// Configure query entities.
Collection<QueryEntity> qryEntities = new ArrayList<>();
qryEntities.add(queryEntityHistoryResults());
ccfg.setQueryEntities(qryEntities);
return ccfg;
}
}
*-----------------------------------------
/EXAMPLE-IGNITE - CLIENT-ONLY.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";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd";>
<import resource="example-default - client-only.xml"/>
<bean parent="ignite.cfg"/>
</beans>
*-----------------------------------------
/EXAMPLE-DEFAULT - CLIENT-ONLY.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";>
<bean id="h2-example-db" class="org.h2.jdbcx.JdbcDataSource">
<property name="URL" value="jdbc:h2:tcp://localhost/mem:ExampleDb"
/>
<property name="user" value="sa" />
</bean>
<bean abstract="true" id="ignite.cfg"
class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="clientMode" value="true" />
<property name="peerClassLoadingEnabled" value="true"/>
<property name="includeEventTypes">
<list>
<util:constant
static-field="org.apache.ignite.events.EventType.EVT_TASK_STARTED"/>
<util:constant
static-field="org.apache.ignite.events.EventType.EVT_TASK_FINISHED"/>
<util:constant
static-field="org.apache.ignite.events.EventType.EVT_TASK_FAILED"/>
<util:constant
static-field="org.apache.ignite.events.EventType.EVT_TASK_TIMEDOUT"/>
<util:constant
static-field="org.apache.ignite.events.EventType.EVT_TASK_SESSION_ATTR_SET"/>
<util:constant
static-field="org.apache.ignite.events.EventType.EVT_TASK_REDUCED"/>
<util:constant
static-field="org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_PUT"/>
<util:constant
static-field="org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_READ"/>
<util:constant
static-field="org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_REMOVED"/>
</list>
</property>
<property name="discoverySpi">
<bean
class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<bean
class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder">
<property name="addresses">
<list>
<value>127.0.0.1:47500..47509</value>
</list>
</property>
</bean>
</property>
</bean>
</property>
</bean>
</beans>
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Argument-Type-Mismatch-for-Oracle-CLOB-tp7748.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
