Update abstract_adapter patch

drecom · Jan 1, 2017 · c0ca348 · c0ca348
1 parent abeeaab
commit c0ca348
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/lib/active_record/turntable/active_record_ext/abstract_adapter.rb b/lib/active_record/turntable/active_record_ext/abstract_adapter.rb
@@ -7,13 +7,14 @@ module AbstractAdapter
         protected
 
         # @note override for logging current shard name
-        def log(sql, name = "SQL", binds = [])
+        def log(sql, name = "SQL", binds = [], statement_name = nil)
           @instrumenter.instrument(
                                    "sql.active_record",
-                                   :sql           => sql,
-                                   :name          => name,
-                                   :connection_id => object_id,
-                                   :binds         => binds,
+                                   :sql            => sql,
+                                   :name           => name,
+                                   :connection_id  => object_id,
+                                   :statement_name => statement_name,
+                                   :binds          => binds,
                                    :turntable_shard_name => turntable_shard_name) { yield }
         rescue Exception => e
           message = "#{e.class.name}: #{e.message}: #{sql} : #{turntable_shard_name}"