Extremely Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241import { Oid } from "./oid.ts";import { Column, Format } from "./connection.ts";
// Datetime parsing based on:// https://github.com/bendrucker/postgres-date/blob/master/index.jsconst DATETIME_RE = /^(\d{1,})-(\d{2})-(\d{2}) (\d{2}):(\d{2}):(\d{2})(\.\d{1,})?/;const DATE_RE = /^(\d{1,})-(\d{2})-(\d{2})$/;const TIMEZONE_RE = /([Z+-])(\d{2})?:?(\d{2})?:?(\d{2})?/;const BC_RE = /BC$/;
function decodeDate(dateStr: string): null | Date { const matches = DATE_RE.exec(dateStr);
if (!matches) { return null; }
const year = parseInt(matches[1], 10); // remember JS dates are 0-based const month = parseInt(matches[2], 10) - 1; const day = parseInt(matches[3], 10); const date = new Date(year, month, day); // use `setUTCFullYear` because if date is from first // century `Date`'s compatibility for millenium bug // would set it as 19XX date.setUTCFullYear(year);
return date;}/** * Decode numerical timezone offset from provided date string. * * Matched these kinds: * - `Z (UTC)` * - `-05` * - `+06:30` * - `+06:30:10` * * Returns offset in miliseconds. */function decodeTimezoneOffset(dateStr: string): null | number { // get rid of date part as TIMEZONE_RE would match '-MM` part const timeStr = dateStr.split(" ")[1]; const matches = TIMEZONE_RE.exec(timeStr);
if (!matches) { return null; }
const type = matches[1];
if (type === "Z") { // Zulu timezone === UTC === 0 return 0; }
// in JS timezone offsets are reversed, ie. timezones // that are "positive" (+01:00) are represented as negative // offsets and vice-versa const sign = type === "-" ? 1 : -1;
const hours = parseInt(matches[2], 10); const minutes = parseInt(matches[3] || "0", 10); const seconds = parseInt(matches[4] || "0", 10);
const offset = hours * 3600 + minutes * 60 + seconds;
return sign * offset * 1000;}
function decodeDatetime(dateStr: string): null | number | Date { /** * Postgres uses ISO 8601 style date output by default: * 1997-12-17 07:37:16-08 */
// there are special `infinity` and `-infinity` // cases representing out-of-range dates if (dateStr === "infinity") { return Number(Infinity); } else if (dateStr === "-infinity") { return Number(-Infinity); }
const matches = DATETIME_RE.exec(dateStr);
if (!matches) { return decodeDate(dateStr); }
const isBC = BC_RE.test(dateStr);
const year = parseInt(matches[1], 10) * (isBC ? -1 : 1); // remember JS dates are 0-based const month = parseInt(matches[2], 10) - 1; const day = parseInt(matches[3], 10); const hour = parseInt(matches[4], 10); const minute = parseInt(matches[5], 10); const second = parseInt(matches[6], 10); // ms are written as .007 const msMatch = matches[7]; const ms = msMatch ? 1000 * parseFloat(msMatch) : 0;
let date: Date;
const offset = decodeTimezoneOffset(dateStr); if (offset === null) { date = new Date(year, month, day, hour, minute, second, ms); } else { // This returns miliseconds from 1 January, 1970, 00:00:00, // adding decoded timezone offset will construct proper date object. const utc = Date.UTC(year, month, day, hour, minute, second, ms); date = new Date(utc + offset); }
// use `setUTCFullYear` because if date is from first // century `Date`'s compatibility for millenium bug // would set it as 19XX date.setUTCFullYear(year); return date;}
function decodeBinary() { throw new Error("Not implemented!");}
const HEX = 16;const BACKSLASH_BYTE_VALUE = 92;const HEX_PREFIX_REGEX = /^\\x/;
function decodeBytea(byteaStr: string): Uint8Array { if (HEX_PREFIX_REGEX.test(byteaStr)) { return decodeByteaHex(byteaStr); } else { return decodeByteaEscape(byteaStr); }}
function decodeByteaHex(byteaStr: string): Uint8Array { let bytesStr = byteaStr.slice(2); let bytes = new Uint8Array(bytesStr.length / 2); for (let i = 0, j = 0; i < bytesStr.length; i += 2, j++) { bytes[j] = parseInt(bytesStr[i] + bytesStr[i + 1], HEX); } return bytes;}
function decodeByteaEscape(byteaStr: string): Uint8Array { let bytes = []; let i = 0; while (i < byteaStr.length) { if (byteaStr[i] !== "\\") { bytes.push(byteaStr.charCodeAt(i)); ++i; } else { if (/[0-7]{3}/.test(byteaStr.substr(i + 1, 3))) { bytes.push(parseInt(byteaStr.substr(i + 1, 3), 8)); i += 4; } else { let backslashes = 1; while ( i + backslashes < byteaStr.length && byteaStr[i + backslashes] === "\\" ) { backslashes++; } for (var k = 0; k < Math.floor(backslashes / 2); ++k) { bytes.push(BACKSLASH_BYTE_VALUE); } i += Math.floor(backslashes / 2) * 2; } } } return new Uint8Array(bytes);}
const decoder = new TextDecoder();
function decodeText(value: Uint8Array, typeOid: number): any { const strValue = decoder.decode(value);
switch (typeOid) { case Oid.char: case Oid.varchar: case Oid.text: case Oid.time: case Oid.timetz: case Oid.inet: case Oid.cidr: case Oid.macaddr: case Oid.name: case Oid.uuid: case Oid.oid: case Oid.regproc: case Oid.regprocedure: case Oid.regoper: case Oid.regoperator: case Oid.regclass: case Oid.regtype: case Oid.regrole: case Oid.regnamespace: case Oid.regconfig: case Oid.regdictionary: case Oid.int8: // @see https://github.com/buildondata/deno-postgres/issues/91. case Oid.numeric: case Oid.void: return strValue; case Oid.bool: return strValue[0] === "t"; case Oid.int2: case Oid.int4: return parseInt(strValue, 10); case Oid.float4: case Oid.float8: return parseFloat(strValue); case Oid.timestamptz: case Oid.timestamp: return decodeDatetime(strValue); case Oid.date: return decodeDate(strValue); case Oid.json: case Oid.jsonb: return JSON.parse(strValue); case Oid.bytea: return decodeBytea(strValue); default: throw new Error(`Don't know how to parse column type: ${typeOid}`); }}
export function decode(value: Uint8Array, column: Column) { if (column.format === Format.BINARY) { return decodeBinary(); } else if (column.format === Format.TEXT) { return decodeText(value, column.typeOid); } else { throw new Error(`Unknown column format: ${column.format}`); }}