Struct TestMySql 

pub struct TestMySql {
    pub server_url: String,
    pub dbname: String,
}

Fields

server_url: String

dbname: String

Implementations

impl TestMySql

pub fn new<S>(database_url: String, migrations: S) -> Self

where S: MigrationSource<'static> + Send + Sync + 'static,

Examples found in repository

examples/mysql_example.rs (lines 7-10)

async fn main() -> anyhow::Result<()> {
    // Create a test database with migrations
    let tdb = TestMySql::new(
        "mysql://root:password@127.0.0.1:3307".to_string(),
        Path::new("./fixtures/mysql_migrations"),
    );

    println!("Created test database: {}", tdb.dbname);
    println!("Database URL: {}", tdb.url());

    // Get a connection pool
    let pool = tdb.get_pool().await;

    // Insert a test record
    sqlx::query("INSERT INTO todos (title) VALUES (?)")
        .bind("Test MySQL Todo")
        .execute(&pool)
        .await?;

    // Query the record back
    let (id, title): (i32, String) = sqlx::query_as("SELECT id, title FROM todos WHERE title = ?")
        .bind("Test MySQL Todo")
        .fetch_one(&pool)
        .await?;

    println!("Retrieved todo: id={id}, title={title}");

    // Test CSV loading
    let csv_data = "title\nLoaded from CSV\nAnother CSV entry";
    tdb.load_csv_data("todos", csv_data).await?;

    // Count all todos
    let count: (i64,) = sqlx::query_as("SELECT COUNT(*) FROM todos")
        .fetch_one(&pool)
        .await?;

    println!("Total todos in database: {}", count.0);

    // The database will be automatically dropped when tdb goes out of scope
    println!("Test completed successfully! Database will be cleaned up automatically.");

    Ok(())
}

pub fn server_url(&self) -> String

pub fn url(&self) -> String

Examples found in repository

examples/mysql_example.rs (line 13)

async fn main() -> anyhow::Result<()> {
    // Create a test database with migrations
    let tdb = TestMySql::new(
        "mysql://root:password@127.0.0.1:3307".to_string(),
        Path::new("./fixtures/mysql_migrations"),
    );

    println!("Created test database: {}", tdb.dbname);
    println!("Database URL: {}", tdb.url());

    // Get a connection pool
    let pool = tdb.get_pool().await;

    // Insert a test record
    sqlx::query("INSERT INTO todos (title) VALUES (?)")
        .bind("Test MySQL Todo")
        .execute(&pool)
        .await?;

    // Query the record back
    let (id, title): (i32, String) = sqlx::query_as("SELECT id, title FROM todos WHERE title = ?")
        .bind("Test MySQL Todo")
        .fetch_one(&pool)
        .await?;

    println!("Retrieved todo: id={id}, title={title}");

    // Test CSV loading
    let csv_data = "title\nLoaded from CSV\nAnother CSV entry";
    tdb.load_csv_data("todos", csv_data).await?;

    // Count all todos
    let count: (i64,) = sqlx::query_as("SELECT COUNT(*) FROM todos")
        .fetch_one(&pool)
        .await?;

    println!("Total todos in database: {}", count.0);

    // The database will be automatically dropped when tdb goes out of scope
    println!("Test completed successfully! Database will be cleaned up automatically.");

    Ok(())
}

pub async fn get_pool(&self) -> MySqlPool

Examples found in repository

examples/mysql_example.rs (line 16)

async fn main() -> anyhow::Result<()> {
    // Create a test database with migrations
    let tdb = TestMySql::new(
        "mysql://root:password@127.0.0.1:3307".to_string(),
        Path::new("./fixtures/mysql_migrations"),
    );

    println!("Created test database: {}", tdb.dbname);
    println!("Database URL: {}", tdb.url());

    // Get a connection pool
    let pool = tdb.get_pool().await;

    // Insert a test record
    sqlx::query("INSERT INTO todos (title) VALUES (?)")
        .bind("Test MySQL Todo")
        .execute(&pool)
        .await?;

    // Query the record back
    let (id, title): (i32, String) = sqlx::query_as("SELECT id, title FROM todos WHERE title = ?")
        .bind("Test MySQL Todo")
        .fetch_one(&pool)
        .await?;

    println!("Retrieved todo: id={id}, title={title}");

    // Test CSV loading
    let csv_data = "title\nLoaded from CSV\nAnother CSV entry";
    tdb.load_csv_data("todos", csv_data).await?;

    // Count all todos
    let count: (i64,) = sqlx::query_as("SELECT COUNT(*) FROM todos")
        .fetch_one(&pool)
        .await?;

    println!("Total todos in database: {}", count.0);

    // The database will be automatically dropped when tdb goes out of scope
    println!("Test completed successfully! Database will be cleaned up automatically.");

    Ok(())
}

pub async fn load_csv( &self, table: &str, _fields: &[&str], filename: &Path, ) -> Result<()>

pub async fn load_csv_data(&self, table: &str, csv: &str) -> Result<()>

Examples found in repository

examples/mysql_example.rs (line 34)

async fn main() -> anyhow::Result<()> {
    // Create a test database with migrations
    let tdb = TestMySql::new(
        "mysql://root:password@127.0.0.1:3307".to_string(),
        Path::new("./fixtures/mysql_migrations"),
    );

    println!("Created test database: {}", tdb.dbname);
    println!("Database URL: {}", tdb.url());

    // Get a connection pool
    let pool = tdb.get_pool().await;

    // Insert a test record
    sqlx::query("INSERT INTO todos (title) VALUES (?)")
        .bind("Test MySQL Todo")
        .execute(&pool)
        .await?;

    // Query the record back
    let (id, title): (i32, String) = sqlx::query_as("SELECT id, title FROM todos WHERE title = ?")
        .bind("Test MySQL Todo")
        .fetch_one(&pool)
        .await?;

    println!("Retrieved todo: id={id}, title={title}");

    // Test CSV loading
    let csv_data = "title\nLoaded from CSV\nAnother CSV entry";
    tdb.load_csv_data("todos", csv_data).await?;

    // Count all todos
    let count: (i64,) = sqlx::query_as("SELECT COUNT(*) FROM todos")
        .fetch_one(&pool)
        .await?;

    println!("Total todos in database: {}", count.0);

    // The database will be automatically dropped when tdb goes out of scope
    println!("Test completed successfully! Database will be cleaned up automatically.");

    Ok(())
}

Trait Implementations

impl Debug for TestMySql

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

Formats the value using the given formatter.

impl Default for TestMySql

fn default() -> Self

Returns the “default value” for a type.

impl Drop for TestMySql

fn drop(&mut self)

Executes the destructor for this type.