tests: add DATETIME type cast test

Author: dougwilson

test/unit/connection/test-datetime-type-cast.js

@@ -0,0 +1,83 @@
+var assert     = require('assert');
+var common     = require('../../common');
+var connection = common.createConnection({port: common.fakeServerPort, timezone: 'Z'});
+var server     = common.createFakeServer();
+
+server.listen(common.fakeServerPort, function (err) {
+  assert.ifError(err);
+
+  connection.query('SELECT value FROM datetime_rows', function (err, rows) {
+    assert.ifError(err);
+    assert.equal(rows.length, 7);
+    assert.strictEqual(rows[0].value, '0000-00-00 00:00:00');
+    assert.strictEqual(rows[1].value, '2000-00-00 00:00:00');
+    assert.strictEqual(rows[2].value, '2000-01-00 00:00:00');
+    assert.strictEqual(rows[3].value, '2000-01-02 03:04:60');
+    assert.ok(rows[4].value instanceof Date);
+    assert.strictEqual(rows[4].value.toISOString(), '2000-01-02T00:00:00.000Z');
+    assert.ok(rows[5].value instanceof Date);
+    assert.strictEqual(rows[5].value.toISOString(), '2000-01-02T03:04:05.000Z');
+    assert.ok(rows[6].value instanceof Date);
+    assert.strictEqual(rows[6].value.toISOString(), '2000-01-02T03:04:05.006Z');
+
+    connection.destroy();
+    server.destroy();
+  });
+});
+
+server.on('connection', function(conn) {
+  conn.handshake();
+  conn.on('query', function(packet) {
+    switch (packet.sql) {
+      case 'SELECT value FROM datetime_rows':
+        this._sendPacket(new common.Packets.ResultSetHeaderPacket({
+          fieldCount: 1
+        }));
+
+        this._sendPacket(new common.Packets.FieldPacket({
+          catalog    : 'def',
+          charsetNr  : common.Charsets.UTF8_GENERAL_CI,
+          name       : 'value',
+          protocol41 : true,
+          type       : common.Types.DATETIME
+        }));
+
+        this._sendPacket(new common.Packets.EofPacket());
+
+        var writer = new common.PacketWriter();
+        writer.writeLengthCodedString('0000-00-00 00:00:00');
+        this._socket.write(writer.toBuffer(this._parser));
+
+        var writer = new common.PacketWriter();
+        writer.writeLengthCodedString('2000-00-00 00:00:00');
+        this._socket.write(writer.toBuffer(this._parser));
+
+        var writer = new common.PacketWriter();
+        writer.writeLengthCodedString('2000-01-00 00:00:00');
+        this._socket.write(writer.toBuffer(this._parser));
+
+        var writer = new common.PacketWriter();
+        writer.writeLengthCodedString('2000-01-02 03:04:60');
+        this._socket.write(writer.toBuffer(this._parser));
+
+        var writer = new common.PacketWriter();
+        writer.writeLengthCodedString('2000-01-02 00:00:00');
+        this._socket.write(writer.toBuffer(this._parser));
+
+        var writer = new common.PacketWriter();
+        writer.writeLengthCodedString('2000-01-02 03:04:05');
+        this._socket.write(writer.toBuffer(this._parser));
+
+        var writer = new common.PacketWriter();
+        writer.writeLengthCodedString('2000-01-02 03:04:05.006');
+        this._socket.write(writer.toBuffer(this._parser));
+
+        this._sendPacket(new common.Packets.EofPacket());
+        this._parser.resetPacketNumber();
+        break;
+      default:
+        this._handleQueryPacket(packet);
+        break;
+    }
+  });
+});