Store Sherlock::Query in Peek adapter

Signed-off-by: Rémy Coutable <remy@rymai.me>

2 files changed, 72 insertions, 0 deletions

diff --git a/lib/gitlab/performance_bar/peek_mysql_with_queries.rb b/lib/gitlab/performance_bar/peek_mysql_with_queries.rb
new file mode 100644
index 00000000000..ea577de5a69
--- /dev/null
+++ b/lib/gitlab/performance_bar/peek_mysql_with_queries.rb
@@ -0,0 +1,36 @@
+# Inspired by https://github.com/peek/peek-mysql2/blob/master/lib/peek/views/mysql2.rb
+module Gitlab
+  module PerformanceBar
+    module PeekMysqlWithQueries
+      def queries
+        ::Mysql2::Client.query_details
+      end
+
+      def results
+        super.merge(queries: queries)
+      end
+
+      private
+
+      def setup_subscribers
+        super
+
+        # Reset each counter when a new request starts
+        before_request do
+          ::Mysql2::Client.query_details = []
+        end
+
+        subscribe('sql.active_record') do |_, start, finish, _, data|
+          if RequestStore.active? && RequestStore.store[:peek_enabled]
+            track_query(data[:sql].strip, data[:binds], start, finish)
+          end
+        end
+      end
+
+      def track_query(raw_query, bindings, start, finish)
+        query = Gitlab::Sherlock::Query.new(raw_query, start, finish)
+        ::Mysql2::Client.query_details << query.formatted_query
+      end
+    end
+  end
+end
diff --git a/lib/gitlab/performance_bar/peek_pg_with_queries.rb b/lib/gitlab/performance_bar/peek_pg_with_queries.rb
new file mode 100644
index 00000000000..6e9cb593d36
--- /dev/null
+++ b/lib/gitlab/performance_bar/peek_pg_with_queries.rb
@@ -0,0 +1,36 @@
+# Inspired by https://github.com/peek/peek-pg/blob/master/lib/peek/views/pg.rb
+module Gitlab
+  module PerformanceBar
+    module PeekPgWithQueries
+      def queries
+        ::PG::Connection.query_details
+      end
+
+      def results
+        super.merge(queries: queries)
+      end
+
+      private
+
+      def setup_subscribers
+        super
+
+        # Reset each counter when a new request starts
+        before_request do
+          ::PG::Connection.query_details = []
+        end
+
+        subscribe('sql.active_record') do |_, start, finish, _, data|
+          if RequestStore.active? && RequestStore.store[:peek_enabled]
+            track_query(data[:sql].strip, data[:binds], start, finish)
+          end
+        end
+      end
+
+      def track_query(raw_query, bindings, start, finish)
+        query = Gitlab::Sherlock::Query.new(raw_query, start, finish)
+        ::PG::Connection.query_details << query.formatted_query
+      end
+    end
+  end
+end