How to use rust sdk to write a transaction?

[HaoYang670]

Same as the title. Thanks

[Dhghomon]

There's no dedicated method for a transaction but you can put multiple statements into a single query, including inside a transaction:

let mut query = db.query("begin; create person; create person; throw 'Bad transaction!'; commit;").await.unwrap();
    println!("Number of statements: {}\nReturned: {query:#?}", query.num_statements());
    let errs = query.take_errors();
    println!("Errors: {errs:?}");

Is that enough for your use case?

[HaoYang670]

yes. I have tried to use surrealql, it works well

[HuakunShen]

I saw a transaction method in rust, but it doesn't seem to work. Even if I don't run commit, the data is still written to DB.
And the speed is super low comparing to sqlite. 14_000_000 queries took 10s for sqlite, and 11 minutes for surreal DB.
I am guessing it's because of transaction.

I tried to do transaction with JS in one transaction by concatenating the query strings into one because the js library doesn't have transaction method.
But I get all kinds of error, such as out of memory.

https://gist.github.com/HuakunShen/4530b36a5934c22084cd44f0f16f021d#file-surreal-rocks-rs-L49

    let tx = db.transaction().await?;
    // Process each record
    for result in rdr.records() {
        let record = result?;

        let birth_year = match &record[2] {
            "\\N" => None,
            year => Some(year.parse::<i32>()?),
        };

        let death_year = match &record[3] {
            "\\N" => None,
            year => Some(year.parse::<i32>()?),
        };
        // Create record in SurrealDB
        let name = NameBasic {
            nconst: record[0].to_string(),
            primary_name: record[1].to_string(),
            birth_year,
            death_year,
            primary_profession: record[4].to_string(),
            known_for_titles: record[5].to_string(),
        };

        // Insert using the nconst as the record ID
        (&tx)
            .create::<Option<NameBasic>>("name_basic")
            .content(name)
            .await?;
        count += 1;
        if count % 100_000 == 0 {
            println!("Processed {} NameBasics", count);
        }
    }

    println!("Starting database insert...");
    tx.commit().await?;