|
8 | 8 | //! ## Example |
9 | 9 | //! |
10 | 10 | //! ```rust,no_run |
11 | | -//! extern crate r2d2; |
12 | | -//! extern crate duckdb; |
13 | | -//! |
14 | | -//! |
15 | 11 | //! use std::thread; |
16 | 12 | //! use duckdb::{DuckdbConnectionManager, params}; |
| 13 | +//! use r2d2; |
17 | 14 | //! |
| 15 | +//! let manager = DuckdbConnectionManager::file("file.db").unwrap(); |
| 16 | +//! let pool = r2d2::Pool::new(manager).unwrap(); |
| 17 | +//! pool.get() |
| 18 | +//! .unwrap() |
| 19 | +//! .execute("CREATE TABLE IF NOT EXISTS foo (bar INTEGER)", params![]) |
| 20 | +//! .unwrap(); |
18 | 21 | //! |
19 | | -//! fn main() { |
20 | | -//! let manager = DuckdbConnectionManager::file("file.db").unwrap(); |
21 | | -//! let pool = r2d2::Pool::new(manager).unwrap(); |
22 | | -//! pool.get() |
23 | | -//! .unwrap() |
24 | | -//! .execute("CREATE TABLE IF NOT EXISTS foo (bar INTEGER)", params![]) |
25 | | -//! .unwrap(); |
26 | | -//! |
27 | | -//! (0..10) |
28 | | -//! .map(|i| { |
29 | | -//! let pool = pool.clone(); |
30 | | -//! thread::spawn(move || { |
31 | | -//! let conn = pool.get().unwrap(); |
32 | | -//! conn.execute("INSERT INTO foo (bar) VALUES (?)", &[&i]) |
33 | | -//! .unwrap(); |
34 | | -//! }) |
| 22 | +//! (0..10) |
| 23 | +//! .map(|i| { |
| 24 | +//! let pool = pool.clone(); |
| 25 | +//! thread::spawn(move || { |
| 26 | +//! let conn = pool.get().unwrap(); |
| 27 | +//! conn.execute("INSERT INTO foo (bar) VALUES (?)", &[&i]) |
| 28 | +//! .unwrap(); |
35 | 29 | //! }) |
36 | | -//! .collect::<Vec<_>>() |
37 | | -//! .into_iter() |
38 | | -//! .map(thread::JoinHandle::join) |
39 | | -//! .collect::<Result<_, _>>() |
40 | | -//! .unwrap() |
41 | | -//! } |
| 30 | +//! }) |
| 31 | +//! .collect::<Vec<_>>() |
| 32 | +//! .into_iter() |
| 33 | +//! .map(thread::JoinHandle::join) |
| 34 | +//! .collect::<Result<_, _>>() |
| 35 | +//! .unwrap() |
42 | 36 | //! ``` |
43 | 37 | use crate::{Config, Connection, Error, Result}; |
44 | 38 | use std::{ |
|
0 commit comments