文件操作 - pglite.cjs

文件: /var/www/OLD/node_modules/db0/connectors/pglite.cjs

编辑文件内容

"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
module.exports = pgliteConnector;
var _pglite = require("@electric-sql/pglite");
function pgliteConnector(opts) {
  let _client;
  function getClient() {
    return _client ||= _pglite.PGlite.create(opts).then(res => _client = res);
  }
  async function query(sql, params = void 0) {
    const client = await getClient();
    const normalizedSql = normalizeParams(sql);
    const result = await client.query(normalizedSql, params);
    return result;
  }
  return {
    name: "pglite",
    dialect: "postgresql",
    getInstance: () => getClient(),
    exec(sql) {
      return query(sql);
    },
    prepare(sql) {
      const stmt = {
        _sql: sql,
        _params: [],
        bind(...params) {
          if (params.length > 0) {
            this._params = params;
          }
          return this;
        },
        async all(...params) {
          const result = await query(this._sql, params.length > 0 ? params : this._params);
          return result.rows;
        },
        async run(...params) {
          const result = await query(this._sql, params.length > 0 ? params : this._params);
          return {
            success: true,
            // Adding the success property to match the expected type
            result,
            rows: result.rows
          };
        },
        async get(...params) {
          const result = await query(this._sql, params.length > 0 ? params : this._params);
          return result.rows[0];
        }
      };
      return stmt;
    }
  };
}
function normalizeParams(sql) {
  let i = 0;
  return sql.replace(/\?/g, () => `$${++i}`);
}

文件操作 - pglite.cjs

文件: /var/www/OLD/node_modules/db0/connectors/pglite.cjs

编辑文件内容

修改文件时间

删除文件