如何使用Apache AGE将一个节点连接到一组节点中的所有节点？

针对你的CSV数据场景，这里提供两种实现方案：基于CSV导入的批量处理，以及直接用SQL生成范围连接的方法。

一、基于CSV文件的批量处理方案 #

1. 先将CSV数据导入PostgreSQL普通表 #

首先创建临时表存储CSV数据：

CREATE TABLE edge_temp (
    start_id VARCHAR(8),
    strength INT,
    start_verse VARCHAR(8),
    end_verse VARCHAR(8)
);

用COPY命令导入CSV文件（替换为你的文件绝对路径）：

COPY edge_temp FROM '/absolute/path/to/your/data.csv' DELIMITER ',' CSV HEADER;

2. 分两种情况创建边 #

处理单个目标顶点的行（end_verse为00000000）

直接为每一行创建从start_id到start_verse的边：

SELECT create_edge(
    'your_graph', -- 替换为你的图名称
    'connects_to', -- 替换为你的边标签
    (SELECT id FROM your_graph.vertex WHERE vertex_id = start_id), -- 假设顶点表名为vertex，ID字段为vertex_id
    (SELECT id FROM your_graph.vertex WHERE vertex_id = start_verse),
    jsonb_build_object('strength', strength)
)
FROM edge_temp
WHERE end_verse = '00000000';

处理范围目标顶点的行

利用PostgreSQL的generate_series生成start_verse到end_verse之间的所有顶点ID，再批量创建边：

WITH range_targets AS (
    SELECT
        start_id,
        strength,
        -- 将字符串ID转为数值生成序列，再转回8位格式化字符串
        TO_CHAR(generate_series(CAST(start_verse AS BIGINT), CAST(end_verse AS BIGINT)), 'FM00000000') AS target_id
    FROM edge_temp
    WHERE end_verse != '00000000'
)
SELECT create_edge(
    'your_graph',
    'connects_to',
    (SELECT id FROM your_graph.vertex WHERE vertex_id = start_id),
    (SELECT id FROM your_graph.vertex WHERE vertex_id = target_id),
    jsonb_build_object('strength', strength)
)
FROM range_targets;

二、直接用SQL实现范围连接（无需CSV） #

如果已经明确要连接的起始顶点和目标范围，可直接用SQL生成目标顶点列表并创建边：

WITH target_vertices AS (
    -- 生成20008022到20008030之间的所有8位格式ID
    SELECT TO_CHAR(generate_series(20008022, 20008030), 'FM00000000') AS vertex_id
)
SELECT create_edge(
    'your_graph',
    'connects_to',
    (SELECT id FROM your_graph.vertex WHERE vertex_id = '01001001'),
    (SELECT id FROM your_graph.vertex WHERE vertex_id = target_vertices.vertex_id),
    '{"strength": 16}'::jsonb
)
FROM target_vertices;

注意事项 #

• 确保所有涉及的顶点已经存在于你的Apache AGE图中，否则create_edge会执行失败
• 如果顶点ID包含非数字字符，需调整generate_series的逻辑来适配ID生成规则
• 对于大规模数据，可考虑使用批量操作或并行处理提升效率

内容的提问来源于stack exchange，提问作者MarkSoulz