ASP.NET应用调用PostgreSQL函数偶现‘函数不存在’异常求助

我来帮你分析下这个偶发的函数找不到问题，这种时好时坏的情况通常和数据库连接的上下文或者调用细节的隐性差异有关，咱们一步步拆解排查：

1. 最可能的原因：Schema 上下文不一致 #

你的函数明确在sylvia schema下，但PostgreSQL和Oracle的默认schema处理逻辑不一样：

• Oracle通常默认使用当前用户对应的schema，但PostgreSQL的默认search_path可能包含public等其他schema，不一定包含sylvia
• 如果连接池里的某些连接被修改过search_path，或者应用没有明确指定schema，就会出现"有时找到有时找不到"的情况

解决方法： #

• 调用时明确指定schema：把C#代码里的cmd.CommandText从"PRO_OCCUPATION_ADD"改成"sylvia.PRO_OCCUPATION_ADD"，直接锁定函数所在的schema
• 全局设置默认schema：
  • 要么在连接字符串中添加SearchPath=sylvia，确保每个新连接的默认schema都是sylvia
  • 要么在数据库层面给应用用户设置默认schema：

    ALTER ROLE your_application_user SET search_path TO sylvia;
    

2. 连接池复用导致的异常状态 #

你的代码使用了自定义连接池（m_hashConn），如果某个连接的上下文被修改后没有恢复，复用这个连接时就会出问题：

• 比如之前的操作执行了SET search_path TO public;但没改回来，后续用这个连接调用函数就会找不到
• 或者连接的事务状态异常，导致函数查找逻辑出错

解决方法： #

• 每次获取连接后重置上下文：在使用连接前，执行SET search_path TO sylvia;确保schema正确
• 检查连接失效逻辑：确认invalidateConnectionID方法在异常时会正确标记连接为无效，避免复用有问题的连接
• 添加连接健康检查：在从连接池获取连接时，执行简单的查询（比如SELECT 1;）验证连接状态

3. 参数类型的隐性不匹配 #

PostgreSQL对函数重载的参数类型匹配非常严格，哪怕是细微的类型差异都可能导致找不到函数：

• 你的代码中参数是直接Add的，没有明确指定NpgsqlDbType，虽然看起来类型匹配，但偶尔可能出现隐性转换问题
• 比如long转bigint是对的，但如果参数值是DBNull，会不会触发不同的函数匹配逻辑？

解决方法： #

明确指定每个参数的数据库类型，避免隐性转换：

cmd.Parameters.Add("p_OccupationId", NpgsqlDbType.BigInt).Value = genPK;
cmd.Parameters.Add("p_OccupationName", NpgsqlDbType.Text).Value = row.OccupationName;
cmd.Parameters.Add("p_OccupationDetails", NpgsqlDbType.Text).Value = row.IsOccupationDetailsNull() ? DBNull.Value : (object)row.OccupationDetails;

另外，可以开启标识符引用：cmd.QuoteIdentifiers = true;，确保参数名和函数定义的大小写完全匹配（PostgreSQL默认会把未加引号的标识符转成小写，你的代码里参数名是驼峰，函数里是小写，Npgsql通常会处理，但开启这个更保险）

4. 事务上下文的影响 #

你的代码绑定了事务（cmdInsertUpdateDelete.Transaction = tx;），如果事务中存在未提交的DDL操作，或者事务的隔离级别导致元数据读取异常，也可能出现偶发的函数找不到问题。

解决方法： #

• 确保事务结束后正确提交或回滚，连接回到干净状态
• 尝试在非事务环境下测试调用，看是否还会出现异常，排除事务的影响

验证步骤 #

1. 先给函数调用加上sylvia.前缀，观察是否还会出现异常，这是最快验证schema问题的方法
2. 查看PostgreSQL的日志文件（postgresql.log），当出现错误时，日志会记录实际执行的SQL语句和连接的上下文信息，能帮你定位具体是哪个连接出了问题
3. 在代码中添加日志，每次获取连接后执行SHOW search_path;并打印结果，看异常发生时的search_path是否包含sylvia

附用户提供的相关代码 #

PostgreSQL函数定义：

CREATE OR REPLACE FUNCTION sylvia.pro_occupation_add( p_occupationid bigint, p_occupationname text, p_occupationdetails text) 
RETURNS void 
LANGUAGE 'plpgsql' 
AS $BODY$ 
begin 
  insert into sylvia.occupation (occupationid,occupationname,occupationdetails) 
  values (p_occupationid, p_occupationname, p_occupationdetails); 
end; 
$BODY$;

C#核心调用代码：

private DataSet _createOccupation(DataSet inputDS) {
    ErrorDS errDS = new ErrorDS();
    EmployeeHistDS employeeHistDS = new EmployeeHistDS();
    DBConnectionDS connDS = new DBConnectionDS();

    //extract dbconnection
    connDS.Merge(inputDS.Tables[connDS.DBConnections.TableName], false, MissingSchemaAction.Error);
    connDS.AcceptChanges();

    //create command
    NpgsqlCommand cmd = new NpgsqlCommand();
    cmd.CommandText = "PRO_OCCUPATION_ADD";
    cmd.CommandType = CommandType.StoredProcedure;

    employeeHistDS.Merge(inputDS.Tables[employeeHistDS.Occupation.TableName], false, MissingSchemaAction.Error);
    employeeHistDS.AcceptChanges();

    foreach (EmployeeHistDS.OccupationRow row in employeeHistDS.Occupation) {
        long genPK = IDGenerator.GetNextGenericPK();
        if (genPK == -1) {
            return UtilDL.GetDBOperationFailed();
        }
        cmd.Parameters.Add("p_OccupationId", genPK);
        cmd.Parameters.Add("p_OccupationName", row.OccupationName);
        if (!row.IsOccupationDetailsNull())
            cmd.Parameters.Add("p_OccupationDetails", row.OccupationDetails);
        else
            cmd.Parameters.Add("p_OccupationDetails", DBNull.Value);

        bool bError = false;
        int nRowAffected = -1;
        nRowAffected = ADOController.Instance.ExecuteNonQuery(cmd, connDS.DBConnections[0].ConnectionID, ref bError);
        if (bError == true) {
            ErrorDS.Error err = errDS.Errors.NewError();
            err.ErrorCode = ErrorCode.ERR_DB_OPERATION_FAILED.ToString();
            err.ErrorTier = ErrorTier.ERR_TIER_DL.ToString();
            err.ErrorLevel = ErrorLevel.ERR_LEVEL_SEVER.ToString();
            err.ErrorInfo1 = ActionID.ACTION_OCCUPATION_ADD.ToString();
            errDS.Errors.AddError(err);
            errDS.AcceptChanges();
            return errDS;
        }
    }
    errDS.Clear();
    errDS.AcceptChanges();
    return errDS;
}

public int ExecuteNonQuery(NpgsqlCommand cmdInsertUpdateDelete, int connectionID, ref bool bError) {
    CConnectionInfo connInfo = (CConnectionInfo)this.m_hashConn[connectionID];
    if (connInfo == null) {
        AppLogger.LogWarning("Connection ID '" + connectionID + "' does not exist in connection pool.\nCould not execute ExecuteNonQuery method.");
        bError = true;
        return -1;
    }
    NpgsqlConnection conn = connInfo.m_Conn_PG;
    NpgsqlTransaction tx = connInfo.m_Tx_PG;

    cmdInsertUpdateDelete.Connection = conn;
    cmdInsertUpdateDelete.Transaction = tx;

    try {
        bError = false;
        return cmdInsertUpdateDelete.ExecuteNonQuery();
    } catch (Exception ex) {
        WriteErrorLog(ex, connectionID);
        AppLogger.LogFatal("Error executing ExecuteNonQuery method.\n" + cmdInsertUpdateDelete.CommandText, ex);
        invalidateConnectionID(connectionID);
        bError = true;
        return -1;
    } finally {
        cmdInsertUpdateDelete.Transaction = null;
        cmdInsertUpdateDelete.Connection = null;
    }
}

内容的提问来源于stack exchange，提问作者Mahiuddin Al Kamal