CodeGym /课程 /SQL SELF /分析当前的查询和事务

分析当前的查询和事务

SQL SELF

第 55 级 , 课程 4

可用

分析当前的查询和事务

我们先从基础说起。PostgreSQL给我们提供了一套超棒的工具，可以用来分析SQL查询和事务。比如说，内置的current_query()和txid_current()函数能让你：

获取当前正在执行的SQL查询。
知道这个查询是在什么事务里跑的。
把SQL操作记录下来，方便后续分析。
追踪事务问题，比如你的代码以为会发生A，结果却发生了B。

这些功能在标准的debug输出帮不上忙，或者你想“事后分析”查询行为时特别有用。

内置函数概览

`current_query()`函数

current_query()会返回当前连接里正在执行的SQL查询文本。“它怎么知道的？”你可能会问。PostgreSQL其实一直在追踪每个连接的状态，这个函数就是让你能偷看一下“后台发生了啥”。

语法：

SELECT current_query();

执行例子：

-- 在函数里执行查询
DO $$
BEGIN
    RAISE NOTICE '当前查询: %', current_query();
END;
$$;

-- 结果:
-- NOTICE: 当前查询: DO $$ BEGIN RAISE NOTICE '当前查询: %', current_query(); END; $$;

从例子可以看到，current_query()会告诉你当前执行的查询文本。这个信息在分析复杂过程时特别有用：你能清楚知道此刻到底在执行什么！

`txid_current()`函数

说到事务，txid_current()就是个神器。它会返回当前事务的唯一ID。如果你想追踪同一个事务里的操作顺序，这个特别有用。

语法：

SELECT txid_current();

执行例子：

BEGIN;

-- 获取当前事务ID
SELECT txid_current();

-- 输出:
-- 564 (比如说，这就是ID)

-- 结束事务
COMMIT;

这些事务ID可以用来对比日志、分析操作顺序，甚至调试多用户系统。

实际任务中的用法例子

在执行过程中记录当前查询。

有时候一个过程或函数里有很多SQL查询。想知道哪里出错了，可以把当前SQL查询记录下来。比如：

DO $$
DECLARE
    current_txn_id BIGINT;
BEGIN
    current_txn_id := txid_current();
    RAISE NOTICE '当前事务ID: %', current_txn_id;

    RAISE NOTICE '当前查询: %', current_query();

    -- 这里可以加你自己的操作
END;
$$;

这段代码会在控制台输出事务ID和当前查询文本。这样你就能精确知道此刻在执行什么。

分析事务，定位问题。

假设有个场景，用户抱怨批量更新时丢数据。你写了几个过程，每个都在同一个事务里跑。怎么查是谁的问题？看例子：

BEGIN;

-- 记录事务日志
DO $$
BEGIN
    RAISE NOTICE '当前事务ID: %', txid_current();
END;
$$;

-- 执行“有问题”的SQL查询
UPDATE orders
SET status = 'processed'
WHERE id IN (SELECT order_id FROM pending_orders);

COMMIT;

如果更新没成功，你马上就能看到相关的事务ID。这不仅方便查错，还能帮你判断事务有没有冲突。

记录查询，做历史分析。

有时候你不光要修当前的问题，还得记住都执行过哪些SQL查询。比如你可以建个日志表：

CREATE TABLE query_log (
    log_time TIMESTAMP DEFAULT NOW(),
    query_text TEXT,
    txn_id BIGINT
);

这样用current_query()和txid_current()来记录查询：

DO $$
BEGIN
    INSERT INTO query_log (query_text, txn_id)
    VALUES (current_query(), txid_current());
END;
$$;

现在query_log表里就有每个查询和它所属事务的信息了。这对分析数据库运行情况特别有用。

实用场景案例

例子1：事务审计

假设你在分析多用户系统的操作。记录事务ID（txid_current）可以让你把同一事务的操作归在一起。

DO $$
DECLARE
    txn_id BIGINT;
BEGIN
    txn_id := txid_current();
    RAISE NOTICE '事务开始，ID: %', txn_id;

    -- 某个操作
    UPDATE users SET last_login = NOW() WHERE id = 123;

    RAISE NOTICE '当前查询: %', current_query();
END;
$$;

例子2：简化过程调试

你调用了个复杂过程，结果出错了。你可以在函数的不同阶段加current_query()日志，这样就能看到每一步执行了什么查询：

CREATE OR REPLACE FUNCTION debugged_function() RETURNS VOID AS $$
BEGIN
    RAISE NOTICE '更新前的当前查询: %', current_query();
    UPDATE data_table SET field = 'debugging';
    RAISE NOTICE '更新后的当前查询: %', current_query();
END;
$$ LANGUAGE plpgsql;

等函数执行完，你会收到两个通知，分别显示对应的SQL查询。