Function copy_ndjson_row_failure_aborts

nodedb/tests/sql_copy_from.rs:223–251

()

#[tokio::test]
async fn copy_ndjson_row_failure_aborts() {
    let srv = TestServer::start().await;

    srv.exec("CREATE COLLECTION copy_fail_test (id INT, name TEXT)")
        .await
        .expect("CREATE COLLECTION");

    // Lines 1-2 are fine; line 3 is malformed JSON.
    let ndjson = "{\"id\": 1, \"name\": \"alice\"}\n\
                  {\"id\": 2, \"name\": \"bob\"}\n\
                  {not valid json at all\n\
                  {\"id\": 4, \"name\": \"dave\"}\n";
    let f = write_temp(ndjson, ".ndjson");
    let path = f.path().to_string_lossy().to_string();

    let result = srv
        .exec(&format!("COPY copy_fail_test FROM '{path}'"))
        .await;
    assert!(result.is_err(), "expected COPY to fail on malformed row");

    let err_msg = result.unwrap_err();
    assert!(
        err_msg.contains("3") || err_msg.to_lowercase().contains("row"),
        "error should reference row 3, got: {err_msg}"
    );

    // No rows should have been committed (all-or-nothing semantics).
    assert_eq!(count_rows(&srv, "copy_fail_test").await, 0);
}