Struct mysql::conn::pool::Pool
[−]
[src]
pub struct Pool(_);
Pool
serves to provide you with a PooledConn
's.
However you can prepare statements directly on Pool
without
invoking Pool::get_conn
.
Pool
will hold at least min
connections and will create as many as max
connections.
Example of multithreaded Pool
usage:
use mysql::conn::pool; use std::default::Default; use mysql::conn::Opts; use std::thread; fn get_opts() -> Opts { // ... } let opts = get_opts(); let pool = pool::Pool::new(opts).unwrap(); let mut threads = Vec::new(); for _ in 0..100 { let pool = pool.clone(); threads.push(thread::spawn(move || { let mut result = pool.prep_exec("SELECT 1", ()).unwrap(); assert_eq!(result.next().unwrap().unwrap().unwrap(), vec![1.into()]); })); } for t in threads.into_iter() { assert!(t.join().is_ok()); }
For more info on how to work with mysql connection please look at
PooledConn
documentation.
Methods
impl Pool
fn new<T: Into<Opts>>(opts: T) -> MyResult<Pool>
Creates new pool with min = 10
and max = 100
.
fn new_manual<T: Into<Opts>>(min: usize, max: usize, opts: T) -> MyResult<Pool>
Same as new
but you can set min
and max
.
fn get_conn(&self) -> MyResult<PooledConn>
Gives you a PooledConn
.
Pool
will check that connection is alive via
Conn::ping
and will
call Conn::reset
if
necessary.
fn try_get_conn(&self, timeout_ms: u32) -> MyResult<PooledConn>
Will try to get connection for a duration of timeout_ms
milliseconds.
Failure
This function will return Error::DriverError(DriverError::Timeout)
if timeout was
reached while waiting for new connection to become available.
fn prepare<'a, T: AsRef<str> + 'a>(&'a self, query: T) -> MyResult<Stmt<'a>>
Will prepare statement.
It will try to find connection which has this statement cached.
fn prep_exec<'a, A, T>(&'a self, query: A, params: T) -> MyResult<QueryResult<'a>> where A: AsRef<str>, T: Into<Params>
Shortcut for try!(pool.get_conn()).prep_exec(..)
.
It will try to find connection which has this statement cached.
fn start_transaction(&self, consistent_snapshot: bool, isolation_level: Option<IsolationLevel>, readonly: Option<bool>) -> MyResult<Transaction>
Shortcut for try!(pool.get_conn()).start_transaction(..)
.