oreolek/nmig
1
0
Fork 0
Code Releases Activity

Update FromMySQL2PostgreSQL.js

Browse source
This commit is contained in:
Anatoly Khaytovich 2016-01-08 07:52:43 +02:00
parent a88a4cb56f
commit 8f5605e157
1 changed files with 6 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
migration/fmtp/FromMySQL2PostgreSQL.js
View file

@ -1243,7 +1243,7 @@ FromMySQL2PostgreSQL.prototype.processIndexAndKey = function(self) {
};
}
}
for (let attr in objPgIndices) {
if (attr.toLowerCase() === 'primary') {
indexType = 'PK';
@ -1252,14 +1252,12 @@ FromMySQL2PostgreSQL.prototype.processIndexAndKey = function(self) {
} else {
// "schema_idxname_{integer}_idx" - is NOT a mistake.
let columnName = objPgIndices[attr].column_name[0].slice(1, -1) + cnt;
let columnName = objPgIndices[attr].column_name[0].slice(1, -1) + cnt++;
indexType = 'index';
sql = 'CREATE ' + (objPgIndices[attr].is_unique ? 'UNIQUE ' : '') + 'INDEX "'
+ self._schema + '_' + self._clonedSelfTableName + '_' + columnName + '_idx" ON "'
+ self._schema + '"."' + self._clonedSelfTableName
+ '" (' + objPgIndices[attr].column_name.join(',') + ');';
cnt++;
}
processIndexAndKeyPromises.push(
@ -1278,10 +1276,6 @@ FromMySQL2PostgreSQL.prototype.processIndexAndKey = function(self) {
self.generateError(self, '\t--[processIndexAndKey] ' + err2, sql);
resolveProcessIndexAndKeySql();
} else {
let success = '\t--[processIndexAndKey] "' + self._schema + '"."'
+ self._clonedSelfTableName + '": PK/indices are successfully set...';
self.log(self, success);
resolveProcessIndexAndKeySql();
}
});
@ -1293,6 +1287,10 @@ FromMySQL2PostgreSQL.prototype.processIndexAndKey = function(self) {
Promise.all(processIndexAndKeyPromises).then(
function() {
let success = '\t--[processIndexAndKey] "' + self._schema + '"."'
+ self._clonedSelfTableName + '": PK/indices are successfully set...';
self.log(self, success);
resolveProcessIndexAndKey(self);
}
);
@ -1502,4 +1500,3 @@ FromMySQL2PostgreSQL.prototype.run = function(config) {
};
module.exports.FromMySQL2PostgreSQL = FromMySQL2PostgreSQL;