chore: Update vendored sources to duckdb/duckdb@4a788da

Merge pull request duckdb/duckdb#9802 from Giorgi/master Merge pull request duckdb/duckdb#9811 from Tishj/pandas_analyzer_skip_nulls Merge pull request duckdb/duckdb#9827 from Mytherin/cifix Merge pull request duckdb/duckdb#9826 from carlopi/verboseerror
duckdb · Dec 14, 2023 · fa088ce · fa088ce
1 parent 0f153df
commit fa088ce
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 2 deletions.
diff --git a/src/duckdb/src/function/table/version/pragma_version.cpp b/src/duckdb/src/function/table/version/pragma_version.cpp
@@ -1,8 +1,8 @@
 #ifndef DUCKDB_VERSION
-#define DUCKDB_VERSION "v0.9.3-dev923"
+#define DUCKDB_VERSION "v0.9.3-dev933"
 #endif
 #ifndef DUCKDB_SOURCE_ID
-#define DUCKDB_SOURCE_ID "e2e2897cbd"
+#define DUCKDB_SOURCE_ID "4a788da69f"
 #endif
 #include "duckdb/function/table/system_functions.hpp"
 #include "duckdb/main/database.hpp"

diff --git a/src/duckdb/src/include/duckdb.h b/src/duckdb/src/include/duckdb.h
@@ -1172,6 +1172,19 @@ between calls to this function.
 DUCKDB_API duckdb_state duckdb_execute_prepared(duckdb_prepared_statement prepared_statement,
                                                 duckdb_result *out_result);
 
+/*!
+Executes the prepared statement with the given bound parameters, and returns a streaming query result.
+
+This method can be called multiple times for each prepared statement, and the parameters can be modified
+between calls to this function.
+
+* prepared_statement: The prepared statement to execute.
+* out_result: The query result.
+* returns: `DuckDBSuccess` on success or `DuckDBError` on failure.
+*/
+DUCKDB_API duckdb_state duckdb_execute_prepared_streaming(duckdb_prepared_statement prepared_statement,
+                                                          duckdb_result *out_result);
+
 /*!
 Executes the prepared statement with the given bound parameters, and returns an arrow query result.
 

diff --git a/src/duckdb/src/main/capi/prepared-c.cpp b/src/duckdb/src/main/capi/prepared-c.cpp
@@ -320,6 +320,17 @@ duckdb_state duckdb_execute_prepared(duckdb_prepared_statement prepared_statemen
 	return duckdb_translate_result(std::move(result), out_result);
 }
 
+duckdb_state duckdb_execute_prepared_streaming(duckdb_prepared_statement prepared_statement,
+                                               duckdb_result *out_result) {
+	auto wrapper = reinterpret_cast<PreparedStatementWrapper *>(prepared_statement);
+	if (!wrapper || !wrapper->statement || wrapper->statement->HasError()) {
+		return DuckDBError;
+	}
+
+	auto result = wrapper->statement->Execute(wrapper->values, true);
+	return duckdb_translate_result(std::move(result), out_result);
+}
+
 duckdb_statement_type duckdb_prepared_statement_type(duckdb_prepared_statement statement) {
 	if (!statement) {
 		return DUCKDB_STATEMENT_TYPE_INVALID;