Fix merge conflicts from SeaQL/sea-orm master branch

This commit is contained in:
Charles Chege 2021-10-29 10:44:09 +03:00
commit a1382b1b41
3 changed files with 30 additions and 7 deletions

View File

@ -133,21 +133,41 @@ impl ConnectOptions {
self self
} }
/// Get the maximum number of connections of the pool, if set
pub fn get_max_connections(&self) -> Option<u32> {
self.max_connections
}
/// Set the minimum number of connections of the pool /// Set the minimum number of connections of the pool
pub fn min_connections(&mut self, value: u32) -> &mut Self { pub fn min_connections(&mut self, value: u32) -> &mut Self {
self.min_connections = Some(value); self.min_connections = Some(value);
self self
} }
/// Get the minimum number of connections of the pool, if set
pub fn get_min_connections(&self) -> Option<u32> {
self.min_connections
}
/// Set the timeout duration when acquiring a connection /// Set the timeout duration when acquiring a connection
pub fn connect_timeout(&mut self, value: Duration) -> &mut Self { pub fn connect_timeout(&mut self, value: Duration) -> &mut Self {
self.connect_timeout = Some(value); self.connect_timeout = Some(value);
self self
} }
/// Get the timeout duration when acquiring a connection, if set
pub fn get_connect_timeout(&self) -> Option<Duration> {
self.connect_timeout
}
/// Set the idle duration before closing a connection /// Set the idle duration before closing a connection
pub fn idle_timeout(&mut self, value: Duration) -> &mut Self { pub fn idle_timeout(&mut self, value: Duration) -> &mut Self {
self.idle_timeout = Some(value); self.idle_timeout = Some(value);
self self
} }
/// Get the idle duration before closing a connection, if set
pub fn get_idle_timeout(&self) -> Option<Duration> {
self.idle_timeout
}
} }

View File

@ -41,12 +41,10 @@ impl SqlxSqliteConnector {
use sqlx::ConnectOptions; use sqlx::ConnectOptions;
opt.disable_statement_logging(); opt.disable_statement_logging();
} }
if let Ok(pool) = options if options.get_max_connections().is_none() {
.pool_options() options.max_connections(1);
.max_connections(1) }
.connect_with(opt) if let Ok(pool) = options.pool_options().connect_with(opt).await {
.await
{
Ok(DatabaseConnection::SqlxSqlitePoolConnection( Ok(DatabaseConnection::SqlxSqlitePoolConnection(
SqlxSqlitePoolConnection { pool }, SqlxSqlitePoolConnection { pool },
)) ))

View File

@ -266,10 +266,15 @@
mod database; mod database;
mod docs; mod docs;
mod driver; mod driver;
/// Module for the Entity type and operations
pub mod entity; pub mod entity;
/// Error types for all database operations
pub mod error; pub mod error;
/// This module performs execution of queries on a Model or ActiveModel
mod executor; mod executor;
/// Holds types and methods to perform queries
pub mod query; pub mod query;
/// Holds types that defines the schemas of an Entity
pub mod schema; pub mod schema;
#[doc(hidden)] #[doc(hidden)]
#[cfg(feature = "macros")] #[cfg(feature = "macros")]