无需监听事件及修改函数，在C#中获取PostgreSQL函数的Notice信息

如果不能修改PostgreSQL函数或数据库设置，也不想通过绑定Notice事件的方式获取函数抛出的Notice信息，可以利用Npgsql驱动的日志系统间接捕获这些信息——Npgsql默认会将服务器发送的Notice消息作为日志输出，只需配置日志提供者即可收集或查看。

方法1：直接输出到控制台 #

通过配置控制台日志提供者，让Notice信息直接打印到控制台：

using Microsoft.Extensions.Logging;
using Npgsql;

// 创建日志工厂并配置控制台输出
using var loggerFactory = LoggerFactory.Create(builder =>
{
    builder.AddConsole()
           .SetMinimumLevel(LogLevel.Information); // Notice对应日志级别为Information
});

// 让Npgsql使用该日志工厂
NpgsqlConnection.GlobalLoggingParameter = loggerFactory.CreateLogger<NpgsqlConnection>();

// 连接数据库并执行目标函数
using var conn = new NpgsqlConnection("你的数据库连接字符串");
conn.Open();

using var cmd = new NpgsqlCommand("SELECT 你的函数名();", conn);
cmd.ExecuteNonQuery();

运行后，函数抛出的Notice信息会直接显示在控制台中。

方法2：收集到变量中 #

如果需要将Notice信息保存到变量供后续处理，可以自定义日志提供者来收集消息：

using Microsoft.Extensions.Logging;
using Npgsql;
using System.Collections.Generic;

// 自定义日志提供者，用于收集Notice信息
public class NoticeCollectorLoggerProvider : ILoggerProvider
{
    public List<string> CollectedNotices { get; } = new List<string>();

    public ILogger CreateLogger(string categoryName)
    {
        return new NoticeCollectorLogger(this);
    }

    public void Dispose() { }

    private class NoticeCollectorLogger : ILogger
    {
        private readonly NoticeCollectorLoggerProvider _provider;

        public NoticeCollectorLogger(NoticeCollectorLoggerProvider provider)
        {
            _provider = provider;
        }

        public IDisposable BeginScope<TState>(TState state) => null;

        public bool IsEnabled(LogLevel logLevel)
        {
            return logLevel == LogLevel.Information;
        }

        public void Log<TState>(LogLevel logLevel, EventId eventId, TState state, Exception exception, Func<TState, Exception, string> formatter)
        {
            if (IsEnabled(logLevel))
            {
                var logMsg = formatter(state, exception);
                // 过滤出Notice消息（Npgsql日志中Notice前缀为"Notice:"）
                if (logMsg.StartsWith("Notice:"))
                {
                    _provider.CollectedNotices.Add(logMsg.Substring(7).Trim());
                }
            }
        }
    }
}

// 使用自定义日志提供者收集Notice
var noticeCollector = new NoticeCollectorLoggerProvider();
using var loggerFactory = LoggerFactory.Create(builder =>
{
    builder.AddProvider(noticeCollector);
});

NpgsqlConnection.GlobalLoggingParameter = loggerFactory.CreateLogger<NpgsqlConnection>();

using var conn = new NpgsqlConnection("你的数据库连接字符串");
conn.Open();

using var cmd = new NpgsqlCommand("SELECT 你的函数名();", conn);
cmd.ExecuteNonQuery();

// 处理收集到的Notice信息
foreach (var notice in noticeCollector.CollectedNotices)
{
    Console.WriteLine($"捕获到Notice：{notice}");
}

这种方式不需要对PostgreSQL函数或数据库做任何修改，也无需绑定Notice事件，完全通过客户端日志机制实现信息捕获。

内容的提问来源于stack exchange，提问作者Giorgos Dimas