|
3 | 3 |
|
4 | 4 | use anyhow::Result; |
5 | 5 | use indoc::indoc; |
6 | | -use postgresql_embedded::{PostgreSQL, Settings, VersionReq}; |
7 | | -use sqlx::PgPool; |
| 6 | +use sqlx::{PgPool, Row}; |
8 | 7 | use tracing::info; |
9 | 8 |
|
| 9 | +use postgresql_embedded::{PostgreSQL, Settings, VersionReq}; |
| 10 | + |
10 | 11 | /// Example of how to install and configure the vector extension. |
11 | 12 | /// |
12 | 13 | /// See: <https://github.com/tensorchord/pgvecto.rs/?tab=readme-ov-file#quick-start> |
@@ -59,6 +60,27 @@ async fn main() -> Result<()> { |
59 | 60 | info!("Creating data"); |
60 | 61 | create_data(&pool).await?; |
61 | 62 |
|
| 63 | + info!("Squared Euclidean Distance"); |
| 64 | + execute_query( |
| 65 | + &pool, |
| 66 | + "SELECT '[1, 2, 3]'::vector <-> '[3, 2, 1]'::vector AS value;", |
| 67 | + ) |
| 68 | + .await?; |
| 69 | + |
| 70 | + info!("Negative Dot Product"); |
| 71 | + execute_query( |
| 72 | + &pool, |
| 73 | + "SELECT '[1, 2, 3]'::vector <#> '[3, 2, 1]'::vector AS value;", |
| 74 | + ) |
| 75 | + .await?; |
| 76 | + |
| 77 | + info!("Cosine Distance"); |
| 78 | + execute_query( |
| 79 | + &pool, |
| 80 | + "SELECT '[1, 2, 3]'::vector <=> '[3, 2, 1]'::vector AS value;", |
| 81 | + ) |
| 82 | + .await?; |
| 83 | + |
62 | 84 | info!("Stopping database"); |
63 | 85 | postgresql.stop().await?; |
64 | 86 | Ok(()) |
@@ -117,6 +139,13 @@ async fn create_data(pool: &PgPool) -> Result<()> { |
117 | 139 | Ok(()) |
118 | 140 | } |
119 | 141 |
|
| 142 | +async fn execute_query(pool: &PgPool, query: &str) -> Result<()> { |
| 143 | + let row = sqlx::query(query).fetch_one(pool).await?; |
| 144 | + let value: f32 = row.try_get("value")?; |
| 145 | + info!("{}: {}", query, value); |
| 146 | + Ok(()) |
| 147 | +} |
| 148 | + |
120 | 149 | #[cfg(target_os = "linux")] |
121 | 150 | #[cfg(test)] |
122 | 151 | mod test { |
|
0 commit comments