duckdb-iceberg/test/sql/local/irc/insert/count_star_optimizer.test at d0016950d05ea9a3f92c1197c20c3532bc8b0c3a · duckdb/duckdb-iceberg · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
# name: test/sql/local/irc/insert/count_star_optimizer.test
# description: Test count star optimizer in an iceberg scan
# group: [insert]

require-env ICEBERG_SERVER_AVAILABLE

require avro

require parquet

require iceberg

require httpfs

# Do not ignore 'HTTP' error messages!
set ignore_error_messages

statement ok
set enable_logging=true

statement ok
set logging_level='debug'

statement ok
CREATE SECRET (
    TYPE S3,
    KEY_ID 'admin',
    SECRET 'password',
    ENDPOINT '127.0.0.1:9000',
    URL_STYLE 'path',
    USE_SSL 0
);

statement ok
ATTACH '' AS my_datalake (
    TYPE ICEBERG,
    CLIENT_ID 'admin',
    CLIENT_SECRET 'password',
    ENDPOINT 'http://127.0.0.1:8181'
);

# use statistics information.
query II
explain SELECT count(*) FROM my_datalake.default.count_star_optimizer;
----
physical_plan	<REGEX>:.*COLUMN_DATA_SCAN.*~1.*


statement ok
BEGIN;

query I
select count(*) from my_datalake.default.count_star_optimizer;
----
2

statement ok
insert into my_datalake.default.count_star_optimizer select 3,'ccc';

query I
select count(*) from my_datalake.default.count_star_optimizer;
----
3

statement ok
ABORT;

statement ok
delete from my_datalake.default.count_star_optimizer where id = 1;

query I
select count(*) from my_datalake.default.count_star_optimizer;
----
1

# contain delete file, do not use the statistics information.
query II
explain SELECT count(*) FROM  my_datalake.default.count_star_optimizer;
----
physical_plan	<REGEX>:.*ICEBERG_SCAN.*rows.*