Skip to content

Commit bb82c22

Browse files
committed
Move escapeSql to shared location
1 parent 7172397 commit bb82c22

File tree

3 files changed

+7
-4
lines changed

3 files changed

+7
-4
lines changed

services/features.js

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,15 +6,12 @@ const async = require('async'),
66
GeoPoint = require('geopoint'),
77
HttpStatus = require('http-status-codes'),
88
postgres = require('./postgres'),
9+
escapeSql = postgres.escapeSql,
910
ServiceError = common.utils.ServiceError,
1011
turf = require('turf');
1112

1213
let featureDatabasePool;
1314

14-
function escapeSql(value) {
15-
return `'${value.replace(/'/g,"''")}'`;
16-
}
17-
1815
function executeQuery(query, callback) {
1916
featureDatabasePool.connect((err, client, done) => {
2017
if (err) return callback(err);

services/featuresCosmosDb.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ const async = require('async'),
66
GeoPoint = require('geopoint'),
77
HttpStatus = require('http-status-codes'),
88
process = require('process'),
9+
escapeSql = require('./postgres').escapeSql,
910
ServiceError = common.utils.ServiceError,
1011
turf = require('turf'),
1112
url = require('url');

services/postgres.js

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,10 @@ const pg = require('pg'),
33
querystring = require('querystring'),
44
url = require('url');
55

6+
function escapeSql(value) {
7+
return `'${value.replace(/'/g,"''")}'`;
8+
}
9+
610
function init(callback) {
711
const connectionString = process.env.FEATURES_CONNECTION_STRING;
812

@@ -30,5 +34,6 @@ function init(callback) {
3034
}
3135

3236
module.exports = {
37+
escapeSql: escapeSql,
3338
init: init
3439
};

0 commit comments

Comments
 (0)