标签: functions

我有一个用 Perl 编写的非分叉游戏守护进程，它使用 acync 查询将玩家统计数据写入 PostgreSQL 9.3 数据库。但是当我需要从数据库中读取某些内容时（例如玩家是否被禁止或玩家是否具有 VIP 身份），那么我使用同步查询。

这会使游戏停止一小会，直到从数据库中读取该值。

我无法重写我的游戏守护程序以使用异步查询来读取值（我尝试过，但它需要进行太多更改），所以我的问题是：将几个不相关的查询组合在一起是否有意义（我需要在新玩家连接) 到 1 个过程，如何同时将多个值返回到我的 Perl 程序？

我当前的查询都以玩家 ID 作为参数并返回 1 个值：

-- Has the player been banned?
select true from pref_ban where id=?

-- What is the reputation of this player?
select
count(nullif(nice, false)) -
count(nullif(nice, true)) as rep
from pref_rep where id=?

-- Is he or she a special VIP player?
select vip > now() as vip from pref_users where id=?

-- How many …

我的理解是 PostgreSQL 函数的执行类似于事务。但是，当我尝试在函数中“SET LOCAL statement_timeout”时，它不起作用。以下是它在事务中的工作方式：

BEGIN; 
  SET LOCAL statement_timeout = 100; 
  SELECT pg_sleep(10); 
COMMIT;

结果在哪里（如预期的那样）：

BEGIN
SET
ERROR:  canceling statement due to statement timeout
ROLLBACK

但是，如果我将相同的命令放在函数体中：

CREATE OR REPLACE FUNCTION test() RETURNS void AS '
    SET LOCAL statement_timeout = 100;
    SELECT pg_sleep(10);
' LANGUAGE sql;

SELECT test();

超时不会发生，函数test()执行需要 10 秒。

请告知为什么这两种情况不同，以及我如何纠正它以在函数内设置语句超时。

我有一个查询需要根据标量 UDF 的结果进行过滤。查询必须作为单个语句发送（因此我不能将 UDF 结果分配给局部变量）并且我不能使用 TVF。我知道标量 UDF 引起的性能问题，包括强制整个计划串行运行、过多的内存授予、基数估计问题和缺乏内联。对于这个问题，请假设我需要使用标量 UDF。

UDF 本身调用起来非常昂贵，但理论上查询可以由优化器在逻辑上以这样一种方式实现，即函数只需要计算一次。我为这个问题模拟了一个大大简化的例子。以下查询在我的机器上执行需要 6152 毫秒：

SELECT x1.ID
FROM dbo.X_100_INTEGERS x1
WHERE x1.ID >= dbo.EXPENSIVE_UDF();

查询计划中的过滤器运算符表明该函数为每一行计算一次：

DDL 和数据准备：

CREATE OR ALTER FUNCTION dbo.EXPENSIVE_UDF () RETURNS INT
AS
BEGIN
    DECLARE @tbl TABLE (VAL VARCHAR(5));

    -- make the function expensive to call
    INSERT INTO @tbl
    SELECT [VALUE]
    FROM STRING_SPLIT(REPLICATE(CAST('Z ' AS VARCHAR(MAX)), 20000), ' ');

    RETURN 1;
END;

GO

DROP TABLE IF EXISTS dbo.X_100_INTEGERS;

CREATE TABLE dbo.X_100_INTEGERS (ID INT NOT NULL);

-- insert 100 …

我们有一个 SQL Server 数据库，它有一个数据库审计规范，它审计对数据库的所有执行操作。

CREATE DATABASE AUDIT SPECIFICATION [dbAudit]
FOR SERVER AUDIT [servAudit]
ADD (EXECUTE ON DATABASE::[DatabaseName] BY [public])

我们发现，某些查询会将结果集中的每一行的标量函数的使用写入审计日志。当这种情况发生时，日志在我们可以 ETL 到它的最终休息位置之前就被填满了，我们的日志记录出现了空白。

不幸的是，由于合规性原因，我们不能简单地停止审核每条EXECUTE语句。

我们解决这个问题的第一个想法是使用Server AuditWHERE上的子句来过滤掉活动。代码如下所示：

WHERE [object_id] not in (Select object_id from sys.objects where type = 'FN' )

不幸的是，SQL Server 不允许关系 IN 运算符（可能是因为它不想在每次必须写入审核日志时进行查询）。

我们想避免编写一个存储过程，其硬代码object_id中WHERE条款，但是这是我们在解决这个问题的最好办法目前的想法。是否有我们应该考虑的替代方法？

我们注意到，当在递归 CTE 中使用标量函数时，它会导致查询为结果集中的每一行写入审计日志。

有一些标量值函数由供应商提供，我们无法删除或移动到备用数据库。

我想看看是否有办法欺骗 SQL Server 为查询使用某个计划。

1. 环境

想象一下，您有一些在不同进程之间共享的数据。因此，假设我们有一些占用大量空间的实验结果。然后，对于每个过程，我们知道我们想要使用哪一年/哪月的实验结果。

if object_id('dbo.SharedData') is not null
    drop table SharedData

create table dbo.SharedData (
    experiment_year int,
    experiment_month int,
    rn int,
    calculated_number int,
    primary key (experiment_year, experiment_month, rn)
)
go

现在，对于每个过程，我们都将参数保存在表中

if object_id('dbo.Params') is not null
    drop table dbo.Params

create table dbo.Params (
    session_id int,
    experiment_year int,
    experiment_month int,
    primary key (session_id)
)
go

2. 测试数据

让我们添加一些测试数据：

insert into dbo.Params (session_id, experiment_year, experiment_month)
select 1, 2014, 3 union all
select 2, 2014, 4 
go

insert into …

我有一个看起来像这样的表（在 PostgreSQL 9.4 中）：

CREATE TABLE dates_ranges (kind int, start_date date, end_date date);
INSERT INTO dates_ranges VALUES 
    (1, '2018-01-01', '2018-01-31'),
    (1, '2018-01-01', '2018-01-05'),
    (1, '2018-01-03', '2018-01-06'),
    (2, '2018-01-01', '2018-01-01'),
    (2, '2018-01-01', '2018-01-02'),
    (3, '2018-01-02', '2018-01-08'),
    (3, '2018-01-05', '2018-01-10');

现在我想计算给定日期和每种类型，计算dates_ranges每个日期有多少行。零可以省略。

想要的结果：

+-------+------------+----+
|  kind | as_of_date |  n |
+-------+------------+----+
|     1 | 2018-01-01 |  2 |
|     1 | 2018-01-02 |  2 |
|     1 | 2018-01-03 |  3 |
|     2 | 2018-01-01 |  2 |
| …

在CentOS v7上使用phpPgAdmin v5.6和PostgreSQL v11.2，当我尝试访问架构中的选项卡时，出现以下错误：Functionspublic

ERROR:  column p.proisagg does not exist
LINE 18:    WHERE NOT p.proisagg
                      ^
HINT:  Perhaps you meant to reference the column "p.prolang".
Dans l'instruction :

            SELECT
                p.oid AS prooid,
                p.proname,
                p.proretset,
                pg_catalog.format_type(p.prorettype, NULL) AS proresult,
                pg_catalog.oidvectortypes(p.proargtypes) AS proarguments,
                pl.lanname AS prolanguage,
                pg_catalog.obj_description(p.oid, 'pg_proc') AS procomment,
                p.proname || ' (' || pg_catalog.oidvectortypes(p.proargtypes) || ')' AS proproto,
                CASE WHEN p.proretset THEN 'setof ' ELSE '' END || pg_catalog.format_type(p.prorettype, NULL) AS proreturns, …