16 releases
0.2.6 | Jul 13, 2023 |
---|---|
0.2.5 | Jul 13, 2023 |
0.1.9 | Jul 6, 2023 |
#1006 in Database interfaces
85 downloads per month
49KB
938 lines
rssql
Struct-free Rust SQL tool.
Intro
sqlx
based sql tools, support mysql (mariadb)
, postgresql
and sqlite
.
Example
Start with the easy ones
use rssql::PostgreSQL;
async fn postgresql_select_example() {
let mut postgresql = PostgreSQL::connect("postgre://user:password@127.0.0.1:5432/test")
.await
.unwrap();
let check = postgresql.check_connection().await;
assert_eq!(check, true);
let rets = postgresql.execute_fetch_all("SELECT * FROM info").await.unwrap();
// let rets = postgresql.execute_fetch_one("SELECT * FROM info").await.unwrap();
println!("{}", rets);
println!("{}", rets.rows_affected().unwrap());
postgresql.close().await;
}
Output
+----+-------+------------+
| id | name | date |
+----+-------+------------+
| 1 | test1 | 2023-06-11 |
| 2 | test2 | 2023-06-11 |
+----+-------+------------+
More
use rssql::PostgreSQL;
async fn test_postgresql() {
/// Connect to database.
let mut postgresql = PostgreSQL::connect("postgre://user:password@127.0.0.1:5432/test")
.await
.unwrap();
/// Check connection.
let check = postgresql.check_connection().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_affected = postgresql.execute(&sql).await.unwrap();
assert_eq!(rows_affected, 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;
}
Dependencies
~39–54MB
~1M SLoC