tests: add TIMESTAMP type cast test

Author: dougwilson

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

@@ -0,0 +1,109 @@
+var after  = require('after');
+var assert = require('assert');
+var common = require('../../common');
+var server = common.createFakeServer();
+
+server.listen(common.fakeServerPort, function (err) {
+  assert.ifError(err);
+
+  var done = after(2, function () {
+    server.destroy();
+  });
+
+  var conn1 = common.createConnection({
+    port     : common.fakeServerPort,
+    timezone : 'Z'
+  });
+  conn1.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');
+    conn1.destroy();
+    done();
+  });
+
+  var conn2 = common.createConnection({
+    dateStrings : true,
+    port        : common.fakeServerPort,
+    timezone    : 'Z'
+  });
+  conn2.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.strictEqual(rows[4].value, '2000-01-02 00:00:00');
+    assert.strictEqual(rows[5].value, '2000-01-02 03:04:05');
+    assert.strictEqual(rows[6].value, '2000-01-02 03:04:05.006');
+    conn2.destroy();
+    done();
+  });
+});
+
+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.TIMESTAMP
+        }));
+
+        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;
+    }
+  });
+});