V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
sirthisman
V2EX  ›  PostgreSQL

有什么不通过写脚本的方式,将 postgreSQL 的建表语句转换为 doris 的建表语句吗?

  •  
  •   sirthisman · 249 天前 · 1558 次点击
    这是一个创建于 249 天前的主题,其中的信息可能已经有所发展或是发生改变。

    求助,我们要做从 hawq 引擎(建表语句是 postgreSQL 格式)到 Starrocks (建表语句是 doris 格式)数据库的数据迁移。大概数百张表。需要在 Starrocks 中同步对应表结构。请教下各位有什么工具可以批量转换建表语句么?

    9 条回复    2024-03-14 13:48:39 +08:00
    smallpigzbl
        1
    smallpigzbl  
       249 天前
    chatgpt ,我常用的是丢一段表结构给它,转成 yml 格式给我。。。
    amoia50
        2
    amoia50  
       249 天前
    antlr 语法解析,可以外包支持
    hemingwang0902
        3
    hemingwang0902  
       249 天前
    @smallpigzbl 正解
    dRider
        4
    dRider  
       249 天前
    语法树转换,我之前做数据平台的是 hive\mysql\doris\Clickhouse 的可视化转换和自动建表,可以参考我之前做的: https://github.com/DLuPan/DorisParser
    zouzou0208
        5
    zouzou0208  
       248 天前
    qsbaq
        6
    qsbaq  
       248 天前
    直接丢给 ai
    weiiai
        7
    weiiai  
       245 天前
    Starrocks 官方有工具,可以去论坛看看
    sirthisman
        8
    sirthisman  
    OP
       239 天前
    尝试自己写个 SQL 拼一下:
    --拼 Starrocks 建表语句
    select
    'CREATE TABLE IF NOT EXISTS '||table_schema||'.'||table_name||' (
    ' tb
    ,string_agg(column_all,',
    ' order by ordinal_position)||'
    )
    ' cb
    ,'COMMENT '||'"'||table_comment||'"'
    ,分桶键
    from(
    select
    c.column_name||' '||case when c.data_type in('character','character varying','text') then 'string'
    when c.data_type in('numeric','real') then 'decimal'||(case when COALESCE(character_maximum_length,numeric_precision) is not null and numeric_scale>0
    then '('||COALESCE(character_maximum_length,numeric_precision)||','||numeric_scale ||')'
    else '' end)
    when c.data_type like 'time%' then 'datetime'
    when c.data_type like 'double%' then 'double'
    else c.data_type end||' comment '||'"'||c.column_name||'"' column_all
    ,t.table_schema
    ,t.table_name
    ,a.table_comment
    ,c.ordinal_position
    ,c.column_name
    ,c.data_type
    ,COALESCE ( character_maximum_length, numeric_precision, - 1 ) AS LENGTHTYPE
    ,numeric_scale
    ,a.column_comment
    ,分桶键
    from information_schema.tables t
    left join information_schema.COLUMNS c on t.table_name = c.table_name and t.table_schema=c.table_schema
    left join (select
    b.nspname,
    a.relname,
    cast( obj_description (a.relfilenode, 'pg_class' ) AS VARCHAR ) AS table_comment,
    d.attname,
    c.description as column_comment
    from pg_class a
    left join pg_namespace b on a.relnamespace=b.oid
    left join pg_description c on c.objoid = a.oid
    left join pg_attribute d on c.objoid=d.attrelid and d.attnum = c.objsubid
    left join pg_type o on d.atttypid=o.oid
    ) a on a.nspname=c.table_schema and a.relname = c.table_name and a.attname=c.column_name
    left join (select
    table_schema
    ,table_name
    ,'DISTRIBUTED BY HASH('||case when ordinal_position=1 then column_name end||') PROPERTIES ("replication_num" = "1");' 分桶键
    from information_schema.COLUMNS
    where ordinal_position=1
    ) p on p.table_name = c.table_name and p.table_schema=c.table_schema
    where t.table_schema in ('tds'/*,'ext','rds','rpt','udt'*/)
    order by t.table_schema
    ,t.table_name
    ,c.ordinal_position
    ) d
    group by table_schema
    ,table_name
    ,table_comment
    ,分桶键
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   3444 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 27ms · UTC 11:43 · PVG 19:43 · LAX 03:43 · JFK 06:43
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.