Create failing test for sidorares#1847

Author: Dorian Sechesan

test/common.js

@@ -53,9 +53,7 @@ exports.waitDatabaseReady = function(callback) {
   tryConnect();
 };
 
-exports.createConnection = function(args) {
-
-  const driver = require('../index.js');
+function createConnectionFromDriver(driver, args) {
   if (!args?.port && process.env.MYSQL_CONNECTION_URL) {
     return driver.createConnection({ ...args, uri: process.env.MYSQL_CONNECTION_URL })
   }
@@ -88,6 +86,18 @@ exports.createConnection = function(args) {
 
   const conn = driver.createConnection(params);
   return conn;
+}
+
+exports.createConnection = function(args) {
+
+  const driver = require('../index.js');
+  return createConnectionFromDriver(driver, args);
+};
+
+exports.createConnectionPromise = function(args) {
+
+  const driver = require('../promise.js');
+  return createConnectionFromDriver(driver, args);
 };
 
 exports.getConfig = function(input) {

test/integration/connection/test-query-stream-errors-propagation.mjs

@@ -0,0 +1,25 @@
+import * as common from '../../common.js';
+import assert from 'node:assert';
+
+function killConnection(connectionId) {
+  const killer = common.createConnection();
+  killer.query('KILL ?', [connectionId]);
+  killer.end();
+}
+
+const connection = await common.createConnectionPromise();
+const query = connection.connection.query('SELECT SLEEP(10)');
+const stream = query.stream();
+
+// kill the connection
+killConnection(connection.threadId);
+
+try {
+  // iterate the streaming result here
+  for await (const row of stream) {
+    // do stuff with row
+  }
+  assert.fail('The query stream should have thrown the connection error');
+} catch (e) {
+  assert.ok('The query stream has thrown the connection error');
+}

test/run.js

@@ -7,7 +7,7 @@ const options = {
 };
 
 if (process.env.FILTER) {
-  options.include = new RegExp(`${process.env.FILTER}.*\\.js$`);
+  options.include = new RegExp(`${process.env.FILTER}.*\\.m?js$`);
 }
 
 require('urun')(__dirname, options);