Loader: use ValueTuple as hash key (#1868)
This commit is contained in:
parent
36e2f14d79
commit
17c943d84e
@ -34,7 +34,7 @@ tracing = { version = "0.1", default-features = false, features = ["attributes",
|
|||||||
rust_decimal = { version = "1", default-features = false, optional = true }
|
rust_decimal = { version = "1", default-features = false, optional = true }
|
||||||
bigdecimal = { version = "0.3", default-features = false, optional = true }
|
bigdecimal = { version = "0.3", default-features = false, optional = true }
|
||||||
sea-orm-macros = { version = "0.12.3", path = "sea-orm-macros", default-features = false, features = ["strum"] }
|
sea-orm-macros = { version = "0.12.3", path = "sea-orm-macros", default-features = false, features = ["strum"] }
|
||||||
sea-query = { version = "0.30.1", default-features = false, features = ["thread-safe", "hashable-value", "backend-mysql", "backend-postgres", "backend-sqlite"] }
|
sea-query = { version = "0.30.2", default-features = false, features = ["thread-safe", "hashable-value", "backend-mysql", "backend-postgres", "backend-sqlite"] }
|
||||||
sea-query-binder = { version = "0.5.0", default-features = false, optional = true }
|
sea-query-binder = { version = "0.5.0", default-features = false, optional = true }
|
||||||
strum = { version = "0.25", default-features = false }
|
strum = { version = "0.25", default-features = false }
|
||||||
serde = { version = "1.0", default-features = false }
|
serde = { version = "1.0", default-features = false }
|
||||||
|
@ -158,24 +158,20 @@ where
|
|||||||
|
|
||||||
let data = stmt.all(db).await?;
|
let data = stmt.all(db).await?;
|
||||||
|
|
||||||
let hashmap: HashMap<String, <R as EntityTrait>::Model> = data.into_iter().fold(
|
let hashmap: HashMap<ValueTuple, <R as EntityTrait>::Model> = data.into_iter().fold(
|
||||||
HashMap::<String, <R as EntityTrait>::Model>::new(),
|
HashMap::new(),
|
||||||
|mut acc: HashMap<String, <R as EntityTrait>::Model>,
|
|mut acc, value: <R as EntityTrait>::Model| {
|
||||||
value: <R as EntityTrait>::Model| {
|
|
||||||
{
|
{
|
||||||
let key = extract_key(&rel_def.to_col, &value);
|
let key = extract_key(&rel_def.to_col, &value);
|
||||||
|
acc.insert(key, value);
|
||||||
acc.insert(format!("{key:?}"), value);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
acc
|
acc
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
|
|
||||||
let result: Vec<Option<<R as EntityTrait>::Model>> = keys
|
let result: Vec<Option<<R as EntityTrait>::Model>> =
|
||||||
.iter()
|
keys.iter().map(|key| hashmap.get(key).cloned()).collect();
|
||||||
.map(|key| hashmap.get(&format!("{key:?}")).cloned())
|
|
||||||
.collect();
|
|
||||||
|
|
||||||
Ok(result)
|
Ok(result)
|
||||||
}
|
}
|
||||||
@ -213,11 +209,10 @@ where
|
|||||||
|
|
||||||
let data = stmt.all(db).await?;
|
let data = stmt.all(db).await?;
|
||||||
|
|
||||||
let mut hashmap: HashMap<String, Vec<<R as EntityTrait>::Model>> =
|
let mut hashmap: HashMap<ValueTuple, Vec<<R as EntityTrait>::Model>> =
|
||||||
keys.iter()
|
keys.iter()
|
||||||
.fold(HashMap::new(), |mut acc, key: &ValueTuple| {
|
.fold(HashMap::new(), |mut acc, key: &ValueTuple| {
|
||||||
acc.insert(format!("{key:?}"), Vec::new());
|
acc.insert(key.clone(), Vec::new());
|
||||||
|
|
||||||
acc
|
acc
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -226,7 +221,7 @@ where
|
|||||||
let key = extract_key(&rel_def.to_col, &value);
|
let key = extract_key(&rel_def.to_col, &value);
|
||||||
|
|
||||||
let vec = hashmap
|
let vec = hashmap
|
||||||
.get_mut(&format!("{key:?}"))
|
.get_mut(&key)
|
||||||
.expect("Failed at finding key on hashmap");
|
.expect("Failed at finding key on hashmap");
|
||||||
|
|
||||||
vec.push(value);
|
vec.push(value);
|
||||||
@ -234,12 +229,7 @@ where
|
|||||||
|
|
||||||
let result: Vec<Vec<R::Model>> = keys
|
let result: Vec<Vec<R::Model>> = keys
|
||||||
.iter()
|
.iter()
|
||||||
.map(|key: &ValueTuple| {
|
.map(|key: &ValueTuple| hashmap.get(key).cloned().unwrap_or_default())
|
||||||
hashmap
|
|
||||||
.get(&format!("{key:?}"))
|
|
||||||
.cloned()
|
|
||||||
.unwrap_or_default()
|
|
||||||
})
|
|
||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
Ok(result)
|
Ok(result)
|
||||||
@ -287,14 +277,14 @@ where
|
|||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
// Map of M::PK -> Vec<R::PK>
|
// Map of M::PK -> Vec<R::PK>
|
||||||
let mut keymap: HashMap<String, Vec<ValueTuple>> = Default::default();
|
let mut keymap: HashMap<ValueTuple, Vec<ValueTuple>> = Default::default();
|
||||||
|
|
||||||
let keys: Vec<ValueTuple> = {
|
let keys: Vec<ValueTuple> = {
|
||||||
let condition = prepare_condition(&via_rel.to_tbl, &via_rel.to_col, &pkeys);
|
let condition = prepare_condition(&via_rel.to_tbl, &via_rel.to_col, &pkeys);
|
||||||
let stmt = V::find().filter(condition);
|
let stmt = V::find().filter(condition);
|
||||||
let data = stmt.all(db).await?;
|
let data = stmt.all(db).await?;
|
||||||
data.into_iter().for_each(|model| {
|
data.into_iter().for_each(|model| {
|
||||||
let pk = format!("{:?}", extract_key(&via_rel.to_col, &model));
|
let pk = extract_key(&via_rel.to_col, &model);
|
||||||
let entry = keymap.entry(pk).or_default();
|
let entry = keymap.entry(pk).or_default();
|
||||||
|
|
||||||
let fk = extract_key(&rel_def.from_col, &model);
|
let fk = extract_key(&rel_def.from_col, &model);
|
||||||
@ -309,11 +299,12 @@ where
|
|||||||
let stmt = <Select<R> as QueryFilter>::filter(stmt.select(), condition);
|
let stmt = <Select<R> as QueryFilter>::filter(stmt.select(), condition);
|
||||||
|
|
||||||
let data = stmt.all(db).await?;
|
let data = stmt.all(db).await?;
|
||||||
|
|
||||||
// Map of R::PK -> R::Model
|
// Map of R::PK -> R::Model
|
||||||
let data: HashMap<String, <R as EntityTrait>::Model> = data
|
let data: HashMap<ValueTuple, <R as EntityTrait>::Model> = data
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.map(|model| {
|
.map(|model| {
|
||||||
let key = format!("{:?}", extract_key(&rel_def.to_col, &model));
|
let key = extract_key(&rel_def.to_col, &model);
|
||||||
(key, model)
|
(key, model)
|
||||||
})
|
})
|
||||||
.collect();
|
.collect();
|
||||||
@ -321,14 +312,11 @@ where
|
|||||||
let result: Vec<Vec<R::Model>> = pkeys
|
let result: Vec<Vec<R::Model>> = pkeys
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.map(|pkey| {
|
.map(|pkey| {
|
||||||
let fkeys = keymap
|
let fkeys = keymap.get(&pkey).cloned().unwrap_or_default();
|
||||||
.get(&format!("{pkey:?}"))
|
|
||||||
.cloned()
|
|
||||||
.unwrap_or_default();
|
|
||||||
|
|
||||||
let models: Vec<_> = fkeys
|
let models: Vec<_> = fkeys
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.filter_map(|fkey| data.get(&format!("{fkey:?}")).cloned())
|
.filter_map(|fkey| data.get(&fkey).cloned())
|
||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
models
|
models
|
||||||
|
Loading…
x
Reference in New Issue
Block a user