文件操作 - pglite.mjs

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

编辑文件内容

import { PGlite } from "@electric-sql/pglite";
export default function pgliteConnector(opts) {
  let _client;
  function getClient() {
    return _client ||= 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.mjs

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

编辑文件内容

修改文件时间

删除文件