Add InitialQuery event

src/Common/ProfileEvents.cpp

@@ -8,6 +8,7 @@
     M(Query, "Number of queries to be interpreted and potentially executed. Does not include queries that failed to parse or were rejected due to AST size limits, quota limits or limits on the number of simultaneously running queries. May include internal queries initiated by ClickHouse itself. Does not count subqueries.") \
     M(SelectQuery, "Same as Query, but only for SELECT queries.") \
     M(InsertQuery, "Same as Query, but only for INSERT queries.") \
+    M(InitialQuery, "Same as Query, but only counts initial queries (see is_initial_query).")\
     M(QueriesWithSubqueries, "Count queries with all subqueries") \
     M(SelectQueriesWithSubqueries, "Count SELECT queries with all subqueries") \
     M(InsertQueriesWithSubqueries, "Count INSERT queries with all subqueries") \

src/Databases/DatabaseReplicatedWorker.cpp

@@ -6,7 +6,10 @@
 #include <filesystem>
 
 namespace fs = std::filesystem;
-
+namespace ProfileEvents
+{
+    extern const Event InitialQuery;
+}
 namespace DB
 {
 
@@ -264,7 +267,7 @@ String DatabaseReplicatedDDLWorker::tryEnqueueAndExecuteEntry(DDLLogEntry & entr
     chassert(!task->entry.query.empty());
     assert(!zookeeper->exists(task->getFinishedNodePath()));
     task->is_initial_query = true;
-
+    ProfileEvents::increment(ProfileEvents::InitialQuery);
     LOG_DEBUG(log, "Waiting for worker thread to process all entries before {}", entry_name);
     UInt64 timeout = query_context->getSettingsRef().database_replicated_initial_query_timeout_sec;
     {

tests/queries/0_stateless/02950_initialquery_event.reference

@@ -0,0 +1 @@
+InitialQuery	6	Same as Query, but only counts initial queries (see is_initial_query).

tests/queries/0_stateless/02950_initialquery_event.sql

@@ -0,0 +1 @@
+SELECT * FROM system.events where event = 'InitialQuery'