Throw error if the array passed to insert is empty (#4289)

UPGRADING.md

@@ -68,6 +68,8 @@ CustomClient.prototype.driverName = 'abcd';
 
 * "first" and "pluck" can no longer be both chained on the same operation. Previously only the last one chained was used, now this would throw an error. 
 
+* Trying to execute an operation resulting in an empty query such as inserting an empty array, will now throw an error on all database drivers.
+
 ### Upgrading to version 0.21.0+
 
 * Node.js older than 10 is no longer supported, make sure to update your environment; 

lib/dialects/mssql/index.js

@@ -222,6 +222,8 @@ class Client_MSSQL extends Client {
     const sql = typeof query === 'string' ? query : query.sql;
     let rowCount = 0;
 
+    if (!sql) throw new Error('The query is empty');
+
     debug('request::request sql=%s', sql);
 
     const request = new Driver.Request(sql, (err, remoteRowCount) => {

lib/dialects/mysql/index.js

@@ -91,6 +91,8 @@ class Client_MySQL extends Client {
   // Grab a connection, run the query via the MySQL streaming interface,
   // and pass that through to the stream we've sent back to the client.
   _stream(connection, obj, stream, options) {
+    if (!obj.sql) throw new Error('The query is empty');
+
     options = options || {};
     const queryOptions = Object.assign({ sql: obj.sql }, obj.options);
     return new Promise((resolver, rejecter) => {
@@ -113,6 +115,8 @@ class Client_MySQL extends Client {
   // and any other necessary prep work.
   _query(connection, obj) {
     if (!obj || typeof obj === 'string') obj = { sql: obj };
+    if (!obj.sql) throw new Error('The query is empty');
+
     return new Promise(function (resolver, rejecter) {
       if (!obj.sql) {
         resolver();

lib/dialects/oracle/index.js

@@ -43,6 +43,8 @@ class Client_Oracle extends Client {
   }
 
   _stream(connection, obj, stream, options) {
+    if (!obj.sql) throw new Error('The query is empty');
+
     return new Promise(function (resolver, rejecter) {
       stream.on('error', (err) => {
         if (isConnectionError(err)) {

lib/dialects/postgres/index.js

@@ -160,6 +160,8 @@ class Client_PG extends Client {
   }
 
   _stream(connection, obj, stream, options) {
+    if (!obj.sql) throw new Error('The query is empty');
+
     const PGQueryStream = process.browser
       ? undefined
       : require('pg-query-stream');
@@ -184,6 +186,8 @@ class Client_PG extends Client {
   // Runs the query on the specified connection, providing the bindings
   // and any other necessary prep work.
   _query(connection, obj) {
+    if (!obj.sql) throw new Error('The query is empty');
+
     let queryConfig = {
       text: obj.sql,
       values: obj.bindings || [],

lib/dialects/sqlite3/index.js

@@ -84,6 +84,8 @@ class Client_SQLite3 extends Client {
   // Runs the query on the specified connection, providing the bindings and any
   // other necessary prep work.
   _query(connection, obj) {
+    if (!obj.sql) throw new Error('The query is empty');
+
     const { method } = obj;
     let callMethod;
     switch (method) {
@@ -114,13 +116,15 @@ class Client_SQLite3 extends Client {
     });
   }
 
-  _stream(connection, sql, stream) {
+  _stream(connection, obj, stream) {
+    if (!obj.sql) throw new Error('The query is empty');
+
     const client = this;
     return new Promise(function (resolver, rejecter) {
       stream.on('error', rejecter);
       stream.on('end', resolver);
       return client
-        ._query(connection, sql)
+        ._query(connection, obj)
         .then((obj) => obj.response)
         .then((rows) => rows.forEach((row) => stream.write(row)))
         .catch(function (err) {

test/integration/query/inserts.js

@@ -797,6 +797,13 @@ module.exports = function (knex) {
         });
     });
 
+    it('should throw an error if the array passed in is empty', async function () {
+      expect(knex('account').insert([])).to.be.rejectedWith(
+        Error,
+        'The query is empty'
+      );
+    });
+
     it('should handle empty inserts', function () {
       return knex.schema
         .createTable('test_default_table', function (qb) {