Struct Database

pub struct Database {
    pub pool: ConnectionPool,
}

Represents a MySQL database connection manager.

The Database struct maintains a connection pool to MySQL and provides methods for establishing connections with configurable parameters. It uses SQLx’s connection pooling to efficiently manage database connections.

Fields

pool: ConnectionPool

The connection pool for MySQL connections.

Implementations

impl Database

pub async fn connect( connection_string: &str, connection_pool_size: u32, ) -> Result<Self>

Establishes a new connection pool to MySQL with the specified configuration.

This method initializes a new connection pool with the given parameters and verifies that the connection can be established successfully.

Arguments

• connection_string - The MySQL connection URL (e.g., “mysql://user:password@localhost:3306/database”)
• connection_pool_size - Maximum number of connections in the pool

Returns

Returns a Result containing the Database instance if successful, or an error if the connection could not be established.

Examples

use darkwing::database::Database;

async fn example() -> anyhow::Result<()> {
    let db = Database::connect(
        "mysql://user:password@localhost:3306/database",
        5
    ).await?;
    Ok(())
}

Trait Implementations

impl BrowserProfileAccessRepository for Database

Implementation of BrowserProfileAccessRepository for the main database.

fn get_by_user_id_and_browser_profile_id<'life0, 'async_trait>( &'life0 self, user_id: i64, browser_profile_id: i64, ) -> Pin<Box<dyn Future<Output = Result<Option<BrowserProfileAccess>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves browser profile access permissions for a specific user and profile.

fn get_teamlead_id_by_browser_profile<'life0, 'async_trait>( &'life0 self, browser_profile: MiniBrowserProfile, ) -> Pin<Box<dyn Future<Output = Result<Option<i64>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves the teamlead ID associated with a browser profile.

impl BrowserProfileRepository for Database

fn get_mini_by_id<'life0, 'async_trait>( &'life0 self, id: i64, ) -> Pin<Box<dyn Future<Output = Result<MiniBrowserProfile>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves minimal browser profile information by ID.

fn get_preliminary_by_id<'life0, 'async_trait>( &'life0 self, id: i64, ) -> Pin<Box<dyn Future<Output = Result<BrowserProfilePreliminary>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves preliminary browser profile data by ID. This includes basic profile information without full fingerprint details.

fn get_by_id_with_fingerprint<'life0, 'async_trait>( &'life0 self, id: i64, ) -> Pin<Box<dyn Future<Output = Result<BrowserProfileWithFingerprint>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves complete browser profile information including fingerprint data by ID.

fn get_homepages_by_browser_profile_id<'life0, 'async_trait>( &'life0 self, id: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Homepage>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves all homepages associated with a browser profile ID.

fn get_bookmarks<'life0, 'async_trait>( &'life0 self, user_id: i64, team_id: i64, main_website: MainWebsite, ) -> Pin<Box<dyn Future<Output = Result<Vec<Bookmark>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves bookmarks filtered by user ID, team ID and main website.

fn get_extensions<'life0, 'async_trait>( &'life0 self, user_id: i64, team_id: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Extension>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves extensions available to a user based on user ID and team ID.

fn update_datadir_hash<'life0, 'async_trait>( &'life0 self, id: i64, hash: String, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Updates or inserts the datadir hash for a browser profile.

fn is_pending_transfer<'life0, 'async_trait>( &'life0 self, id: i64, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Checks if a browser profile has a pending transfer.

impl Clone for Database

fn clone(&self) -> Database

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Database

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ProxyRepository for Database

fn maybe_get_by_id<'life0, 'async_trait>( &'life0 self, id: i64, ) -> Pin<Box<dyn Future<Output = Result<Option<Proxy>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves proxy information by ID if it exists and is not deleted.

impl SettingsRepository for Database

Implementation of SettingsRepository for the main Database type.

fn get_by_team_id_and_user_id<'life0, 'async_trait>( &'life0 self, team_id: i64, user_id: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Setting>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves settings for a specific team and user combination.

impl TeamsRepository for Database

Implementation of TeamsRepository for the main Database type.

fn get_team_by_id<'life0, 'async_trait>( &'life0 self, id: i64, ) -> Pin<Box<dyn Future<Output = Result<Team>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves a team by its unique identifier.

impl UsersRepository for Database

Implementation of UsersRepository for the main database.

This implementation provides the actual database operations using SQLx to interact with the underlying database.

fn get_user_by_id<'life0, 'async_trait>( &'life0 self, id: u64, ) -> Pin<Box<dyn Future<Output = Result<User>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves a user by their unique identifier.