@@ -687,11 +687,7 @@ impl Statement {
687687 rt. block_on ( async move {
688688 let mut stmt = stmt. lock ( ) . await ;
689689 stmt. reset ( ) ;
690- if let Some ( params) = params {
691- map_params ( & stmt, Some ( params) ) . unwrap ( )
692- } else {
693- libsql:: params:: Params :: None
694- }
690+ map_params ( & stmt, params) . unwrap ( )
695691 } )
696692 } ;
697693 let stmt = self . stmt . clone ( ) ;
@@ -725,11 +721,7 @@ impl Statement {
725721 let ( rows, column_names) = rt. block_on ( async move {
726722 let mut stmt = stmt. lock ( ) . await ;
727723 stmt. reset ( ) ;
728- let params = if let Some ( params) = params {
729- map_params ( & stmt, Some ( params) ) . unwrap ( )
730- } else {
731- libsql:: params:: Params :: None
732- } ;
724+ let params = map_params ( & stmt, params) ?;
733725 let rows = stmt. query ( params) . await . map_err ( Error :: from) ?;
734726 let mut column_names = Vec :: new ( ) ;
735727 for i in 0 ..rows. column_count ( ) {
@@ -759,11 +751,7 @@ impl Statement {
759751
760752 let mut stmt = self . stmt . lock ( ) . await ;
761753 stmt. reset ( ) ;
762- let params = if let Some ( params) = params {
763- map_params ( & stmt, Some ( params) ) ?
764- } else {
765- libsql:: params:: Params :: None
766- } ;
754+ let params = map_params ( & stmt, params) ?;
767755 stmt. query ( params) . await . map_err ( Error :: from) ?;
768756 let changes = if conn. total_changes ( ) == total_changes_before {
769757 0
@@ -816,11 +804,7 @@ impl Statement {
816804 rt. block_on ( async move {
817805 let mut stmt = self . stmt . lock ( ) . await ;
818806 stmt. reset ( ) ;
819- let params = if let Some ( params) = params {
820- map_params ( & stmt, Some ( params) ) ?
821- } else {
822- libsql:: params:: Params :: None
823- } ;
807+ let params = map_params ( & stmt, params) ?;
824808 let mut rows = stmt. query ( params) . await . map_err ( Error :: from) ?;
825809 let mut column_names = Vec :: new ( ) ;
826810 for i in 0 ..rows. column_count ( ) {
0 commit comments