333

schangxiang@126.com

2025-09-19 18966e02fb573c7e2bb0c6426ed792b38b910940

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
"use strict";
 
// s2.2.7.13 (introduced in TDS 7.3.B)
const valueParse = require('../value-parser');
 
function nullHandler(parser, columnMetaData, options, callback) {
  callback(null);
}
 
module.exports = function (parser, columnsMetaData, options, callback) {
  const length = Math.ceil(columnsMetaData.length / 8);
  parser.readBuffer(length, bytes => {
    const bitmap = [];
 
    for (let i = 0, len = bytes.length; i < len; i++) {
      const byte = bytes[i];
 
      for (let j = 0; j <= 7; j++) {
        bitmap.push(byte & 1 << j ? true : false);
      }
    }
 
    const columns = options.useColumnNames ? {} : [];
    const len = columnsMetaData.length;
    let i = 0;
 
    function next(done) {
      if (i === len) {
        return done();
      }
 
      const columnMetaData = columnsMetaData[i];
      (bitmap[i] ? nullHandler : valueParse)(parser, columnMetaData, options, value => {
        const column = {
          value: value,
          metadata: columnMetaData
        };
 
        if (options.useColumnNames) {
          if (columns[columnMetaData.colName] == null) {
            columns[columnMetaData.colName] = column;
          }
        } else {
          columns.push(column);
        }
 
        i++;
        next(done);
      });
    }
 
    next(() => {
      callback({
        name: 'NBCROW',
        event: 'row',
        columns: columns
      });
    });
  });
};