How to determine whether data exists and does not exist after inserting data, will not repeat.

[huang12zheng]

pub async fn access_mobile(app_id: AppId, mobile: Mobile) -> anyhow::Result<String> {
    let db = DB.get().unwrap();
    // let $mid=176823181;select * from account where ->identity_has->(mobile where id=type::thing('mobile',$mid))
    let mut results = db
    .query(BeginStatement)
    .query("let $aflag=(select id from account where ->identity_has->(mobile where id=type::thing('mobile',$mid)))")
    .query("if array::len($aflag) = 0 then")
    .query("")
    .bind(("mid", mobile.id))
    .await?;
    #[cfg(test)]
    assert_debug_snapshot!(results);
    let ath: Option<String> = results.take((0, "id"))?;
    #[cfg(test)]
    assert_debug_snapshot!(ath);
    if ath.is_none() {
        let aid = Uuid::now_v7().to_string();
        let ath = ("account", aid.to_owned()).into_thing();
        // #[cfg(test)]
        // assert_debug_snapshot!(aid);
        let mid = mobile.id;
        let account = Account {
            app_id: app_id,
            id: aid.to_owned(),
        };

        let _results = db
            .query("let $aret=(create account content $account)")
            .query("let $mret=(create type::thing('mobile',$mid))")
            // https://github.com/surrealdb/surrealdb/issues/1313
            .query("relate $aret->identity_has->$mret")
            .query(CommitStatement)
            .bind(("account", &account))
            .bind(("mid", &mid))
            .await?;
        #[cfg(test)]
        assert_debug_snapshot!(_results);
        Ok(ath.to_string())
    } else {
        db.query(CommitStatement).await?;
        #[cfg(test)]
        assert_debug_snapshot!(ath);
        Ok(ath.unwrap())
    }
}

+Response(
          1 │+    {
          2 │+        0: Ok(
          3 │+            [],
          4 │+        ),
          5 │+        1: Err(
          6 │+            Db(
          7 │+                RecordExists {
          8 │+                    thing: "mobile:176823150",
          9 │+                },
         10 │+            ),
         11 │+        ),
         12 │+        2: Err(
         13 │+            Db(
         14 │+                RelateStatement {
         15 │+                    value: "NONE",
         16 │+                },
         17 │+            ),
         18 │+        ),
         19 │+    },
    2    20 │ )

#[tokio::test]
async fn sigin() {
    set_snapshot_suffix!("sigin");
    set_filters!(r"[0-9a-zA-Z]{20}\b", "[UID]",);
    set_filters!(r"[0-9a-zA-Z-]{36}\b", "[GID]",);
    init_db().await.ok();

    let result1 = access_mobile(1, Mobile { id: 17682318150 }).await.ok();
    let result2 = access_mobile(1, Mobile { id: 17682318150 }).await.ok();
    assert_eq!(result1, result2);
}