PostgreSQL批量修改函數(shù)擁有者的操作

更新時(shí)間：2021年01月04日 11:10:42 作者：modestchen

這篇文章主要介紹了PostgreSQL批量修改函數(shù)擁有者的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

Postgresql如何批量修改函數(shù)擁有者，默認(rèn)創(chuàng)建的函數(shù)對(duì)象的擁有者為當(dāng)前創(chuàng)建的用戶，如果使用postgres超級(jí)管理員創(chuàng)建一個(gè)test()的函數(shù)，擁有者就是postgres用戶。下面講解下如何批量修改擁有者。

本文演示的Postgresql版本如下：

PostgreSQL 9.6.8

名稱	數(shù)據(jù)類型	備注
specific_schema	sql_identifier	包含該函數(shù)的模式名
routine_name	sql_identifier	該函數(shù)的名字（在重載的情況下可能重復(fù)）
specific_name	sql_identifier	該函數(shù)的"專用名"。這是一個(gè)在模式中唯一標(biāo)識(shí)該函數(shù)的名稱，即使該函數(shù)真正的名稱已經(jīng)被重載。專用名的格式尚未被定義，它應(yīng)當(dāng)僅被用來(lái)與指定例程名稱的其他實(shí)例進(jìn)行比較。

名稱	數(shù)據(jù)類型	備注
parameter_name	sql_identifier	參數(shù)名，如果參數(shù)沒(méi)有名稱則為空
udt_name	sql_identifier	該參數(shù)的數(shù)據(jù)類型的名字
ordinal_position	cardinal_number	該參數(shù)在函數(shù)參數(shù)列表中的順序位置（從 1 開(kāi)始計(jì)數(shù)）
specific_name	cardinal_number	該函數(shù)的"專用名"。詳見(jiàn)第 35.40 節(jié)。

單個(gè)修改

如果需要修改的函數(shù)只有一個(gè)，請(qǐng)執(zhí)行如下SQL語(yǔ)句即可：

// 無(wú)參數(shù)函數(shù)
ALTER FUNCTION "abc"."test"() OWNER TO "dbadmin";
//帶參數(shù)函數(shù)
ALTER FUNCTION "abc"."test3"(p1 varchar, p2 varchar) OWNER TO "dbadmin";

批量修改

首先可以查詢當(dāng)前模式下函數(shù)的所有者分別是哪個(gè)用戶，使用下面SQL來(lái)查詢：

SELECT 
n.nspname as "Schema",
p.proname as "Name",
pg_catalog.pg_get_function_result(p.oid) as "Result data type",
pg_catalog.pg_get_function_arguments(p.oid) as "Argument data types",
pg_catalog.pg_get_userbyid(p.proowner) as "Owner"
FROM pg_catalog.pg_proc p
  LEFT JOIN pg_catalog.pg_namespace n ON n.oid = p.pronamespace
  LEFT JOIN pg_catalog.pg_language l ON l.oid = p.prolang
WHERE pg_catalog.pg_function_is_visible(p.oid)
  AND n.nspname <> 'pg_catalog'
  AND n.nspname <> 'information_schema'
ORDER BY 1, 2;

當(dāng)前顯示模式“abc”有2個(gè)無(wú)參函數(shù)和1個(gè)帶參函數(shù)，擁有者都是postgres超級(jí)用戶。

然后根據(jù)上面講的兩個(gè)視圖： routines 和 parameters關(guān)聯(lián)查詢出模式下的所有函數(shù)和參數(shù)（目的是為了拼接SQL語(yǔ)句），參考如下：

SELECT 
"routines".specific_schema,
"routines".routine_name, 
COALESCE("parameters".parameter_name, '') AS parameter_name, -- COALESCE返回參數(shù)中的第一個(gè)非null的值
COALESCE("parameters".udt_name, '') AS udt_name,
COALESCE("parameters".parameter_name, '') || ' ' || COALESCE("parameters".udt_name, '') AS params,
"parameters".ordinal_position 
FROM "information_schema"."routines"
LEFT JOIN "information_schema"."parameters" ON "routines".specific_name="parameters".specific_name 
WHERE "routines".specific_schema='abc' 
ORDER BY 1,2,6;

這里我們?cè)偈褂镁酆虾瘮?shù): string_agg 把字段 params所有行連接成字符串，并用逗號(hào)分隔符分隔。

WITH tmp AS (SELECT 
"routines".specific_schema,
"routines".routine_name, 
COALESCE("parameters".parameter_name, '') AS parameter_name, -- COALESCE返回參數(shù)中的第一個(gè)非null的值
COALESCE("parameters".udt_name, '') AS udt_name,
COALESCE("parameters".parameter_name, '') || ' ' || COALESCE("parameters".udt_name, '') AS params,
"parameters".ordinal_position 
FROM "information_schema"."routines"
LEFT JOIN "information_schema"."parameters" ON "routines".specific_name="parameters".specific_name 
WHERE "routines".specific_schema='abc' 
ORDER BY 1,2,6) 
SELECT 
specific_schema, 
routine_name, 
string_agg(params, ',') AS params, 
'"'||specific_schema||'"."'||routine_name||'"('||string_agg(params, ',')||')' AS fname 
FROM tmp GROUP BY specific_schema, routine_name;

最后使用一個(gè)Postgres執(zhí)行代碼片段完成批量修改，完整SQL如下：

DO $$
DECLARE r record;
BEGIN
FOR r IN
WITH tmp AS (SELECT 
"routines".specific_schema,
"routines".routine_name, 
COALESCE("parameters".parameter_name, '') AS parameter_name, -- COALESCE返回參數(shù)中的第一個(gè)非null的值
COALESCE("parameters".udt_name, '') AS udt_name,
COALESCE("parameters".parameter_name, '') || ' ' || COALESCE("parameters".udt_name, '') AS params,
"parameters".ordinal_position 
FROM "information_schema"."routines"
LEFT JOIN "information_schema"."parameters" ON "routines".specific_name="parameters".specific_name 
WHERE "routines".specific_schema='abc' 
ORDER BY 1,2,6) SELECT '"'||specific_schema||'"."'||routine_name||'"('||string_agg(params, ',')||')' AS fname FROM tmp GROUP BY specific_schema, routine_name
LOOP
EXECUTE 'ALTER FUNCTION '|| r.fname||' OWNER TO "dbadmin" ';
END LOOP;
END $$;

可以看到模式“abc”的Owner已經(jīng)全部改為dbadmin這個(gè)賬號(hào)了。

上次批量修改函數(shù)可能存在部分特殊場(chǎng)景會(huì)報(bào)錯(cuò)，會(huì)把“參數(shù)類型” + “返回類型” 拼接在一起

改進(jìn)方法：我們通過(guò)pg_catalog目錄來(lái)實(shí)現(xiàn)批量修改，參考代碼如下：

DO $$
DECLARE r record;
BEGIN
FOR r IN
 WITH tmp AS (
 SELECT n.nspname as "Schema",
 p.proname as "Name",
 pg_catalog.pg_get_function_result(p.oid) as "Result data type",
 pg_catalog.pg_get_function_arguments(p.oid) as "Argument data types",
 CASE
 WHEN p.proisagg THEN 'agg'
 WHEN p.proiswindow THEN 'window'
 WHEN p.prorettype = 'pg_catalog.trigger'::pg_catalog.regtype THEN 'trigger'
 ELSE 'normal'
 END as "Type"
 FROM pg_catalog.pg_proc p
  LEFT JOIN pg_catalog.pg_namespace n ON n.oid = p.pronamespace
 WHERE n.nspname = 'etl'
 ORDER BY 1, 2, 4
 ) SELECT '"' || "Schema" || '"' || '.' || '"' || "Name" || '"' || '(' || "Argument data types" ||')' AS fname FROM tmp
LOOP
EXECUTE 'ALTER FUNCTION '|| r.fname||' OWNER TO "postgres" ';
END LOOP;
END $$;

補(bǔ)充：PostgreSQL更改Owner所有者

網(wǎng)上一個(gè)大神寫(xiě)的

SELECT
‘a(chǎn)lter table ' || nsp.nspname || ‘.' || cls.relname || ' owner to usr_zhudong;' || chr ( 13 )
FROM
pg_catalog.pg_class cls,
pg_catalog.pg_namespace nsp
WHERE
nsp.nspname IN ( ‘public' )
AND cls.relnamespace = nsp.oid
AND cls.relkind = ‘r'
ORDER BY
nsp.nspname,
cls.relname;

我來(lái)做一個(gè)改版

SELECT
'alter table ' || nsp.nspname || '.' || cls.relname || ' owner to test2;' || chr ( 13 )
FROM
pg_catalog.pg_class cls,
pg_catalog.pg_namespace nsp
WHERE
nsp.nspname IN ( 'public' )
AND cls.relnamespace = nsp.oid
AND cls.relkind = 'r'
ORDER BY
nsp.nspname,
cls.relname;
 
SELECT
'alter table "' || nsp.nspname || '"."' || cls.relname || '" owner to user01;' || chr ( 13 )
FROM
pg_catalog.pg_class cls,
pg_catalog.pg_namespace nsp
WHERE
nsp.nspname IN ( 'public' )
AND cls.relnamespace = nsp.oid
AND cls.relkind = 'r'
ORDER BY
nsp.nspname,
cls.relname;

效果：