78 lines
1.6 KiB
JavaScript
78 lines
1.6 KiB
JavaScript
var pg = require('./pg');
|
|
|
|
function json() {}
|
|
|
|
json.prototype = new pg('json');
|
|
|
|
var p = json.prototype;
|
|
|
|
p._contentType = "application/json; charset=utf-8";
|
|
|
|
var typeNames = {
|
|
16: 'string', // bool
|
|
17: 'string', // bytea
|
|
20: 'number',
|
|
21: 'number',
|
|
23: 'number',
|
|
25: 'string', // text
|
|
26: 'number',
|
|
114: 'object', // JSON
|
|
701: 'number',
|
|
1015: 'string[]', // _varchar
|
|
1042: 'string',
|
|
1043: 'string',
|
|
1005: 'number[]', // _int2
|
|
1007: 'number[]', // _int4
|
|
1014: 'string[]', // _bpchar
|
|
1016: 'number[]', // _int8
|
|
1021: 'number[]', // _float4
|
|
1022: 'number[]', // _float8
|
|
1008: 'string[]',
|
|
1009: 'string[]',
|
|
1114: 'date', // timestamp without timezone
|
|
1182: 'date', // date
|
|
1184: 'date', // timestamp
|
|
1186: 'string', // interval
|
|
1231: 'number[]', // _numeric
|
|
|
|
};
|
|
|
|
function formatResultFields(flds) {
|
|
var nfields = {};
|
|
for (var i=0; i<flds.length; ++i) {
|
|
var f = flds[i];
|
|
/*
|
|
{ name: 'the_geom',
|
|
tableID: 5528687,
|
|
columnID: 6,
|
|
dataTypeID: 77869,
|
|
dataTypeSize: -1,
|
|
dataTypeModifier: -1,
|
|
format: 'text' },
|
|
*/
|
|
var tname = typeNames[f.dataTypeID];
|
|
if ( ! tname ) {
|
|
if ( f.name.match(/^the_geom/) ) {
|
|
tname = 'geometry';
|
|
} else {
|
|
tname = f.dataTypeID; // unknown
|
|
}
|
|
}
|
|
nfields[f.name] = { type: tname };
|
|
}
|
|
return nfields;
|
|
}
|
|
|
|
|
|
p.transform = function(result, options, callback) {
|
|
var j = {
|
|
time: options.total_time,
|
|
fields: formatResultFields(result.fields),
|
|
total_rows: result.rowCount,
|
|
rows: result.rows
|
|
}
|
|
callback(null, j);
|
|
};
|
|
|
|
module.exports = json;
|