{/* Auto-generated by scripts/mdx_snippets_gen.py. Do not edit manually. */} export const RsAdd = "let new_data = create_some_records()?;\ntbl.add(new_data).execute().await.unwrap();\n"; export const RsConnect = "#[tokio::main]\nasync fn main() -> Result<()> {\n if std::path::Path::new(\"data\").exists() {\n std::fs::remove_dir_all(\"data\").unwrap();\n }\n // --8<-- [start:connect_uri]\n let uri = \"data/sample-lancedb\";\n let db = connect(uri).execute().await?;\n // --8<-- [end:connect_uri]\n\n // --8<-- [start:list_names]\n println!(\"{:?}\", db.table_names().execute().await?);\n // --8<-- [end:list_names]\n let tbl = create_table(&db).await?;\n create_index(&tbl).await?;\n let batches = search(&tbl).await?;\n println!(\"{:?}\", batches);\n\n create_empty_table(&db).await.unwrap();\n\n // --8<-- [start:delete]\n tbl.delete(\"id > 24\").await.unwrap();\n // --8<-- [end:delete]\n\n // --8<-- [start:drop_table]\n db.drop_table(\"my_table\").await.unwrap();\n // --8<-- [end:drop_table]\n Ok(())\n}\n"; export const RsConnectUri = "let uri = \"data/sample-lancedb\";\nlet db = connect(uri).execute().await?;\n"; export const RsCreateEmptyTable = "let schema = Arc::new(Schema::new(vec![\n Field::new(\"id\", DataType::Int32, false),\n Field::new(\"item\", DataType::Utf8, true),\n]));\ndb.create_empty_table(\"empty_table\", schema).execute().await\n"; export const RsCreateIndex = "table.create_index(&[\"vector\"], Index::Auto).execute().await\n"; export const RsCreateTable = "let initial_data = create_some_records()?;\nlet tbl = db\n .create_table(\"my_table\", initial_data)\n .execute()\n .await\n .unwrap();\n"; export const RsDelete = "tbl.delete(\"id > 24\").await.unwrap();\n"; export const RsDropTable = "db.drop_table(\"my_table\").await.unwrap();\n"; export const RsListNames = "println!(\"{:?}\", db.table_names().execute().await?);\n"; export const RsOpenExistingTbl = "let table = db.open_table(\"my_table\").execute().await.unwrap();\n"; export const RsSearch = "table\n .query()\n .limit(2)\n .nearest_to(&[1.0; 128])?\n .execute()\n .await?\n .try_collect::>()\n .await\n";