purescript-node-postgres/src/Database/Postgres.js at master · epost/purescript-node-postgres · GitHub - github.com

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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

// module Database.Postgres

var pg = require('pg');

exports.mkPool = function (conInfo) {
  return function () {
    return new pg.Pool(conInfo);
  };
}

exports.connectImpl = function (pool) {
  return function(error, success) {
    pool.connect(function(err, client) {
      if (err) {
        error(err);
      } else {
        success(client);
      }
    });
    return function(cancelError, onCancelerError, onCancelerSuccess) {
      onCancelerSuccess();
    };
  };
}

exports.runQuery_ = function(queryStr) {
  return function(client) {
    return function(error, success) {
      client.query(queryStr, function(err, result) {
        if (err) {
          error(err);
        } else {
          success(result.rows);
        }
      });
      return function(cancelError, onCancelerError, onCancelerSuccess) {
        onCancelerSuccess();
      };
    };
  };
}

exports.runQuery = function(queryStr) {
  return function(params) {
    return function(client) {
      return function(error, success) {
        client.query(queryStr, params, function(err, result) {
          if (err) return error(err);
          success(result.rows);
        });
        return function(cancelError, onCancelerError, onCancelerSuccess) {
          onCancelerSuccess();
        };
      };
    };
  };
}

exports.runQueryValue_ = function(queryStr) {
  return function(client) {
    return function(error, success) {
      client.query(queryStr, function(err, result) {
        if (err) return error(err);
        success(result.rows.length > 0 ? result.rows[0][result.fields[0].name] : undefined);
      });
      return function(cancelError, onCancelerError, onCancelerSuccess) {
        onCancelerSuccess();
      };
    };
  };
}

exports.runQueryValue = function(queryStr) {
  return function(params) {
    return function(client) {
      return function(error, success) {
        client.query(queryStr, params, function(err, result) {
          if (err) return error(err);
          success(result.rows.length > 0 ? result.rows[0][result.fields[0].name] : undefined);
        });
        return function(cancelError, onCancelerError, onCancelerSuccess) {
          onCancelerSuccess();
        };
      };
    };
  };
}

exports.release = function (client) {
  return function () {
    client.release();
  };
}

exports.end = function(pool) {
  return function() {
    pool.end();
  };
}