Fix Cursor.execute() for blob bind parameters

Fixes #69

Author: penberg

src/lib.rs

@@ -406,16 +406,17 @@ async fn execute(cursor: &Cursor, sql: String, parameters: Option<&PyTuple>) ->
     let params = match parameters {
         Some(parameters) => {
             let mut params = vec![];
-            for parameter in parameters.iter() {
-                let param = match parameter.extract::<i32>() {
-                    Ok(value) => libsql_core::Value::Integer(value as i64),
-                    Err(_) => match parameter.extract::<f64>() {
-                        Ok(value) => libsql_core::Value::Real(value),
-                        Err(_) => match parameter.extract::<&str>() {
-                            Ok(value) => libsql_core::Value::Text(value.to_string()),
-                            Err(_) => todo!(),
-                        },
-                    },
+            for param in parameters.iter() {
+                let param = if let Ok(value) = param.extract::<i32>() {
+                    libsql_core::Value::Integer(value as i64)
+                } else if let Ok(value) = param.extract::<f64>() {
+                    libsql_core::Value::Real(value)
+                } else if let Ok(value) = param.extract::<&str>() {
+                    libsql_core::Value::Text(value.to_string())
+                } else if let Ok(value) = param.extract::<&[u8]>() {
+                    libsql_core::Value::Blob(value.to_vec())
+                } else {
+                    return Err(PyValueError::new_err("Unsupported parameter type"));
                 };
                 params.push(param);
             }

tests/test_suite.py

@@ -66,6 +66,15 @@ def test_cursor_fetchmany(provider):
     assert [(5, 'erin@example.com')] == res.fetchmany(2)
     assert [] == res.fetchmany(2)
 
+@pytest.mark.parametrize("provider", ["sqlite", "libsql"])
+def test_cursor_execute_blob(provider):
+    conn = connect(provider, ":memory:")
+    cur = conn.cursor()
+    cur.execute("CREATE TABLE users (id INTEGER, data BLOB)")
+    cur.execute("INSERT INTO users VALUES (?, ?)", (1, b'foobar'))
+    res = cur.execute("SELECT * FROM users")
+    assert (1, b'foobar') == res.fetchone()
+
 @pytest.mark.parametrize("provider", ["libsql", "sqlite"])
 def test_cursor_executemany(provider):
     conn = connect(provider, ":memory:")