Function make

packages/sql/src/internal/statement.ts:304–376

(
  acquirer: Connection.Connection.Acquirer,
  compiler: Statement.Compiler,
  spanAttributes: ReadonlyArray<readonly [string, unknown]>,
  transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
)

/** @internal */
export const make = (
  acquirer: Connection.Connection.Acquirer,
  compiler: Statement.Compiler,
  spanAttributes: ReadonlyArray<readonly [string, unknown]>,
  transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
): Statement.Constructor => {
  const cache = transformRows === undefined ? constructorCache.noTransforms : constructorCache.transforms
  if (cache.has(acquirer)) {
    return cache.get(acquirer)!
  }
  const self = Object.assign(
    function sql(strings: unknown, ...args: Array<any>): any {
      if (Array.isArray(strings) && "raw" in strings) {
        return statement(
          acquirer,
          compiler,
          strings as TemplateStringsArray,
          args,
          spanAttributes,
          transformRows
        )
      } else if (typeof strings === "string") {
        return new IdentifierImpl(strings)
      }

      throw "absurd"
    },
    {
      unsafe<A extends object = Connection.Row>(
        sql: string,
        params?: ReadonlyArray<unknown>
      ) {
        return new StatementPrimitive<A>(
          [new LiteralImpl(sql, params)],
          acquirer,
          compiler,
          spanAttributes,
          transformRows
        )
      },
      literal(sql: string) {
        return new FragmentImpl([new LiteralImpl(sql)])
      },
      in: in_,
      insert(value: any) {
        return new RecordInsertHelperImpl(
          Array.isArray(value) ? value : [value],
          undefined
        )
      },
      update(value: any, omit: any) {
        return new RecordUpdateHelperSingleImpl(value, omit ?? [], undefined)
      },
      updateValues(value: any, alias: any) {
        return new RecordUpdateHelperImpl(value, alias, undefined)
      },
      and,
      or,