rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-15 09:22:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

More work on mapping params

Browse Source
This commit is contained in:
George MacKerron
2023-05-05 10:53:32 +01:00
parent cb88df7ffa
commit fdb9d4373d
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
proxy/src/http/websocket.rs
View File

@@ -323,16 +323,17 @@ async fn handle_sql(
}
});
// let sql = percent_decode(sql.as_bytes()).decode_utf8()?.to_string();
let query = &queryData.query;
let params = queryData.params.iter().map(|value| match value {
Value::Null => None as &(dyn ToSql + Sync),
Value::Bool(b) => b as &(dyn ToSql + Sync),
Value::Number(n) => &n.as_f64() as &(dyn ToSql + Sync),
Value::String(s) => s as &(dyn ToSql + Sync),
_ => panic!("wrong parameter type")
}).collect::<Vec<&(dyn ToSql + Sync)>>().as_ref();
let rows: Vec<HashMap<_, _>> = client
.query(&queryData.query, queryData.params.iter().map(|x| match x {
Value::Null => None,
Value::Bool(boolean) => boolean,
Value::Number(number) => number,
Value::String(string) => string,
_ => return Err(anyhow::anyhow!("unsupported param type"))
}).collect())
.query(query, params)
.await?
.into_iter()
.filter_map(|el| {