Function cbm_store_insert_edge

src/store/store.c:2041–2071

/* ── Edge CRUD ──────────────────────────────────────────────────── */

int64_t cbm_store_insert_edge(cbm_store_t *s, const cbm_edge_t *e) {
    /* Conflict target includes local_name_gen (#768) so IMPORTS edges with
     * different local_name coexist while re-inserting the same import still
     * upserts. Must match the table's UNIQUE constraint in init_schema. */
    sqlite3_stmt *stmt =
        prepare_cached(s, &s->stmt_insert_edge,
                       "INSERT INTO edges (project, source_id, target_id, type, properties) "
                       "VALUES (?1, ?2, ?3, ?4, ?5) "
                       "ON CONFLICT(source_id, target_id, type, local_name_gen) DO UPDATE SET "
                       "properties = json_patch(properties, ?5) "
                       "RETURNING id;");
    if (!stmt) {
        return CBM_STORE_ERR;
    }

    bind_text(stmt, SKIP_ONE, safe_str(e->project));
    sqlite3_bind_int64(stmt, PAIR_LEN, e->source_id);
    sqlite3_bind_int64(stmt, CBM_SZ_3, e->target_id);
    bind_text(stmt, ST_COL_4, safe_str(e->type));
    bind_text(stmt, ST_COL_5, safe_props(e->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, "insert_edge");
    return CBM_STORE_ERR;
}

/* Scan an edge from current row of stmt. */
static void scan_edge(sqlite3_stmt *stmt, cbm_edge_t *e) {