http://git-wip-us.apache.org/repos/asf/ignite/blob/8e7c852b/modules/web-console/frontend/app/modules/configuration/generator/generator-java.js ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/configuration/generator/generator-java.js b/modules/web-console/frontend/app/modules/configuration/generator/generator-java.js deleted file mode 100644 index 296b942..0000000 --- a/modules/web-console/frontend/app/modules/configuration/generator/generator-java.js +++ /dev/null @@ -1,3617 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -// Java generation entry point. -const $generatorJava = {}; - -/** - * Translate some value to valid java code. - * - * @param val Value to convert. - * @param type Value type. - * @returns {*} String with value that will be valid for java. - */ -$generatorJava.toJavaCode = function(val, type) { - if (val === null) - return 'null'; - - if (type === 'raw') - return val; - - if (type === 'class') - return val + '.class'; - - if (type === 'float') - return val + 'f'; - - if (type === 'path') - return '"' + val.replace(/\\/g, '\\\\') + '"'; - - if (type) - return type + '.' + val; - - if (typeof (val) === 'string') - return '"' + val.replace('"', '\\"') + '"'; - - if (typeof (val) === 'number' || typeof (val) === 'boolean') - return String(val); - - return 'Unknown type: ' + typeof (val) + ' (' + val + ')'; -}; - -/** - * @param propName Property name. - * @param setterName Optional concrete setter name. - * @returns Property setter with name by java conventions. - */ -$generatorJava.setterName = function(propName, setterName) { - return setterName ? setterName : $generatorCommon.toJavaName('set', propName); -}; - -// Add constructor argument -$generatorJava.constructorArg = function(obj, propName, dflt, notFirst, opt) { - const v = (obj ? obj[propName] : null) || dflt; - - if ($generatorCommon.isDefinedAndNotEmpty(v)) - return (notFirst ? ', ' : '') + $generatorJava.toJavaCode(v); - else if (!opt) - return notFirst ? ', null' : 'null'; - - return ''; -}; - -/** - * Add variable declaration. - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param varFullType Variable full class name to be added to imports. - * @param varFullActualType Variable actual full class name to be added to imports. - * @param varFullGenericType1 Optional full class name of first generic. - * @param varFullGenericType2 Optional full class name of second generic. - * @param subClass If 'true' then variable will be declared as anonymous subclass. - */ -$generatorJava.declareVariable = function(res, varName, varFullType, varFullActualType, varFullGenericType1, varFullGenericType2, subClass) { - res.emptyLineIfNeeded(); - - const varType = res.importClass(varFullType); - - const varNew = !res.vars[varName]; - - if (varNew) - res.vars[varName] = true; - - if (varFullActualType && varFullGenericType1) { - const varActualType = res.importClass(varFullActualType); - const varGenericType1 = res.importClass(varFullGenericType1); - let varGenericType2 = null; - - if (varFullGenericType2) - varGenericType2 = res.importClass(varFullGenericType2); - - res.line((varNew ? (varType + '<' + varGenericType1 + (varGenericType2 ? ', ' + varGenericType2 : '') + '> ') : '') + - varName + ' = new ' + varActualType + '<>();'); - } - else - res.line((varNew ? (varType + ' ') : '') + varName + ' = new ' + varType + '()' + (subClass ? ' {' : ';')); - - if (!subClass) - res.needEmptyLine = true; - - return varName; -}; - -/** - * Add local variable declaration. - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param varFullType Variable full class name to be added to imports. - */ -$generatorJava.declareVariableLocal = function(res, varName, varFullType) { - const varType = res.importClass(varFullType); - - res.line(varType + ' ' + varName + ' = new ' + varType + '();'); - - res.needEmptyLine = true; -}; - -/** - * Add custom variable declaration. - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param varFullType Variable full class name to be added to imports. - * @param varExpr Custom variable creation expression. - * @param modifier Additional variable modifier. - */ -$generatorJava.declareVariableCustom = function(res, varName, varFullType, varExpr, modifier) { - const varType = res.importClass(varFullType); - - const varNew = !res.vars[varName]; - - if (varNew) - res.vars[varName] = true; - - res.line((varNew ? ((modifier ? modifier + ' ' : '') + varType + ' ') : '') + varName + ' = ' + varExpr + ';'); - - res.needEmptyLine = true; -}; - -/** - * Add array variable declaration. - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param varFullType Variable full class name to be added to imports. - * @param length Array length. - */ -$generatorJava.declareVariableArray = function(res, varName, varFullType, length) { - const varType = res.importClass(varFullType); - - const varNew = !res.vars[varName]; - - if (varNew) - res.vars[varName] = true; - - res.line((varNew ? (varType + '[] ') : '') + varName + ' = new ' + varType + '[' + length + '];'); - - res.needEmptyLine = true; -}; - -/** - * Clear list of declared variables. - * - * @param res - */ -$generatorJava.resetVariables = function(res) { - res.vars = {}; -}; - -/** - * Add property via setter / property name. - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param obj Source object with data. - * @param propName Property name to take from source object. - * @param dataType Optional info about property data type. - * @param setterName Optional special setter name. - * @param dflt Optional default value. - */ -$generatorJava.property = function(res, varName, obj, propName, dataType, setterName, dflt) { - if (!_.isNil(obj)) { - const val = obj[propName]; - - if ($generatorCommon.isDefinedAndNotEmpty(val)) { - const missDflt = _.isNil(dflt); - - // Add to result if no default provided or value not equals to default. - if (missDflt || (!missDflt && val !== dflt)) { - res.line(varName + '.' + $generatorJava.setterName(propName, setterName) + - '(' + $generatorJava.toJavaCode(val, dataType) + ');'); - - return true; - } - } - } - - return false; -}; - -/** - * Add enum property via setter / property name. - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param obj Source object with data. - * @param propName Property name to take from source object. - * @param dataType Name of enum class - * @param setterName Optional special setter name. - * @param dflt Optional default value. - */ -$generatorJava.enumProperty = function(res, varName, obj, propName, dataType, setterName, dflt) { - const val = obj[propName]; - - if ($generatorCommon.isDefinedAndNotEmpty(val)) { - const missDflt = _.isNil(dflt); - - // Add to result if no default provided or value not equals to default. - if (missDflt || (!missDflt && val !== dflt)) { - res.line(varName + '.' + $generatorJava.setterName(propName, setterName) + - '(' + $generatorJava.toJavaCode(val, dataType ? res.importClass(dataType) : null) + ');'); - - return true; - } - } - - return false; -}; - -// Add property for class name. -$generatorJava.classNameProperty = function(res, varName, obj, propName) { - const val = obj[propName]; - - if (!_.isNil(val)) { - res.line(varName + '.' + $generatorJava.setterName(propName) + - '("' + $generatorCommon.JavaTypes.fullClassName(val) + '");'); - } -}; - -/** - * Add list property. - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param obj Source object with data. - * @param propName Property name to take from source object. - * @param dataType Optional data type. - * @param setterName Optional setter name. - */ -$generatorJava.listProperty = function(res, varName, obj, propName, dataType, setterName) { - const val = obj[propName]; - - if (val && val.length > 0) { - res.emptyLineIfNeeded(); - - res.importClass('java.util.Arrays'); - - $generatorJava.fxVarArgs(res, varName + '.' + $generatorJava.setterName(propName, setterName), false, - _.map(val, (v) => $generatorJava.toJavaCode(v, dataType)), '(Arrays.asList(', '))'); - - res.needEmptyLine = true; - } -}; - -/** - * Add function with varargs arguments. - * - * @param res Resulting output with generated code. - * @param fx Function name. - * @param quote Whether to quote arguments. - * @param args Array with arguments. - * @param startBlock Optional start block string. - * @param endBlock Optional end block string. - * @param startQuote Start quote string. - * @param endQuote End quote string. - */ -$generatorJava.fxVarArgs = function(res, fx, quote, args, startBlock = '(', endBlock = ')', startQuote = '"', endQuote = '"') { - const quoteArg = (arg) => quote ? startQuote + arg + endQuote : arg; - - if (args.length === 1) - res.append(fx + startBlock + quoteArg(args[0]) + endBlock + ';'); - else { - res.startBlock(fx + startBlock); - - const len = args.length - 1; - - _.forEach(args, (arg, ix) => res.line(quoteArg(arg) + (ix < len ? ', ' : ''))); - - res.endBlock(endBlock + ';'); - } -}; - -/** - * Add array property. - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param obj Source object with data. - * @param propName Property name to take from source object. - * @param setterName Optional setter name. - */ -$generatorJava.arrayProperty = function(res, varName, obj, propName, setterName) { - const val = obj[propName]; - - if (val && val.length > 0) { - res.emptyLineIfNeeded(); - - $generatorJava.fxVarArgs(res, varName + '.' + $generatorJava.setterName(propName, setterName), false, - _.map(val, (v) => 'new ' + res.importClass(v) + '()'), '({ ', ' });'); - - res.needEmptyLine = true; - } -}; - -/** - * Add multi-param property (setter with several arguments). - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param obj Source object with data. - * @param propName Property name to take from source object. - * @param dataType Optional data type. - * @param setterName Optional setter name. - */ -$generatorJava.multiparamProperty = function(res, varName, obj, propName, dataType, setterName) { - const val = obj[propName]; - - if (val && val.length > 0) { - $generatorJava.fxVarArgs(res, varName + '.' + $generatorJava.setterName(propName, setterName), false, - _.map(val, (v) => $generatorJava.toJavaCode(dataType === 'class' ? res.importClass(v) : v, dataType))); - } -}; - -/** - * Add complex bean. - * - * @param res Resulting output with generated code. - * @param varName Variable name. - * @param bean - * @param beanPropName Bean property name. - * @param beanVarName - * @param beanClass Bean class. - * @param props - * @param createBeanAlthoughNoProps If 'true' then create empty bean. - */ -$generatorJava.beanProperty = function(res, varName, bean, beanPropName, beanVarName, beanClass, props, createBeanAlthoughNoProps) { - if (bean && $generatorCommon.hasProperty(bean, props)) { - res.emptyLineIfNeeded(); - - $generatorJava.declareVariable(res, beanVarName, beanClass); - - _.forIn(props, function(descr, propName) { - if (props.hasOwnProperty(propName)) { - if (descr) { - switch (descr.type) { - case 'list': - $generatorJava.listProperty(res, beanVarName, bean, propName, descr.elementsType, descr.setterName); - break; - - case 'array': - $generatorJava.arrayProperty(res, beanVarName, bean, propName, descr.setterName); - break; - - case 'enum': - $generatorJava.enumProperty(res, beanVarName, bean, propName, descr.enumClass, descr.setterName, descr.dflt); - break; - - case 'float': - $generatorJava.property(res, beanVarName, bean, propName, 'float', descr.setterName); - break; - - case 'path': - $generatorJava.property(res, beanVarName, bean, propName, 'path', descr.setterName); - break; - - case 'raw': - $generatorJava.property(res, beanVarName, bean, propName, 'raw', descr.setterName); - break; - - case 'propertiesAsList': - const val = bean[propName]; - - if (val && val.length > 0) { - $generatorJava.declareVariable(res, descr.propVarName, 'java.util.Properties'); - - _.forEach(val, function(nameAndValue) { - const eqIndex = nameAndValue.indexOf('='); - - if (eqIndex >= 0) { - res.line(descr.propVarName + '.setProperty(' + - '"' + nameAndValue.substring(0, eqIndex) + '", ' + - '"' + nameAndValue.substr(eqIndex + 1) + '");'); - } - }); - - res.needEmptyLine = true; - - res.line(beanVarName + '.' + $generatorJava.setterName(propName) + '(' + descr.propVarName + ');'); - } - break; - - case 'bean': - if ($generatorCommon.isDefinedAndNotEmpty(bean[propName])) - res.line(beanVarName + '.' + $generatorJava.setterName(propName) + '(new ' + res.importClass(bean[propName]) + '());'); - - break; - - default: - $generatorJava.property(res, beanVarName, bean, propName, null, descr.setterName, descr.dflt); - } - } - else - $generatorJava.property(res, beanVarName, bean, propName); - } - }); - - res.needEmptyLine = true; - - res.line(varName + '.' + $generatorJava.setterName(beanPropName) + '(' + beanVarName + ');'); - - res.needEmptyLine = true; - } - else if (createBeanAlthoughNoProps) { - res.emptyLineIfNeeded(); - res.line(varName + '.' + $generatorJava.setterName(beanPropName) + '(new ' + res.importClass(beanClass) + '());'); - - res.needEmptyLine = true; - } -}; - -/** - * Add eviction policy. - * - * @param res Resulting output with generated code. - * @param varName Current using variable name. - * @param evtPlc Data to add. - * @param propName Name in source data. - */ -$generatorJava.evictionPolicy = function(res, varName, evtPlc, propName) { - if (evtPlc && evtPlc.kind) { - const evictionPolicyDesc = $generatorCommon.EVICTION_POLICIES[evtPlc.kind]; - - const obj = evtPlc[evtPlc.kind.toUpperCase()]; - - $generatorJava.beanProperty(res, varName, obj, propName, propName, - evictionPolicyDesc.className, evictionPolicyDesc.fields, true); - } -}; - -// Generate cluster general group. -$generatorJava.clusterGeneral = function(cluster, clientNearCfg, res) { - if (!res) - res = $generatorCommon.builder(); - - $generatorJava.declareVariable(res, 'cfg', 'org.apache.ignite.configuration.IgniteConfiguration'); - - $generatorJava.property(res, 'cfg', cluster, 'name', null, 'setGridName'); - res.needEmptyLine = true; - - $generatorJava.property(res, 'cfg', cluster, 'localHost'); - res.needEmptyLine = true; - - if (clientNearCfg) { - res.line('cfg.setClientMode(true);'); - - res.needEmptyLine = true; - } - - if (cluster.discovery) { - const d = cluster.discovery; - - $generatorJava.declareVariable(res, 'discovery', 'org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi'); - - switch (d.kind) { - case 'Multicast': - $generatorJava.beanProperty(res, 'discovery', d.Multicast, 'ipFinder', 'ipFinder', - 'org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder', - { - multicastGroup: null, - multicastPort: null, - responseWaitTime: null, - addressRequestAttempts: null, - localAddress: null, - addresses: {type: 'list'} - }, true); - - break; - - case 'Vm': - $generatorJava.beanProperty(res, 'discovery', d.Vm, 'ipFinder', 'ipFinder', - 'org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder', - {addresses: {type: 'list'}}, true); - - break; - - case 'S3': - $generatorJava.beanProperty(res, 'discovery', d.S3, 'ipFinder', 'ipFinder', - 'org.apache.ignite.spi.discovery.tcp.ipfinder.s3.TcpDiscoveryS3IpFinder', {bucketName: null}, true); - - break; - - case 'Cloud': - $generatorJava.beanProperty(res, 'discovery', d.Cloud, 'ipFinder', 'ipFinder', - 'org.apache.ignite.spi.discovery.tcp.ipfinder.cloud.TcpDiscoveryCloudIpFinder', - { - credential: null, - credentialPath: null, - identity: null, - provider: null, - regions: {type: 'list'}, - zones: {type: 'list'} - }, true); - - break; - - case 'GoogleStorage': - $generatorJava.beanProperty(res, 'discovery', d.GoogleStorage, 'ipFinder', 'ipFinder', - 'org.apache.ignite.spi.discovery.tcp.ipfinder.gce.TcpDiscoveryGoogleStorageIpFinder', - { - projectName: null, - bucketName: null, - serviceAccountP12FilePath: null, - serviceAccountId: null - }, true); - - break; - - case 'Jdbc': - $generatorJava.declareVariable(res, 'ipFinder', - 'org.apache.ignite.spi.discovery.tcp.ipfinder.jdbc.TcpDiscoveryJdbcIpFinder'); - $generatorJava.property(res, 'ipFinder', d.Jdbc, 'initSchema'); - - const datasource = d.Jdbc; - if (datasource.dataSourceBean && datasource.dialect) { - res.needEmptyLine = !datasource.initSchema; - - res.line('ipFinder.setDataSource(DataSources.INSTANCE_' + datasource.dataSourceBean + ');'); - } - - res.needEmptyLine = true; - - res.line('discovery.setIpFinder(ipFinder);'); - - break; - - case 'SharedFs': - $generatorJava.beanProperty(res, 'discovery', d.SharedFs, 'ipFinder', 'ipFinder', - 'org.apache.ignite.spi.discovery.tcp.ipfinder.sharedfs.TcpDiscoverySharedFsIpFinder', {path: null}, true); - - break; - - case 'ZooKeeper': - const finderVar = 'ipFinder'; - - $generatorJava.declareVariable(res, 'ipFinder', 'org.apache.ignite.spi.discovery.tcp.ipfinder.zk.TcpDiscoveryZookeeperIpFinder'); - - if (d.ZooKeeper) { - if ($generatorCommon.isDefinedAndNotEmpty(d.ZooKeeper.curator)) - res.line(finderVar + '.setCurator(new ' + res.importClass(d.ZooKeeper.curator) + '());'); - - $generatorJava.property(res, finderVar, d.ZooKeeper, 'zkConnectionString'); - - if (d.ZooKeeper.retryPolicy && d.ZooKeeper.retryPolicy.kind) { - const kind = d.ZooKeeper.retryPolicy.kind; - const retryPolicy = d.ZooKeeper.retryPolicy[kind]; - - switch (kind) { - case 'ExponentialBackoff': - res.line(finderVar + '.setRetryPolicy(new ' + res.importClass('org.apache.curator.retry.ExponentialBackoffRetry') + '(' + - $generatorJava.constructorArg(retryPolicy, 'baseSleepTimeMs', 1000) + - $generatorJava.constructorArg(retryPolicy, 'maxRetries', 10, true) + - $generatorJava.constructorArg(retryPolicy, 'maxSleepMs', null, true, true) + '));'); - - break; - - case 'BoundedExponentialBackoff': - res.line(finderVar + '.setRetryPolicy(new ' + res.importClass('org.apache.curator.retry.BoundedExponentialBackoffRetry') + '(' + - $generatorJava.constructorArg(retryPolicy, 'baseSleepTimeMs', 1000) + - $generatorJava.constructorArg(retryPolicy, 'maxSleepTimeMs', 2147483647, true) + - $generatorJava.constructorArg(retryPolicy, 'maxRetries', 10, true) + '));'); - - break; - - case 'UntilElapsed': - res.line(finderVar + '.setRetryPolicy(new ' + res.importClass('org.apache.curator.retry.RetryUntilElapsed') + '(' + - $generatorJava.constructorArg(retryPolicy, 'maxElapsedTimeMs', 60000) + - $generatorJava.constructorArg(retryPolicy, 'sleepMsBetweenRetries', 1000, true) + '));'); - - break; - - case 'NTimes': - res.line(finderVar + '.setRetryPolicy(new ' + res.importClass('org.apache.curator.retry.RetryNTimes') + '(' + - $generatorJava.constructorArg(retryPolicy, 'n', 10) + - $generatorJava.constructorArg(retryPolicy, 'sleepMsBetweenRetries', 1000, true) + '));'); - - break; - - case 'OneTime': - res.line(finderVar + '.setRetryPolicy(new ' + res.importClass('org.apache.curator.retry.RetryOneTime') + '(' + - $generatorJava.constructorArg(retryPolicy, 'sleepMsBetweenRetry', 1000) + '));'); - - break; - - case 'Forever': - res.line(finderVar + '.setRetryPolicy(new ' + res.importClass('org.apache.curator.retry.RetryForever') + '(' + - $generatorJava.constructorArg(retryPolicy, 'retryIntervalMs', 1000) + '));'); - - break; - - case 'Custom': - if (retryPolicy && $generatorCommon.isDefinedAndNotEmpty(retryPolicy.className)) - res.line(finderVar + '.setRetryPolicy(new ' + res.importClass(retryPolicy.className) + '());'); - - break; - - default: - } - } - - $generatorJava.property(res, finderVar, d.ZooKeeper, 'basePath', null, null, '/services'); - $generatorJava.property(res, finderVar, d.ZooKeeper, 'serviceName', null, null, 'ignite'); - $generatorJava.property(res, finderVar, d.ZooKeeper, 'allowDuplicateRegistrations', null, null, false); - } - - res.line('discovery.setIpFinder(ipFinder);'); - - break; - - default: - res.line('Unknown discovery kind: ' + d.kind); - } - - res.needEmptyLine = false; - - $generatorJava.clusterDiscovery(d, res); - - res.emptyLineIfNeeded(); - - res.line('cfg.setDiscoverySpi(discovery);'); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate atomics group. -$generatorJava.clusterAtomics = function(atomics, res) { - if (!res) - res = $generatorCommon.builder(); - - if ($generatorCommon.hasAtLeastOneProperty(atomics, ['cacheMode', 'atomicSequenceReserveSize', 'backups'])) { - res.startSafeBlock(); - - $generatorJava.declareVariable(res, 'atomicCfg', 'org.apache.ignite.configuration.AtomicConfiguration'); - - $generatorJava.enumProperty(res, 'atomicCfg', atomics, 'cacheMode', 'org.apache.ignite.cache.CacheMode', null, 'PARTITIONED'); - - const cacheMode = atomics.cacheMode ? atomics.cacheMode : 'PARTITIONED'; - - let hasData = cacheMode !== 'PARTITIONED'; - - hasData = $generatorJava.property(res, 'atomicCfg', atomics, 'atomicSequenceReserveSize', null, null, 1000) || hasData; - - if (cacheMode === 'PARTITIONED') - hasData = $generatorJava.property(res, 'atomicCfg', atomics, 'backups', null, null, 0) || hasData; - - res.needEmptyLine = true; - - res.line('cfg.setAtomicConfiguration(atomicCfg);'); - - res.needEmptyLine = true; - - if (!hasData) - res.rollbackSafeBlock(); - } - - return res; -}; - -// Generate binary group. -$generatorJava.clusterBinary = function(binary, res) { - if (!res) - res = $generatorCommon.builder(); - - if ($generatorCommon.binaryIsDefined(binary)) { - const varName = 'binary'; - - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.configuration.BinaryConfiguration'); - - if ($generatorCommon.isDefinedAndNotEmpty(binary.idMapper)) - res.line(varName + '.setIdMapper(new ' + res.importClass(binary.idMapper) + '());'); - - if ($generatorCommon.isDefinedAndNotEmpty(binary.nameMapper)) - res.line(varName + '.setNameMapper(new ' + res.importClass(binary.nameMapper) + '());'); - - if ($generatorCommon.isDefinedAndNotEmpty(binary.serializer)) - res.line(varName + '.setSerializer(new ' + res.importClass(binary.serializer) + '());'); - - res.needEmptyLine = $generatorCommon.isDefinedAndNotEmpty(binary.idMapper) || $generatorCommon.isDefinedAndNotEmpty(binary.serializer); - - if ($generatorCommon.isDefinedAndNotEmpty(binary.typeConfigurations)) { - const arrVar = 'types'; - - $generatorJava.declareVariable(res, arrVar, 'java.util.Collection', 'java.util.ArrayList', 'org.apache.ignite.binary.BinaryTypeConfiguration'); - - _.forEach(binary.typeConfigurations, function(type) { - if ($generatorCommon.isDefinedAndNotEmpty(type.typeName)) - res.line(arrVar + '.add(' + $generatorJava.binaryTypeFunctionName(type.typeName) + '());'); // TODO IGNITE-2269 Replace using of separated methods for binary type configurations to extended constructors. - }); - - res.needEmptyLine = true; - - res.line(varName + '.setTypeConfigurations(' + arrVar + ');'); - - res.needEmptyLine = true; - } - - $generatorJava.property(res, varName, binary, 'compactFooter', null, null, true); - - res.needEmptyLine = true; - - res.line('cfg.setBinaryConfiguration(' + varName + ');'); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate cache key configurations. -$generatorJava.clusterCacheKeyConfiguration = function(keyCfgs, res) { - if (!res) - res = $generatorCommon.builder(); - - keyCfgs = _.filter(keyCfgs, (cfg) => cfg.typeName && cfg.affinityKeyFieldName); - - if (_.isEmpty(keyCfgs)) - return res; - - $generatorJava.declareVariableArray(res, 'keyConfigurations', 'org.apache.ignite.cache.CacheKeyConfiguration', keyCfgs.length); - - const cacheKeyCfg = res.importClass('org.apache.ignite.cache.CacheKeyConfiguration'); - - _.forEach(keyCfgs, (cfg, idx) => { - res.needEmptyLine = true; - - res.line(`keyConfigurations[${idx}] = new ${cacheKeyCfg}("${cfg.typeName}", "${cfg.affinityKeyFieldName}");`); - - res.needEmptyLine = true; - }); - - res.line('cfg.setCacheKeyConfiguration(keyConfigurations);'); - - res.needEmptyLine = true; - - return res; -}; - -// TODO IGNITE-2269 Remove specified methods after implamentation of extended constructors. -// Construct binary type configuration factory method name. -$generatorJava.binaryTypeFunctionName = function(typeName) { - const dotIdx = typeName.lastIndexOf('.'); - - const shortName = dotIdx > 0 ? typeName.substr(dotIdx + 1) : typeName; - - return $generatorCommon.toJavaName('binaryType', shortName); -}; - -// TODO IGNITE-2269 Remove specified methods after implamentation of extended constructors. -// Generate factory method for specified BinaryTypeConfiguration. -$generatorJava.binaryTypeConfiguration = function(type, res) { - const typeName = type.typeName; - - res.line('/**'); - res.line(' * Create binary type configuration for ' + typeName + '.'); - res.line(' *'); - res.line(' * @return Configured binary type.'); - res.line(' */'); - res.startBlock('private static BinaryTypeConfiguration ' + $generatorJava.binaryTypeFunctionName(typeName) + '() {'); - - $generatorJava.resetVariables(res); - - const typeVar = 'typeCfg'; - - $generatorJava.declareVariable(res, typeVar, 'org.apache.ignite.binary.BinaryTypeConfiguration'); - - $generatorJava.property(res, typeVar, type, 'typeName'); - - if ($generatorCommon.isDefinedAndNotEmpty(type.idMapper)) - res.line(typeVar + '.setIdMapper(new ' + res.importClass(type.idMapper) + '());'); - - if ($generatorCommon.isDefinedAndNotEmpty(type.nameMapper)) - res.line(typeVar + '.setNameMapper(new ' + res.importClass(type.nameMapper) + '());'); - - if ($generatorCommon.isDefinedAndNotEmpty(type.serializer)) - res.line(typeVar + '.setSerializer(new ' + res.importClass(type.serializer) + '());'); - - $generatorJava.property(res, typeVar, type, 'enum', null, null, false); - - res.needEmptyLine = true; - - res.line('return ' + typeVar + ';'); - res.endBlock('}'); - - res.needEmptyLine = true; -}; - -// TODO IGNITE-2269 Remove specified methods after implamentation of extended constructors. -// Generates binary type configuration factory methods. -$generatorJava.binaryTypeConfigurations = function(binary, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!_.isNil(binary)) { - _.forEach(binary.typeConfigurations, function(type) { - $generatorJava.binaryTypeConfiguration(type, res); - }); - } - - return res; -}; - -// Generate collision group. -$generatorJava.clusterCollision = function(collision, res) { - if (!res) - res = $generatorCommon.builder(); - - if (collision && collision.kind && collision.kind !== 'Noop') { - const spi = collision[collision.kind]; - - if (collision.kind !== 'Custom' || (spi && $generatorCommon.isDefinedAndNotEmpty(spi.class))) { - const varName = 'collisionSpi'; - - switch (collision.kind) { - case 'JobStealing': - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.spi.collision.jobstealing.JobStealingCollisionSpi'); - - $generatorJava.property(res, varName, spi, 'activeJobsThreshold', null, null, 95); - $generatorJava.property(res, varName, spi, 'waitJobsThreshold', null, null, 0); - $generatorJava.property(res, varName, spi, 'messageExpireTime', null, null, 1000); - $generatorJava.property(res, varName, spi, 'maximumStealingAttempts', null, null, 5); - $generatorJava.property(res, varName, spi, 'stealingEnabled', null, null, true); - - if ($generatorCommon.isDefinedAndNotEmpty(spi.externalCollisionListener)) { - res.line(varName + '.' + $generatorJava.setterName('externalCollisionListener') + - '(new ' + res.importClass(spi.externalCollisionListener) + '());'); - } - - if ($generatorCommon.isDefinedAndNotEmpty(spi.stealingAttributes)) { - const stealingAttrsVar = 'stealingAttrs'; - - res.needEmptyLine = true; - - $generatorJava.declareVariable(res, stealingAttrsVar, 'java.util.Map', 'java.util.HashMap', 'String', 'java.io.Serializable'); - - _.forEach(spi.stealingAttributes, function(attr) { - res.line(stealingAttrsVar + '.put("' + attr.name + '", "' + attr.value + '");'); - }); - - res.needEmptyLine = true; - - res.line(varName + '.setStealingAttributes(' + stealingAttrsVar + ');'); - } - - break; - - case 'FifoQueue': - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.spi.collision.fifoqueue.FifoQueueCollisionSpi'); - - $generatorJava.property(res, varName, spi, 'parallelJobsNumber'); - $generatorJava.property(res, varName, spi, 'waitingJobsNumber'); - - break; - - case 'PriorityQueue': - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.spi.collision.priorityqueue.PriorityQueueCollisionSpi'); - - $generatorJava.property(res, varName, spi, 'parallelJobsNumber'); - $generatorJava.property(res, varName, spi, 'waitingJobsNumber'); - $generatorJava.property(res, varName, spi, 'priorityAttributeKey', null, null, 'grid.task.priority'); - $generatorJava.property(res, varName, spi, 'jobPriorityAttributeKey', null, null, 'grid.job.priority'); - $generatorJava.property(res, varName, spi, 'defaultPriority', null, null, 0); - $generatorJava.property(res, varName, spi, 'starvationIncrement', null, null, 1); - $generatorJava.property(res, varName, spi, 'starvationPreventionEnabled', null, null, true); - - break; - - case 'Custom': - $generatorJava.declareVariable(res, varName, spi.class); - - break; - - default: - } - - res.needEmptyLine = true; - - res.line('cfg.setCollisionSpi(' + varName + ');'); - - res.needEmptyLine = true; - } - } - - return res; -}; - -// Generate communication group. -$generatorJava.clusterCommunication = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - const cfg = $generatorCommon.COMMUNICATION_CONFIGURATION; - - $generatorJava.beanProperty(res, 'cfg', cluster.communication, 'communicationSpi', 'commSpi', cfg.className, cfg.fields); - - res.needEmptyLine = false; - - $generatorJava.property(res, 'cfg', cluster, 'networkTimeout', null, null, 5000); - $generatorJava.property(res, 'cfg', cluster, 'networkSendRetryDelay', null, null, 1000); - $generatorJava.property(res, 'cfg', cluster, 'networkSendRetryCount', null, null, 3); - $generatorJava.property(res, 'cfg', cluster, 'segmentCheckFrequency'); - $generatorJava.property(res, 'cfg', cluster, 'waitForSegmentOnStart', null, null, false); - $generatorJava.property(res, 'cfg', cluster, 'discoveryStartupDelay', null, null, 60000); - - res.needEmptyLine = true; - - return res; -}; - -// Generate REST access group. -$generatorJava.clusterConnector = function(connector, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!_.isNil(connector) && connector.enabled) { - const cfg = _.cloneDeep($generatorCommon.CONNECTOR_CONFIGURATION); - - if (connector.sslEnabled) { - cfg.fields.sslClientAuth = {dflt: false}; - cfg.fields.sslFactory = {type: 'bean'}; - } - - $generatorJava.beanProperty(res, 'cfg', connector, 'connectorConfiguration', 'clientCfg', - cfg.className, cfg.fields, true); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate deployment group. -$generatorJava.clusterDeployment = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - $generatorJava.enumProperty(res, 'cfg', cluster, 'deploymentMode', 'org.apache.ignite.configuration.DeploymentMode', null, 'SHARED'); - - res.softEmptyLine(); - - const p2pEnabled = cluster.peerClassLoadingEnabled; - - if (!_.isNil(p2pEnabled)) { - $generatorJava.property(res, 'cfg', cluster, 'peerClassLoadingEnabled', null, null, false); - - if (p2pEnabled) { - $generatorJava.property(res, 'cfg', cluster, 'peerClassLoadingMissedResourcesCacheSize', null, null, 100); - $generatorJava.property(res, 'cfg', cluster, 'peerClassLoadingThreadPoolSize', null, null, 2); - $generatorJava.multiparamProperty(res, 'cfg', cluster, 'peerClassLoadingLocalClassPathExclude'); - } - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate discovery group. -$generatorJava.clusterDiscovery = function(disco, res) { - if (!res) - res = $generatorCommon.builder(); - - if (disco) { - $generatorJava.property(res, 'discovery', disco, 'localAddress'); - $generatorJava.property(res, 'discovery', disco, 'localPort', null, null, 47500); - $generatorJava.property(res, 'discovery', disco, 'localPortRange', null, null, 100); - - if ($generatorCommon.isDefinedAndNotEmpty(disco.addressResolver)) { - $generatorJava.beanProperty(res, 'discovery', disco, 'addressResolver', 'addressResolver', disco.addressResolver, {}, true); - res.needEmptyLine = false; - } - - $generatorJava.property(res, 'discovery', disco, 'socketTimeout', null, null, 5000); - $generatorJava.property(res, 'discovery', disco, 'ackTimeout', null, null, 5000); - $generatorJava.property(res, 'discovery', disco, 'maxAckTimeout', null, null, 600000); - $generatorJava.property(res, 'discovery', disco, 'networkTimeout', null, null, 5000); - $generatorJava.property(res, 'discovery', disco, 'joinTimeout', null, null, 0); - $generatorJava.property(res, 'discovery', disco, 'threadPriority', null, null, 10); - $generatorJava.property(res, 'discovery', disco, 'heartbeatFrequency', null, null, 2000); - $generatorJava.property(res, 'discovery', disco, 'maxMissedHeartbeats', null, null, 1); - $generatorJava.property(res, 'discovery', disco, 'maxMissedClientHeartbeats', null, null, 5); - $generatorJava.property(res, 'discovery', disco, 'topHistorySize', null, null, 1000); - - if ($generatorCommon.isDefinedAndNotEmpty(disco.listener)) { - $generatorJava.beanProperty(res, 'discovery', disco, 'listener', 'listener', disco.listener, {}, true); - res.needEmptyLine = false; - } - - if ($generatorCommon.isDefinedAndNotEmpty(disco.dataExchange)) { - $generatorJava.beanProperty(res, 'discovery', disco, 'dataExchange', 'dataExchange', disco.dataExchange, {}, true); - res.needEmptyLine = false; - } - - if ($generatorCommon.isDefinedAndNotEmpty(disco.metricsProvider)) { - $generatorJava.beanProperty(res, 'discovery', disco, 'metricsProvider', 'metricsProvider', disco.metricsProvider, {}, true); - res.needEmptyLine = false; - } - - $generatorJava.property(res, 'discovery', disco, 'reconnectCount', null, null, 10); - $generatorJava.property(res, 'discovery', disco, 'statisticsPrintFrequency', null, null, 0); - $generatorJava.property(res, 'discovery', disco, 'ipFinderCleanFrequency', null, null, 60000); - - if ($generatorCommon.isDefinedAndNotEmpty(disco.authenticator)) { - $generatorJava.beanProperty(res, 'discovery', disco, 'authenticator', 'authenticator', disco.authenticator, {}, true); - res.needEmptyLine = false; - } - - $generatorJava.property(res, 'discovery', disco, 'forceServerMode', null, null, false); - $generatorJava.property(res, 'discovery', disco, 'clientReconnectDisabled', null, null, false); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate events group. -$generatorJava.clusterEvents = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - if (cluster.includeEventTypes && cluster.includeEventTypes.length > 0) { - res.emptyLineIfNeeded(); - - const evtGrps = angular.element(document.getElementById('app')).injector().get('igniteEventGroups'); - - if (cluster.includeEventTypes.length === 1) { - const evtGrp = _.find(evtGrps, {value: cluster.includeEventTypes[0]}); - const evts = res.importStatic(evtGrp.class + '.' + evtGrp.value); - - res.line('cfg.setIncludeEventTypes(' + evts + ');'); - } - else { - _.forEach(cluster.includeEventTypes, function(value, ix) { - const evtGrp = _.find(evtGrps, {value}); - const evts = res.importStatic(evtGrp.class + '.' + evtGrp.value); - - if (ix === 0) - res.line('int[] events = new int[' + evts + '.length'); - else - res.line(' + ' + evts + '.length'); - }); - - res.line('];'); - - res.needEmptyLine = true; - - res.line('int k = 0;'); - - _.forEach(cluster.includeEventTypes, function(value, idx) { - res.needEmptyLine = true; - - const evtGrp = _.find(evtGrps, {value}); - const evts = res.importStatic(evtGrp.class + '.' + value); - - res.line('System.arraycopy(' + evts + ', 0, events, k, ' + evts + '.length);'); - - if (idx < cluster.includeEventTypes.length - 1) - res.line('k += ' + evts + '.length;'); - }); - - res.needEmptyLine = true; - - res.line('cfg.setIncludeEventTypes(events);'); - } - - res.needEmptyLine = true; - } - - res.needEmptyLine = true; - - return res; -}; - -// Generate failover group. -$generatorJava.clusterFailover = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - if ($generatorCommon.isDefinedAndNotEmpty(cluster.failoverSpi) && _.findIndex(cluster.failoverSpi, function(spi) { - return $generatorCommon.isDefinedAndNotEmpty(spi.kind) && (spi.kind !== 'Custom' || $generatorCommon.isDefinedAndNotEmpty(_.get(spi, spi.kind + '.class'))); - }) >= 0) { - const arrayVarName = 'failoverSpiList'; - - $generatorJava.declareVariable(res, arrayVarName, 'java.util.List', 'java.util.ArrayList', 'org.apache.ignite.spi.failover.FailoverSpi'); - - _.forEach(cluster.failoverSpi, function(spi) { - if (spi.kind && (spi.kind !== 'Custom' || $generatorCommon.isDefinedAndNotEmpty(_.get(spi, spi.kind + '.class')))) { - const varName = 'failoverSpi'; - - const maxAttempts = _.get(spi, spi.kind + '.maximumFailoverAttempts'); - - if ((spi.kind === 'JobStealing' || spi.kind === 'Always') && $generatorCommon.isDefinedAndNotEmpty(maxAttempts) && maxAttempts !== 5) { - const spiCls = res.importClass($generatorCommon.failoverSpiClass(spi)); - - $generatorJava.declareVariableCustom(res, varName, 'org.apache.ignite.spi.failover.FailoverSpi', 'new ' + spiCls + '()'); - - if ($generatorCommon.isDefinedAndNotEmpty(spi[spi.kind].maximumFailoverAttempts)) - res.line('((' + spiCls + ') ' + varName + ').setMaximumFailoverAttempts(' + spi[spi.kind].maximumFailoverAttempts + ');'); - - res.needEmptyLine = true; - - res.line(arrayVarName + '.add(' + varName + ');'); - } - else - res.line(arrayVarName + '.add(new ' + res.importClass($generatorCommon.failoverSpiClass(spi)) + '());'); - - res.needEmptyLine = true; - } - }); - - res.line('cfg.setFailoverSpi(' + arrayVarName + '.toArray(new FailoverSpi[' + arrayVarName + '.size()]));'); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate marshaller group. -$generatorJava.clusterLogger = function(logger, res) { - if (!res) - res = $generatorCommon.builder(); - - if ($generatorCommon.loggerConfigured(logger)) { - const varName = 'logger'; - - const log = logger[logger.kind]; - - switch (logger.kind) { - case 'Log4j2': - $generatorJava.declareVariableCustom(res, varName, 'org.apache.ignite.logger.log4j2.Log4J2Logger', - 'new Log4J2Logger(' + $generatorJava.toJavaCode(log.path, 'path') + ')'); - - res.needEmptyLine = true; - - if ($generatorCommon.isDefinedAndNotEmpty(log.level)) - res.line(varName + '.setLevel(' + res.importClass('org.apache.logging.log4j.Level') + '.' + log.level + ');'); - - break; - - case 'Null': - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.logger.NullLogger'); - - break; - - case 'Java': - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.logger.java.JavaLogger'); - - break; - - case 'JCL': - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.logger.jcl.JclLogger'); - - break; - - case 'SLF4J': - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.logger.slf4j.Slf4jLogger'); - - break; - - case 'Log4j': - if (log.mode === 'Default') - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.logger.log4j.Log4JLogger'); - else { - $generatorJava.declareVariableCustom(res, varName, 'org.apache.ignite.logger.log4j.Log4JLogger', - 'new Log4JLogger(' + $generatorJava.toJavaCode(log.path, 'path') + ')'); - } - - if ($generatorCommon.isDefinedAndNotEmpty(log.level)) - res.line(varName + '.setLevel(' + res.importClass('org.apache.log4j.Level') + '.' + log.level + ');'); - - break; - - case 'Custom': - $generatorJava.declareVariable(res, varName, log.class); - - break; - - default: - } - - res.needEmptyLine = true; - - res.line('cfg.setGridLogger(' + varName + ');'); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate marshaller group. -$generatorJava.clusterMarshaller = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - const marshaller = cluster.marshaller; - - if (marshaller && marshaller.kind) { - const marshallerDesc = $generatorCommon.MARSHALLERS[marshaller.kind]; - - $generatorJava.beanProperty(res, 'cfg', marshaller[marshaller.kind], 'marshaller', 'marshaller', - marshallerDesc.className, marshallerDesc.fields, true); - - $generatorJava.beanProperty(res, 'marshaller', marshaller[marshaller.kind], marshallerDesc.className, marshallerDesc.fields, true); - } - - $generatorJava.property(res, 'cfg', cluster, 'marshalLocalJobs', null, null, false); - $generatorJava.property(res, 'cfg', cluster, 'marshallerCacheKeepAliveTime', null, null, 10000); - $generatorJava.property(res, 'cfg', cluster, 'marshallerCacheThreadPoolSize', null, 'setMarshallerCachePoolSize'); - - res.needEmptyLine = true; - - return res; -}; - -// Generate metrics group. -$generatorJava.clusterMetrics = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - $generatorJava.property(res, 'cfg', cluster, 'metricsExpireTime'); - $generatorJava.property(res, 'cfg', cluster, 'metricsHistorySize', null, null, 10000); - $generatorJava.property(res, 'cfg', cluster, 'metricsLogFrequency', null, null, 60000); - $generatorJava.property(res, 'cfg', cluster, 'metricsUpdateFrequency', null, null, 2000); - - res.needEmptyLine = true; - - return res; -}; - -// Generate swap group. -$generatorJava.clusterSwap = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - if (cluster.swapSpaceSpi && cluster.swapSpaceSpi.kind === 'FileSwapSpaceSpi') { - $generatorJava.beanProperty(res, 'cfg', cluster.swapSpaceSpi.FileSwapSpaceSpi, 'swapSpaceSpi', 'swapSpi', - $generatorCommon.SWAP_SPACE_SPI.className, $generatorCommon.SWAP_SPACE_SPI.fields, true); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate time group. -$generatorJava.clusterTime = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - $generatorJava.property(res, 'cfg', cluster, 'clockSyncSamples', null, null, 8); - $generatorJava.property(res, 'cfg', cluster, 'clockSyncFrequency', null, null, 120000); - $generatorJava.property(res, 'cfg', cluster, 'timeServerPortBase', null, null, 31100); - $generatorJava.property(res, 'cfg', cluster, 'timeServerPortRange', null, null, 100); - - res.needEmptyLine = true; - - return res; -}; - -// Generate ODBC configuration group. -$generatorJava.clusterODBC = function(odbc, res) { - if (!res) - res = $generatorCommon.builder(); - - if (odbc && odbc.odbcEnabled) { - $generatorJava.beanProperty(res, 'cfg', odbc, 'odbcConfiguration', 'odbcConfiguration', - $generatorCommon.ODBC_CONFIGURATION.className, $generatorCommon.ODBC_CONFIGURATION.fields, true); - } - - res.needEmptyLine = true; - - return res; -}; - -// Generate thread pools group. -$generatorJava.clusterPools = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - $generatorJava.property(res, 'cfg', cluster, 'publicThreadPoolSize'); - $generatorJava.property(res, 'cfg', cluster, 'systemThreadPoolSize'); - $generatorJava.property(res, 'cfg', cluster, 'managementThreadPoolSize'); - $generatorJava.property(res, 'cfg', cluster, 'igfsThreadPoolSize'); - $generatorJava.property(res, 'cfg', cluster, 'rebalanceThreadPoolSize'); - - res.needEmptyLine = true; - - return res; -}; - -// Generate transactions group. -$generatorJava.clusterTransactions = function(transactionConfiguration, res) { - if (!res) - res = $generatorCommon.builder(); - - $generatorJava.beanProperty(res, 'cfg', transactionConfiguration, 'transactionConfiguration', - 'transactionConfiguration', $generatorCommon.TRANSACTION_CONFIGURATION.className, - $generatorCommon.TRANSACTION_CONFIGURATION.fields, false); - - return res; -}; - -// Generate user attributes group. -$generatorJava.clusterUserAttributes = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - if ($generatorCommon.isDefinedAndNotEmpty(cluster.attributes)) { - $generatorJava.declareVariable(res, 'attributes', 'java.util.Map', 'java.util.HashMap', 'java.lang.String', 'java.lang.String'); - - _.forEach(cluster.attributes, function(attr) { - res.line('attributes.put("' + attr.name + '", "' + attr.value + '");'); - }); - - res.needEmptyLine = true; - - res.line('cfg.setUserAttributes(attributes);'); - - res.needEmptyLine = true; - } - - res.needEmptyLine = true; - - return res; -}; - - -// Generate cache general group. -$generatorJava.cacheGeneral = function(cache, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!varName) - varName = $generatorJava.nextVariableName('cache', cache); - - $generatorJava.property(res, varName, cache, 'name'); - - $generatorJava.enumProperty(res, varName, cache, 'cacheMode', 'org.apache.ignite.cache.CacheMode'); - $generatorJava.enumProperty(res, varName, cache, 'atomicityMode', 'org.apache.ignite.cache.CacheAtomicityMode'); - - if (cache.cacheMode === 'PARTITIONED' && $generatorJava.property(res, varName, cache, 'backups')) - $generatorJava.property(res, varName, cache, 'readFromBackup'); - - $generatorJava.property(res, varName, cache, 'copyOnRead'); - - if (cache.cacheMode === 'PARTITIONED' && cache.atomicityMode === 'TRANSACTIONAL') - $generatorJava.property(res, varName, cache, 'invalidate'); - - res.needEmptyLine = true; - - return res; -}; - -// Generate cache memory group. -$generatorJava.cacheMemory = function(cache, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!varName) - varName = $generatorJava.nextVariableName('cache', cache); - - $generatorJava.enumProperty(res, varName, cache, 'memoryMode', 'org.apache.ignite.cache.CacheMemoryMode', null, 'ONHEAP_TIERED'); - - if (cache.memoryMode !== 'OFFHEAP_VALUES') - $generatorJava.property(res, varName, cache, 'offHeapMaxMemory', null, null, -1); - - res.softEmptyLine(); - - $generatorJava.evictionPolicy(res, varName, cache.evictionPolicy, 'evictionPolicy'); - - $generatorJava.property(res, varName, cache, 'startSize', null, null, 1500000); - $generatorJava.property(res, varName, cache, 'swapEnabled', null, null, false); - - res.needEmptyLine = true; - - return res; -}; - -// Generate cache query & indexing group. -$generatorJava.cacheQuery = function(cache, domains, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!varName) - varName = $generatorJava.nextVariableName('cache', cache); - - $generatorJava.property(res, varName, cache, 'sqlSchema'); - $generatorJava.property(res, varName, cache, 'sqlOnheapRowCacheSize', null, null, 10240); - $generatorJava.property(res, varName, cache, 'longQueryWarningTimeout', null, null, 3000); - - const indexedTypes = _.reduce(domains, (acc, domain) => { - if (domain.queryMetadata === 'Annotations') { - acc.push(domain.keyType); - acc.push(domain.valueType); - } - - return acc; - }, []); - - if (indexedTypes.length > 0) { - res.softEmptyLine(); - - $generatorJava.multiparamProperty(res, varName, {indexedTypes}, 'indexedTypes', 'class'); - } - - res.softEmptyLine(); - - $generatorJava.multiparamProperty(res, varName, cache, 'sqlFunctionClasses', 'class'); - - res.softEmptyLine(); - - $generatorJava.property(res, varName, cache, 'snapshotableIndex', null, null, false); - $generatorJava.property(res, varName, cache, 'sqlEscapeAll', null, null, false); - - res.needEmptyLine = true; - - return res; -}; - -/** - * Generate cache store datasource. - * - * @param storeFactory Factory to generate data source for. - * @param res Resulting output with generated code. - */ -$generatorJava.cacheStoreDataSource = function(storeFactory, res) { - const dialect = storeFactory.connectVia ? (storeFactory.connectVia === 'DataSource' ? storeFactory.dialect : null) : storeFactory.dialect; - - if (dialect) { - const varName = 'dataSource'; - - const dataSourceBean = storeFactory.dataSourceBean; - - const varType = res.importClass($generatorCommon.dataSourceClassName(dialect)); - - res.line('public static final ' + varType + ' INSTANCE_' + dataSourceBean + ' = create' + dataSourceBean + '();'); - - res.needEmptyLine = true; - - res.startBlock('private static ' + varType + ' create' + dataSourceBean + '() {'); - if (dialect === 'Oracle') - res.startBlock('try {'); - - $generatorJava.resetVariables(res); - - $generatorJava.declareVariable(res, varName, varType); - - switch (dialect) { - case 'Generic': - res.line(varName + '.setJdbcUrl(props.getProperty("' + dataSourceBean + '.jdbc.url"));'); - - break; - - case 'DB2': - res.line(varName + '.setServerName(props.getProperty("' + dataSourceBean + '.jdbc.server_name"));'); - res.line(varName + '.setPortNumber(Integer.valueOf(props.getProperty("' + dataSourceBean + '.jdbc.port_number")));'); - res.line(varName + '.setDatabaseName(props.getProperty("' + dataSourceBean + '.jdbc.database_name"));'); - res.line(varName + '.setDriverType(Integer.valueOf(props.getProperty("' + dataSourceBean + '.jdbc.driver_type")));'); - - break; - - case 'PostgreSQL': - res.line(varName + '.setUrl(props.getProperty("' + dataSourceBean + '.jdbc.url"));'); - - break; - - default: - res.line(varName + '.setURL(props.getProperty("' + dataSourceBean + '.jdbc.url"));'); - } - - res.line(varName + '.setUser(props.getProperty("' + dataSourceBean + '.jdbc.username"));'); - res.line(varName + '.setPassword(props.getProperty("' + dataSourceBean + '.jdbc.password"));'); - - res.needEmptyLine = true; - - res.line('return dataSource;'); - - if (dialect === 'Oracle') { - res.endBlock('}'); - res.startBlock('catch (' + res.importClass('java.sql.SQLException') + ' ex) {'); - res.line('throw new Error(ex);'); - res.endBlock('}'); - } - - res.endBlock('}'); - - res.needEmptyLine = true; - - return dataSourceBean; - } - - return null; -}; - -$generatorJava.clusterDataSources = function(cluster, res) { - if (!res) - res = $generatorCommon.builder(); - - const datasources = []; - - let storeFound = false; - - function startSourcesFunction() { - if (!storeFound) { - res.line('/** Helper class for datasource creation. */'); - res.startBlock('public static class DataSources {'); - - storeFound = true; - } - } - - _.forEach(cluster.caches, function(cache) { - const factoryKind = cache.cacheStoreFactory.kind; - - const storeFactory = cache.cacheStoreFactory[factoryKind]; - - if (storeFactory) { - const beanClassName = $generatorJava.dataSourceClassName(res, storeFactory); - - if (beanClassName && !_.includes(datasources, beanClassName)) { - datasources.push(beanClassName); - - if (factoryKind === 'CacheJdbcPojoStoreFactory' || factoryKind === 'CacheJdbcBlobStoreFactory') { - startSourcesFunction(); - - $generatorJava.cacheStoreDataSource(storeFactory, res); - } - } - } - }); - - if (cluster.discovery.kind === 'Jdbc') { - const datasource = cluster.discovery.Jdbc; - - if (datasource.dataSourceBean && datasource.dialect) { - const beanClassName = $generatorJava.dataSourceClassName(res, datasource); - - if (beanClassName && !_.includes(datasources, beanClassName)) { - startSourcesFunction(); - - $generatorJava.cacheStoreDataSource(datasource, res); - } - } - } - - if (storeFound) - res.endBlock('}'); - - return res; -}; - -/** - * Generate cache store group. - * - * @param cache Cache descriptor. - * @param domains Domain model descriptors. - * @param cacheVarName Cache variable name. - * @param res Resulting output with generated code. - * @returns {*} Java code for cache store configuration. - */ -$generatorJava.cacheStore = function(cache, domains, cacheVarName, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!cacheVarName) - cacheVarName = $generatorJava.nextVariableName('cache', cache); - - if (cache.cacheStoreFactory && cache.cacheStoreFactory.kind) { - const factoryKind = cache.cacheStoreFactory.kind; - - const storeFactory = cache.cacheStoreFactory[factoryKind]; - - if (storeFactory) { - const storeFactoryDesc = $generatorCommon.STORE_FACTORIES[factoryKind]; - - const varName = 'storeFactory' + storeFactoryDesc.suffix; - - if (factoryKind === 'CacheJdbcPojoStoreFactory') { - // Generate POJO store factory. - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory', null, null, null, true); - res.deep++; - - res.line('/** {@inheritDoc} */'); - res.startBlock('@Override public ' + res.importClass('org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore') + ' create() {'); - - res.line('setDataSource(DataSources.INSTANCE_' + storeFactory.dataSourceBean + ');'); - - res.needEmptyLine = true; - - res.line('return super.create();'); - res.endBlock('}'); - res.endBlock('};'); - - res.needEmptyLine = true; - - res.line(varName + '.setDialect(new ' + - res.importClass($generatorCommon.jdbcDialectClassName(storeFactory.dialect)) + '());'); - - res.needEmptyLine = true; - - if (storeFactory.sqlEscapeAll) { - res.line(varName + '.setSqlEscapeAll(true);'); - - res.needEmptyLine = true; - } - - const domainConfigs = _.filter(domains, function(domain) { - return $generatorCommon.domainQueryMetadata(domain) === 'Configuration' && - $generatorCommon.isDefinedAndNotEmpty(domain.databaseTable); - }); - - if ($generatorCommon.isDefinedAndNotEmpty(domainConfigs)) { - $generatorJava.declareVariable(res, 'jdbcTypes', 'java.util.Collection', 'java.util.ArrayList', 'org.apache.ignite.cache.store.jdbc.JdbcType'); - - res.needEmptyLine = true; - - _.forEach(domainConfigs, function(domain) { - if ($generatorCommon.isDefinedAndNotEmpty(domain.databaseTable)) - res.line('jdbcTypes.add(jdbcType' + $generatorJava.extractType(domain.valueType) + '(' + cacheVarName + '.getName()));'); - }); - - res.needEmptyLine = true; - - res.line(varName + '.setTypes(jdbcTypes.toArray(new JdbcType[jdbcTypes.size()]));'); - - res.needEmptyLine = true; - } - - res.line(cacheVarName + '.setCacheStoreFactory(' + varName + ');'); - } - else if (factoryKind === 'CacheJdbcBlobStoreFactory') { - // Generate POJO store factory. - $generatorJava.declareVariable(res, varName, 'org.apache.ignite.cache.store.jdbc.CacheJdbcBlobStoreFactory', null, null, null, storeFactory.connectVia === 'DataSource'); - - if (storeFactory.connectVia === 'DataSource') { - res.deep++; - - res.line('/** {@inheritDoc} */'); - res.startBlock('@Override public ' + res.importClass('org.apache.ignite.cache.store.jdbc.CacheJdbcBlobStore') + ' create() {'); - - res.line('setDataSource(DataSources.INSTANCE_' + storeFactory.dataSourceBean + ');'); - - res.needEmptyLine = true; - - res.line('return super.create();'); - res.endBlock('}'); - res.endBlock('};'); - - res.needEmptyLine = true; - - $generatorJava.property(res, varName, storeFactory, 'initSchema'); - $generatorJava.property(res, varName, storeFactory, 'createTableQuery'); - $generatorJava.property(res, varName, storeFactory, 'loadQuery'); - $generatorJava.property(res, varName, storeFactory, 'insertQuery'); - $generatorJava.property(res, varName, storeFactory, 'updateQuery'); - $generatorJava.property(res, varName, storeFactory, 'deleteQuery'); - } - else { - $generatorJava.property(res, varName, storeFactory, 'connectionUrl'); - - if (storeFactory.user) { - $generatorJava.property(res, varName, storeFactory, 'user'); - res.line(varName + '.setPassword(props.getProperty("ds.' + storeFactory.user + '.password"));'); - } - } - - res.needEmptyLine = true; - - res.line(cacheVarName + '.setCacheStoreFactory(' + varName + ');'); - } - else - $generatorJava.beanProperty(res, cacheVarName, storeFactory, 'cacheStoreFactory', varName, storeFactoryDesc.className, storeFactoryDesc.fields, true); - - res.needEmptyLine = true; - } - } - - res.softEmptyLine(); - - $generatorJava.property(res, cacheVarName, cache, 'storeKeepBinary', null, null, false); - $generatorJava.property(res, cacheVarName, cache, 'loadPreviousValue', null, null, false); - $generatorJava.property(res, cacheVarName, cache, 'readThrough', null, null, false); - $generatorJava.property(res, cacheVarName, cache, 'writeThrough', null, null, false); - - res.softEmptyLine(); - - if (cache.writeBehindEnabled) { - $generatorJava.property(res, cacheVarName, cache, 'writeBehindEnabled', null, null, false); - $generatorJava.property(res, cacheVarName, cache, 'writeBehindBatchSize', null, null, 512); - $generatorJava.property(res, cacheVarName, cache, 'writeBehindFlushSize', null, null, 10240); - $generatorJava.property(res, cacheVarName, cache, 'writeBehindFlushFrequency', null, null, 5000); - $generatorJava.property(res, cacheVarName, cache, 'writeBehindFlushThreadCount', null, null, 1); - } - - res.needEmptyLine = true; - - return res; -}; - -// Generate cache node filter group. -$generatorJava.cacheNodeFilter = function(cache, igfss, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!varName) - varName = $generatorJava.nextVariableName('cache', cache); - - switch (_.get(cache, 'nodeFilter.kind')) { - case 'IGFS': - const foundIgfs = _.find(igfss, (igfs) => igfs._id === cache.nodeFilter.IGFS.igfs); - - if (foundIgfs) { - const predClsName = res.importClass('org.apache.ignite.internal.processors.igfs.IgfsNodePredicate'); - - res.line(`${varName}.setNodeFilter(new ${predClsName}("${foundIgfs.name}"));`); - } - - break; - - case 'OnNodes': - const nodes = cache.nodeFilter.OnNodes.nodeIds; - - if ($generatorCommon.isDefinedAndNotEmpty(nodes)) { - const startQuote = res.importClass('java.util.UUID') + '.fromString("'; - - $generatorJava.fxVarArgs(res, varName + '.setNodeFilter(new ' + - res.importClass('org.apache.ignite.internal.util.lang.GridNodePredicate'), true, nodes, '(', '))', - startQuote, '")'); - } - - break; - - case 'Custom': - res.line(varName + '.setNodeFilter(new ' + res.importClass(cache.nodeFilter.Custom.className) + '());'); - - break; - - default: break; - } - - res.needEmptyLine = true; - - return res; -}; - -// Generate cache concurrency group. -$generatorJava.cacheConcurrency = function(cache, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!varName) - varName = $generatorJava.nextVariableName('cache', cache); - - $generatorJava.property(res, varName, cache, 'maxConcurrentAsyncOperations', null, null, 500); - $generatorJava.property(res, varName, cache, 'defaultLockTimeout', null, null, 0); - $generatorJava.enumProperty(res, varName, cache, 'atomicWriteOrderMode', 'org.apache.ignite.cache.CacheAtomicWriteOrderMode'); - $generatorJava.enumProperty(res, varName, cache, 'writeSynchronizationMode', 'org.apache.ignite.cache.CacheWriteSynchronizationMode', null, 'PRIMARY_SYNC'); - - res.needEmptyLine = true; - - return res; -}; - -// Generate cache rebalance group. -$generatorJava.cacheRebalance = function(cache, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!varName) - varName = $generatorJava.nextVariableName('cache', cache); - - if (cache.cacheMode !== 'LOCAL') { - $generatorJava.enumProperty(res, varName, cache, 'rebalanceMode', 'org.apache.ignite.cache.CacheRebalanceMode', null, 'ASYNC'); - $generatorJava.property(res, varName, cache, 'rebalanceThreadPoolSize', null, null, 1); - $generatorJava.property(res, varName, cache, 'rebalanceBatchSize', null, null, 524288); - $generatorJava.property(res, varName, cache, 'rebalanceBatchesPrefetchCount', null, null, 2); - $generatorJava.property(res, varName, cache, 'rebalanceOrder', null, null, 0); - $generatorJava.property(res, varName, cache, 'rebalanceDelay', null, null, 0); - $generatorJava.property(res, varName, cache, 'rebalanceTimeout', null, null, 10000); - $generatorJava.property(res, varName, cache, 'rebalanceThrottle', null, null, 0); - } - - res.softEmptyLine(); - - if (cache.igfsAffinnityGroupSize) { - res.line(varName + '.setAffinityMapper(new ' + res.importClass('org.apache.ignite.igfs.IgfsGroupDataBlocksKeyMapper') + '(' + cache.igfsAffinnityGroupSize + '));'); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate cache server near cache group. -$generatorJava.cacheServerNearCache = function(cache, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!varName) - varName = $generatorJava.nextVariableName('cache', cache); - - if (cache.cacheMode === 'PARTITIONED' && cache.nearCacheEnabled) { - res.needEmptyLine = true; - - if (cache.nearConfiguration) { - $generatorJava.declareVariable(res, 'nearCfg', 'org.apache.ignite.configuration.NearCacheConfiguration'); - - res.needEmptyLine = true; - - if (cache.nearConfiguration.nearStartSize) { - $generatorJava.property(res, 'nearCfg', cache.nearConfiguration, 'nearStartSize', null, null, 375000); - - res.needEmptyLine = true; - } - - if (cache.nearConfiguration.nearEvictionPolicy && cache.nearConfiguration.nearEvictionPolicy.kind) { - $generatorJava.evictionPolicy(res, 'nearCfg', cache.nearConfiguration.nearEvictionPolicy, 'nearEvictionPolicy'); - - res.needEmptyLine = true; - } - - res.line(varName + '.setNearConfiguration(nearCfg);'); - - res.needEmptyLine = true; - } - } - - return res; -}; - -// Generate cache statistics group. -$generatorJava.cacheStatistics = function(cache, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - if (!varName) - varName = $generatorJava.nextVariableName('cache', cache); - - $generatorJava.property(res, varName, cache, 'statisticsEnabled', null, null, false); - $generatorJava.property(res, varName, cache, 'managementEnabled', null, null, false); - - res.needEmptyLine = true; - - return res; -}; - -// Generate domain model query fields. -$generatorJava.domainModelQueryFields = function(res, domain) { - const fields = domain.fields; - - if (fields && fields.length > 0) { - $generatorJava.declareVariable(res, 'fields', 'java.util.LinkedHashMap', 'java.util.LinkedHashMap', 'java.lang.String', 'java.lang.String'); - - _.forEach(fields, function(field) { - res.line('fields.put("' + field.name + '", "' + $generatorCommon.JavaTypes.fullClassName(field.className) + '");'); - }); - - res.needEmptyLine = true; - - res.line('qryMeta.setFields(fields);'); - - res.needEmptyLine = true; - } -}; - -// Generate domain model query aliases. -$generatorJava.domainModelQueryAliases = function(res, domain) { - const aliases = domain.aliases; - - if (aliases && aliases.length > 0) { - $generatorJava.declareVariable(res, 'aliases', 'java.util.Map', 'java.util.HashMap', 'java.lang.String', 'java.lang.String'); - - _.forEach(aliases, function(alias) { - res.line('aliases.put("' + alias.field + '", "' + alias.alias + '");'); - }); - - res.needEmptyLine = true; - - res.line('qryMeta.setAliases(aliases);'); - - res.needEmptyLine = true; - } -}; - -// Generate domain model indexes. -$generatorJava.domainModelQueryIndexes = function(res, domain) { - const indexes = domain.indexes; - - if (indexes && indexes.length > 0) { - res.needEmptyLine = true; - - $generatorJava.declareVariable(res, 'indexes', 'java.util.List', 'java.util.ArrayList', 'org.apache.ignite.cache.QueryIndex'); - - _.forEach(indexes, function(index) { - const fields = index.fields; - - // One row generation for 1 field index. - if (fields && fields.length === 1) { - const field = index.fields[0]; - - res.line('indexes.add(new ' + res.importClass('org.apache.ignite.cache.QueryIndex') + - '("' + field.name + '", ' + - res.importClass('org.apache.ignite.cache.QueryIndexType') + '.' + index.indexType + ', ' + - field.direction + ', "' + index.name + '"));'); - } - else { - res.needEmptyLine = true; - - $generatorJava.declareVariable(res, 'index', 'org.apache.ignite.cache.QueryIndex'); - - $generatorJava.property(res, 'index', index, 'name'); - $generatorJava.enumProperty(res, 'index', index, 'indexType', 'org.apache.ignite.cache.QueryIndexType'); - - res.needEmptyLine = true; - - if (fields && fields.length > 0) { - $generatorJava.declareVariable(res, 'indFlds', 'java.util.LinkedHashMap', 'java.util.LinkedHashMap', 'String', 'Boolean'); - - _.forEach(fields, function(field) { - res.line('indFlds.put("' + field.name + '", ' + field.direction + ');'); - }); - - res.needEmptyLine = true; - - res.line('index.setFields(indFlds);'); - - res.needEmptyLine = true; - } - - res.line('indexes.add(index);'); - } - }); - - res.needEmptyLine = true; - - res.line('qryMeta.setIndexes(indexes);'); - - res.needEmptyLine = true; - } -}; - -// Generate domain model db fields. -$generatorJava.domainModelDatabaseFields = function(res, domain, fieldProperty) { - const dbFields = domain[fieldProperty]; - - if (dbFields && dbFields.length > 0) { - res.needEmptyLine = true; - - res.importClass('java.sql.Types'); - - res.startBlock('jdbcType.' + $generatorCommon.toJavaName('set', fieldProperty) + '('); - - const lastIx = dbFields.length - 1; - - res.importClass('org.apache.ignite.cache.store.jdbc.JdbcTypeField'); - - _.forEach(dbFields, function(field, ix) { - res.line('new JdbcTypeField(' + - 'Types.' + field.databaseFieldType + ', ' + '"' + field.databaseFieldName + '", ' + - res.importClass(field.javaFieldType) + '.class, ' + '"' + field.javaFieldName + '"' + ')' + (ix < lastIx ? ',' : '')); - }); - - res.endBlock(');'); - - res.needEmptyLine = true; - } -}; - -// Generate domain model general group. -$generatorJava.domainModelGeneral = function(domain, res) { - if (!res) - res = $generatorCommon.builder(); - - switch ($generatorCommon.domainQueryMetadata(domain)) { - case 'Annotations': - if ($generatorCommon.isDefinedAndNotEmpty(domain.keyType) || $generatorCommon.isDefinedAndNotEmpty(domain.valueType)) { - const types = []; - - if ($generatorCommon.isDefinedAndNotEmpty(domain.keyType)) - types.push($generatorJava.toJavaCode(res.importClass(domain.keyType), 'class')); - else - types.push('???'); - - if ($generatorCommon.isDefinedAndNotEmpty(domain.valueType)) - types.push($generatorJava.toJavaCode(res.importClass(domain.valueType), 'class')); - else - types.push('???'); - - if ($generatorCommon.isDefinedAndNotEmpty(types)) - $generatorJava.fxVarArgs(res, 'cache.setIndexedTypes', false, types); - } - - break; - - case 'Configuration': - $generatorJava.classNameProperty(res, 'jdbcTypes', domain, 'keyType'); - $generatorJava.property(res, 'jdbcTypes', domain, 'valueType'); - - if ($generatorCommon.isDefinedAndNotEmpty(domain.fields)) { - res.needEmptyLine = true; - - $generatorJava.classNameProperty(res, 'qryMeta', domain, 'keyType'); - $generatorJava.property(res, 'qryMeta', domain, 'valueType'); - } - - break; - - default: - } - - res.needEmptyLine = true; - - return res; -}; - -// Generate domain model for query group. -$generatorJava.domainModelQuery = function(domain, res) { - if (!res) - res = $generatorCommon.builder(); - - if ($generatorCommon.domainQueryMetadata(domain) === 'Configuration') { - $generatorJava.domainModelQueryFields(res, domain); - $generatorJava.domainModelQueryAliases(res, domain); - $generatorJava.domainModelQueryIndexes(res, domain); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate domain model for store group. -$generatorJava.domainStore = function(domain, withTypes, res) { - if (!res) - res = $generatorCommon.builder(); - - $generatorJava.property(res, 'jdbcType', domain, 'databaseSchema'); - $generatorJava.property(res, 'jdbcType', domain, 'databaseTable'); - - if (withTypes) { - $generatorJava.classNameProperty(res, 'jdbcType', domain, 'keyType'); - $generatorJava.property(res, 'jdbcType', domain, 'valueType'); - } - - $generatorJava.domainModelDatabaseFields(res, domain, 'keyFields'); - $generatorJava.domainModelDatabaseFields(res, domain, 'valueFields'); - - res.needEmptyLine = true; - - return res; -}; - -// Generate domain model configs. -$generatorJava.cacheDomains = function(domains, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - const domainConfigs = _.filter(domains, function(domain) { - return $generatorCommon.domainQueryMetadata(domain) === 'Configuration' && - $generatorCommon.isDefinedAndNotEmpty(domain.fields); - }); - - // Generate domain model configs. - if ($generatorCommon.isDefinedAndNotEmpty(domainConfigs)) { - $generatorJava.declareVariable(res, 'queryEntities', 'java.util.Collection', 'java.util.ArrayList', 'org.apache.ignite.cache.QueryEntity'); - - _.forEach(domainConfigs, function(domain) { - if ($generatorCommon.isDefinedAndNotEmpty(domain.fields)) - res.line('queryEntities.add(queryEntity' + $generatorJava.extractType(domain.valueType) + '());'); - }); - - res.needEmptyLine = true; - - res.line(varName + '.setQueryEntities(queryEntities);'); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate cache configs. -$generatorJava.cache = function(cache, varName, res) { - if (!res) - res = $generatorCommon.builder(); - - $generatorJava.cacheGeneral(cache, varName, res); - $generatorJava.cacheMemory(cache, varName, res); - $generatorJava.cacheQuery(cache, cache.domains, varName, res); - $generatorJava.cacheStore(cache, cache.domains, varName, res); - - const igfs = _.get(cache, 'nodeFilter.IGFS.instance'); - - $generatorJava.cacheNodeFilter(cache, igfs ? [igfs] : [], varName, res); - $generatorJava.cacheConcurrency(cache, varName, res); - $generatorJava.cacheRebalance(cache, varName, res); - $generatorJava.cacheServerNearCache(cache, varName, res); - $generatorJava.cacheStatistics(cache, varName, res); - $generatorJava.cacheDomains(cache.domains, varName, res); -}; - -// Generation of cache domain model in separate methods. -$generatorJava.clusterDomains = function(caches, res) { - const domains = []; - - const typeVarName = 'jdbcType'; - const metaVarName = 'qryMeta'; - - _.forEach(caches, function(cache) { - _.forEach(cache.domains, function(domain) { - if (_.isNil(_.find(domains, function(m) { - return m === domain.valueType; - }))) { - $generatorJava.resetVariables(res); - - const type = $generatorJava.extractType(domain.valueType); - - if ($generatorCommon.isDefinedAndNotEmpty(domain.databaseTable)) { - res.line('/**'); - res.line(' * Create JDBC type for ' + type + '.'); - res.line(' *'); - res.line(' * @param cacheName Cache name.'); - res.line(' * @return Configured JDBC type.'); - res.line(' */'); - res.startBlock('private static JdbcType jdbcType' + type + '(String cacheName) {'); - - $generatorJava.declareVariable(res, typeVarName, 'org.apache.ignite.cache.store.jdbc.JdbcType'); - - res.needEmptyLine = true; - - res.line(typeVarName + '.setCacheName(cacheName);'); - - $generatorJava.domainStore(domain, true, res); - - res.needEmptyLine = true; - - res.line('return ' + typeVarName + ';'); - res.endBlock('}'); - - res.needEmptyLine = true; - } - - if ($generatorCommon.domainQueryMetadata(domain) === 'Configuration' && - $generatorCommon.isDefinedAndNotEmpty(domain.fields)) { - res.line('/**'); - res.line(' * Create SQL Query descriptor for ' + type + '.'); - res.line(' *'); - res.line(' * @return Configured query entity.'); - res.line(' */'); - res.startBlock('private static QueryEntity queryEntity' + type + '() {'); - - $generatorJava.declareVariable(res, metaVarName, 'org.apache.ignite.cache.QueryEntity'); - - $generatorJava.classNameProperty(res, metaVarName, domain, 'keyType'); - $generatorJava.property(res, metaVarName, domain, 'valueType'); - - res.needEmptyLine = true; - - $generatorJava.domainModelQuery(domain, res); - - res.emptyLineIfNeeded(); - res.line('return ' + metaVarName + ';'); - - res.needEmptyLine = true; - - res.endBlock('}'); - } - - domains.push(domain.valueType); - } - }); - }); -}; - -/** - * @param prefix Variable prefix. - * @param obj Object to process. - * @param names Known names to generate next unique name. - */ -$generatorJava.nextVariableName = function(prefix, obj, names) { - let nextName = $generatorCommon.toJavaName(prefix, obj.name); - - let ix = 0; - - const checkNextName = (name) => name === nextName + (ix === 0 ? '' : '_' + ix); - - while (_.find(names, (name) => checkNextName(name))) - ix++; - - if (ix > 0) - nextName = nextName + '_' + ix; - - return nextName; -}; - -// Generate cluster caches. -$generatorJava.clusterCaches = function(caches, igfss, isSrvCfg, res) { - function clusterCache(cache, names) { - res.emptyLineIfNeeded(); - - const cacheName = $generatorJava.nextVariableName('cache', cache, names); - - $generatorJava.resetVariables(res); - - const hasDatasource = $generatorCommon.cacheHasDatasource(cache); - - res.line('/**'); - res.line(' * Create configuration for cache "' + cache.name + '".'); - res.line(' *'); - res.line(' * @return Configured cache.'); - - if (hasDatasource) - res.line(' * @throws Exception if failed to create cache configuration.'); - - res.line(' */'); - res.startBlock('public static CacheConfiguration ' + cacheName + '()' + (hasDatasource ? ' throws Exception' : '') + ' {'); - - $generatorJava.declareVariable(res, cacheName, 'org.apache.ignite.configuration.CacheConfiguration'); - - $generatorJava.cache(cache, cacheName, res); - - res.line('return ' + cacheName + ';'); - res.endBlock('}'); - - names.push(cacheName); - - res.needEmptyLine = true; - } - - if (!res) - res = $generatorCommon.builder(); - - const names = []; - - if ($generatorCommon.isDefinedAndNotEmpty(caches)) { - res.emptyLineIfNeeded(); - - _.forEach(caches, function(cache) { - clusterCache(cache, names); - }); - - res.needEmptyLine = true; - } - - if (isSrvCfg && $generatorCommon.isDefinedAndNotEmpty(igfss)) { - res.emptyLineIfNeeded(); - - _.forEach(igfss, function(igfs) { - clusterCache($generatorCommon.igfsDataCache(igfs), names); - clusterCache($generatorCommon.igfsMetaCache(igfs), names); - }); - - res.needEmptyLine = true; - } - - return res; -}; - -// Generate cluster caches. -$generatorJava.clusterCacheUse = function(caches, igfss, res) { - function clusterCacheInvoke(cache, names) { - names.push($generatorJava.nextVariableName('cache', cache, names)); - } - - if (!res) - res = $generatorCommon.builder(); - - const cacheNames = []; - - _.forEach(caches, function(cache) { - clusterCacheInvoke(cache, cacheNames); - }); - - const igfsNames = []; - - _.forEach(igfss, function(igfs) { - clusterCacheInvoke($generatorCommon.igfsDataCache(igfs), igfsNames); - clusterCacheInvoke($generatorCommon.igfsMetaCache(igfs), igfsNames); - }); - - const allCacheNames = cacheNames.concat(igfsNames); - - if (allCacheNames.length) { - res.line('cfg.setCacheConfiguration(' + allCacheNames.join('(), ') + '());'); - - res.needEmptyLine = true; - } - - return res; -}; - -// Get class name from fully specified class path. -$generatorJava.extractType = function(fullType) { - return fullType.substring(fullType.lastIndexOf('.') + 1); -}; - -/** - * Generate java class code. - * - * @param domain Domain model object. - * @param key If 'true' then key class should be generated. - * @param pkg Package name. - * @param useConstructor If 'true' then empty and full constructors should be generat
<TRUNCATED>
