diff --git a/pgsql.go b/pgsql.go
index dd3cce437f0..f91b354d97f 100644
--- a/pgsql.go
+++ b/pgsql.go
@@ -652,7 +652,7 @@ func receivedPgsqlRequest(msg *PgsqlMessage) {
 
         trans.Pgsql = bson.M{
             "query":  query,
-            "query.raw": msg.Query,
+            "query.raw": query,
             "method": getQueryMethod(query),
         }