Identify sequencer name by querying it from database using table name and automincrement column

Author: AliGebily

scripts/data/import/importData.js

@@ -24,29 +24,48 @@ async function writeDataToDatabase(filePath, logger) {
       const model = models[modelName];
       const modelRecords = jsonData[modelName];
       if (modelRecords && modelRecords.length > 0) {
-        logger.info(
-          `Importing data for model: ${modelName}`,
-        );
+        logger.info(`Importing data for model: ${modelName}`);
         await model.bulkCreate(modelRecords, {
           transaction,
         });
         logger.info(
           `Records imported for model: ${modelName} = ${modelRecords.length}`,
         );
+
+        // Set autoincrement sequencers in the database to be set to max of the autoincrement column,
+        // so that, when next insertions don't provide value of autoincrement column, as in case of using APIs,
+        // it should be set automatically based on last value of sequencers.
         const modelAttributes = Object.keys(model.rawAttributes);
         const tableName = model.getTableName();
         /* eslint-disable no-await-in-loop */
-        for (let attributeIndex = 0; attributeIndex < modelAttributes.length; attributeIndex += 1) {
+        for (
+          let attributeIndex = 0;
+          attributeIndex < modelAttributes.length;
+          attributeIndex += 1
+        ) {
           const field = modelAttributes[attributeIndex];
           const fieldInfo = model.rawAttributes[field];
           if (fieldInfo.autoIncrement) {
-          const query = `SELECT setval('${tableName}_${field}_seq', (SELECT MAX(${field}) FROM ${tableName}))`;
-          const setValue = (await models.sequelize.query(query, {
-            transaction,
-          }))[0][0].setval;
-          logger.info(`Updated autoIncrement for ${modelName}.${field} with max value = ${setValue}`);
+            // Get sequence name corresponding to automincrment column in a table
+            const selectSequenceQuery = `SELECT pg_get_serial_sequence('${tableName}', '${field}')`;
+            const sequenceName = (
+              await models.sequelize.query(selectSequenceQuery, {
+                transaction,
+              })
+            )[0][0].pg_get_serial_sequence;
+
+            // update sequence value to be set to max value of the autoincrement column in the table
+            const query = `SELECT setval('${sequenceName}', (SELECT MAX(${field}) FROM ${tableName}))`;
+            const setValue = (
+              await models.sequelize.query(query, {
+                transaction,
+              })
+            )[0][0].setval;
+            logger.info(
+              `Updated autoIncrement for ${modelName}.${field} with max value = ${setValue}`,
+            );
+          }
         }
-      }
       } else {
         logger.info(`No records to save for model: ${modelName}`);
       }