diff --git a/lib/modules/Sql.pmod/pgsql.pike b/lib/modules/Sql.pmod/pgsql.pike
index 2790dff7e92f2e165bdb3a2b61fa7ed7ed6a5931..9008852b7c877fe63ed32b9e1377f9481a8e6392 100644
--- a/lib/modules/Sql.pmod/pgsql.pike
+++ b/lib/modules/Sql.pmod/pgsql.pike
@@ -1718,18 +1718,18 @@ object big_query(string q,void|mapping(string|int:mixed) bindings,
     tp=UNDEFINED;
   connectionclosed=0;
   for(;;)
-   {
-  .pgsql_util.pgsql_result(this,q,_fetchlimit,portalbuffersize,_alltyped,from);
-  if(unnamedportalinuse)
-    portalname=PORTALPREFIX+(string)pportalcount++;
-  else
-    unnamedportalinuse++;
-  _c.portal->_portalname=portalname;
-  qstate=inquery;
-  portalsinflight++; portalsopened++;
-  clearmessage=1;
-  mixed err;
-  if(!(err = catch
+  { .pgsql_util.pgsql_result(this,q,_fetchlimit,portalbuffersize,_alltyped,
+     from);
+    if(unnamedportalinuse)
+      portalname=PORTALPREFIX+(string)pportalcount++;
+    else
+      unnamedportalinuse++;
+    _c.portal->_portalname=portalname;
+    qstate=inquery;
+    portalsinflight++; portalsopened++;
+    clearmessage=1;
+    mixed err;
+    if(!(err = catch
     { if(!sizeof(preparedname) || !tp || !tp->preparedname)
       { PD("Parse statement %s\n",preparedname);
 	// Even though the protocol doesn't require the Parse command to be
@@ -1924,13 +1924,13 @@ object big_query(string q,void|mapping(string|int:mixed) bindings,
 	tprepared=tp;
       }
     }))
-    break;
-  PD("%O\n",err);
-  resync(1);
-  backendstatus=UNDEFINED;
-  if(!connectionclosed)
-    throw(err);
-  tp=UNDEFINED;
+      break;
+    PD("%O\n",err);
+    resync(1);
+    backendstatus=UNDEFINED;
+    if(!connectionclosed)
+      throw(err);
+    tp=UNDEFINED;
   }
   { object tportal=_c.portal;		// Make copy, because it might dislodge
     tportal->fetch_row(1);		// upon initial fetch_row()