fix: file not purged when copy into table. (#13812)

fix: file not purge when copy into table.

src/query/storages/fuse/src/io/files.rs

@@ -69,6 +69,12 @@ impl Files {
 
     #[async_backtrace::framed]
     async fn delete_files(op: Operator, locations: Vec<String>) -> Result<()> {
+        // temporary fix for https://github.com/datafuselabs/databend/issues/13804
+        let locations = locations
+            .into_iter()
+            .map(|loc| loc.trim_start_matches('/').to_owned())
+            .filter(|loc| !loc.is_empty())
+            .collect::<Vec<_>>();
         info!("deleting files: {:?}", &locations);
         op.remove(locations).await?;
         Ok(())

tests/suites/1_stateful/00_stage/00_0002_copy_purge.result

@@ -0,0 +1,19 @@
+>>>> drop table if exists ii
+>>>> create table ii(a int, b int)
+>>>> drop stage if exists s_ii
+>>>> create stage s_ii url='fs:///tmp/00_0002/';
+>>>> copy into ii from @s_ii file_format = (type = CSV) purge = true
+<<<<
+>>>> list @s_ii
+<<<<
+>>>> select * from ii
+1	1
+2	2
+>>>> truncate table ii
+>>>> copy into ii from @s_ii file_format = (type = CSV) files = ('i1.csv') purge = true
+<<<<
+>>>> list @s_ii
+<<<<
+>>>> select * from ii
+1	1
+2	2

tests/suites/1_stateful/00_stage/00_0002_copy_purge.sh

@@ -0,0 +1,36 @@
+#!/usr/bin/env bash
+
+CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
+. "$CURDIR"/../../../shell_env.sh
+
+rm -rf /tmp/00_0002
+mkdir -p /tmp/00_0002
+cat << EOF > /tmp/00_0002/i0.csv
+1,1
+2,2
+EOF
+
+stmt "drop table if exists ii"
+stmt "create table ii(a int, b int)"
+
+stmt "drop stage if exists s_ii"
+stmt "create stage s_ii url='fs:///tmp/00_0002/';"
+
+query "copy into ii from @s_ii file_format = (type = CSV) purge = true"
+
+query "list @s_ii"
+
+stmt "select * from ii"
+
+stmt "truncate table ii"
+
+cat << EOF > /tmp/00_0002/i1.csv
+1,1
+2,2
+EOF
+
+query "copy into ii from @s_ii file_format = (type = CSV) files = ('i1.csv') purge = true"
+
+query "list @s_ii"
+
+stmt "select * from ii"