Merge branch 'release/v5.0.0' into develop

README.md

@@ -11,10 +11,8 @@ from MySQL to PostgreSQL as easy and smooth as possible.</p>
    indexes, primary and foreign keys exactly as they were before migration.</li>
 
 <li>Ability to rename tables and columns during migration.</li>
-<li>Ability to recover migration process if disaster took place (without restarting from the beginning).</li>
-<li>Ability to migrate big databases - in order to eliminate "process out of memory" issues NMIG will split each table's data into several chunks.<br>Each group of chunks will be loaded via separate worker process.</li>
-
-<li> Speed of data transfer - in order to migrate data fast NMIG uses PostgreSQL COPY protocol.</li>
+<li>Ability to recover migration process if disaster took place without restarting from the beginning.</li>
+<li>Ability to migrate big databases fast - in order to migrate data NMIG utilizes PostgreSQL COPY protocol.</li>
 <li>Ease of monitoring - NMIG will provide detailed output about every step, it takes during the execution.</li>
 <li>
  Ease of configuration - all the parameters required for migration should be put in one single JSON document.
@@ -89,7 +87,7 @@ from MySQL to PostgreSQL as easy and smooth as possible.</p>
 <b>Note:</b> "logs_directory" will be created during script execution.</p>
 
 <h3>VERSION</h3>
-<p>Current version is 4.0.2<br />
+<p>Current version is 5.0.0<br />
 (major version . improvements . bug fixes)</p>
 
 <h3>KNOWN ISSUES</h3>

package.json

@@ -1,6 +1,6 @@
 {
     "name": "nmig",
-    "version": "4.0.2",
+    "version": "5.0.0",
     "description": "The database migration app",
     "author": "Anatoly Khaytovich<[email protected]>",
     "license": "GPL-3.0",
@@ -19,11 +19,11 @@
     },
     "devDependencies": {
         "@types/mysql": "^2.15.7",
-        "@types/node": "^12.7.5",
-        "@types/pg": "^7.11.1",
+        "@types/node": "^12.7.12",
+        "@types/pg": "^7.11.2",
         "@types/tape": "^4.2.33",
         "tape": "^4.11.0",
-        "typescript": "^3.6.3"
+        "typescript": "^3.6.4"
     },
     "scripts": {
         "build": "tsc",

src/DataLoader.ts

@@ -195,7 +195,7 @@ async function getJson2csvStream(
 ): Promise<any> {
     const tableColumnsResult: DBAccessQueryResult = await dbAccess.query(
         'DataLoader::populateTableWorker',
-        `SHOW COLUMNS FROM ${ originalTableName };`,
+        `SHOW COLUMNS FROM \`${ originalTableName }\`;`,
         DBVendors.MYSQL,
         true,
         false

src/TableProcessor.ts

@@ -18,7 +18,7 @@
  *
  * @author Anatoly Khaytovich <[email protected]>
  */
-import { log, generateError } from './FsOps';
+import { log } from './FsOps';
 import Conversion from './Conversion';
 import DBAccess from './DBAccess';
 import DBAccessQueryResult from './DBAccessQueryResult';
@@ -100,7 +100,7 @@ export async function createTable(conversion: Conversion, tableName: string): Pr
         .join(',');
 
     const sqlCreateTable: string = `CREATE TABLE IF NOT EXISTS "${ conversion._schema }"."${ tableName }"(${ columnsDefinition });`;
-    const createTableResult: DBAccessQueryResult = await dbAccess.query(logTitle, sqlCreateTable, DBVendors.PG, false, false);
+    const createTableResult: DBAccessQueryResult = await dbAccess.query(logTitle, sqlCreateTable, DBVendors.PG, true, false);
 
     if (!createTableResult.error) {
         log(conversion, `\t--[${ logTitle }] Table "${ conversion._schema }"."${ tableName }" is created...`, conversion._dicTables[tableName].tableLogPath);