fix(query): view query should not cover the origin query (#18272)

Run `CREATE VIEW c AS SELECT * FROM hits.hits LIMIT `

query the query_history:

```sql
SELECT query_start_time, query_duration_ms, query_id, query_text FROM system_history.query_history;
```

In main :

│ 2025-06-30 04:54:06.178345 │                 0 │ 475d40329f8946fd9cc2310f79de643f │ SELECT * FROM hits.hits LIMIT 1                                                                                                                                                                       │

In pr:

│ 2025-06-30 04:59:20.485635 │                82 │ 04319b72fff94aac8b6c4f72fae01414 │ CREATE VIEW c AS SELECT * FROM hits.hits LIMIT 1                                                                                                                                                      │

Author: TCeason

src/query/service/src/sessions/query_ctx_shared.rs

@@ -631,6 +631,10 @@ impl QueryContextShared {
     }
 
     pub fn attach_query_str(&self, kind: QueryKind, query: String) {
+        // `create view as view_query` the view_query should not cover create view
+        if !self.get_query_str().is_empty() {
+            return;
+        }
         {
             let mut running_query = self.running_query.write();
             *running_query = Some(short_sql(
@@ -649,14 +653,18 @@ impl QueryContextShared {
 
     pub fn attach_query_hash(&self, text_hash: String, parameterized_hash: String) {
         {
-            let mut running_query_hash = self.running_query_text_hash.write();
-            *running_query_hash = Some(text_hash);
+            if self.get_query_text_hash().is_empty() {
+                let mut running_query_hash = self.running_query_text_hash.write();
+                *running_query_hash = Some(text_hash);
+            }
         }
 
         {
-            let mut running_query_parameterized_hash =
-                self.running_query_parameterized_hash.write();
-            *running_query_parameterized_hash = Some(parameterized_hash);
+            if self.get_query_parameterized_hash().is_empty() {
+                let mut running_query_parameterized_hash =
+                    self.running_query_parameterized_hash.write();
+                *running_query_parameterized_hash = Some(parameterized_hash);
+            }
         }
     }
 

tests/logging/check_logs_table.sh

@@ -15,6 +15,7 @@ function check_query_log() {
     full_sql_query+=" query_id = '$query_id'"
   fi
 
+  echo $full_sql_query
   response=$(curl -s -u root: -XPOST "http://localhost:8000/v1/query" \
     -H 'Content-Type: application/json' \
     -d "{\"sql\": \"$full_sql_query\"}")
@@ -39,6 +40,9 @@ response=$(curl -s -u root: -XPOST "http://localhost:8000/v1/query" -H 'Content-
 response=$(curl -s -u root: -XPOST "http://localhost:8000/v1/query" -H 'Content-Type: application/json' -d '{"sql": "create table t (a INT)"}')
 create_query_id=$(echo $response | jq -r '.id')
 echo "Create Query ID: $create_query_id"
+response=$(curl -s -u root: -XPOST "http://localhost:8000/v1/query" -H 'Content-Type: application/json' -d '{"sql": "create view v as select a from t"}')
+create_view_query_id=$(echo $response | jq -r '.id')
+echo "Create VIEW Query ID: $create_view_query_id"
 response=$(curl -s -u root: -XPOST "http://localhost:8000/v1/query" -H 'Content-Type: application/json' -d '{"sql": "insert into t values (1),(2),(3)"}')
 insert_query_id=$(echo $response | jq -r '.id')
 echo "Insert Query ID: $insert_query_id"
@@ -63,8 +67,6 @@ check_query_log "basic-3" "$query_id" "SELECT count(*) FROM system_history.log_h
 # Test 4
 check_query_log "basic-4" "$query_id" "SELECT count(*) FROM system_history.query_history WHERE" "1"
 
-# Test 5
-check_query_log "basic-5" "$select_query_id" "SELECT count(*) FROM system_history.log_history WHERE target = 'databend::log::access' and" "1"
 
 # Test 6
 check_query_log "basic-6" "$select_query_id" "SELECT count(*) FROM system_history.access_history WHERE" "1"
@@ -78,7 +80,8 @@ check_query_log "basic-8" "$insert_query_id" "SELECT objects_modified[0]['object
 # Test 9
 check_query_log "basic-9" "$select_query_id" "SELECT base_objects_accessed[0]['object_name'] FROM system_history.access_history WHERE" "default.default.t"
 
-
+# Test 10
+check_query_log "basic-10" $create_view_query_id "select query_text from system_history.query_history where" "CREATE VIEW v AS SELECT a FROM t"
 
 # Check timezone, regression test for https://github.com/databendlabs/databend/pull/18059
 check_query_log "t-1" "$select_query_id" "settings (timezone='Asia/Shanghai') SELECT DATE_DIFF(hour, timestamp, now()) FROM system_history.log_history WHERE target = 'databend::log::profile' and" "0"