diff --git a/wire.ts b/wire.ts
index cb1facb..eaaefa9 100644
--- a/wire.ts
+++ b/wire.ts
@@ -91,7 +91,7 @@ export class PostgresError extends WireError {
   }
 }
 
-function severity_level(s: string): LogLevel {
+function severity_log_level(s: string): LogLevel {
   switch (s) {
     case "DEBUG":
       return "debug";
@@ -628,7 +628,7 @@ function wire_impl(
       case NoticeResponse.type: {
         const { fields } = ser_decode(NoticeResponse, msg);
         const notice = new PostgresError(fields);
-        log(severity_level(notice.severity), notice, notice.message);
+        log(severity_log_level(notice.severity), notice, notice.message);
         wire.emit("notice", notice);
         return true;
       }
@@ -1101,10 +1101,12 @@ function wire_impl(
     stdin: ReadableStream<Uint8Array> | null,
     stdout: WritableStream<Uint8Array> | null
   ): ResultStream<Row> {
-    log("debug", { query: query }, `executing simple query`);
-
     yield* await pipeline(
-      () => (write(QueryMessage, { query }), write_copy_in(stdin)),
+      () => {
+        log("debug", { query }, `executing simple query`);
+        write(QueryMessage, { query });
+        write_copy_in(stdin);
+      },
       async () => {
         for (let chunks = [], err; ; ) {
           const msg = await read_msg();
@@ -1145,12 +1147,7 @@ function wire_impl(
     stdin: ReadableStream<Uint8Array> | null,
     stdout: WritableStream<Uint8Array> | null
   ): ResultStream<Row> {
-    log(
-      "debug",
-      { query: st.query, statement: st.name, params },
-      `executing query`
-    );
-
+    const { query, name: statement } = st;
     const { ser_params, Row } = await st.parse();
     const param_values = ser_params(params);
     const portal = st.portal();
@@ -1158,6 +1155,7 @@ function wire_impl(
     try {
       const { rows, tag } = await pipeline(
         async () => {
+          log("debug", { query, statement, params }, `executing query`);
           write(Bind, {
             portal,
             statement: st.name,
@@ -1198,12 +1196,7 @@ function wire_impl(
     stdin: ReadableStream<Uint8Array> | null,
     stdout: WritableStream<Uint8Array> | null
   ): ResultStream<Row> {
-    log(
-      "debug",
-      { query: st.query, statement: st.name, params },
-      `executing chunked query`
-    );
-
+    const { query, name: statement } = st;
     const { ser_params, Row } = await st.parse();
     const param_values = ser_params(params);
     const portal = st.portal();
@@ -1211,6 +1204,7 @@ function wire_impl(
     try {
       let { done, rows, tag } = await pipeline(
         () => {
+          log("debug", { query, statement, params }, `executing chunked query`);
           write(Bind, {
             portal,
             statement: st.name,