您好,登錄后才能下訂單哦!
這篇文章主要講解了“Rust怎么連接PostgreSQL數(shù)據(jù)庫”,文中的講解內(nèi)容簡單清晰,易于學(xué)習(xí)與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“Rust怎么連接PostgreSQL數(shù)據(jù)庫”吧!
pgxr 是一個(gè) Rust 的 crate 庫,可以實(shí)現(xiàn)用 Rust 語言來編寫 PostgreSQL 的擴(kuò)展函數(shù)(相當(dāng)于存儲過程)。
這次,我們使用 postgres 這個(gè) crate 來連接和操作 PostgreSQL 數(shù)據(jù)庫。
創(chuàng)建好項(xiàng)目后,在 cargo.toml 里添加 postgres 的依賴:
首先,導(dǎo)入相關(guān)的類型,并創(chuàng)建一個(gè) Person struct:
再創(chuàng)建 create_db 函數(shù),用來創(chuàng)建數(shù)據(jù)庫和表,它返回一個(gè) Result,里面可能是 Client 或錯(cuò)誤:
注意,Client::connect() 函數(shù)所接受的連接字符串可以是兩種形式的:
Key-Value 形式。例如:Client::connect("host=localhost user=postgres", NoTls)?; 具體的 key 需要查閱官方文檔。URL 形式。本例中使用的是 URL 形式。
一個(gè)相對完整的數(shù)據(jù)庫連接字符串 URL 格式是:
postgres://username[:password]@host[:port][/database],其中 password、port、database 都是可選的。所以上面代碼中做了相應(yīng)的判斷處理。
Client::connect() 函數(shù)的第二個(gè)參數(shù)用的是 NoTls,為了簡單起見,這里我們不使用 TLS。
第 30、32 行,使用 Client 的 execute 方法先刪除數(shù)據(jù)表(如果存在的話),然后再創(chuàng)建 person 表。
最后返回 Client。
接下來,創(chuàng)建 insert_data 函數(shù),來插入一些數(shù)據(jù):
注意該函數(shù)的參數(shù) Client 必須是 mut 的。
再創(chuàng)建一個(gè)查詢數(shù)據(jù)的函數(shù):
這里,我們直接對 Client 的 query 方法返回的結(jié)果進(jìn)行遍歷,最后方法返回一個(gè) Vec。
最后,在 main 函數(shù)里依次調(diào)用這些函數(shù),并把查詢結(jié)果打印出來:
結(jié)果如下:
全部代碼如下:
use postgres::{error::Error, Client, NoTls}; #[derive(Debug)] struct Person { id: i32, name: String, data: Option<Vec<u8>>, } fn create_db() -> Result<Client, Error> { let username = "postgres"; let password = "postgres"; let host = "localhost"; let port = "5432"; let database = "rust2021"; let conn_str = &format!( "postgres://{}{}{}@{}{}{}{}{}", username, if password.is_empty() { "" } else { ":" }, password, host, if port.is_empty() { "" } else { ":" }, port, if database.is_empty() { "" } else { "/" }, database ); let mut client = Client::connect(conn_str, NoTls)?; let _ = client.execute("DROP TABLE person", &[]); client.execute( "CREATE TABLE person ( id SERIAL PRIMARY KEY, name TEXT NOT NULL, data BYTEA )", &[], )?; Ok(client) fn insert_data(client: &mut Client) -> Result<(), Error> { let p1 = Person { id: 1, name: "Dave".to_string(), data: None, }; let p2 = Person { id: 2, name: "Nick".to_string(), "INSERT INTO person (id, name, data) VALUES ($1, $2, $3), ($4, $5, $6)", &[&p1.id, &p1.name, &p1.data, &p2.id, &p2.name, &p2.data], Ok(()) fn get_data(client: &mut Client) -> Result<Vec<Person>, Error> { let mut persons = Vec::new(); for row in client.query("SELECT id, name, data FROM person", &[])? { persons.push(Person { id: row.get(0), name: row.get(1), data: row.get(2), }); } Ok(persons) fn main() -> Result<(), Error> { let mut client = create_db()?; insert_data(&mut client)?; let persons = get_data(&mut client)?; for p in persons { println!("Person: {:?}", p);
感謝各位的閱讀,以上就是“Rust怎么連接PostgreSQL數(shù)據(jù)庫”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對Rust怎么連接PostgreSQL數(shù)據(jù)庫這一問題有了更深刻的體會,具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云,小編將為大家推送更多相關(guān)知識點(diǎn)的文章,歡迎關(guān)注!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。