Function cbm_store_upsert_node

src/store/store.c:1783–1814

/* ── Node CRUD ──────────────────────────────────────────────────── */

int64_t cbm_store_upsert_node(cbm_store_t *s, const cbm_node_t *n) {
    sqlite3_stmt *stmt =
        prepare_cached(s, &s->stmt_upsert_node,
                       "INSERT INTO nodes (project, label, name, qualified_name, file_path, "
                       "start_line, end_line, properties) "
                       "VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8) "
                       "ON CONFLICT(project, qualified_name) DO UPDATE SET "
                       "label=?2, name=?3, file_path=?5, start_line=?6, end_line=?7, properties=?8 "
                       "RETURNING id;");
    if (!stmt) {
        return CBM_STORE_ERR;
    }

    bind_text(stmt, SKIP_ONE, safe_str(n->project));
    bind_text(stmt, ST_COL_2, safe_str(n->label));
    bind_text(stmt, ST_COL_3, safe_str(n->name));
    bind_text(stmt, ST_COL_4, safe_str(n->qualified_name));
    bind_text(stmt, ST_COL_5, safe_str(n->file_path));
    sqlite3_bind_int(stmt, ST_COL_6, n->start_line);
    sqlite3_bind_int(stmt, ST_COL_7, n->end_line);
    bind_text(stmt, ST_COL_8, safe_props(n->properties_json));

    int rc = sqlite3_step(stmt);
    if (rc == SQLITE_ROW) {
        int64_t id = sqlite3_column_int64(stmt, 0);
        sqlite3_reset(stmt); /* unblock COMMIT — RETURNING leaves stmt active */
        return id;
    }
    sqlite3_reset(stmt);
    store_set_error_sqlite(s, "upsert_node");
    return CBM_STORE_ERR;
}

/* Scan a node from current row of stmt. Heap-allocates strings. */
static void scan_node(sqlite3_stmt *stmt, cbm_node_t *n) {