sidorares · sidorares · Aug 28, 2022 · Oct 7, 2021 · Mar 30, 2022 · Apr 3, 2022
diff --git a/lib/auth_plugins/mysql_clear_password.js b/lib/auth_plugins/mysql_clear_password.js
@@ -0,0 +1,12 @@
+'use strict'
+
+module.exports = pluginOptions => ({ connection, command }) => {
+  const password =
+    command.password || pluginOptions.password || connection.config.password;
+
+  const cleartextPassword = function(password) {
+    return Buffer.from(`${password}\0`)
+  };
+
+  return cleartextPassword(password)
+};
diff --git a/lib/commands/auth_switch.js b/lib/commands/auth_switch.js
@@ -9,11 +9,13 @@ const Packets = require('../packets/index.js');
 const sha256_password = require('../auth_plugins/sha256_password');
 const caching_sha2_password = require('../auth_plugins/caching_sha2_password.js');
 const mysql_native_password = require('../auth_plugins/mysql_native_password.js');
+const mysql_clear_password = require('../auth_plugins/mysql_clear_password.js');
 
 const standardAuthPlugins = {
   sha256_password: sha256_password({}),
   caching_sha2_password: caching_sha2_password({}),
-  mysql_native_password: mysql_native_password({})
+  mysql_native_password: mysql_native_password({}),
+  mysql_clear_password: mysql_clear_password({})
 };
 
 function warnLegacyAuthSwitch() {

diff --git a/lib/constants/types.js b/lib/constants/types.js
@@ -1,32 +1,64 @@
 'use strict';
 
+module.exports = {
+  0x00: 'DECIMAL', // aka DECIMAL 
+  0x01: 'TINY', // aka TINYINT, 1 byte
+  0x02: 'SHORT', // aka SMALLINT, 2 bytes
+  0x03: 'LONG', // aka INT, 4 bytes
+  0x04: 'FLOAT', // aka FLOAT, 4-8 bytes
+  0x05: 'DOUBLE', // aka DOUBLE, 8 bytes
+  0x06: 'NULL', // NULL (used for prepared statements, I think)
+  0x07: 'TIMESTAMP', // aka TIMESTAMP
+  0x08: 'LONGLONG', // aka BIGINT, 8 bytes
+  0x09: 'INT24', // aka MEDIUMINT, 3 bytes
+  0x0a: 'DATE', // aka DATE
+  0x0b: 'TIME', // aka TIME
+  0x0c: 'DATETIME', // aka DATETIME
+  0x0d: 'YEAR', // aka YEAR, 1 byte (don't ask)
+  0x0e: 'NEWDATE', // aka ?
+  0x0f: 'VARCHAR', // aka VARCHAR (?)
+  0x10: 'BIT', // aka BIT, 1-8 byte
+  0xf5: 'JSON',
+  0xf6: 'NEWDECIMAL', // aka DECIMAL
+  0xf7: 'ENUM', // aka ENUM
+  0xf8: 'SET', // aka SET
+  0xf9: 'TINY_BLOB', // aka TINYBLOB, TINYTEXT
+  0xfa: 'MEDIUM_BLOB', // aka MEDIUMBLOB, MEDIUMTEXT
+  0xfb: 'LONG_BLOB', // aka LONGBLOG, LONGTEXT
+  0xfc: 'BLOB', // aka BLOB, TEXT
+  0xfd: 'VAR_STRING', // aka VARCHAR, VARBINARY
+  0xfe: 'STRING', // aka CHAR, BINARY
+  0xff: 'GEOMETRY' // aka GEOMETRY
+};
+
+
 // Manually extracted from mysql-5.5.23/include/mysql_com.h
 // some more info here: http://dev.mysql.com/doc/refman/5.5/en/c-api-prepared-statement-type-codes.html
-exports.DECIMAL = 0x00; // aka DECIMAL (http://dev.mysql.com/doc/refman/5.0/en/precision-math-decimal-changes.html)
-exports.TINY = 0x01; // aka TINYINT, 1 byte
-exports.SHORT = 0x02; // aka SMALLINT, 2 bytes
-exports.LONG = 0x03; // aka INT, 4 bytes
-exports.FLOAT = 0x04; // aka FLOAT, 4-8 bytes
-exports.DOUBLE = 0x05; // aka DOUBLE, 8 bytes
-exports.NULL = 0x06; // NULL (used for prepared statements, I think)
-exports.TIMESTAMP = 0x07; // aka TIMESTAMP
-exports.LONGLONG = 0x08; // aka BIGINT, 8 bytes
-exports.INT24 = 0x09; // aka MEDIUMINT, 3 bytes
-exports.DATE = 0x0a; // aka DATE
-exports.TIME = 0x0b; // aka TIME
-exports.DATETIME = 0x0c; // aka DATETIME
-exports.YEAR = 0x0d; // aka YEAR, 1 byte (don't ask)
-exports.NEWDATE = 0x0e; // aka ?
-exports.VARCHAR = 0x0f; // aka VARCHAR (?)
-exports.BIT = 0x10; // aka BIT, 1-8 byte
-exports.JSON = 0xf5;
-exports.NEWDECIMAL = 0xf6; // aka DECIMAL
-exports.ENUM = 0xf7; // aka ENUM
-exports.SET = 0xf8; // aka SET
-exports.TINY_BLOB = 0xf9; // aka TINYBLOB, TINYTEXT
-exports.MEDIUM_BLOB = 0xfa; // aka MEDIUMBLOB, MEDIUMTEXT
-exports.LONG_BLOB = 0xfb; // aka LONGBLOG, LONGTEXT
-exports.BLOB = 0xfc; // aka BLOB, TEXT
-exports.VAR_STRING = 0xfd; // aka VARCHAR, VARBINARY
-exports.STRING = 0xfe; // aka CHAR, BINARY
-exports.GEOMETRY = 0xff; // aka GEOMETRY
+module.exports.DECIMAL = 0x00; // aka DECIMAL (http://dev.mysql.com/doc/refman/5.0/en/precision-math-decimal-changes.html)
+module.exports.TINY = 0x01; // aka TINYINT, 1 byte
+module.exports.SHORT = 0x02; // aka SMALLINT, 2 bytes
+module.exports.LONG = 0x03; // aka INT, 4 bytes
+module.exports.FLOAT = 0x04; // aka FLOAT, 4-8 bytes
+module.exports.DOUBLE = 0x05; // aka DOUBLE, 8 bytes
+module.exports.NULL = 0x06; // NULL (used for prepared statements, I think)
+module.exports.TIMESTAMP = 0x07; // aka TIMESTAMP
+module.exports.LONGLONG = 0x08; // aka BIGINT, 8 bytes
+module.exports.INT24 = 0x09; // aka MEDIUMINT, 3 bytes
+module.exports.DATE = 0x0a; // aka DATE
+module.exports.TIME = 0x0b; // aka TIME
+module.exports.DATETIME = 0x0c; // aka DATETIME
+module.exports.YEAR = 0x0d; // aka YEAR, 1 byte (don't ask)
+module.exports.NEWDATE = 0x0e; // aka ?
+module.exports.VARCHAR = 0x0f; // aka VARCHAR (?)
+module.exports.BIT = 0x10; // aka BIT, 1-8 byte
+module.exports.JSON = 0xf5;
+module.exports.NEWDECIMAL = 0xf6; // aka DECIMAL
+module.exports.ENUM = 0xf7; // aka ENUM
+module.exports.SET = 0xf8; // aka SET
+module.exports.TINY_BLOB = 0xf9; // aka TINYBLOB, TINYTEXT
+module.exports.MEDIUM_BLOB = 0xfa; // aka MEDIUMBLOB, MEDIUMTEXT
+module.exports.LONG_BLOB = 0xfb; // aka LONGBLOG, LONGTEXT
+module.exports.BLOB = 0xfc; // aka BLOB, TEXT
+module.exports.VAR_STRING = 0xfd; // aka VARCHAR, VARBINARY
+module.exports.STRING = 0xfe; // aka CHAR, BINARY
+module.exports.GEOMETRY = 0xff; // aka GEOMETRY
diff --git a/lib/packets/column_definition.js b/lib/packets/column_definition.js
@@ -52,6 +52,7 @@ class ColumnDefinition {
     );
     this.columnLength = packet.readInt32();
     this.columnType = packet.readInt8();
+    this.type = this.columnType;
     this.flags = packet.readInt16();
     this.decimals = packet.readInt8();
   }
@@ -67,6 +68,7 @@ class ColumnDefinition {
       characterSet: this.characterSet,
       columnLength: this.columnLength,
       columnType: this.columnType,
+      type: this.columnType,
       flags: this.flags,
       decimals: this.decimals
     };

diff --git a/package-lock.json b/package-lock.json
diff --git a/test/integration/connection/test-binary-multiple-results.js b/test/integration/connection/test-binary-multiple-results.js
@@ -39,6 +39,7 @@ const fields1 = [
     catalog: 'def',
     characterSet: 63,
     columnType: 8,
+    type: 8,
     decimals: 0,
     flags: 129,
     name: '1',
@@ -53,6 +54,7 @@ const nr_fields = [
     catalog: 'def',
     characterSet: 63,
     columnType: 3,
+    type: 3,
     decimals: 0,
     flags: 0,
     name: 'test',

diff --git a/test/integration/connection/test-disconnects.js b/test/integration/connection/test-disconnects.js
@@ -61,6 +61,7 @@ const server = common.createServer(
             characterSet: 63,
             columnLength: 1,
             columnType: 8,
+            type: 8,
             flags: 129,
             decimals: 0
           }

diff --git a/test/integration/connection/test-execute-bind-date.js b/test/integration/connection/test-execute-bind-date.js
@@ -7,7 +7,7 @@ const assert = require('assert');
 const date = new Date(2018, 2, 10, 15, 12, 34, 1234);
 
 let rows;
-connection.execute('SELECT ? AS result', [date], (err, _rows) => {
+connection.execute('SELECT CAST(? AS DATETIME(6)) AS result', [date], (err, _rows) => {
   if (err) {
     throw err;
   }

diff --git a/test/integration/connection/test-execute-nocolumndef.js b/test/integration/connection/test-execute-nocolumndef.js
@@ -53,6 +53,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 63,
     columnType: 8,
+    type: 8,
     flags: 161,
     decimals: 0
   },
@@ -65,6 +66,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 224,
     columnType: 253,
+    type: 253,
     flags: 1,
     decimals: 31
   },
@@ -77,6 +79,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 224,
     columnType: 253,
+    type: 253,
     flags: 0,
     decimals: 31
   },
@@ -89,6 +92,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 224,
     columnType: 250,
+    type: 250,
     flags: 0,
     decimals: 31
   },
@@ -101,6 +105,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 224,
     columnType: 253,
+    type: 253,
     flags: 0,
     decimals: 31
   },
@@ -113,6 +118,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 224,
     columnType: 253,
+    type: 253,
     flags: 0,
     decimals: 31
   },
@@ -125,6 +131,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 224,
     columnType: 253,
+    type: 253,
     flags: 0,
     decimals: 31
   },
@@ -137,6 +144,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 224,
     columnType: 253,
+    type: 253,
     flags: 0,
     decimals: 31
   },
@@ -149,6 +157,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 224,
     columnType: 253,
+    type: 253,
     flags: 0,
     decimals: 31
   },
@@ -161,6 +170,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 63,
     columnType: 8,
+    type: 8,
     flags: 160,
     decimals: 0
   },
@@ -173,6 +183,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 63,
     columnType: 5,
+    type: 5,
     flags: 128,
     decimals: 2
   },
@@ -185,6 +196,7 @@ const expectedFields = [
     orgTable: '',
     characterSet: 224,
     columnType: 253,
+    type: 253,
     flags: 1,
     decimals: 31
   }

diff --git a/test/integration/connection/test-multiple-results.js b/test/integration/connection/test-multiple-results.js
@@ -38,6 +38,7 @@ const fields1 = [
     catalog: 'def',
     characterSet: 63,
     columnType: 8,
+    type: 8,
     decimals: 0,
     flags: 129,
     name: '1',
@@ -52,6 +53,7 @@ const nr_fields = [
     catalog: 'def',
     characterSet: 63,
     columnType: 3,
+    type: 3,
     decimals: 0,
     flags: 0,
     name: 'test',

diff --git a/test/integration/connection/test-type-casting.js b/test/integration/connection/test-type-casting.js
@@ -1,6 +1,7 @@
 'use strict';
 
 const common = require('../../common');
+const driver = require('../../../index.js'); //needed to check driver.Types
 const connection = common.createConnection();
 const assert = require('assert');
 
@@ -38,17 +39,26 @@ connection.query('select 1', waitConnectErr => {
   connection.query(`INSERT INTO ${table} SET${inserts.join(',\n')}`);
 
   let row;
-  connection.query('SELECT * FROM type_casting', (err, rows) => {
+  let fieldData; // to lookup field types
+  connection.query(`SELECT * FROM ${table}`, (err, rows, fields) => {
     if (err) {
       throw err;
     }
 
     row = rows[0];
+    // build a fieldName: fieldType lookup table
+    fieldData = fields.reduce((a,v) => {
+      a[v['name']] = v['type'];
+      return a;
+    }, {} );
     connection.end();
   });
 
   process.on('exit', () => {
     tests.forEach(test => {
+      // check that the column type matches the type name stored in driver.Types
+      const columnType = fieldData[test.columnName];
+      assert.equal(test.columnType === driver.Types[columnType], true, test.columnName);
       let expected = test.expect || test.insert;
       let got = row[test.columnName];
       let message;