rssql

Struct-free Rust SQL tool.

Intro

sqlx based sql tools, support mysql (mariadb), postgresql and sqlite.

Example

Start with the easy ones

```rust use rssql::PostgreSQL;

async fn postgresqlselectexample() { let mut postgresql = PostgreSQL::connect("postgre://user:password@127.0.0.1:5432/test") .await .unwrap(); let check = postgresql.checkconnection().await; asserteq!(check, true); let rets = postgresql.executefetchall("SELECT * FROM info").await.unwrap(); // let rets = postgresql.executefetchone("SELECT * FROM info").await.unwrap(); println!("{}", rets); println!("{}", rets.rows_affected().unwrap()); postgresql.close().await; } ```

Output

bash +----+-------+------------+ | id | name | date | +----+-------+------------+ | 1 | test1 | 2023-06-11 | | 2 | test2 | 2023-06-11 | +----+-------+------------+

More

```rust use rssql::PostgreSQL;

async fn testpostgresql() { /// Connect to database. let mut postgresql = PostgreSQL::connect("postgre://user:password@127.0.0.1:5432/test") .await .unwrap(); /// Check connection. let check = postgresql.checkconnection().await; assert_eq!(check, true);

let sql = "CREATE TABLE IF NOT EXISTS info (id INT PRIMARY KEY NOT NULL, name VARCHAR(16), date DATE)";
let _ = postgresql.execute(sql).await.unwrap();

/// Insert 10 rows data into table `info`.
for i in 0..10 {
    let sql = format!(
        "INSERT INTO info (id, name, date) VALUES ({}, 'test{}', '2023-07-07')",
        i, i
    );
    let rows_affecteds = postgresql.execute(&sql).await.unwrap();
    assert_eq!(rows_affecteds, 1);
}

/// Select all from table `info`.
let rets = postgresql.execute_fetch_all("SELECT * FROM info").await.unwrap();
// let rets = postgresql.execute_fetch_one("SELECT * FROM info").await.unwrap();
println!("{}", rets);

/// Get first one from returns by column name.
for column in &rets.column {
    let value = rets.get_first_one(&column).unwrap();
    println!("{}", value);
}

/// Get all by column name.
let values = rets.get_all("name").unwrap();
for value in values {
    match value {
        SQLDataTypes::MySQLDataTypes(m) => (),
        SQLDataTypes::PostgreSQLDataTypes(p) => (),
        SQLDataTypes::SQLiteDataTypes(s) => match s {
            SQLiteDataTypes::Binary(b) => (),
            SQLiteDataTypes::Bool(b) => (),
            SQLiteDataTypes::DateTime(d) => (),
            SQLiteDataTypes::F64(f) => {
                let new_f = f + 3.14;
                println!("new float value: {}", new_f);
            }
            SQLiteDataTypes::I32(i) => (),
            SQLiteDataTypes::I64(i) => (),
            SQLiteDataTypes::NaiveDate(n) => (),
            SQLiteDataTypes::NaiveDateTime(n) => (),
            SQLiteDataTypes::NaiveTime(n) => (),
            SQLiteDataTypes::String(s) => (),
        },
    }
}

/// Close the connection.
postgresql.close().await;

} ```