aboutsummaryrefslogtreecommitdiff
path: root/database/src
diff options
context:
space:
mode:
Diffstat (limited to 'database/src')
-rw-r--r--database/src/kv/binning.rs4
-rw-r--r--database/src/kv/index.rs1
-rw-r--r--database/src/kv/mod.rs4
3 files changed, 5 insertions, 4 deletions
diff --git a/database/src/kv/binning.rs b/database/src/kv/binning.rs
index 1057a28..42e58fc 100644
--- a/database/src/kv/binning.rs
+++ b/database/src/kv/binning.rs
@@ -40,7 +40,7 @@ impl BinningComponent {
let mut new_out = Vec::new();
for value in path.get_matching_values(ob) {
for mut co in keys.clone() {
- co.extend((co.len() as u32).to_be_bytes());
+ co.extend((value.len() as u32).to_be_bytes());
co.extend(value);
new_out.push(co);
}
@@ -88,7 +88,7 @@ impl Filter {
Filter::Match(path, value) => {
vec![vec![(BinningComponent::Match(path.to_owned()), {
let mut co = Vec::new();
- co.extend((co.len() as u32).to_be_bytes());
+ co.extend((value.len() as u32).to_be_bytes());
co.extend(value);
co
})]]
diff --git a/database/src/kv/index.rs b/database/src/kv/index.rs
index 23b8349..81a4f55 100644
--- a/database/src/kv/index.rs
+++ b/database/src/kv/index.rs
@@ -63,6 +63,7 @@ pub fn iter_index<'a>(
prefix: Vec<u8>,
sort: &Sort,
) -> Result<Box<dyn Iterator<Item = Result<(RowNum, Vec<u8>)>> + 'a>> {
+ eprintln!("{prefix:?}");
Ok(match sort {
Sort::None => Box::new(
PrefixIterator {
diff --git a/database/src/kv/mod.rs b/database/src/kv/mod.rs
index 9cb05fc..8d42ec7 100644
--- a/database/src/kv/mod.rs
+++ b/database/src/kv/mod.rs
@@ -246,7 +246,7 @@ mod test {
}
#[test]
- pub fn filter() -> Result<()> {
+ pub fn query_match() -> Result<()> {
let db = jellykv::memory::new();
let mut rows = [0, 0, 0];
@@ -268,7 +268,7 @@ mod test {
Ok(())
})?;
- assert_eq!(result.unwrap(), 0);
+ assert_eq!(result, Some(rows[0]));
Ok(())
}
}