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.
