postgres copystream support

plugins/dbgate-plugin-postgres/package.json

@@ -37,5 +37,8 @@
     "pg": "^8.11.5",
     "webpack": "^5.91.0",
     "webpack-cli": "^5.1.4"
+  },
+  "dependencies": {
+    "pg-copy-streams": "^6.0.6"
   }
 }

plugins/dbgate-plugin-postgres/src/backend/drivers.js

@@ -4,6 +4,7 @@ const stream = require('stream');
 const driverBases = require('../frontend/drivers');
 const Analyser = require('./Analyser');
 const pg = require('pg');
+const pgCopyStreams = require('pg-copy-streams');
 const { getLogger, createBulkInsertStreamBase, makeUniqueColumnNames, extractDbNameFromComposite } =
   global.DBGATE_PACKAGES['dbgate-tools'];
 
@@ -292,6 +293,11 @@ const drivers = driverBases.map(driverBase => ({
 
     return schemas;
   },
+
+  writeQueryFromStream(dbhan, sql) {
+    const stream = dbhan.client.query(pgCopyStreams.from(sql));
+    return stream;
+  },
 }));
 
 module.exports = drivers;