4 replies

Parameterization from string and array of values

I have a sql string with placeholders and an array of values for those placeholders. How can I have drizzle parameterize and execute it?
for context I'm trying to have pg-boss use the same session as my drizzle transaction. pg-boss generates strings and arrays of values, but I can't find anything to render the sql in the api.

I am using node-postgres.

import type { Db as DbInterface } from 'pg-boss';
import type { db } from '~/lib/db';

class PgBossDrizzleTransactionAdapter implements DbInterface {
  tx: Parameters<Parameters<db['transaction']>[0]>[0];

  constructor(tx: Parameters<Parameters<db['transaction']>[0]>[0]) {
    this.tx = tx;
  }
  executeSql(text: string, values: any[]): Promise<{ rows: any[] }> {
    return this.tx.execute(text, values);
  }
}

import type { Db as DbInterface } from 'pg-boss';
import type { db } from '~/lib/db';

class PgBossDrizzleTransactionAdapter implements DbInterface {
  tx: Parameters<Parameters<db['transaction']>[0]>[0];

  constructor(tx: Parameters<Parameters<db['transaction']>[0]>[0]) {
    this.tx = tx;
  }
  executeSql(text: string, values: any[]): Promise<{ rows: any[] }> {
    return this.tx.execute(text, values);
  }
}

Drizzle Team•6mo ago•

4 replies

El Grande Padre

Parameterization from string and array of values

import type { Db as DbInterface } from 'pg-boss';
import type { db } from '~/lib/db';

class PgBossDrizzleTransactionAdapter implements DbInterface {
  tx: Parameters<Parameters<db['transaction']>[0]>[0];

  constructor(tx: Parameters<Parameters<db['transaction']>[0]>[0]) {
    this.tx = tx;
  }
  executeSql(text: string, values: any[]): Promise<{ rows: any[] }> {
    return this.tx.execute(text, values);
  }
}

import type { Db as DbInterface } from 'pg-boss';
import type { db } from '~/lib/db';

class PgBossDrizzleTransactionAdapter implements DbInterface {
  tx: Parameters<Parameters<db['transaction']>[0]>[0];

  constructor(tx: Parameters<Parameters<db['transaction']>[0]>[0]) {
    this.tx = tx;
  }
  executeSql(text: string, values: any[]): Promise<{ rows: any[] }> {
    return this.tx.execute(text, values);
  }
}

Parameterization from string and array of values

Similar Threads

Parameterization from string and array of values

Similar Threads

Similar Threads

Similar Threads