C#连接SQL Sever数据库与数据查询实例之数据仓库详解

C#连接SQL Server数据库与数据查询实例之数据仓库详解

概述

在C#应用程序中，连接SQL Server数据库和进行数据查询是非常常见的操作。本文将详细介绍如何进行C#与SQL Server数据库的连接，并进行简单的数据查询。

连接SQL Server数据库

首先，我们需要引入System.Data.SqlClient命名空间，因为这个命名空间中包含了用于连接SQL Server数据库的类。

using System.Data.SqlClient;

然后，我们需要初始化SqlConnection对象并指定连接字符串。连接字符串中包含了需要连接的数据库的相关信息，例如服务器名称、数据库名称、身份验证方式和用户名密码等。

string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
SqlConnection connection = new SqlConnection(connectionString);

接下来，我们尝试打开连接。如果连接成功，则可以进行下一步操作，否则应该进行错误处理。

try
{
    connection.Open();
    // 执行操作
}
catch (Exception ex)
{
    // 处理错误
}

最后，当使用完SqlConnection对象后，应该关闭连接。

connection.Close();

数据查询实例

示例1

以下示例展示了如何查询Person表中的所有记录：

string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
string queryString = "SELECT * FROM Person";
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand command = new SqlCommand(queryString, connection);

try
{
    connection.Open();
    SqlDataReader reader = command.ExecuteReader();
    while (reader.Read())
    {
        Console.WriteLine(String.Format("{0}, {1}", reader[0], reader[1]));
    }
    reader.Close();
}
catch (Exception ex)
{
    Console.WriteLine(ex.Message);
}
finally
{
    connection.Close();
}

在上面的代码中，首先定义了一个查询字符串queryString，然后使用SqlConnection和SqlCommand对象进行数据查询。在try代码块中，我们通过读取查询结果集中的每一行记录并输出结果来展示了数据查询的简单操作。最后，我们在finally代码块中关闭了连接。

示例2

以下示例展示了如何查询Person表中的所有在25岁以上并且在value1到value2之间的记录：

string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
string queryString = "SELECT * FROM Person WHERE Age > 25 AND Value BETWEEN @value1 AND @value2";
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand command = new SqlCommand(queryString, connection);
command.Parameters.AddWithValue("@value1", 10);
command.Parameters.AddWithValue("@value2", 20);

try
{
    connection.Open();
    SqlDataReader reader = command.ExecuteReader();
    while (reader.Read())
    {
        Console.WriteLine(String.Format("{0}, {1}", reader[0], reader[1]));
    }
    reader.Close();
}
catch (Exception ex)
{
    Console.WriteLine(ex.Message);
}
finally
{
    connection.Close();
}

在上面的代码中，我们使用了WHERE子句和BETWEEN运算符对查询结果进行筛选，并且使用了参数化查询来防止SQL注入攻击。

结论

本文简单介绍了如何使用C#连接SQL Server数据库和进行简单的数据查询。通过本文的学习，您应该能够掌握C#与SQL Server数据库的基本操作和实践。