當(dāng)前位置:首頁(yè) >  站長(zhǎng) >  數(shù)據(jù)庫(kù) >  正文

postgresql數(shù)據(jù)庫(kù) timescaledb 時(shí)序庫(kù) 把大數(shù)據(jù)量表轉(zhuǎn)換為超表的問(wèn)題

 2021-04-23 16:52  來(lái)源: 腳本之家   我來(lái)投稿 撤稿糾錯(cuò)

  域名預(yù)訂/競(jìng)價(jià),好“米”不錯(cuò)過(guò)

前言

這幾天工作的時(shí)候發(fā)現(xiàn)在 timescaledb 時(shí)序庫(kù) 中有部分大數(shù)據(jù)量的表不是超表,估計(jì)是當(dāng)時(shí)建庫(kù)的時(shí)候沒(méi)有改 影響插入,查詢效率 ,因此需要改成超表

因工作原因 部分內(nèi)容做保密處理了

一 創(chuàng)建新表

首先因?yàn)樵?timescaledb 時(shí)序庫(kù) 中創(chuàng)建超表必須是要沒(méi)有數(shù)據(jù)的表

因此第一步是 創(chuàng)建一張跟原表一模一樣的表(表名后面加個(gè)_cs) 你可以直接copy建表語(yǔ)句,也可以直接用工具復(fù)制表結(jié)構(gòu)

二 把新表改為超表

把新建的表改為超表,7天一分區(qū)

--我是7天一分區(qū)
SELECT create_hypertable('表名_cs', 'alarm_time', chunk_time_interval => INTERVAL '7 day');
-- 加個(gè)索引
CREATE INDEX "表名_cs_create_time_idx" ON "hrmw"."表名_cs" USING btree (
 "create_time" "code"."列名" DESC NULLS FIRST
);

 

三 插入數(shù)據(jù)

1.數(shù)據(jù)量不大的情況可以直接插入

1INSERT into 表名_cs SELECT * from 表名;

2.如果數(shù)據(jù)量比較大 可以采取 一天一天 插入 或者一個(gè)月 或者幾個(gè)月一起插入

INSERT into 表名_cs SELECT * from 表名 where alarm_time >= '2020-9-1';INSERT into 表名_cs SELECT * from 表名 where alarm_time >= '2020-10-1' and alarm_time < '2020-11-1' ;

3.運(yùn)用函數(shù)(儲(chǔ)存過(guò)程)

對(duì)于表數(shù)據(jù)量太大,一天一天的插入的話 可以運(yùn)用儲(chǔ)存過(guò)程(postgresql 數(shù)據(jù)庫(kù)叫函數(shù))

下面是我寫(xiě)的函數(shù)。大家可以借鑒

CREATE
 OR REPLACE PROCEDURE "hrmw"."sp_into_表名_pt" ( ) AS $BODY$ BEGIN
 -- 一般按照表名來(lái)建函數(shù)
 DECLARE --我聲明的變量有點(diǎn)多 按實(shí)際的來(lái)
  target_text TEXT;
 sqltext TEXT;
 sqltext1 TEXT;
 sqltext2 TEXT;
 rd record;
 nloop INT;
 isexist TEXT;
 datestr TEXT;
 begindate TEXT;
 n INT;
 BEGIN
   --查詢最早一天的時(shí)間
   sqltext := 'select to_char(min(alarm_time),''yyyy-mm-dd'') datestr from tb_hrmw_moni_target';   
  EXECUTE sqltext INTO begindate;
  n := date_part( 'day', now( ) - begindate :: DATE );
--enddate:=(to_char(now(),'yyyy-mm-dd'))::text;
  FOR nloop IN 0..n
  LOOP
  datestr := ( begindate :: DATE + nloop ) :: TEXT;
  sqltext2 := '
  insert into 表名_cs
  select
  列名1,
  code,
  列名2,
  alarm_time,
  列名3,
  列名4
  from 表名
  where alarm_time >= ''' || datestr || ' 00:00:00''
  and alarm_time <= ''' || datestr || ' 23:59:59''
  ';
  EXECUTE sqltext2;
  COMMIT;
  
 END loop;
RETURN;

END;

END $BODY$ LANGUAGE plpgsql

 

END loop;RETURN;

END;

END $BODY$ LANGUAGE plpgsql

四 查看效果

模式 _timescaledb_internal下面的就是分區(qū)

文章來(lái)源:腳本之家

來(lái)源地址:https://www.jb51.net/article/205450.htm

申請(qǐng)創(chuàng)業(yè)報(bào)道,分享創(chuàng)業(yè)好點(diǎn)子。點(diǎn)擊此處,共同探討創(chuàng)業(yè)新機(jī)遇!

相關(guān)文章

熱門(mén)排行

信息推薦