Software: Apache/2.4.41 (Ubuntu). PHP/8.0.30 

uname -a: Linux apirnd 5.4.0-204-generic #224-Ubuntu SMP Thu Dec 5 13:38:28 UTC 2024 x86_64 

uid=33(www-data) gid=33(www-data) groups=33(www-data) 

Safe-mode: OFF (not secure)

/usr/local/share/.cache/yarn/v6/npm-knex-2.4.0-integrity/node_modules/knex/lib/dialects/pgnative/   drwxr-xr-x
Free 12.95 GB of 57.97 GB (22.33%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     index.js (1.38 KB)      -rw-r--r--

// PostgreSQL Native Driver (pg-native)
// -------
const Client_PG = require('../postgres');

class Client_PgNative extends Client_PG {
  constructor(...args) {
    super(...args);
    this.driverName = 'pgnative';
    this.canCancelQuery = true;
  }

  _driver() {
    return require('pg').native;
  }

  _stream(connection, obj, stream, options) {
    if (!obj.sql) throw new Error('The query is empty');

    const client = this;
    return new Promise((resolver, rejecter) => {
      stream.on('error', rejecter);
      stream.on('end', resolver);

      return client
        ._query(connection, obj)
        .then((obj) => obj.response)
        .then(({ rows }) => rows.forEach((row) => stream.write(row)))
        .catch(function (err) {
          stream.emit('error', err);
        })
        .then(function () {
          stream.end();
        });
    });
  }

  async cancelQuery(connectionToKill) {
    try {
      return await this._wrappedCancelQueryCall(null, connectionToKill);
    } catch (err) {
      this.logger.warn(`Connection Error: ${err}`);
      throw err;
    }
  }

  _wrappedCancelQueryCall(emptyConnection, connectionToKill) {
    return new Promise(function (resolve, reject) {
      connectionToKill.native.cancel(function (err) {
        if (err) {
          reject(err);
          return;
        }

        resolve(true);
      });
    });
  }
}

module.exports = Client_PgNative;