ormer 0.1.2

#[derive(Debug, ormer::Model)]
#[table = "test_users"]
struct TestUser {
    #[primary]
    id: i32,
    name: String,
    age: i32,
}

#[tokio::test]
async fn test_insert_single_and_batch() -> Result<(), Box<dyn std::error::Error>> {
    // 连接数据库
    let db = ormer::Database::connect(ormer::DbType::Turso, ":memory:").await?;
    db.create_table::<TestUser>().await?;

    // 测试插入单个对象
    db.insert(&TestUser {
        id: 1,
        name: "Alice".to_string(),
        age: 20,
    })
    .await?;
    println!("插入单个对象成功");

    // 查询验证
    let users = db.select::<TestUser>().collect::<Vec<_>>().await?;
    assert_eq!(users.len(), 1);
    assert_eq!(users[0].name, "Alice");
    println!("第一次查询: {:?}", users);

    // 测试插入 Vec（使用 &vec![...]）
    db.insert(&vec![
        TestUser {
            id: 2,
            name: "Bob".to_string(),
            age: 25,
        },
        TestUser {
            id: 3,
            name: "Charlie".to_string(),
            age: 30,
        },
    ])
    .await?;
    println!("插入 Vec 成功");

    // 查询验证
    let users = db.select::<TestUser>().collect::<Vec<_>>().await?;
    assert_eq!(users.len(), 3);
    println!("第二次查询: {:?}", users);

    // 测试插入数组切片
    let users_array = vec![
        TestUser {
            id: 4,
            name: "David".to_string(),
            age: 35,
        },
        TestUser {
            id: 5,
            name: "Eve".to_string(),
            age: 28,
        },
    ];
    db.insert(&users_array).await?;
    println!("插入数组切片成功");

    // 查询验证
    let users = db.select::<TestUser>().collect::<Vec<_>>().await?;
    assert_eq!(users.len(), 5);
    println!("第三次查询: {:?}", users);

    println!("\n测试通过！insert 方法支持单个对象和数组");

    Ok(())
}

#[tokio::test]
async fn test_insert_or_update_single_and_batch() -> Result<(), Box<dyn std::error::Error>> {
    // 连接数据库
    let db = ormer::Database::connect(ormer::DbType::Turso, ":memory:").await?;
    db.create_table::<TestUser>().await?;

    // 测试插入或更新单个对象
    db.insert_or_update(&TestUser {
        id: 1,
        name: "Alice".to_string(),
        age: 20,
    })
    .await?;
    println!("第一次 insert_or_update 单个对象成功");

    // 查询验证
    let users = db.select::<TestUser>().collect::<Vec<_>>().await?;
    assert_eq!(users.len(), 1);
    assert_eq!(users[0].name, "Alice");
    println!("第一次查询: {:?}", users);

    // 使用 insert_or_update 更新同一条记录
    db.insert_or_update(&TestUser {
        id: 1,
        name: "Alice Updated".to_string(),
        age: 21,
    })
    .await?;
    println!("第二次 insert_or_update 单个对象成功（更新操作）");

    // 查询验证
    let users = db.select::<TestUser>().collect::<Vec<_>>().await?;
    assert_eq!(users.len(), 1);
    assert_eq!(users[0].name, "Alice Updated");
    assert_eq!(users[0].age, 21);
    println!("第二次查询: {:?}", users);

    // 测试批量 insert_or_update
    db.insert_or_update(&vec![
        TestUser {
            id: 1,
            name: "Alice Again".to_string(),
            age: 22,
        },
        TestUser {
            id: 2,
            name: "Bob".to_string(),
            age: 25,
        },
        TestUser {
            id: 3,
            name: "Charlie".to_string(),
            age: 30,
        },
    ])
    .await?;
    println!("批量 insert_or_update 成功");

    // 查询验证
    let users = db.select::<TestUser>().collect::<Vec<_>>().await?;
    assert_eq!(users.len(), 3);
    assert_eq!(users[0].name, "Alice Again"); // id=1 被更新
    assert_eq!(users[1].name, "Bob"); // id=2 新插入
    assert_eq!(users[2].name, "Charlie"); // id=3 新插入
    println!("第三次查询: {:?}", users);

    println!("\n测试通过！insert_or_update 方法支持单个对象和数组");

    Ok(())
}