Use const keyword to declare varibles
This commit is contained in:
parent
b4ce13e429
commit
ada58f6ea2
@ -1,60 +1,16 @@
|
|||||||
function BaseDataview() {}
|
const FLOAT_OIDS = {
|
||||||
|
|
||||||
module.exports = BaseDataview;
|
|
||||||
|
|
||||||
BaseDataview.prototype.getResult = function(psql, override, callback) {
|
|
||||||
var self = this;
|
|
||||||
this.sql(psql, override, function(err, query) {
|
|
||||||
if (err) {
|
|
||||||
return callback(err);
|
|
||||||
}
|
|
||||||
|
|
||||||
psql.query(query, function(err, result) {
|
|
||||||
if (err) {
|
|
||||||
return callback(err, result);
|
|
||||||
}
|
|
||||||
|
|
||||||
result = self.format(result, override);
|
|
||||||
result.type = self.getType();
|
|
||||||
|
|
||||||
return callback(null, result);
|
|
||||||
|
|
||||||
}, true); // use read-only transaction
|
|
||||||
});
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
BaseDataview.prototype.search = function(psql, userQuery, callback) {
|
|
||||||
return callback(null, this.format({ rows: [] }));
|
|
||||||
};
|
|
||||||
|
|
||||||
var FLOAT_OIDS = {
|
|
||||||
700: true,
|
700: true,
|
||||||
701: true,
|
701: true,
|
||||||
1700: true
|
1700: true
|
||||||
};
|
};
|
||||||
|
|
||||||
var DATE_OIDS = {
|
const DATE_OIDS = {
|
||||||
1082: true,
|
1082: true,
|
||||||
1114: true,
|
1114: true,
|
||||||
1184: true
|
1184: true
|
||||||
};
|
};
|
||||||
|
|
||||||
var columnTypeQueryTpl = ctx => `SELECT pg_typeof(${ctx.column})::oid FROM (${ctx.query}) _cdb_column_type limit 1`;
|
const columnTypeQueryTpl = ctx => `SELECT pg_typeof(${ctx.column})::oid FROM (${ctx.query}) _cdb_column_type limit 1`;
|
||||||
|
|
||||||
BaseDataview.prototype.getColumnType = function (psql, column, query, callback) {
|
|
||||||
var readOnlyTransaction = true;
|
|
||||||
|
|
||||||
var columnTypeQuery = columnTypeQueryTpl({ column, query });
|
|
||||||
|
|
||||||
psql.query(columnTypeQuery, function(err, result) {
|
|
||||||
if (err) {
|
|
||||||
return callback(err);
|
|
||||||
}
|
|
||||||
var pgType = result.rows[0].pg_typeof;
|
|
||||||
callback(null, getPGTypeName(pgType));
|
|
||||||
}, readOnlyTransaction);
|
|
||||||
};
|
|
||||||
|
|
||||||
function getPGTypeName (pgType) {
|
function getPGTypeName (pgType) {
|
||||||
return {
|
return {
|
||||||
@ -62,3 +18,44 @@ function getPGTypeName (pgType) {
|
|||||||
date: DATE_OIDS.hasOwnProperty(pgType)
|
date: DATE_OIDS.hasOwnProperty(pgType)
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
module.exports = class BaseDataview {
|
||||||
|
getResult (psql, override, callback) {
|
||||||
|
const self = this;
|
||||||
|
this.sql(psql, override, function(err, query) {
|
||||||
|
if (err) {
|
||||||
|
return callback(err);
|
||||||
|
}
|
||||||
|
|
||||||
|
psql.query(query, function(err, result) {
|
||||||
|
if (err) {
|
||||||
|
return callback(err, result);
|
||||||
|
}
|
||||||
|
|
||||||
|
result = self.format(result, override);
|
||||||
|
result.type = self.getType();
|
||||||
|
|
||||||
|
return callback(null, result);
|
||||||
|
|
||||||
|
}, true); // use read-only transaction
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
search (psql, userQuery, callback) {
|
||||||
|
return callback(null, this.format({ rows: [] }));
|
||||||
|
};
|
||||||
|
|
||||||
|
getColumnType (psql, column, query, callback) {
|
||||||
|
const readOnlyTransaction = true;
|
||||||
|
|
||||||
|
const columnTypeQuery = columnTypeQueryTpl({ column, query });
|
||||||
|
|
||||||
|
psql.query(columnTypeQuery, function(err, result) {
|
||||||
|
if (err) {
|
||||||
|
return callback(err);
|
||||||
|
}
|
||||||
|
const pgType = result.rows[0].pg_typeof;
|
||||||
|
callback(null, getPGTypeName(pgType));
|
||||||
|
}, readOnlyTransaction);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
Loading…
Reference in New Issue
Block a user