make DoPutPreparedStatenentResult mandatory

apache · Mar 10, 2024 · e8067f7 · e8067f7
1 parent 8ba176e
commit e8067f7
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 24 deletions.
diff --git a/arrow-flight/examples/flight_sql_server.rs b/arrow-flight/examples/flight_sql_server.rs
@@ -620,7 +620,7 @@ impl FlightSqlService for FlightSqlServiceImpl {
         &self,
         _query: CommandPreparedStatementQuery,
         _request: Request<PeekableFlightDataStream>,
-    ) -> Result<Option<DoPutPreparedStatementResult>, Status> {
+    ) -> Result<DoPutPreparedStatementResult, Status> {
         Err(Status::unimplemented(
             "do_put_prepared_statement_query not implemented",
         ))

diff --git a/arrow-flight/src/sql/server.rs b/arrow-flight/src/sql/server.rs
@@ -399,15 +399,14 @@ pub trait FlightSqlService: Sync + Send + Sized + 'static {
 
     /// Bind parameters to given prepared statement.
     ///
-    /// Note that `DoPutPreparedStatementResult` contains an optional
-    /// opaque handle that the client should pass
+    /// Returns an opaque handle that the client should pass
     /// back to the server during subsequent requests with this
     /// prepared statement.
     async fn do_put_prepared_statement_query(
         &self,
         _query: CommandPreparedStatementQuery,
         _request: Request<PeekableFlightDataStream>,
-    ) -> Result<Option<DoPutPreparedStatementResult>, Status> {
+    ) -> Result<DoPutPreparedStatementResult, Status> {
         Err(Status::unimplemented(
             "do_put_prepared_statement_query has no default implementation",
         ))
@@ -715,19 +714,13 @@ where
                 Ok(Response::new(Box::pin(output)))
             }
             Command::CommandPreparedStatementQuery(command) => {
-                if let Some(result) = self
+                let result = self
                     .do_put_prepared_statement_query(command, request)
-                    .await?
-                {
-                    let output = futures::stream::iter(vec![Ok(PutResult {
-                        app_metadata: result.as_any().encode_to_vec().into(),
-                    })]);
-                    Ok(Response::new(Box::pin(output)))
-                } else {
-                    Ok(Response::new(
-                        futures::stream::once(async { Ok(PutResult::default()) }).boxed(),
-                    ))
-                }
+                    .await?;
+                let output = futures::stream::iter(vec![Ok(PutResult {
+                    app_metadata: result.as_any().encode_to_vec().into(),
+                })]);
+                Ok(Response::new(Box::pin(output)))
             }
             Command::CommandStatementSubstraitPlan(command) => {
                 let record_count = self.do_put_substrait_plan(command, request).await?;

diff --git a/arrow-flight/tests/flight_sql_client_cli.rs b/arrow-flight/tests/flight_sql_client_cli.rs
@@ -560,7 +560,7 @@ impl FlightSqlService for FlightSqlServiceImpl {
         &self,
         _query: CommandPreparedStatementQuery,
         request: Request<PeekableFlightDataStream>,
-    ) -> Result<Option<DoPutPreparedStatementResult>, Status> {
+    ) -> Result<DoPutPreparedStatementResult, Status> {
         // just make sure decoding the parameters works
         let parameters = FlightRecordBatchStream::new_from_flight_data(
             request.into_inner().map_err(|e| e.into()),
@@ -579,14 +579,15 @@ impl FlightSqlService for FlightSqlServiceImpl {
                 )));
             }
         }
-        if self.stateless_prepared_statements {
-            let result = DoPutPreparedStatementResult {
-                prepared_statement_handle: UPDATED_PREPARED_STATEMENT_HANDLE.to_string().into(),
-            };
-            Ok(Some(result))
+        let prepared_statement_handle = if self.stateless_prepared_statements {
+            UPDATED_PREPARED_STATEMENT_HANDLE.to_string().into()
         } else {
-            Ok(None)
-        }
+            PREPARED_STATEMENT_HANDLE.to_string().into()
+        };
+        let result = DoPutPreparedStatementResult {
+            prepared_statement_handle,
+        };
+        Ok(result)
     }
 
     async fn do_put_prepared_statement_update(