如何在 C# 中使用 SqlCommand 读取每一行和值？

Question

我是使用 C# 的新手，现在正在搞乱 SQL Server 连接。我的连接正常，我可以运行查询，只是无法查看返回的任何数据。我已经看到您需要运行command.ExecuteReader() 才能取回数据，但除了第一列和第一行之外，我无法获取任何其他数据。

这是我的代码：

<%@ WebHandler Language="C#" Class="biquery_query" %>
using System;
using System.Web;
using System.Data;
using System.Data.SqlClient;

public class biquery_query : IHttpHandler {

    public void ProcessRequest (HttpContext context) {
        var query = context.Request.QueryString["query"];
        query = "SELECT * FROM [hidden].[dbo].[hidden]";

        SqlConnection sqlConnection = new SqlConnection(@"Data Source=hidden;Initial Catalog=hidden;User ID=hidden;Password=hidden;");

        // Create Query Command
        SqlCommand command = new SqlCommand();
        command.CommandType = CommandType.Text;
        command.CommandText = query;
        command.Connection = sqlConnection;

        // Open connection and execute query
        sqlConnection.Open();
        command.ExecuteNonQuery();

        using(SqlDataReader rdr = command.ExecuteReader())
        {
            while(rdr.Read())
            {
                string app_id= rdr["app_id"].ToString();
                string app_os= rdr["app_os"].ToString();
                string date= rdr["date"].ToString();
                context.Response.Write(app_id);
            } 
        }

        sqlConnection.Close();
    }

    public bool IsReusable {
        get {
            return false;
        }
    }
}

我的数据库表有 5 列 (app_id, app_os, date, unix, users)。

有没有办法可以选择rdr["app_id"][0] 来获取第一个app_id 或rdr["users"][30]。

任何帮助将不胜感激，谢谢！

Answer 1

使用 SqlDataReader，一切都必须逐行完成 - 顺序访问。 SqlDataReader 的优点是您可以处理一个非常大的记录集，而无需一次将所有数据都保存在内存中。缺点是不能按要求去做。

您的另一种选择是通过 SqlDataAdapter 将整个记录集放入 DataTable 或 DataSet 对象中。这里是sample code from MS：

private static DataSet SelectRows(DataSet dataset,
    string connectionString,string queryString) 
{
    using (SqlConnection connection = 
        new SqlConnection(connectionString))
    {
        SqlDataAdapter adapter = new SqlDataAdapter();
        adapter.SelectCommand = new SqlCommand(
            queryString, connection);
        adapter.Fill(dataset);
        return dataset;
    }
}

Answer 2

当您拥有DataReader 时，您可以使用您的column name 读取您的数据。我刚刚读到string，你可以随意convert。请检查：

public class test
{
    public string app_id { get; set; }
    public string app_os { get; set; }
    public string date { get; set; }
    public string users { get; set; }
}

List<test> list = new List<test>();
using (SqlDataReader rdr = command.ExecuteReader())
{
    while (rdr.Read())
    {
        test ob = new test();
        ob.app_id = rdr["app_id"].ToString();
        ob.app_os = rdr["app_os"].ToString();
        ob.date = rdr["date"].ToString();
        ob.users = rdr["users"].ToString();
        list.Add(ob);
    }
}

请检查上面的代码，我创建了一个class 名称test 并将完整数据从DataReader 读取到list。现在您可以使用您的数据进行进一步处理。

您可以在从Database 读取数据时验证您的数据，请查看以下内容：

//ob.app_id = rdr["app_id"].ToString();
// if app_id is string
ob.app_id = (rdr["app_id"] == DBNull.Value) ? string.Empty : Convert.ToString(rdr["app_id"]);
// if app_id is int
ob.app_id = (rdr["app_id"] == DBNull.Value) ? 0 : Convert.ToInt64(rdr["app_id"]);

Answer 3

ExecuteNonQuery 用于查询不返回结果集（如 INSERT 或 UPDATE）时。

删除对ExecuteNonQuery 的调用，只使用ExecuteReader。