Feature/hck 4566 bbva sequences definition for postgresql re fro (#91)

* RE: add handling of schema sequences

* FE: add alter script generation for modified schema sequences

* FE: FE: add alter script generation for deleted schema sequences

* FE: FE: add alter script generation for added schema sequences

* FE: define types for sequence helper

* FE: fix changing of sequence type

* FE: add schema name for sequence owned by option column name

* RE: fix duplicating of sequences in SELECT query

* RE: update passing arguments in functions

* Add missed types

* RE: fix incorrect argument passing

Author: serhii-filonenko

forward_engineering/alterScript/alterScriptFromDeltaHelper.js

@@ -31,6 +31,7 @@ const {
 const {AlterScriptDto, ModificationScript} = require("./types/AlterScriptDto");
 const {App, CoreData} = require("../types/coreApplicationTypes");
 const {InternalDefinitions, ModelDefinitions, ExternalDefinitions} = require("../types/coreApplicationDataTypes");
+const { getModifyContainerSequencesScriptDtos, getDeleteContainerSequencesScriptDtos, getAddContainerSequencesScriptDtos } = require('./alterScriptHelpers/containerHelpers/sequencesHelper');
 
 
 /**
@@ -300,6 +301,41 @@ const prettifyAlterScriptDto = (dto) => {
     }
 }
 
+/**
+ * @param {{
+ * collection: Object,
+ * app: App,
+ * }} dto
+ * @return {AlterScriptDto[]}
+ * */
+const getAlterContainersSequencesScriptDtos = ({ collection, app }) => {
+    const addedContainers = collection.properties?.containers?.properties?.added?.items;
+    const deletedContainers = collection.properties?.containers?.properties?.deleted?.items;
+    const modifiedContainers = collection.properties?.containers?.properties?.modified?.items;
+
+    const addContainersSequencesScriptDtos = []
+        .concat(addedContainers)
+        .filter(Boolean)
+        .map(container => Object.values(container.properties)[0])
+        .flatMap(container => getAddContainerSequencesScriptDtos({ app })({ container }))
+    const deleteContainersScriptDtos = []
+        .concat(deletedContainers)
+        .filter(Boolean)
+        .map(container => Object.values(container.properties)[0])
+        .flatMap(container => getDeleteContainerSequencesScriptDtos({ app })({ container }))
+    const modifyContainersScriptDtos = []
+        .concat(modifiedContainers)
+        .filter(Boolean)
+        .map(container => Object.values(container.properties)[0])
+        .flatMap(container => getModifyContainerSequencesScriptDtos({ app })({ container }))
+
+    return [
+        ...addContainersSequencesScriptDtos,
+        ...deleteContainersScriptDtos,
+        ...modifyContainersScriptDtos,
+    ].filter(Boolean);
+};
+
 /**
  * @param data {CoreData}
  * @param app {App}
@@ -336,11 +372,13 @@ const getAlterScriptDtos = (data, app) => {
         externalDefinitions,
     });
     const relationshipScriptDtos = getAlterRelationshipsScriptDtos({collection, app});
+    const containersSequencesScriptDtos = getAlterContainersSequencesScriptDtos({collection, app});
 
     return [
         ...containersScriptDtos,
         ...modelDefinitionsScriptDtos,
         ...collectionsScriptDtos,
+        ...containersSequencesScriptDtos,
         ...viewScriptDtos,
         ...relationshipScriptDtos,
     ]

forward_engineering/alterScript/alterScriptHelpers/containerHelpers/sequencesHelper.js

@@ -0,0 +1,88 @@
+const { AlterScriptDto } = require('../../types/AlterScriptDto');
+const { App } = require('../../../types/coreApplicationTypes');
+const sequencesCompModKey = 'sequences';
+
+/**
+ * @param {{ app: App }}
+ * @return {({ container }: { container: object }) => AlterScriptDto[]}
+ * */
+const getAddContainerSequencesScriptDtos = ({ app }) => ({ container }) => {
+    const _ = app.require('lodash');
+    const ddlProvider = require('../../../ddlProvider')(null, null, app);
+    const { getDbName } = require('../../../utils/general')(_);
+    const schemaName = getDbName([container.role]);
+
+    return (container.role?.sequences || [])
+        .map((sequence) => ddlProvider.createSchemaSequence({ schemaName, sequence }))
+        .map((script) => AlterScriptDto.getInstance([script], true, false))
+        .filter(Boolean);
+};
+
+/**
+ * @param {{ app: App }}
+ * @return {({ container }: { container: object }) => AlterScriptDto[]}
+ * */
+const getModifyContainerSequencesScriptDtos = ({ app }) => ({ container }) => {
+    const _ = app.require('lodash');
+    const ddlProvider = require('../../../ddlProvider')(null, null, app);
+    const { getDbName, getGroupItemsByCompMode } = require('../../../utils/general')(_);
+
+    const schemaName = getDbName([container.role]);
+    const sequencesCompMod = container.role?.compMod?.[sequencesCompModKey] || {};
+    const { new: newItems = [], old: oldItems = [] } = sequencesCompMod;
+
+    const { removed, added, modified } = getGroupItemsByCompMode({
+        newItems,
+        oldItems,
+    });
+
+    const removedScriptDtos = removed
+        .map((sequence) => {
+            return ddlProvider.dropSchemaSequence({ schemaName, sequence });
+        })
+        .map((script) => AlterScriptDto.getInstance([script], true, true));
+    const addedScriptDtos = added
+        .map((sequence) =>
+            ddlProvider.createSchemaSequence({ schemaName, sequence })
+        )
+        .map((script) => AlterScriptDto.getInstance([script], true, false));
+
+    const modifiedScriptDtos = modified
+        .map((sequence) => {
+            const oldSequence = _.find(oldItems, { id: sequence.id }) || {};
+            return ddlProvider.alterSchemaSequence({
+                schemaName,
+                sequence,
+                oldSequence,
+            });
+        })
+        .map((script) => AlterScriptDto.getInstance([script], true, false));
+
+    return [
+        ...modifiedScriptDtos,
+        ...removedScriptDtos,
+        ...addedScriptDtos,
+    ].filter(Boolean);
+};
+
+/**
+ * @param {{ app: App }}
+ * @return {({ container }: { container: object }) => AlterScriptDto[]}
+ * */
+const getDeleteContainerSequencesScriptDtos = ({ app }) => ({ container }) => {
+    const _ = app.require('lodash');
+    const ddlProvider = require('../../../ddlProvider')(null, null, app);
+    const { getDbName } = require('../../../utils/general')(_);
+    const schemaName = getDbName([container.role]);
+
+    return (container.role?.sequences || [])
+        .map((sequence) => ddlProvider.dropSchemaSequence({ schemaName, sequence }))
+        .map((script) => AlterScriptDto.getInstance([script], true, true))
+        .filter(Boolean);
+};
+
+module.exports = {
+    getAddContainerSequencesScriptDtos,
+    getModifyContainerSequencesScriptDtos,
+    getDeleteContainerSequencesScriptDtos,
+};