diff --git a/packages/api/src/controllers/runners.js b/packages/api/src/controllers/runners.js
index 7f820f25f..26dd76eb2 100644
--- a/packages/api/src/controllers/runners.js
+++ b/packages/api/src/controllers/runners.js
@@ -21,7 +21,7 @@ module.exports = {
   opened: [],
 
   dispatchMessage(runid, message) {
-    console.log('DISPATCHING', message);
+    // console.log('DISPATCHING', message);
     if (_.isString(message)) {
       socket.emit(`runner-info-${runid}`, {
         message,
diff --git a/packages/api/src/utility/socket.js b/packages/api/src/utility/socket.js
index 55bea000b..aefed81fb 100644
--- a/packages/api/src/utility/socket.js
+++ b/packages/api/src/utility/socket.js
@@ -8,11 +8,11 @@ module.exports = {
     return socket;
   },
   emit(message, data) {
-    console.log('EMIT:', message, data);
+    // console.log('EMIT:', message, data);
     socket.emit(message, data);
   },
   emitChanged(key) {
-    console.log('EMIT_CHANGED:', key);
+    // console.log('EMIT_CHANGED:', key);
     socket.emit('clean-cache', key);
     socket.emit(key);
   },
diff --git a/packages/engines/default/createBulkInsertStreamBase.js b/packages/engines/default/createBulkInsertStreamBase.js
index a47096199..68aa47e60 100644
--- a/packages/engines/default/createBulkInsertStreamBase.js
+++ b/packages/engines/default/createBulkInsertStreamBase.js
@@ -29,6 +29,7 @@ function createBulkInsertStreamBase(driver, stream, pool, name, options) {
 
   writable.checkStructure = async () => {
     let structure = await driver.analyseSingleTable(pool, name);
+    // console.log('ANALYSING', name, structure);
     if (structure && options.dropIfExists) {
       console.log(`Dropping table ${fullNameQuoted}`);
       await driver.query(pool, `DROP TABLE ${fullNameQuoted}`);
@@ -59,7 +60,7 @@ function createBulkInsertStreamBase(driver, stream, pool, name, options) {
 
     dmp.putRaw(`INSERT INTO ${fullNameQuoted} (`);
     dmp.putCollection(',', this.columnNames, (col) => dmp.putRaw(driver.dialect.quoteIdentifier(col)));
-    dmp.putRaw('\n');
+    dmp.putRaw(')\n VALUES\n');
 
     let wasRow = false;
     for (const row of rows) {
@@ -67,7 +68,10 @@ function createBulkInsertStreamBase(driver, stream, pool, name, options) {
       dmp.putRaw('(');
       dmp.putCollection(',', this.columnNames, (col) => dmp.putValue(row[col]));
       dmp.putRaw(')');
+      wasRow = true;
     }
+    dmp.putRaw(';');
+    // require('fs').writeFileSync('/home/jena/test.sql', dmp.s);
     await driver.query(pool, dmp.s);
   };
 
diff --git a/packages/engines/mysql/index.js b/packages/engines/mysql/index.js
index 66f00d2bc..f90456bf1 100644
--- a/packages/engines/mysql/index.js
+++ b/packages/engines/mysql/index.js
@@ -6,7 +6,7 @@ const MySqlDumper = require('./MySqlDumper');
 const dialect = {
   rangeSelect: true,
   stringEscapeChar: '\\',
-  fallbackDataType: 'nvarchar(max)',
+  fallbackDataType: 'longtext',
   quoteIdentifier(s) {
     return '`' + s + '`';
   },
diff --git a/packages/engines/postgres/PostgreAnalyser.js b/packages/engines/postgres/PostgreAnalyser.js
index 9a5fc798f..2448aff24 100644
--- a/packages/engines/postgres/PostgreAnalyser.js
+++ b/packages/engines/postgres/PostgreAnalyser.js
@@ -46,7 +46,7 @@ class PostgreAnalyser extends DatabaseAnalayser {
     if (this.singleObjectFilter) {
       const { typeField, schemaName, pureName } = this.singleObjectFilter;
       if (!typeFields || !typeFields.includes(typeField)) return null;
-      res = res.replace(/=OBJECT_ID_CONDITION/g, ` = '${typeField}:${schemaName}.${pureName}'`);
+      res = res.replace(/=OBJECT_ID_CONDITION/g, ` = '${typeField}:${schemaName || 'public'}.${pureName}'`);
       return res;
     }
     if (!this.modifications || !typeFields || this.modifications.length == 0) {
diff --git a/packages/engines/postgres/index.js b/packages/engines/postgres/index.js
index a53f99d29..95c4dd971 100644
--- a/packages/engines/postgres/index.js
+++ b/packages/engines/postgres/index.js
@@ -6,8 +6,9 @@ const PostgreDumper = require('./PostgreDumper');
 /** @type {import('@dbgate/types').SqlDialect} */
 const dialect = {
   rangeSelect: true,
-  stringEscapeChar: '\\',
-  fallbackDataType: 'nvarchar(max)',
+  // stringEscapeChar: '\\',
+  stringEscapeChar: "'",
+  fallbackDataType: 'varchar',
   quoteIdentifier(s) {
     return '"' + s + '"';
   },