如何建立C与数据库服务器端的连接？

C# 与数据库建立连接的详细指南

在C#中，与数据库建立连接是进行数据操作的基础，以下是使用C#与常见数据库（如SQL Server、MySQL和SQLite）建立连接的详细步骤和示例代码。

一、准备工作

安装必要的软件和库

SQL Server：确保已安装SQL Server数据库，并配置好相应的服务。

MySQL：下载并安装MySQL服务器和客户端工具。

SQLite：下载SQLite数据库文件，无需单独安装服务器。

添加数据库引用

在Visual Studio中创建一个新的C#项目，然后通过NuGet包管理器添加所需的数据库驱动。

System.Data.SqlClient：用于连接SQL Server。

MySql.Data.MySqlClient：用于连接MySQL。

System.Data.SQLite：用于连接SQLite。

二、连接字符串

连接字符串包含连接数据库所需的信息，例如服务器地址、数据库名称、用户名和密码等。

数据库类型	连接字符串示例
SQL Server	Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;
MySQL	Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;
SQLite	Data Source=mydatabase.db;Version=3;

三、代码示例

连接到SQL Server

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            try
            {
                connection.Open();
                Console.WriteLine("Connection to SQL Server successful!");
            }
            catch (Exception ex)
            {
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

连接到MySQL

using System;
using MySql.Data.MySqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            try
            {
                connection.Open();
                Console.WriteLine("Connection to MySQL successful!");
            }
            catch (Exception ex)
            {
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

连接到SQLite

using System;
using System.Data.SQLite;
class Program
{
    static void Main()
    {
        string connectionString = "Data Source=mydatabase.db;Version=3;";
        using (SQLiteConnection connection = new SQLiteConnection(connectionString))
        {
            try
            {
                connection.Open();
                Console.WriteLine("Connection to SQLite successful!");
            }
            catch (Exception ex)
            {
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

四、执行查询

一旦成功建立连接，可以执行SQL查询来操作数据库中的数据，以下是一个简单的示例，展示如何执行SELECT查询并读取结果。

在SQL Server上执行查询

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            try
            {
                connection.Open();
                string query = "SELECT  FROM myTable";
                SqlCommand command = new SqlCommand(query, connection);
                using (SqlDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine($"{reader["Column1"]}, {reader["Column2"]}");
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

在MySQL上执行查询

using System;
using MySql.Data.MySqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            try
            {
                connection.Open();
                string query = "SELECT  FROM myTable";
                MySqlCommand command = new MySqlCommand(query, connection);
                using (MySqlDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine($"{reader["Column1"]}, {reader["Column2"]}");
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

在SQLite上执行查询

using System;
using System.Data.SQLite;
class Program
{
    static void Main()
    {
        string connectionString = "Data Source=mydatabase.db;Version=3;";
        using (SQLiteConnection connection = new SQLiteConnection(connectionString))
        {
            try
            {
                connection.Open();
                string query = "SELECT  FROM myTable";
                SQLiteCommand command = new SQLiteCommand(query, connection);
                using (SQLiteDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine($"{reader["Column1"]}, {reader["Column2"]}");
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

五、FAQs（常见问题解答）

如何在C#中处理数据库连接超时？

答：可以通过设置连接字符串中的Connect Timeout参数来控制连接超时，对于SQL Server，可以在连接字符串中添加Connect Timeout=30，表示连接超时时间为30秒，其他数据库也有类似的设置方法，还可以在代码中捕获TimeoutException异常并进行相应处理。

2. 如何在C#中安全地存储数据库连接字符串？

答：不应将数据库连接字符串硬编码在代码中，建议使用配置文件（如app.config或web.config）来存储连接字符串，并通过加密保护敏感信息，可以使用环境变量或安全的密钥管理系统来存储密码和其他敏感信息，然后在应用程序启动时动态加载这些配置，这样可以减少敏感信息泄露的风险，提高应用程序的安全性。