build

Author: porsager

cjs/src/index.js

@@ -75,7 +75,6 @@ function Postgres(a, b) {
     PostgresError,
     options,
     listen,
-    notify,
     begin,
     close,
     end
@@ -95,6 +94,7 @@ function Postgres(a, b) {
       types: typed,
       typed,
       unsafe,
+      notify,
       array,
       json,
       file

cjs/src/types.js

@@ -159,6 +159,7 @@ const builders = Object.entries({
   select,
   as: select,
   returning: select,
+  '\\(': select,
 
   update(first, rest, parameters, types, options) {
     return (rest.length ? rest.flat() : Object.keys(first)).map(x =>
@@ -200,8 +201,10 @@ const mergeUserTypes = module.exports.mergeUserTypes = function(types) {
 function typeHandlers(types) {
   return Object.keys(types).reduce((acc, k) => {
     types[k].from && [].concat(types[k].from).forEach(x => acc.parsers[x] = types[k].parse)
-    acc.serializers[types[k].to] = types[k].serialize
-    types[k].from && [].concat(types[k].from).forEach(x => acc.serializers[x] = types[k].serialize)
+    if (types[k].serialize) {
+      acc.serializers[types[k].to] = types[k].serialize
+      types[k].from && [].concat(types[k].from).forEach(x => acc.serializers[x] = types[k].serialize)
+    }
     return acc
   }, { parsers: {}, serializers: {} })
 }

deno/README.md

@@ -238,9 +238,10 @@ const users = [
 ]
 
 sql`
-  update users set name = update_data.name, age = update_data.age
+  update users set name = update_data.name, (age = update_data.age)::int
   from (values ${sql(users)}) as update_data (id, name, age)
-  where users.id = update_data.id
+  where users.id = (update_data.id)::int
+  returning users.id, users.name, users.age
 `
 ```
 
@@ -449,6 +450,11 @@ Using a file for a query is also supported with optional parameters to use if th
 const result = await sql.file('query.sql', ['Murray', 68])
 ```
 
+### Multiple statements in one query
+#### `await sql`select 1;select 2`.simple()
+
+The postgres wire protocol supports "simple" and "extended" queries. "simple" queries supports multiple statements, but does not support any dynamic parameters. "extended" queries support parameters but only one statement. To use "simple" queries you can use sql``.simple(). That will create it as a simple query.
+
 ### Copy to/from as Streams
 
 Postgres.js supports [`COPY ...`](https://www.postgresql.org/docs/14/sql-copy.html) queries, which are exposed as [Node.js streams](https://nodejs.org/api/stream.html).

deno/src/index.js

@@ -76,7 +76,6 @@ function Postgres(a, b) {
     PostgresError,
     options,
     listen,
-    notify,
     begin,
     close,
     end
@@ -96,6 +95,7 @@ function Postgres(a, b) {
       types: typed,
       typed,
       unsafe,
+      notify,
       array,
       json,
       file

deno/src/types.js

@@ -160,6 +160,7 @@ const builders = Object.entries({
   select,
   as: select,
   returning: select,
+  '\\(': select,
 
   update(first, rest, parameters, types, options) {
     return (rest.length ? rest.flat() : Object.keys(first)).map(x =>
@@ -201,8 +202,10 @@ export const mergeUserTypes = function(types) {
 function typeHandlers(types) {
   return Object.keys(types).reduce((acc, k) => {
     types[k].from && [].concat(types[k].from).forEach(x => acc.parsers[x] = types[k].parse)
-    acc.serializers[types[k].to] = types[k].serialize
-    types[k].from && [].concat(types[k].from).forEach(x => acc.serializers[x] = types[k].serialize)
+    if (types[k].serialize) {
+      acc.serializers[types[k].to] = types[k].serialize
+      types[k].from && [].concat(types[k].from).forEach(x => acc.serializers[x] = types[k].serialize)
+    }
     return acc
   }, { parsers: {}, serializers: {} })
 }

deno/types/index.d.ts

@@ -638,6 +638,7 @@ declare namespace postgres {
   type ParameterOrFragment<T> =
   | SerializableParameter<T>
   | Fragment
+  | Fragment[]
 
   interface Sql<TTypes extends Record<string, unknown> = {}> {
     /**