diff --git a/sentry_sdk/integrations/pymongo.py b/sentry_sdk/integrations/pymongo.py
index 947dbe3945..3e67833a92 100644
--- a/sentry_sdk/integrations/pymongo.py
+++ b/sentry_sdk/integrations/pymongo.py
@@ -1,7 +1,7 @@
 import copy
 
 import sentry_sdk
-from sentry_sdk.consts import SPANDATA
+from sentry_sdk.consts import SPANDATA, OP
 from sentry_sdk.integrations import DidNotEnable, Integration
 from sentry_sdk.scope import should_send_default_pii
 from sentry_sdk.tracing import Span
@@ -126,8 +126,6 @@ def started(self, event):
             command.pop("$clusterTime", None)
             command.pop("$signature", None)
 
-            op = "db.query"
-
             tags = {
                 "db.name": event.database_name,
                 SPANDATA.DB_SYSTEM: "mongodb",
@@ -157,7 +155,7 @@ def started(self, event):
 
             query = "{}".format(command)
             span = sentry_sdk.start_span(
-                op=op,
+                op=OP.DB,
                 description=query,
                 origin=PyMongoIntegration.origin,
             )
@@ -170,7 +168,7 @@ def started(self, event):
 
             with capture_internal_exceptions():
                 sentry_sdk.add_breadcrumb(
-                    message=query, category="query", type=op, data=tags
+                    message=query, category="query", type=OP.DB, data=tags
                 )
 
             self._ongoing_operations[self._operation_key(event)] = span.__enter__()
diff --git a/tests/integrations/pymongo/test_pymongo.py b/tests/integrations/pymongo/test_pymongo.py
index 75a05856fb..adbd9d8286 100644
--- a/tests/integrations/pymongo/test_pymongo.py
+++ b/tests/integrations/pymongo/test_pymongo.py
@@ -63,9 +63,9 @@ def test_transactions(sentry_init, capture_events, mongo_server, with_pii):
         for field, value in common_tags.items():
             assert span["tags"][field] == value
 
-    assert find["op"] == "db.query"
-    assert insert_success["op"] == "db.query"
-    assert insert_fail["op"] == "db.query"
+    assert find["op"] == "db"
+    assert insert_success["op"] == "db"
+    assert insert_fail["op"] == "db"
 
     assert find["tags"]["db.operation"] == "find"
     assert insert_success["tags"]["db.operation"] == "insert"
@@ -118,7 +118,7 @@ def test_breadcrumbs(sentry_init, capture_events, mongo_server, with_pii):
         assert "1" in crumb["message"]
     else:
         assert "1" not in crumb["message"]
-    assert crumb["type"] == "db.query"
+    assert crumb["type"] == "db"
     assert crumb["data"] == {
         "db.name": "test_db",
         "db.system": "mongodb",