use super::{Order, QueryKind};
use surrealdb::types::RecordId;
#[test]
fn pagin_uses_bind_placeholders() {
let sql = QueryKind::pagin("user", 10, true, Order::Asc, "id");
assert!(sql.contains("$cursor_value"));
assert!(sql.contains("$cursor_record"));
assert!(sql.contains("LIMIT $count"));
assert!(!sql.contains("DELETE user"));
}
#[test]
fn pagin_uses_stable_tiebreaker_cursor_predicate() {
let sql = QueryKind::pagin("user", 10, true, Order::Desc, "created_at");
assert!(sql.contains("$cursor_value"));
assert!(sql.contains("$cursor_record"));
assert!(sql.contains("OR"));
assert!(sql.contains("record::id(id)"));
}
#[test]
fn pagin_uses_public_id_projection_when_ordering_by_id() {
let sql = QueryKind::pagin("user", 10, true, Order::Desc, "__page_public_id");
assert!(sql.contains("__page_public_id < $cursor_value"));
assert!(sql.contains("ORDER BY __page_public_id DESC, __page_record DESC"));
}
#[test]
fn ordered_scan_uses_stable_tiebreaker() {
let sql = QueryKind::all_by_order("user", Order::Desc, "created_at");
assert!(sql.contains("record::id(id) AS __page_public_id"));
assert!(sql.contains("ORDER BY created_at DESC, __page_record DESC"));
}
#[test]
fn ordered_scan_uses_public_id_projection_when_ordering_by_id() {
let sql = QueryKind::all_by_order("user", Order::Asc, "id");
assert!(sql.contains("SELECT *, __page_public_id AS id FROM $rows"));
assert!(sql.contains("ORDER BY __page_public_id ASC, __page_record ASC"));
}
#[test]
fn view_ordered_scan_includes_hidden_source_order_field() {
let sql = QueryKind::view_all_by_order(Order::Asc, "created_at", &["title"]);
assert!(sql.contains("SELECT created_at, title, id AS __page_record"));
assert!(
sql.contains("SELECT created_at, title, __page_public_id AS id, __page_record FROM $rows")
);
assert!(sql.contains("ORDER BY created_at ASC, __page_record ASC"));
}
#[test]
fn view_record_scan_carries_source_record_without_polluting_view_id() {
let sql = QueryKind::view_all_with_record(&["title"]);
assert!(sql.contains("record::id(id) AS id"));
assert!(sql.contains("id AS __appdb_record"));
assert!(
sql.find("id AS __appdb_record")
.expect("source record projection should exist")
< sql
.find("record::id(id) AS id")
.expect("public id projection should exist")
);
}
#[test]
fn view_relation_queries_project_related_view_rows() {
let outgoing = QueryKind::view_outgoing(&["title"]);
assert!(outgoing.contains("LET $ids ="));
assert!(outgoing.contains("record::tb(out) = $out_table"));
assert!(outgoing.contains("id AS __appdb_record"));
assert!(outgoing.contains("FROM $ids"));
let incoming = QueryKind::view_incoming(&["title"]);
assert!(incoming.contains("record::tb(in) = $in_table"));
assert!(incoming.contains("id AS __appdb_record"));
}
#[test]
fn view_relation_batch_queries_preserve_owner_and_related_record_evidence() {
let outgoing = QueryKind::view_outgoing_many(&["title"]);
assert!(outgoing.contains("in AS __appdb_owner"));
assert!(outgoing.contains("out.id AS __appdb_record"));
assert!(outgoing.contains("in IN $ins"));
assert!(outgoing.contains("record::tb(out) = $out_table"));
let incoming = QueryKind::view_incoming_many(&["title"]);
assert!(incoming.contains("out AS __appdb_owner"));
assert!(incoming.contains("in.id AS __appdb_record"));
assert!(incoming.contains("out IN $outs"));
assert!(incoming.contains("record::tb(in) = $in_table"));
}
#[test]
fn single_field_lookup_uses_dynamic_field_and_reports_multiple_matches() {
let sql = QueryKind::select_id_single("user");
assert_eq!(
sql,
"SELECT VALUE id FROM $table WHERE type::field($k) = $v LIMIT 2;"
);
}
#[test]
fn relation_lookups_use_bind_placeholders() {
let in_id = RecordId::new("user", "u1");
let sql = QueryKind::select_out_ids(&in_id, "follows", "user");
assert!(sql.contains("FROM $rel"));
assert!(sql.contains("record::tb(out) = $out_table"));
}
#[test]
fn graph_accessors_use_bind_placeholders() {
let in_id = RecordId::new("user", "u1");
let out_sql = QueryKind::select_outgoing_rows(&in_id, "follows", "user");
assert!(out_sql.contains("LET $ids ="));
assert!(out_sql.contains("record::tb(out) = $out_table"));
assert!(out_sql.contains("FROM $ids"));
let count_sql = QueryKind::count_incoming_in_table(&in_id, "follows", "user");
assert!(count_sql.contains("count((SELECT VALUE in FROM $rel"));
assert!(count_sql.contains("record::tb(in) = $in_table"));
}
#[test]
fn relate_uses_relation_insert() {
let in_id = RecordId::new("task", "t1");
let out_id = RecordId::new("member", "m1");
let sql = QueryKind::relate(&in_id, &out_id, "task_assignment");
assert!(sql.starts_with("INSERT RELATION INTO $rel"));
}
#[test]
fn table_has_rows_returns_a_boolean_probe() {
let sql = QueryKind::table_has_rows("user");
assert_eq!(
sql,
"RETURN count((SELECT VALUE id FROM $table LIMIT 1)) > 0;"
);
}