Merge branch 'main' into fix_440

cli/src/session.rs

@@ -92,8 +92,8 @@ impl Session {
                 let rows = conn.query_iter(PROMPT_SQL).await;
                 match rows {
                     Ok(mut rows) => {
-                        while let Some(row) = rows.next().await {
-                            let name: (String,) = row.unwrap().try_into().unwrap();
+                        while let Some(Ok(row)) = rows.next().await {
+                            let name: (String,) = row.try_into().unwrap();
                             keywords.push(name.0);
                         }
                     }

cli/tests/http/05-stream.result

@@ -0,0 +1 @@
+1

cli/tests/http/05-stream.sh

@@ -0,0 +1,27 @@
+#!/bin/bash
+## uncomment these when QUERY_DATABEND_ENTERPRISE_LICENSE env is set 
+
+# cat <<SQL | ${BENDSQL}
+# CREATE DATABASE IF NOT EXISTS stream_test;
+
+# CREATE OR REPLACE TABLE stream_test.abc
+# (
+#     title VARCHAR,
+#     author VARCHAR,
+#     date VARCHAR
+# );
+
+# CREATE OR REPLACE STREAM stream_test.s on table stream_test.abc;
+# SQL
+
+# cat <<SQL | ${BENDSQL} -D stream_test
+# DROP TABLE abc
+# SQL
+
+cat <<SQL | ${BENDSQL} -D stream_test
+select 1;
+SQL
+
+cat <<SQL | ${BENDSQL}
+DROP DATABASE IF EXISTS stream_test;
+SQL

sql/Cargo.toml

@@ -17,7 +17,7 @@ flight-sql = ["dep:arrow-array", "dep:arrow-schema", "dep:tonic"]
 databend-client = { workspace = true }
 
 chrono = { version = "0.4.35", default-features = false }
-geozero = { version = "0.12", features = ["default", "with-wkb"] }
+geozero = { version = "0.13", features = ["default", "with-wkb"] }
 glob = "0.3"
 itertools = "0.12"
 jsonb = "0.4"