成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專(zhuān)欄INFORMATION COLUMN

Ogg For Bigdata 同步數(shù)據(jù)多一列

IT那活兒 / 1055人閱讀
Ogg For Bigdata 同步數(shù)據(jù)多一列

點(diǎn)擊上方“IT那活兒”公眾號(hào)，關(guān)注后了解更多內(nèi)容，不管IT什么活兒，干就完了?。。?/strong>

最近業(yè)務(wù)反饋kafka解析出的sql語(yǔ)句多一列，對(duì)比表字段后發(fā)現(xiàn)果然多一列，并且多的這一列在倒數(shù)第三行且是0。該數(shù)據(jù)源是ogg for bigdata。在復(fù)制進(jìn)程的report 文件中發(fā)現(xiàn)了端倪。

源端表結(jié)構(gòu)是沒(méi)有這一列的。由于是往kafka同步，附加日志添加的是全字段。在向公司老哥說(shuō)明情況后，發(fā)現(xiàn)與跨年見(jiàn)表期間一個(gè)現(xiàn)象很類(lèi)似。根據(jù)當(dāng)時(shí)的mos發(fā)現(xiàn)了問(wèn)題所在。

下面的例子證明了這一點(diǎn)：
--創(chuàng)建這個(gè)表，但是先不創(chuàng)建 DEAL_TYPE 列。
SQL> CREATE TABLE "TEST"
( "MIDPLATORDERID" VARCHAR2(64) NOT NULL ENABLE,
"OPPOORDERID" VARCHAR2(64) NOT NULL ENABLE,
"SERVICETYPE" VARCHAR2(2) NOT NULL ENABLE,
"PHONEID" VARCHAR2(20) NOT NULL ENABLE,
"REGION" VARCHAR2(3) NOT NULL ENABLE,
"PRODUCTID" VARCHAR2(32) NOT NULL ENABLE,
"PRODUCTNAME" VARCHAR2(128) NOT NULL ENABLE,
"PRODUCTNAMEANDFEE" VARCHAR2(128) NOT NULL ENABLE,
"FEECOURSE" VARCHAR2(128),
"ORIGINFEE" VARCHAR2(9) NOT NULL ENABLE,
"PREFEE" VARCHAR2(9) NOT NULL ENABLE,
"TOTALFEE" VARCHAR2(9) NOT NULL ENABLE,
"COSTUNIT" VARCHAR2(2) NOT NULL ENABLE,
"ORDERTIME" DATE NOT NULL ENABLE,
"REQUESTTIME" DATE NOT NULL ENABLE,
"PROORDERID" VARCHAR2(32) NOT NULL ENABLE,
"REALFEE" VARCHAR2(9) NOT NULL ENABLE,
"DEDUCTTIME" DATE NOT NULL ENABLE,
"STATUS" VARCHAR2(2) NOT NULL ENABLE
) ;
--可以看到有19個(gè)列被創(chuàng)建出來(lái)了：
SQL> select column_name,data_type,DATA_LENGTH from user_tab_cols where table_name = TEST;

COLUMN_NAME DATA_TYPE DATA_LENGTH
------------------------- -------------------- -----------
MIDPLATORDERID VARCHAR2 64
OPPOORDERID VARCHAR2 64
SERVICETYPE VARCHAR2 2
PHONEID VARCHAR2 20
REGION VARCHAR2 3
PRODUCTID VARCHAR2 32
PRODUCTNAME VARCHAR2 128
PRODUCTNAMEANDFEE VARCHAR2 128
FEECOURSE VARCHAR2 128
ORIGINFEE VARCHAR2 9
PREFEE VARCHAR2 9
TOTALFEE VARCHAR2 9
COSTUNIT VARCHAR2 2
ORDERTIME DATE 7
REQUESTTIME DATE 7
PROORDERID VARCHAR2 32
REALFEE VARCHAR2 9
DEDUCTTIME DATE 7
STATUS VARCHAR2 2

19 rows selected.
--添加一個(gè)帶 default value 的 列 DEAL_TYPE：
SQL> ALTER TABLE TEST ADD (DEAL_TYPE VARCHAR2(1) DEFAULT 0);

Table altered.
--這之后可以看到 user_tab_cols / dba_tab_cols 顯示了 21 個(gè)列，并且包括一個(gè) SYS_NC000XX$ 的列：
SQL> select column_name,data_type,DATA_LENGTH from user_tab_cols where table_name = TEST;

COLUMN_NAME DATA_TYPE DATA_LENGTH
------------------------- -------------------- -----------
MIDPLATORDERID VARCHAR2 64
OPPOORDERID VARCHAR2 64
SERVICETYPE VARCHAR2 2
PHONEID VARCHAR2 20
REGION VARCHAR2 3
PRODUCTID VARCHAR2 32
PRODUCTNAME VARCHAR2 128
PRODUCTNAMEANDFEE VARCHAR2 128
FEECOURSE VARCHAR2 128
ORIGINFEE VARCHAR2 9
PREFEE VARCHAR2 9
TOTALFEE VARCHAR2 9
COSTUNIT VARCHAR2 2
ORDERTIME DATE 7
REQUESTTIME DATE 7
PROORDERID VARCHAR2 32
REALFEE VARCHAR2 9
DEDUCTTIME DATE 7
STATUS VARCHAR2 2
SYS_NC00020$ RAW 126 <===============
DEAL_TYPE VARCHAR2 1

21 rows selected.
知道了問(wèn)題所在后，解決方法很簡(jiǎn)單，只要在源端抓取數(shù)據(jù)的時(shí)候，指定具體的列名稱(chēng)。
如：
TABLE test.test ,cols(col1,col3);



本文作者：呂金臣(上海新炬王翦團(tuán)隊(duì)）

本文來(lái)源：“IT那活兒”公眾號(hào)

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/129188.html

相關(guān)文章

  • OGG Integrated Native DDL簡(jiǎn)單測(cè)試

    OGG Integrated Native DDL簡(jiǎn)單測(cè)試 img{ display:block; margin:0 auto !important; width:100%; } body{ width:75%;...

    IT那活兒 評(píng)論0 收藏1085

  • Hive的安裝及配置

    摘要：本文將逐一介紹連接這三種數(shù)據(jù)庫(kù)數(shù)據(jù)庫(kù)的安裝和配置。配置環(huán)境變量在文件中添加如下內(nèi)容，執(zhí)行使其生效。 title: Hive的安裝及配置summary: 關(guān)鍵詞：Hive ubuntu 安裝和配置 Derby MySQL PostgreSQL 數(shù)據(jù)庫(kù)連接date: 2019-5-19 13:25urlname: 2019051903author: foochaneimg: /media...

    v1 評(píng)論0 收藏0

  • Hadoop分布式集群的搭建

    摘要：分布式集群的搭建關(guān)鍵詞分布式集群環(huán)境搭建網(wǎng)絡(luò)配置環(huán)境大數(shù)據(jù)大數(shù)據(jù)本文作者本文鏈接安裝說(shuō)明用到的軟件軟件版本下載地址節(jié)點(diǎn)安排名稱(chēng)主節(jié)點(diǎn)子節(jié)點(diǎn)子節(jié)點(diǎn)創(chuàng)建用戶(hù)所有的節(jié)點(diǎn)均創(chuàng)建一個(gè)名為的用戶(hù)，并添加管理員權(quán)限。后續(xù)的軟件均可使用此方式配置。 title: Hadoop分布式集群的搭建summary: 關(guān)鍵詞： Hadoop ubuntu 分布式集群 環(huán)境搭建 ssh 網(wǎng)絡(luò)配置 java環(huán)境 ...

    leon 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

最新活動(dòng)
閱讀需要支付1元查看
<