feat: sql.join

README.md

@@ -342,6 +342,11 @@ select * from users
 select * from users where user_id = $1
 ```
 
+Multiple fragments can be joined together with `sql.join` to create more complex dynamic queries:
+```js
+const columns = ['id', 'name', 'age'].map(name => sql(name))
+sql`select ${sql.join(', ', columns)} from users where
+
 ### SQL functions
 Using keywords or calling functions dynamically is also possible by using ``` sql`` ``` fragments.
 ```js

src/index.js

@@ -98,6 +98,7 @@ function Postgres(a, b) {
       notify,
       array,
       json,
+      join,
       file
     })
 
@@ -318,6 +319,10 @@ function Postgres(a, b) {
     return new Parameter(x, 3802)
   }
 
+  function join(sep, xs) {
+    return xs.flatMap((x, i) => i ? Array.isArray(x) ? [sep, ...x] : [sep, x])
+  }
+
   function array(x, type) {
     if (!Array.isArray(x))
       return array(Array.from(arguments))

tests/index.js

@@ -2469,6 +2469,14 @@ t('Supports arrays of fragments', async() => {
   ]
 })
 
+t("Joins fragments with a separator", () => {
+  const fs = [sql`a = ${1}`, sql`b = ${"test"}`]
+  return [
+    sql`select * from t where ${ sql.join(sql` and `, fs) }; `.describe().string,
+    'select * from t where a = $1 and b = $2'
+  ]
+});
+
 t('Does not try rollback when commit errors', async() => {
   let notice = null
   const sql = postgres({ ...options, onnotice: x => notice = x })

types/index.d.ts

@@ -702,6 +702,7 @@ declare namespace postgres {
     file<T extends readonly any[] = Row[]>(path: string | Buffer | URL | number, options?: { cache?: boolean | undefined } | undefined): PendingQuery<T>;
     file<T extends readonly any[] = Row[]>(path: string | Buffer | URL | number, args: (ParameterOrJSON<TTypes[keyof TTypes]>)[], options?: { cache?: boolean | undefined } | undefined): PendingQuery<T>;
     json(value: JSONValue): Parameter;
+    join<T extends any[], U extends any[]>(a: PendingQuery<T>, p: PendingQuery<U>): PendingQuery<T>
 
     reserve(): Promise<ReservedSql<TTypes>>
   }