fix(session): fix PROMPT_SQL unwrap

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