FM / pg

/opt/canhelp/node_modules/drizzle-orm/prisma/pg/

/opt/canhelp/node_modules/drizzle-orm/prisma/pg

Name	Size	Mode	Actions
driver.cjs	2081	0644	edit dl rm
driver.cjs.map	2058	0644	edit dl rm
driver.d.cts	893	0644	edit dl rm
driver.d.ts	888	0644	edit dl rm
driver.js	942	0644	edit dl rm
driver.js.map	2033	0644	edit dl rm
index.cjs	1197	0644	edit dl rm
index.cjs.map	226	0644	edit dl rm
index.d.cts	61	0644	edit dl rm
index.d.ts	59	0644	edit dl rm
index.js	92	0644	edit dl rm
index.js.map	187	0644	edit dl rm
session.cjs	2579	0644	edit dl rm
session.cjs.map	3443	0644	edit dl rm
session.d.cts	1586	0644	edit dl rm
session.d.ts	1581	0644	edit dl rm
session.js	1423	0644	edit dl rm
session.js.map	3419	0644	edit dl rm

Edit: /opt/canhelp/node_modules/drizzle-orm/prisma/pg/session.js (1423B)

import { entityKind } from "../../entity.js";
import { NoopLogger } from "../../logger.js";
import { PgPreparedQuery, PgSession } from "../../pg-core/index.js";
import { fillPlaceholders } from "../../sql/sql.js";
class PrismaPgPreparedQuery extends PgPreparedQuery {
  constructor(prisma, query, logger) {
    super(query);
    this.prisma = prisma;
    this.logger = logger;
  }
  static [entityKind] = "PrismaPgPreparedQuery";
  execute(placeholderValues) {
    const params = fillPlaceholders(this.query.params, placeholderValues ?? {});
    this.logger.logQuery(this.query.sql, params);
    return this.prisma.$queryRawUnsafe(this.query.sql, ...params);
  }
  all() {
    throw new Error("Method not implemented.");
  }
  isResponseInArrayMode() {
    return false;
  }
}
class PrismaPgSession extends PgSession {
  constructor(dialect, prisma, options) {
    super(dialect);
    this.prisma = prisma;
    this.options = options;
    this.logger = options.logger ?? new NoopLogger();
  }
  static [entityKind] = "PrismaPgSession";
  logger;
  execute(query) {
    return this.prepareQuery(this.dialect.sqlToQuery(query)).execute();
  }
  prepareQuery(query) {
    return new PrismaPgPreparedQuery(this.prisma, query, this.logger);
  }
  transaction(_transaction, _config) {
    throw new Error("Method not implemented.");
  }
}
export {
  PrismaPgPreparedQuery,
  PrismaPgSession
};
//# sourceMappingURL=session.js.map

import { entityKind } from "../../entity.js"; import { NoopLogger } from "../../logger.js"; import { PgPreparedQuery, PgSession } from "../../pg-core/index.js"; import { fillPlaceholders } from "../../sql/sql.js"; class PrismaPgPreparedQuery extends PgPreparedQuery { constructor(prisma, query, logger) { super(query); this.prisma = prisma; this.logger = logger; } static [entityKind] = "PrismaPgPreparedQuery"; execute(placeholderValues) { const params = fillPlaceholders(this.query.params, placeholderValues ?? {}); this.logger.logQuery(this.query.sql, params); return this.prisma.$queryRawUnsafe(this.query.sql, ...params); } all() { throw new Error("Method not implemented."); } isResponseInArrayMode() { return false; } } class PrismaPgSession extends PgSession { constructor(dialect, prisma, options) { super(dialect); this.prisma = prisma; this.options = options; this.logger = options.logger ?? new NoopLogger(); } static [entityKind] = "PrismaPgSession"; logger; execute(query) { return this.prepareQuery(this.dialect.sqlToQuery(query)).execute(); } prepareQuery(query) { return new PrismaPgPreparedQuery(this.prisma, query, this.logger); } transaction(_transaction, _config) { throw new Error("Method not implemented."); } } export { PrismaPgPreparedQuery, PrismaPgSession }; //# sourceMappingURL=session.js.map