IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> ORACLE同步表结构到mysql8.0建表结构 转化自定义函数,高效快捷 -> 正文阅读

[大数据]ORACLE同步表结构到mysql8.0建表结构 转化自定义函数,高效快捷

ORACEL和mysql的数据类型存在较大差异(如Oracle的number和mysql的decimal()
导致我们在数据迁移的时候有不小的麻烦
即使我们使用navicat的同步工具,同步表结构和数据,自动生成的字段类型也并不都是我们想用的,如Oracle的interger 同步过来到mysql变成了decimal(65,30),显然不是我们想要的;

于是乎,参考网上的sql写了一个自定义函数,
调用方式为 select fnc_table_to_mysql(‘’用户名’,‘表名’)from dual;
就可以得到一段创建mysql表结构的SQL。

create or replace function fnc_table_to_mysql
( i_owner                       in string,
  i_table_name                  in STRING
)
/*
  已知问题:
  1.不支持分区
  2.不支持函数索引,位图索引等特殊索引定义
  3.不支持自定义数据类型,不支持ROWID,RAW等特殊数据类型
  4.不支持外键
  5.不支持自定义约束
  6.不支持与空间、事务相关属性
  7.TIMESTAMP转换成datetime,需注意精度
  8.超大NUMBER直接转换为bigint,需注意精度
  */
 return clob is
  Result         clob;
  cnt            number;
  data_type      varchar2(128);
  column_str     varchar2(4000);
  -- pk_str         varchar2(4000);
  table_comments varchar2(4000);
  is_pk_column   number := 0;
begin
  select count(*)
  into cnt
  from all_tables
   where owner = UPPER(i_owner)
   and table_name = UPPER(i_table_name);
  if (cnt = 0) then
  RAISE_APPLICATION_ERROR(-20000,'can''t found table,please check input!');
  else
  Result := 'CREATE TABLE `' || lower(i_table_name) || '`( 
  '; 
  --column
  for c in (select a.column_name,
           a.data_type,
           a.data_length,
           a.data_precision,
           a.data_scale,
           a.nullable,
           a.data_default,
           b.COMMENTS
        from all_tab_cols a, all_col_comments b
         where a.owner = UPPER(i_owner)
         and a.table_name = UPPER(i_table_name)
         and a.HIDDEN_COLUMN = 'NO'
         and a.owner = b.OWNER
         and a.TABLE_NAME = b.TABLE_NAME
         and a.COLUMN_NAME = b.COLUMN_NAME
         order by a.column_id) loop
    if (c.data_type = 'VARCHAR2' or c.data_type = 'NVARCHAR2') then
    data_type := 'varchar(' || c.data_length || ')';
    elsif (c.data_type = 'CHAR' or c.data_type = 'NCHAR') then
    data_type := 'varchar(' || c.data_length || ')';
    elsif (c.data_type = 'NUMBER') then
    if (c.column_name like '%ID' and c.data_scale is null) then
      data_type := 'bigint';
    elsif (c.data_precision<3 and c.data_scale = 0) then
      data_type := 'tinyint';
    elsif (c.data_precision<5 and c.data_scale = 0) then
      data_type := 'smallint';
    elsif (c.data_precision<10 and c.data_scale = 0) then
      data_type := 'int';
    elsif (c.data_precision is not null and c.data_scale = 0) then
      data_type := 'bigint';
    elsif (c.data_precision is not null and c.data_scale is not null) then
      data_type := 'decimal(' || c.data_precision || ',' ||
             c.data_scale || ')';
    else
      data_type := 'decimal(32,4)';
    end if;
    elsif (c.data_type = 'DATE' ) then
    data_type := 'date';
     elsif (c.data_type = 'DATETIME' OR c.data_type like 'TIMESTAMP%') then
    data_type := 'datetime';
    elsif (c.data_type = 'CLOB' or c.data_type = 'NCLOB' or
      c.data_type = 'LONG') then
    data_type := 'text';
    elsif (c.data_type = 'BLOB' or c.data_type = 'LONG RAW') then
    data_type := 'blob';
    elsif (c.data_type = 'BINARY_FLOAT') then
    data_type := 'float';
    elsif (c.data_type = 'BINARY_DOUBLE') then
    data_type := 'double';
    else
    data_type := c.data_type;
    end if;
    column_str := '  `' || lower(c.column_name) || '` ' || data_type;
    if (c.column_name like '%ID' and
     (c.data_scale is null or c.data_scale = 0)) then
    select count(*)
      into is_pk_column
      from all_constraints a, all_cons_columns b
     where a.owner = UPPER(i_owner)
       and a.table_name = UPPER(i_table_name)
       and a.constraint_type = 'P'
       and a.OWNER = b.OWNER
       and a.TABLE_NAME = b.TABLE_NAME
       and a.CONSTRAINT_NAME = b.CONSTRAINT_NAME
       and b.COLUMN_NAME = c.column_name;
    if is_pk_column > 0 then
      column_str := column_str ;
    end if;
    end if;
    if c.nullable = 'NO' then
    column_str := column_str || ' NOT NULL';
    end if;
    if (trim(c.data_default) is not null) then
    column_str := column_str || ' DEFAULT ' ||
            trim(replace(replace(c.data_default, chr(13), ''),
                   chr(10),
                   ''));
    end if;
    if c.comments is not null then
    --column_str := column_str || ' COMMENT ''' || c.comments || '''';
    column_str := column_str || ' COMMENT ''' || c.comments || '''';
    end if;
    Result := Result || chr(10) || column_str || ',';
  end loop;
  --pk
  for c in (select a.constraint_name, wm_concat(a.column_name) pk_columns
        from (select a.CONSTRAINT_NAME,
               '`' || b.COLUMN_NAME || '`' column_name
            from all_constraints a, all_cons_columns b
             where a.owner = UPPER(i_owner)
             and a.table_name = UPPER(i_table_name)
             and a.constraint_type = 'P'
             and a.OWNER = b.OWNER
             and a.TABLE_NAME = b.TABLE_NAME
             and a.CONSTRAINT_NAME = b.CONSTRAINT_NAME
             order by b.POSITION) a
         group by a.constraint_name) loop
    Result := Result || chr(10) || '  PRIMARY KEY (' ||
        lower(c.pk_columns) || '),';
  end loop;
  --unique
  for c in (select a.constraint_name, wm_concat(a.column_name) uk_columns
        from (select a.CONSTRAINT_NAME,
               '`' || b.COLUMN_NAME || '`' column_name
            from all_constraints a, all_cons_columns b
             where a.owner = UPPER(i_owner)
             and a.table_name = UPPER(i_table_name)
             and a.constraint_type = 'U'
             and a.OWNER = b.OWNER
             and a.TABLE_NAME = b.TABLE_NAME
             and a.CONSTRAINT_NAME = b.CONSTRAINT_NAME
             order by b.POSITION) a
         group by a.constraint_name) loop
    Result := Result || chr(10) || '  UNIQUE KEY `' ||
        lower(c.constraint_name) || '`(' || lower(c.uk_columns) || '),';
  end loop;
  -- index
  for c in (select a.index_name, wm_concat(a.column_name) ind_columns
        from (select a.index_name,
               '`' || a.COLUMN_NAME || '`' column_name
            from all_ind_columns a
             where a.table_owner = UPPER(i_owner)
             and a.TABLE_NAME = UPPER(i_table_name)
             and not exists
             (select index_name
                from all_constraints b
                 where a.TABLE_OWNER = b.owner
                 and a.TABLE_NAME = b.TABLE_NAME
                 and a.INDEX_NAME = b.INDEX_NAME)
             order by a.COLUMN_POSITION) a
         group by a.index_name) loop
    Result := Result || chr(10) || '  KEY `' || lower(c.index_name) || '`(' ||
        lower(c.ind_columns) || '),';
  end loop;
  Result := substr(Result, 1, length(result) - 1) || chr(10) || ')';
  --table comments
  select max(a.COMMENTS)
    into table_comments
    from all_tab_comments a
   where owner = UPPER(i_owner)
     and table_name = UPPER(i_table_name);
  if (table_comments is not null) then
    Result := Result || 'COMMENT=''' || table_comments || '''';
  end if;
  Result := Result || ';';
  end if;
  return(Result);
end fnc_table_to_mysql;

参考于:https://blog.csdn.net/weixin_42531396/article/details/113123942?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522165207756116782246448404%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fall.%2522%257D&request_id=165207756116782246448404&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2allfirst_rank_ecpm_v1~rank_v31_ecpm-2-113123942-null-null.142v9control,157v4control&utm_term=mysql%E5%BB%BA%E8%A1%A8%E7%9A%84%E6%97%B6%E5%80%99%E5%8F%AF%E4%BB%A5%E7%94%A8trim%EF%BC%88%EF%BC%89%E5%90%97&spm=1018.2226.3001.4187

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-05-11 16:30:44  更:2022-05-11 16:33:14 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/23 22:58:34-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码