mod utils;
use serial_test::serial;
use sqlb::sqlx_exec;
use std::error::Error;
use utils::init_db;
#[serial]
#[tokio::test]
async fn sb_transaction_ok_simple() -> Result<(), Box<dyn Error>> {
let db_pool = init_db().await?;
let test_title_1 = "test sb_transaction_ok_simple title 01";
let fields = vec![("title", test_title_1).into()];
let sb = sqlb::insert().table("todo").data(fields);
let mut db_tx = db_pool.begin().await?;
let row_affected = sqlx_exec::exec(&mut *db_tx, &sb).await?;
assert_eq!(1, row_affected, "row_affected");
Ok(())
}
#[serial]
#[tokio::test]
async fn sb_schema_ok_simple() -> Result<(), Box<dyn Error>> {
let db_pool = init_db().await?;
let test_title_1 = "test sb_schema_ok_simple title 01";
let fields = vec![("title", test_title_1).into()];
let sb = sqlb::insert().table("public.todo").data(fields);
let row_affected = sqlx_exec::exec(&db_pool, &sb).await?;
assert_eq!(1, row_affected, "row_affected");
Ok(())
}