如何将参数传递给 postgre 函数并使用 ExecuteReader 获取数据？

Question

我正在尝试在 C# 应用程序中使用 ExecuteReader 从表中检索所有列。Db 是 postgre。为了测试，我按照教程创建了一个控制台应用程序，该教程确实展示了如何使用函数进行查询，但不使用传递参数。控制台应用程序函数用于测试

    static void Main(string[] args)
    {
        // Connect to a PostgreSQL database
        NpgsqlConnection conn = new NpgsqlConnection("Server=localhost;User Id=postgres; " +
            "Password=pes;Database=pmc;");
        conn.Open();

        // Define a query
        NpgsqlCommand command = new NpgsqlCommand("SELECT * from audit.exception_gl_accounts()", conn);

        // Execute the query and obtain a result set
        NpgsqlDataReader dr = command.ExecuteReader();

        // Output rows
        while (dr.Read())
            Console.Write("{0}\t{1} \n", dr[0], dr[1]);

        conn.Close();
    }
}

在 NpgsqlCommand 中，我将不带参数的查询发送到函数audit.exception_gl_accounts，它运行良好。现在我如何将参数传递给这样的函数

“从 sms.get_accounts_info(@AccountNumber) 选择*；

我正在尝试使用此函数检索所有 5 列并获取这些对象

    public static string GetAccountInfo(string accountNumber)
    {
        NpgsqlConnection conn = new NpgsqlConnection("Server=localhost;User 
                            Id=postgres; " + "Password=pes;Database=pmc;");
        conn.Open();
        NpgsqlCommand command = new NpgsqlCommand("SELECT * FROM 
                           sms.get_accounts_info(@AccountNumber); ", conn);
        command.Parameters.AddWithValue("@AccountNumber", accountNumber);
        NpgsqlDataReader dr = command.ExecuteReader();
        while (dr.Read())
            Console.Write("{0}\t{1} \n", dr[0], dr[1]);
            return dr.ToString();
    }

使用第二个示例代码会出现此错误：

{ “accountNumber”：“Npgsql.ForwardsOnlyDataReader”，“余额”：null，“interestRate”：0，“accountName”：null，“accountType”：null }

任何帮助表示赞赏。

详细信息已更新

控制器

[HttpPost]
[ActionName("info")]
public IHttpActionResult GetAccountInfo([FromBody]AccountInfo 
accountinfo)
 {
accountinfo.accountNumber = BusinessLayer.Api.AccountHolderApi.GetAccountInfo
          (accountinfo.accountNumber);
            return Ok(accountinfo);
 }

账户信息类

public class AccountInfo
    {
      public string accountNumber { get; set; }
      public string balance { get; set; }
      public int interestRate { get; set; }
      public string accountName { get; set; }
      public string accountType { get; set; }
    }

统一资源标识符

http://localhost:8080/v1/accounts/info

获取账户信息

CREATE OR REPLACE FUNCTION sms.get_accounts_info(IN account_number_ character varying)
  RETURNS TABLE(account_number character varying, account_name text, product character varying, interest_rate numeric, balance money) AS
$BODY$
BEGIN
    RETURN QUERY(
        SELECT a.account_number,
        c.customer_name,
            p.deposit_product_name, 
            a.interest_rate::numeric, deposit.get_balance(account_number_)
        FROM deposit.account_holders a 
        JOIN core.customers_view  c ON a.customer_id = c.customer_id
        JOIN core.deposit_products p ON a.deposit_product_id = p.deposit_product_id
        WHERE a.account_number = $1
    );
END
$BODY$
  LANGUAGE plpgsql VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION sms.get_accounts_info(character varying)
  OWNER TO postgres;

Answer 1

如果没有实体框架，您需要编写将数据读取器中的值读取到类实例中的代码AccountInfo：

public static AccountInfo GetAccountInfo(string accountNumber)
{
    AccountInfo result = null;
    using(var conn = new NpgsqlConnection("..."))
    {
        conn.Open();
        using(var command = new NpgsqlCommand("SELECT * FROM sms.get_accounts_info(@AccountNumber); ", conn))
        {
            command.Parameters.AddWithValue("@AccountNumber", accountNumber);
            using(var dr = command.ExecuteReader())
            {
                if(dr.HasRows && dr.Read())
                {
                    result = new AccountInfo { 
                        accountNumber = dr["accountNumber"].ToString(),
                        balance = dr["balance"].ToString(),
                        interestRate = Convert.ToInt32(dr["interestRate"]),
                        accountName = dr["accountName"].ToString()
                    };
                }
            }
        }
    }
    return result;
}

请注意，该函数的返回类型已更改为AccountInfo以前的字符串。另外，它仅限于读取一条记录，如果一次调用sms.get_accounts_info可以返回多条记录，那就是另一回事了。我只是假设这account_number是表中的主键account_holders。

有些细节需要您注意，例如balance数据库中是金钱，但类中是字符串。另外我不知道product（数据库）和accountType（类）是否以及如何对应，所以我省略了它。

数据库连接、命令和数据读取器都IDisposable应该封装在using块中。