Skip to content

Commit 8e1d6ca

Browse files
committed
Updated examples [skip ci]
1 parent a33c4a6 commit 8e1d6ca

File tree

2 files changed

+28
-7
lines changed

2 files changed

+28
-7
lines changed

examples/cohere/src/main.rs

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,10 @@ fn main() -> Result<(), Box<dyn Error>> {
1212

1313
client.execute("CREATE EXTENSION IF NOT EXISTS vector", &[])?;
1414
client.execute("DROP TABLE IF EXISTS documents", &[])?;
15-
client.execute("CREATE TABLE documents (id serial PRIMARY KEY, content text, embedding bit(1024))", &[])?;
15+
client.execute(
16+
"CREATE TABLE documents (id serial PRIMARY KEY, content text, embedding bit(1024))",
17+
&[],
18+
)?;
1619

1720
let input = [
1821
"The dog is barking",
@@ -22,12 +25,18 @@ fn main() -> Result<(), Box<dyn Error>> {
2225
let embeddings = fetch_embeddings(&input, "search_document")?;
2326
for (content, embedding) in input.iter().zip(embeddings) {
2427
let embedding = Bit::from_bytes(&embedding);
25-
client.execute("INSERT INTO documents (content, embedding) VALUES ($1, $2)", &[&content, &embedding])?;
28+
client.execute(
29+
"INSERT INTO documents (content, embedding) VALUES ($1, $2)",
30+
&[&content, &embedding],
31+
)?;
2632
}
2733

2834
let query = "forest";
2935
let query_embedding = fetch_embeddings(&[query], "search_query")?;
30-
for row in client.query("SELECT content FROM documents ORDER BY embedding <~> $1 LIMIT 5", &[&Bit::from_bytes(&query_embedding[0])])? {
36+
for row in client.query(
37+
"SELECT content FROM documents ORDER BY embedding <~> $1 LIMIT 5",
38+
&[&Bit::from_bytes(&query_embedding[0])],
39+
)? {
3140
let content: &str = row.get(0);
3241
println!("{}", content);
3342
}

examples/disco/src/main.rs

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,20 +21,32 @@ fn main() -> Result<(), Box<dyn Error>> {
2121
client.execute("CREATE EXTENSION IF NOT EXISTS vector", &[])?;
2222
client.execute("DROP TABLE IF EXISTS users", &[])?;
2323
client.execute("DROP TABLE IF EXISTS movies", &[])?;
24-
client.execute("CREATE TABLE users (id integer PRIMARY KEY, factors vector(20))", &[])?;
25-
client.execute("CREATE TABLE movies (name text PRIMARY KEY, factors vector(20))", &[])?;
24+
client.execute(
25+
"CREATE TABLE users (id integer PRIMARY KEY, factors vector(20))",
26+
&[],
27+
)?;
28+
client.execute(
29+
"CREATE TABLE movies (name text PRIMARY KEY, factors vector(20))",
30+
&[],
31+
)?;
2632

2733
let data = load_movielens(Path::new(&movielens_path));
2834
let recommender = RecommenderBuilder::new().factors(20).fit_explicit(&data);
2935

3036
for user_id in recommender.user_ids() {
3137
let factors = Vector::from(recommender.user_factors(user_id).unwrap().to_vec());
32-
client.execute("INSERT INTO users (id, factors) VALUES ($1, $2)", &[&user_id, &factors])?;
38+
client.execute(
39+
"INSERT INTO users (id, factors) VALUES ($1, $2)",
40+
&[&user_id, &factors],
41+
)?;
3342
}
3443

3544
for item_id in recommender.item_ids() {
3645
let factors = Vector::from(recommender.item_factors(item_id).unwrap().to_vec());
37-
client.execute("INSERT INTO movies (name, factors) VALUES ($1, $2)", &[&item_id, &factors])?;
46+
client.execute(
47+
"INSERT INTO movies (name, factors) VALUES ($1, $2)",
48+
&[&item_id, &factors],
49+
)?;
3850
}
3951

4052
let movie = "Star Wars (1977)";

0 commit comments

Comments
 (0)