chore: revert "fix: fix memory_size of sliced string view. (#19014)" (#19051)

youngsofun · web-flow · commit 96c2f82f79b7 · 2025-12-03T16:35:06.000+08:00
* Revert "fix: fix memory_size of sliced string view. (#19014)" This reverts commit 8b4a558. * simplify tests. * simplify tests. * simplify tests.
diff --git a/src/common/column/src/binview/mod.rs b/src/common/column/src/binview/mod.rs
@@ -297,8 +297,7 @@ impl<T: ViewType + ?Sized> BinaryViewColumnGeneric<T> {
     }
 
     pub fn memory_size(&self) -> usize {
-        // when read back from parquet, the buffer is a bytes array without views
-        self.total_bytes_len + self.len() * 20
+        self.total_buffer_len + self.len() * 16
     }
 
     fn total_unshared_buffer_len(&self) -> usize {
diff --git a/src/common/column/tests/it/binview/mod.rs b/src/common/column/tests/it/binview/mod.rs
@@ -151,30 +151,15 @@ fn test_slice() {
     ];
 
     let array: Utf8ViewColumn = data.into_iter().collect();
-    assert_eq!(array.total_bytes_len(), 78);
-    assert_eq!(array.total_buffer_len(), 60);
-    assert_eq!(array.memory_size(), 198);
+    assert_eq!(array.memory_size(), 156);
 
-    let a0 = array.clone().sliced(0, 2);
-    assert_eq!(a0.into_iter().collect::<Vec<_>>(), vec!["hello", "world",]);
-    assert_eq!(a0.memory_size(), 50);
-    assert_eq!(a0.total_bytes_len(), 10);
-
-    let a1 = array.clone().sliced(2, 3);
-    assert_eq!(a1.into_iter().collect::<Vec<_>>(), vec![
+    let a3 = array.sliced(2, 3);
+    assert_eq!(a3.into_iter().collect::<Vec<_>>(), vec![
         "databend",
         "yyyyyyyyyyyyyyyyyyyyy",
         "zzzzzzzzzzzzzzzzzzzzz",
     ]);
-    assert_eq!(a1.memory_size(), 110);
-    assert_eq!(a1.total_bytes_len(), 50);
-
-    let a2 = array.sliced(5, 1);
-    assert_eq!(a2.into_iter().collect::<Vec<_>>(), vec![
-        "abcabcabcabcabcabc",
-    ]);
-    assert_eq!(a2.memory_size(), 38);
-    assert_eq!(a2.total_bytes_len(), 18);
+    assert_eq!(a3.memory_size(), 108);
 }
 
 #[test]
diff --git a/src/query/expression/src/values.rs b/src/query/expression/src/values.rs
@@ -892,7 +892,7 @@ impl ScalarRef<'_> {
             ScalarRef::Decimal(_) => n * self.memory_size(),
             ScalarRef::Boolean(_) => n.div_ceil(8),
             ScalarRef::Binary(s) => s.len() * n + (n + 1) * 8,
-            ScalarRef::String(s) => n * (20 + s.len()),
+            ScalarRef::String(s) => n * 16 + if s.len() > 12 && n > 0 { s.len() } else { 0 },
             ScalarRef::Timestamp(_) => n * 8,
             ScalarRef::TimestampTz(_) => n * 16,
             ScalarRef::Date(_) => n * 4,
diff --git a/src/query/expression/tests/it/block.rs b/src/query/expression/tests/it/block.rs
@@ -90,7 +90,7 @@ fn test_block_entry_memory_size() {
     assert_eq!(3, entry.memory_size());
 
     let col = StringType::from_data((0..10).map(|x| x.to_string()).collect::<Vec<_>>());
-    assert_eq!(col.memory_size(), 210);
+    assert_eq!(col.memory_size(), 10 * 16);
 
     let array = ArrayColumn::<Int64Type>::new(
         Buffer::from_iter(0..10i64),
diff --git a/tests/nox/python_client/test_local.py b/tests/nox/python_client/test_local.py
@@ -61,7 +61,7 @@ def test_stream_load():
     ]
     progress = conn.stream_load("INSERT INTO test VALUES", values)
     assert progress.write_rows == 3, f"progress.write_rows: {progress.write_rows}"
-    # assert progress.write_bytes >= 242, f"progress.write_bytes: {progress.write_bytes}"
+    # assert progress.write_bytes == 211, f"progress.write_bytes: {progress.write_bytes}"
 
     rows = conn.query_iter("SELECT * FROM test")
     ret = [row.values() for row in rows]
diff --git a/tests/sqllogictests/suites/base/09_fuse_engine/09_0020_analyze.test b/tests/sqllogictests/suites/base/09_fuse_engine/09_0020_analyze.test
@@ -161,7 +161,7 @@ query T
 select * from fuse_statistic('db_09_0020', 't_string') order by column_name asc;
 ----
 id 10 0 4 [bucket id: 0, min: "1", max: "1", ndv: 1.0, count: 1.0], [bucket id: 1, min: "2", max: "2", ndv: 1.0, count: 1.0], [bucket id: 2, min: "3", max: "3", ndv: 1.0, count: 1.0], [bucket id: 3, min: "4", max: "4", ndv: 1.0, count: 1.0], [bucket id: 4, min: "5", max: "5", ndv: 1.0, count: 1.0], [bucket id: 5, min: "6", max: "6", ndv: 1.0, count: 1.0], [bucket id: 6, min: "7", max: "7", ndv: 1.0, count: 1.0], [bucket id: 7, min: "8", max: "8", ndv: 1.0, count: 1.0], [bucket id: 8, min: "9", max: "9", ndv: 1.0, count: 1.0], [bucket id: 9, min: "10", max: "10", ndv: 1.0, count: 1.0]
-str_val 10 0 23 [bucket id: 0, min: "1.0", max: "1.0", ndv: 1.0, count: 1.0], [bucket id: 1, min: "10.0", max: "10.0", ndv: 1.0, count: 1.0], [bucket id: 2, min: "2.0", max: "2.0", ndv: 1.0, count: 1.0], [bucket id: 3, min: "3.0", max: "3.0", ndv: 1.0, count: 1.0], [bucket id: 4, min: "4.0", max: "4.0", ndv: 1.0, count: 1.0], [bucket id: 5, min: "5.0", max: "5.0", ndv: 1.0, count: 1.0], [bucket id: 6, min: "6.0", max: "6.0", ndv: 1.0, count: 1.0], [bucket id: 7, min: "7.0", max: "7.0", ndv: 1.0, count: 1.0], [bucket id: 8, min: "8.0", max: "8.0", ndv: 1.0, count: 1.0], [bucket id: 9, min: "9.0", max: "9.0", ndv: 1.0, count: 1.0]
+str_val 10 0 16 [bucket id: 0, min: "1.0", max: "1.0", ndv: 1.0, count: 1.0], [bucket id: 1, min: "10.0", max: "10.0", ndv: 1.0, count: 1.0], [bucket id: 2, min: "2.0", max: "2.0", ndv: 1.0, count: 1.0], [bucket id: 3, min: "3.0", max: "3.0", ndv: 1.0, count: 1.0], [bucket id: 4, min: "4.0", max: "4.0", ndv: 1.0, count: 1.0], [bucket id: 5, min: "5.0", max: "5.0", ndv: 1.0, count: 1.0], [bucket id: 6, min: "6.0", max: "6.0", ndv: 1.0, count: 1.0], [bucket id: 7, min: "7.0", max: "7.0", ndv: 1.0, count: 1.0], [bucket id: 8, min: "8.0", max: "8.0", ndv: 1.0, count: 1.0], [bucket id: 9, min: "9.0", max: "9.0", ndv: 1.0, count: 1.0]
 
 # Test string comparison with histogram
 query I
diff --git a/tests/sqllogictests/suites/base/09_fuse_engine/09_0044_issue_17314.test b/tests/sqllogictests/suites/base/09_fuse_engine/09_0044_issue_17314.test
@@ -37,8 +37,8 @@ analyze table t1;
 query IIT
 select * from fuse_statistic('issue_17314', 't1') order by column_name;
 ----
-a 3 0 22 [bucket id: 0, min: "1", max: "1", ndv: 1.0, count: 1.0], [bucket id: 1, min: "2", max: "2", ndv: 1.0, count: 1.0], [bucket id: 2, min: "3", max: "3", ndv: 1.0, count: 1.0]
-b 3 0 23 [bucket id: 0, min: "11", max: "11", ndv: 1.0, count: 1.0], [bucket id: 1, min: "22", max: "22", ndv: 1.0, count: 1.0], [bucket id: 2, min: "33", max: "33", ndv: 1.0, count: 1.0]
+a 3 0 17 [bucket id: 0, min: "1", max: "1", ndv: 1.0, count: 1.0], [bucket id: 1, min: "2", max: "2", ndv: 1.0, count: 1.0], [bucket id: 2, min: "3", max: "3", ndv: 1.0, count: 1.0]
+b 3 0 17 [bucket id: 0, min: "11", max: "11", ndv: 1.0, count: 1.0], [bucket id: 1, min: "22", max: "22", ndv: 1.0, count: 1.0], [bucket id: 2, min: "33", max: "33", ndv: 1.0, count: 1.0]
 
 statement ok
 drop table t1 all;
diff --git a/tests/sqllogictests/suites/base/20+_others/20_0013_query_result_cache.test b/tests/sqllogictests/suites/base/20+_others/20_0013_query_result_cache.test
@@ -89,7 +89,7 @@ EXPLAIN SELECT * FROM t1, t2 ORDER BY a, b;
 ReadQueryResultCache
 ├── SQL: SELECT * FROM t1, t2 ORDER BY a, b
 ├── Number of rows: 9
-└── Result size: 225
+└── Result size: 180
 
 
 
diff --git a/tests/sqllogictests/suites/ee/01_ee_system/01_0002_virtual_column.test b/tests/sqllogictests/suites/ee/01_ee_system/01_0002_virtual_column.test
@@ -326,26 +326,26 @@ query TIIIT
 select * from fuse_statistic('test_virtual_column', 'tweets');
 ----
 id 10 0 4 (empty)
-data['create'] 10 0 24 (empty)
+data['create'] 10 0 16 (empty)
 data['id'] 10 0 8 (empty)
 data['replies'] 7 3 8 (empty)
-data['text'] 7 0 21 (empty)
+data['text'] 7 0 16 (empty)
 data['user']['id'] 6 0 8 (empty)
 data['likes'] 2 0 1 (empty)
-data['tags'][0] 2 0 4 (empty)
-data['tags'][1] 2 0 5 (empty)
+data['tags'][0] 2 0 3 (empty)
+data['tags'][1] 2 0 3 (empty)
 
 query TTTIIIITTIT
 SHOW STATISTICS FROM TABLE test_virtual_column.tweets;
 ----
 test_virtual_column tweets data 10 10 NULL NULL NULL NULL NULL (empty)
-test_virtual_column tweets data['create'] 10 10 10 0 1/08 6/07 24 (empty)
+test_virtual_column tweets data['create'] 10 10 10 0 1/08 6/07 16 (empty)
 test_virtual_column tweets data['id'] 10 10 10 0 1 10 8 (empty)
 test_virtual_column tweets data['likes'] 10 10 2 0 10 25 1 (empty)
 test_virtual_column tweets data['replies'] 10 10 7 3 0 9 8 (empty)
-test_virtual_column tweets data['tags'][0] 10 10 2 0 good new 4 (empty)
-test_virtual_column tweets data['tags'][1] 10 10 2 0 interesting popular 5 (empty)
-test_virtual_column tweets data['text'] 10 10 7 0 a z 21 (empty)
+test_virtual_column tweets data['tags'][0] 10 10 2 0 good new 3 (empty)
+test_virtual_column tweets data['tags'][1] 10 10 2 0 interesting popular 3 (empty)
+test_virtual_column tweets data['text'] 10 10 7 0 a z 16 (empty)
 test_virtual_column tweets data['user']['id'] 10 10 6 0 1 7 8 (empty)
 test_virtual_column tweets id 10 10 10 0 1 10 4 (empty)
 
@@ -357,20 +357,20 @@ query TIIIT
 select * from fuse_statistic('test_virtual_column', 'tweets');
 ----
 id 10 0 4 (empty)
-data['create'] 10 0 24 (empty)
+data['create'] 10 0 16 (empty)
 data['id'] 10 0 8 (empty)
 data['replies'] 7 3 8 (empty)
-data['text'] 8 0 21 (empty)
+data['text'] 8 0 16 (empty)
 data['user']['id'] 4 0 8 (empty)
 
 query TTTIIIITTIT
 SHOW STATISTICS FROM TABLE test_virtual_column.tweets;
 ----
 test_virtual_column tweets data 10 10 NULL NULL NULL NULL NULL (empty)
-test_virtual_column tweets data['create'] 10 10 10 0 1/08 6/07 24 (empty)
+test_virtual_column tweets data['create'] 10 10 10 0 1/08 6/07 16 (empty)
 test_virtual_column tweets data['id'] 10 10 10 0 1 10 8 (empty)
 test_virtual_column tweets data['replies'] 10 10 7 3 0 10 8 (empty)
-test_virtual_column tweets data['text'] 10 10 8 0 a z 21 (empty)
+test_virtual_column tweets data['text'] 10 10 8 0 a z 16 (empty)
 test_virtual_column tweets data['user']['id'] 10 10 4 0 1 7 8 (empty)
 test_virtual_column tweets id 10 10 10 0 1 10 4 (empty)
 
diff --git a/tests/sqllogictests/suites/mode/standalone/explain/index/explain_ngram_index.test b/tests/sqllogictests/suites/mode/standalone/explain/index/explain_ngram_index.test
@@ -319,8 +319,8 @@ INSERT INTO t3 VALUES
 query II
 select block_size, bloom_filter_size, ngram_index_size from fuse_block('test_ngram_index_db', 't3');
 ----
-225 894 NULL
-256 894 NULL
+209 894 NULL
+240 894 NULL
 
 statement ok
 CREATE NGRAM INDEX idx1 ON t3(content1, content2) gram_size = 5 bloom_size = 1048576
@@ -331,8 +331,8 @@ REFRESH NGRAM INDEX idx1 ON t3
 query III
 select block_size, bloom_filter_size, ngram_index_size from fuse_block('test_ngram_index_db', 't3');
 ----
-225 2098570 2097234
-256 2098570 2097234
+209 2098570 2097234
+240 2098570 2097234
 
 query ITT
 SELECT * FROM t3 WHERE content1 like '%speak%'
diff --git a/tests/suites/1_stateful/01_streaming_load/01_0006_streaming_load_parquet.result b/tests/suites/1_stateful/01_streaming_load/01_0006_streaming_load_parquet.result
@@ -5,7 +5,7 @@
 q1.parquet	637	1
 >>>> streaming load: q1.parquet error :
 + curl -sS -H x-databend-query-id:load-q1 -H 'X-Databend-SQL:insert into streaming_load_parquet(c2,c3) from @_databend_load file_format = (type='\''parquet'\'', missing_field_as=error, null_if=())' -F upload=@/tmp/streaming_load_parquet/q1.parquet -u root: -XPUT http://localhost:8000/v1/streaming_load
-{"id":"load-q1","stats":{"rows":1,"bytes":33}}
+{"id":"load-q1","stats":{"rows":1,"bytes":27}}
 <<<<
 >>>> select * from streaming_load_parquet;
 ok	1	2021-01-01
@@ -26,7 +26,7 @@ q2.parquet	431	1
 q3.parquet	431	1
 >>>> streaming load: q3.parquet field_default :
 + curl -sS -H x-databend-query-id:load-q3 -H 'X-Databend-SQL:insert into streaming_load_parquet(c2,c3) from @_databend_load file_format = (type='\''parquet'\'', missing_field_as=field_default, null_if=())' -F upload=@/tmp/streaming_load_parquet/q3.parquet -u root: -XPUT http://localhost:8000/v1/streaming_load
-{"id":"load-q3","stats":{"rows":1,"bytes":29}}
+{"id":"load-q3","stats":{"rows":1,"bytes":23}}
 <<<<
 >>>> select * from streaming_load_parquet;
 ok	NULL	2021-01-01
diff --git a/tests/suites/1_stateful/01_streaming_load/01_0007_streaming_load_placeholder.result b/tests/suites/1_stateful/01_streaming_load/01_0007_streaming_load_placeholder.result
@@ -4,7 +4,7 @@
 >>>> copy into @streaming_load_07/data.csv from (select '2020-01-02' as c4, 110 as c2) file_format=(type='csv')  single=true include_query_id=false use_raw_path=true detailed_output=true overwrite=true;
 data.csv	17	1
 + curl -sS -H x-databend-query-id:load-csv -H 'X-Databend-SQL:insert into streaming_load_07(c3, c4, c2) values ('\''a'\'', ?, ?) from @_databend_load file_format = (type=csv)' -F upload=@/tmp/streaming_load_07/data.csv -u root: -XPUT http://localhost:8000/v1/streaming_load
-{"id":"load-csv","stats":{"rows":1,"bytes":55}}
+{"id":"load-csv","stats":{"rows":1,"bytes":44}}
 <<<<
 >>>> select * from streaming_load_07;
 ok	110	a	2020-01-02
@@ -14,7 +14,7 @@ ok	110	a	2020-01-02
 >>>> copy into @streaming_load_07/data.tsv from (select '2020-01-02' as c4, 110 as c2) file_format=(type='tsv')  single=true include_query_id=false use_raw_path=true detailed_output=true overwrite=true;
 data.tsv	15	1
 + curl -sS -H x-databend-query-id:load-tsv -H 'X-Databend-SQL:insert into streaming_load_07(c3, c4, c2) values ('\''a'\'', ?, ?) from @_databend_load file_format = (type=tsv)' -F upload=@/tmp/streaming_load_07/data.tsv -u root: -XPUT http://localhost:8000/v1/streaming_load
-{"id":"load-tsv","stats":{"rows":1,"bytes":55}}
+{"id":"load-tsv","stats":{"rows":1,"bytes":44}}
 <<<<
 >>>> select * from streaming_load_07;
 ok	110	a	2020-01-02
@@ -24,7 +24,7 @@ ok	110	a	2020-01-02
 >>>> copy into @streaming_load_07/data.ndjson from (select '2020-01-02' as c4, 110 as c2) file_format=(type='ndjson')  single=true include_query_id=false use_raw_path=true detailed_output=true overwrite=true;
 data.ndjson	29	1
 + curl -sS -H x-databend-query-id:load-ndjson -H 'X-Databend-SQL:insert into streaming_load_07(c3, c4, c2) values ('\''a'\'', ?, ?) from @_databend_load file_format = (type=ndjson)' -F upload=@/tmp/streaming_load_07/data.ndjson -u root: -XPUT http://localhost:8000/v1/streaming_load
-{"id":"load-ndjson","stats":{"rows":1,"bytes":55}}
+{"id":"load-ndjson","stats":{"rows":1,"bytes":44}}
 <<<<
 >>>> select * from streaming_load_07;
 ok	110	a	2020-01-02
@@ -34,7 +34,7 @@ ok	110	a	2020-01-02
 >>>> copy into @streaming_load_07/data.parquet from (select '2020-01-02' as c4, 110 as c2) file_format=(type='parquet')  single=true include_query_id=false use_raw_path=true detailed_output=true overwrite=true;
 data.parquet	678	1
 + curl -sS -H x-databend-query-id:load-parquet -H 'X-Databend-SQL:insert into streaming_load_07(c3, c4, c2) values ('\''a'\'', ?, ?) from @_databend_load file_format = (type=parquet)' -F upload=@/tmp/streaming_load_07/data.parquet -u root: -XPUT http://localhost:8000/v1/streaming_load
-{"id":"load-parquet","stats":{"rows":1,"bytes":55}}
+{"id":"load-parquet","stats":{"rows":1,"bytes":44}}
 <<<<
 >>>> select * from streaming_load_07;
 ok	110	a	2020-01-02
diff --git a/tests/suites/1_stateful/01_streaming_load/01_0008_streaming_load_session.result b/tests/suites/1_stateful/01_streaming_load/01_0008_streaming_load_session.result
@@ -3,5 +3,5 @@
 >>>> copy into @streaming_load_08/data.csv from (select '2020-01-02', 110) file_format=(type=csv)  single=true include_query_id=false use_raw_path=true detailed_output=true overwrite=true;
 data.csv	17	1
 {"need_sticky":false,"need_keep_alive":false,"internal":"{\"last_query_ids\":[\"load-csv\"]}"}
-{"id":"load-csv","stats":{"rows":1,"bytes":36}}
-{"id":"load-csv","stats":{"rows":1,"bytes":36}}
+{"id":"load-csv","stats":{"rows":1,"bytes":22}}
+{"id":"load-csv","stats":{"rows":1,"bytes":22}}
diff --git a/tests/suites/1_stateful/05_formats/05_05_parquet/05_05_01_parquet_load_unload.result b/tests/suites/1_stateful/05_formats/05_05_parquet/05_05_01_parquet_load_unload.result
@@ -29,14 +29,14 @@ a"b	1	['a"b']	{"k":"v"}	2044-05-06 10:25:02.868894	10.01	('a',5)	['{"k":"v"}']	[
 NULL	2	['a'b']	[1]	2044-05-06 10:25:02.868894	-10.01	('b',10)	['[1]']	[('b',10)]
 <<<<
 >>>> copy into @s1/unload1/ from test_load_unload
-2	410
+2	406
 >>>> truncate table test_load_unload
 >>>> copy into test_load_unload from @s1/unload1.parquet force=true;
 unload1.parquet	2	0	NULL	NULL
 begin diff select
 end diff
 >>>> copy into @s1/unload2/ from test_load_unload
-2	410
+2	406
 begin diff parquet
 end diff
 >>>> truncate table test_load_unload
diff --git a/tests/suites/1_stateful/07_stage_attachment/07_0001_replace_with_stage.sh b/tests/suites/1_stateful/07_stage_attachment/07_0001_replace_with_stage.sh
@@ -24,7 +24,7 @@ echo "CREATE STAGE s1 FILE_FORMAT = (TYPE = CSV)" | $BENDSQL_CLIENT_CONNECT
 echo "list @s1" | $BENDSQL_CLIENT_CONNECT | awk '{print $1}'
 
 ## Insert with stage use http API
-curl -s -u root: -XPOST "http://localhost:${QUERY_HTTP_HANDLER_PORT}/v1/query" --header 'Content-Type: application/json' -d '{"sql": "replace into sample_table (Id, City, Score) ON(Id) VALUES", "stage_attachment": {"location": "@s1/sample.csv", "copy_options": {"purge": "true"}}, "pagination": { "wait_time_secs": 3}}' | jq -r '.stats.scan_progress.bytes, .error'
+curl -s -u root: -XPOST "http://localhost:${QUERY_HTTP_HANDLER_PORT}/v1/query" --header 'Content-Type: application/json' -d '{"sql": "replace into sample_table (Id, City, Score) ON(Id) VALUES", "stage_attachment": {"location": "@s1/sample.csv", "copy_options": {"purge": "true"}}, "pagination": { "wait_time_secs": 3}}' | jq -r '.stats.scan_progress.bytes,.error'
 
 ## list stage has metacache, so we just we aws client to ensure the data are purged
 aws --endpoint-url ${STORAGE_S3_ENDPOINT_URL} s3 ls s3://testbucket/admin/stage/internal/s1/sample.csv
diff --git a/tests/suites/1_stateful/07_stage_attachment/07_0002_insert_with_stage_deduplicate.sh b/tests/suites/1_stateful/07_stage_attachment/07_0002_insert_with_stage_deduplicate.sh
@@ -51,7 +51,7 @@ curl -s -u root: -XPOST "http://localhost:${QUERY_HTTP_HANDLER_PORT}/v1/query" \
     "pagination": {
       "wait_time_secs": 3
     }
-  }' | jq -r '.stats.scan_progress.bytes,  .error'
+  }' | jq -r '.stats.scan_progress.bytes, .error'
 
 
 echo "select * from sample_table" | $BENDSQL_CLIENT_CONNECT

Original file line number	Diff line number	Diff line change
`@@ -297,8 +297,7 @@ impl<T: ViewType + ?Sized> BinaryViewColumnGeneric<T> {`
`297`	`297`	`}`
`298`	`298`
`299`	`299`	`pub fn memory_size(&self) -> usize {`
`300`		`- // when read back from parquet, the buffer is a bytes array without views`
`301`		`- self.total_bytes_len + self.len() * 20`
	`300`	`+ self.total_buffer_len + self.len() * 16`
`302`	`301`	`}`
`303`	`302`
`304`	`303`	`fn total_unshared_buffer_len(&self) -> usize {`
Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ def test_stream_load():`
`61`	`61`	`]`
`62`	`62`	`progress = conn.stream_load("INSERT INTO test VALUES", values)`
`63`	`63`	`assert progress.write_rows == 3, f"progress.write_rows: {progress.write_rows}"`
`64`		`- # assert progress.write_bytes >= 242, f"progress.write_bytes: {progress.write_bytes}"`
	`64`	`+ # assert progress.write_bytes == 211, f"progress.write_bytes: {progress.write_bytes}"`
`65`	`65`
`66`	`66`	`rows = conn.query_iter("SELECT * FROM test")`
`67`	`67`	`ret = [row.values() for row in rows]`