test-quit.js 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. var assert = require('assert');
  2. var common = require('../../common');
  3. var quitReceived = false;
  4. var queryCli = 'SELECT 1';
  5. var server = common.createServer(serverReady, function(conn) {
  6. conn.on('quit', function() {
  7. // COM_QUIT
  8. quitReceived = true;
  9. conn.stream.end();
  10. server.close();
  11. console.log('quit!!!');
  12. });
  13. conn.on('query', function(q) {
  14. queryServ = q;
  15. conn.writeTextResult([ { '1': '1' } ], [ { catalog: 'def',
  16. schema: '',
  17. table: '',
  18. orgTable: '',
  19. name: '1',
  20. orgName: '',
  21. characterSet: 63,
  22. columnLength: 1,
  23. columnType: 8,
  24. flags: 129,
  25. decimals: 0 } ]);
  26. });
  27. });
  28. function serverReady() {
  29. var connection = common.createConnection({ port: 3307 });
  30. connection.query(queryCli, function(err, _rows, _fields) {
  31. if (err) throw err;
  32. rows = _rows;
  33. fields = _fields;
  34. connection.end();
  35. });
  36. }
  37. process.on('exit', function() {
  38. assert.deepEqual(rows, [{1: 1}]);
  39. assert.equal(fields[0].name, '1');
  40. assert.equal(quitReceived, true);
  41. assert.equal(queryCli, queryServ);
  42. });