Krishna, Looking into your code I assume that you create cache using cache configuration generated by code you provided.
So you should load cache like this bob.loadCache(null, ExceptionMasterKey.class.getName(), "select * from EXCEPTION_MASTER where EXCEPTION_ID='37471' "); P.S. just several minor comments. I see that actually ExceptionMasterKey is just a wrapper for BigDecimal. If you use only ONE type per cache you could replace everywhere ExceptionMasterKey with BigDecimal. Also it is OK to have BigDecimal as a key? How about to use Long (if it is suits your database). Long is much more fast and lightweight than BigDecimal. On Tue, Jul 28, 2015 at 3:53 PM, krishnangc < [email protected]> wrote: > Hi Alexey, > > Thanks for the quick response. I generated the Config file using the Ignite > Schema Import Utility. Please find the code below. > public static <K, V> CacheConfiguration<K, V> cache(String name, > Factory<CacheStore<K, V>> storeFactory) { > if (storeFactory == null) > throw new IllegalArgumentException("Cache store factory cannot > be null."); > > CacheConfiguration<K, V> ccfg = new CacheConfiguration<>(name); > > ccfg.setCacheStoreFactory(storeFactory); > ccfg.setReadThrough(true); > ccfg.setWriteThrough(true); > > // Configure cache types. > Collection<CacheTypeMetadata> meta = new ArrayList<>(); > > // EXCEPTION_MASTER. > CacheTypeMetadata type = new CacheTypeMetadata(); > > meta.add(type); > > type.setDatabaseSchema("ALGORECONUTIL_DEV"); > type.setDatabaseTable("EXCEPTION_MASTER"); > type.setKeyType(ExceptionMasterKey.class.getName()); > type.setValueType(ExceptionMaster.class.getName()); > > // Key fields for EXCEPTION_MASTER. > Collection<CacheTypeFieldMetadata> keys = new ArrayList<>(); > keys.add(new CacheTypeFieldMetadata("EXCEPTION_OID", Types.NUMERIC, > "exceptionOid", java.math.BigDecimal.class)); > > type.setKeyFields(keys); > > // Value fields for EXCEPTION_MASTER. > Collection<CacheTypeFieldMetadata> vals = new ArrayList<>(); > vals.add(new CacheTypeFieldMetadata("EXCEPTION_ID", Types.VARCHAR, > "exceptionId", String.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_CREATED_DATE", > Types.DATE, "exceptionCreatedDate", java.sql.Date.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_PROCESSING_DATE", > Types.DATE, "exceptionProcessingDate", java.sql.Date.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_COMPLETION_DATE", > Types.DATE, "exceptionCompletionDate", java.sql.Date.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_PRIORITY", > Types.VARCHAR, "exceptionPriority", String.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_SEVERITY", > Types.VARCHAR, "exceptionSeverity", String.class)); > > vals.add(new CacheTypeFieldMetadata("GEOGRAPHY_ID", Types.NUMERIC, > "geographyId", java.math.BigDecimal.class)); > > vals.add(new CacheTypeFieldMetadata("COUNTRY_ID", Types.INTEGER, > "countryId", Integer.class)); > > vals.add(new CacheTypeFieldMetadata("BRANCH_ID", Types.INTEGER, > "branchId", Integer.class)); > > vals.add(new CacheTypeFieldMetadata("L1L2STATUS", Types.VARCHAR, > "l1l2status", String.class)); > > vals.add(new CacheTypeFieldMetadata("SERVICE_LEVEL", Types.VARCHAR, > "serviceLevel", String.class)); > > vals.add(new CacheTypeFieldMetadata("RECONCILIATION_TYPE", > Types.VARCHAR, "reconciliationType", String.class)); > > vals.add(new CacheTypeFieldMetadata("UPDATED_BY", Types.VARCHAR, > "updatedBy", String.class)); > > vals.add(new CacheTypeFieldMetadata("UPDATED_DATE", Types.OTHER, > "updatedDate", Object.class)); > > vals.add(new CacheTypeFieldMetadata("SESSION_ID", Types.VARCHAR, > "sessionId", String.class)); > > vals.add(new CacheTypeFieldMetadata("RECORD_END_DATE", Types.OTHER, > "recordEndDate", Object.class)); > > vals.add(new CacheTypeFieldMetadata("RECORD_STATUS", Types.VARCHAR, > "recordStatus", String.class)); > > vals.add(new CacheTypeFieldMetadata("CREATED_DATE", Types.OTHER, > "createdDate", Object.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_CATEGORY", > Types.VARCHAR, "exceptionCategory", String.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_DESCRIPTION", > Types.VARCHAR, "exceptionDescription", String.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_OID", Types.NUMERIC, > "exceptionOid", java.math.BigDecimal.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_STATUS", > Types.VARCHAR, "exceptionStatus", String.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_TYPE_ID", > Types.NUMERIC, "exceptionTypeId", java.math.BigDecimal.class)); > > vals.add(new CacheTypeFieldMetadata("FUNCTIONAL_AREA_ID", > Types.NUMERIC, "functionalAreaId", java.math.BigDecimal.class)); > > vals.add(new CacheTypeFieldMetadata("IPADDRESS", Types.VARCHAR, > "ipaddress", String.class)); > > vals.add(new CacheTypeFieldMetadata("PRODUCTLINE_ID", > Types.NUMERIC, > "productlineId", java.math.BigDecimal.class)); > > vals.add(new CacheTypeFieldMetadata("RECON_ID", Types.VARCHAR, > "reconId", String.class)); > > vals.add(new CacheTypeFieldMetadata("RECORD_VERSION", > Types.INTEGER, > "recordVersion", int.class)); > > vals.add(new CacheTypeFieldMetadata("CREATED_BY", Types.VARCHAR, > "createdBy", String.class)); > > vals.add(new CacheTypeFieldMetadata("LINK_ID", Types.NUMERIC, > "linkId", java.math.BigDecimal.class)); > > vals.add(new CacheTypeFieldMetadata("BUSINESS_CONTEXT_ID", > Types.VARCHAR, "businessContextId", String.class)); > > vals.add(new CacheTypeFieldMetadata("RECON_EXECUTION_ID", > Types.NUMERIC, "reconExecutionId", java.math.BigDecimal.class)); > > vals.add(new CacheTypeFieldMetadata("BUSINESS_PROCESS_ID", > Types.VARCHAR, "businessProcessId", String.class)); > > vals.add(new CacheTypeFieldMetadata("MANUAL_ENTRY_FLAG", > Types.VARCHAR, "manualEntryFlag", String.class)); > > vals.add(new CacheTypeFieldMetadata("PROCESSING_TYPE", > Types.VARCHAR, "processingType", String.class)); > > vals.add(new CacheTypeFieldMetadata("ASSET_CLASS_ID", > Types.VARCHAR, > "assetClassId", String.class)); > > vals.add(new CacheTypeFieldMetadata("TRADE_DATE", Types.DATE, > "tradeDate", java.sql.Date.class)); > > vals.add(new CacheTypeFieldMetadata("PARENT_EXCEPTION_ID", > Types.VARCHAR, "parentExceptionId", String.class)); > > vals.add(new CacheTypeFieldMetadata("MERGED_EXCEPTION_ID", > Types.VARCHAR, "mergedExceptionId", String.class)); > > vals.add(new CacheTypeFieldMetadata("GROUPED_EXCEPTION_ID", > Types.VARCHAR, "groupedExceptionId", String.class)); > > vals.add(new CacheTypeFieldMetadata("EXCEPTION_GROUP_INDICATOR", > Types.VARCHAR, "exceptionGroupIndicator", String.class)); > > vals.add(new CacheTypeFieldMetadata("TOTAL_OUTSTANDING_AMOUNT", > Types.FLOAT, "totalOutstandingAmount", Double.class)); > > vals.add(new CacheTypeFieldMetadata("CLEARING_DATE", Types.DATE, > "clearingDate", java.sql.Date.class)); > > vals.add(new CacheTypeFieldMetadata("REASON_CODE", Types.VARCHAR, > "reasonCode", String.class)); > > vals.add(new CacheTypeFieldMetadata("COMMENTS", Types.VARCHAR, > "comments", String.class)); > > vals.add(new > CacheTypeFieldMetadata("EXCEPTION_AUTHORIZATION_STATUS", Types.VARCHAR, > "exceptionAuthorizationStatus", String.class)); > > vals.add(new CacheTypeFieldMetadata("SUSPENSE_ENTRY_FLAG", > Types.VARCHAR, "suspenseEntryFlag", String.class)); > > type.setValueFields(vals); > > // Query fields for EXCEPTION_MASTER. > Map<String, Class<?>> qryFlds = new LinkedHashMap<>(); > > qryFlds.put("exceptionId", String.class); > > qryFlds.put("exceptionCreatedDate", java.sql.Date.class); > > qryFlds.put("exceptionProcessingDate", java.sql.Date.class); > > qryFlds.put("exceptionCompletionDate", java.sql.Date.class); > > qryFlds.put("exceptionPriority", String.class); > > qryFlds.put("exceptionSeverity", String.class); > > qryFlds.put("geographyId", java.math.BigDecimal.class); > > qryFlds.put("countryId", Integer.class); > > qryFlds.put("branchId", Integer.class); > > qryFlds.put("l1l2status", String.class); > > qryFlds.put("serviceLevel", String.class); > > qryFlds.put("reconciliationType", String.class); > > qryFlds.put("updatedBy", String.class); > > qryFlds.put("updatedDate", Object.class); > > qryFlds.put("sessionId", String.class); > > qryFlds.put("recordEndDate", Object.class); > > qryFlds.put("recordStatus", String.class); > > qryFlds.put("createdDate", Object.class); > > qryFlds.put("exceptionCategory", String.class); > > qryFlds.put("exceptionDescription", String.class); > > qryFlds.put("exceptionOid", java.math.BigDecimal.class); > > qryFlds.put("exceptionStatus", String.class); > > qryFlds.put("exceptionTypeId", java.math.BigDecimal.class); > > qryFlds.put("functionalAreaId", java.math.BigDecimal.class); > > qryFlds.put("ipaddress", String.class); > > qryFlds.put("productlineId", java.math.BigDecimal.class); > > qryFlds.put("reconId", String.class); > > qryFlds.put("recordVersion", int.class); > > qryFlds.put("createdBy", String.class); > > qryFlds.put("linkId", java.math.BigDecimal.class); > > qryFlds.put("businessContextId", String.class); > > qryFlds.put("reconExecutionId", java.math.BigDecimal.class); > > qryFlds.put("businessProcessId", String.class); > > qryFlds.put("manualEntryFlag", String.class); > > qryFlds.put("processingType", String.class); > > qryFlds.put("assetClassId", String.class); > > qryFlds.put("tradeDate", java.sql.Date.class); > > qryFlds.put("parentExceptionId", String.class); > > qryFlds.put("mergedExceptionId", String.class); > > qryFlds.put("groupedExceptionId", String.class); > > qryFlds.put("exceptionGroupIndicator", String.class); > > qryFlds.put("totalOutstandingAmount", Double.class); > > qryFlds.put("clearingDate", java.sql.Date.class); > > qryFlds.put("reasonCode", String.class); > > qryFlds.put("comments", String.class); > > qryFlds.put("exceptionAuthorizationStatus", String.class); > > qryFlds.put("suspenseEntryFlag", String.class); > > > type.setQueryFields(qryFlds); > > // Ascending fields for EXCEPTION_MASTER. > Map<String, Class<?>> ascFlds = new LinkedHashMap<>(); > > ascFlds.put("exceptionOid", java.math.BigDecimal.class); > > type.setAscendingFields(ascFlds); > > ccfg.setTypeMetadata(meta); > > return ccfg; > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/Failed-to-find-mapping-description-tp725p728.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Alexey Kuznetsov GridGain Systems www.gridgain.com
