当前位置：首页 > 行业动态 > 正文

c# 数据库类模板

admin
行业动态
2025-02-21
6

“

csharp，using System;，using System.Data.SqlClient;namespace DatabaseTemplate，{， public class DBHelper， {， private string connectionString = "your_connection_string"; public SqlConnection GetConnection()， {， return new SqlConnection(connectionString);， } // 其他数据库操作方法，如增删改查等， }，}，

“你可以根据实际需求进一步完善和扩展此类，比如添加具体的数据操作方法、错误处理机制等。

C#数据库操作类模板

using System;
using System.Data;
using System.Data.SqlClient;
namespace YourNamespace
{
    public class DatabaseHelper
    {
        private string connectionString = "Your_Connection_String_Here";
        // 获取数据库连接
        private SqlConnection GetConnection()
        {
            return new SqlConnection(connectionString);
        }
        // 执行查询并返回DataTable
        public DataTable ExecuteQuery(string query, params SqlParameter[] parameters)
        {
            using (SqlConnection conn = GetConnection())
            {
                using (SqlCommand cmd = new SqlCommand(query, conn))
                {
                    if (parameters != null)
                    {
                        cmd.Parameters.AddRange(parameters);
                    }
                    using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
                    {
                        DataTable dt = new DataTable();
                        adapter.Fill(dt);
                        return dt;
                    }
                }
            }
        }
        // 执行非查询操作（如Insert, Update, Delete），并返回受影响的行数
        public int ExecuteNonQuery(string query, params SqlParameter[] parameters)
        {
            using (SqlConnection conn = GetConnection())
            {
                using (SqlCommand cmd = new SqlCommand(query, conn))
                {
                    if (parameters != null)
                    {
                        cmd.Parameters.AddRange(parameters);
                    }
                    conn.Open();
                    int rowsAffected = cmd.ExecuteNonQuery();
                    return rowsAffected;
                }
            }
        }
    }
}

以下是对上述代码的解释：

命名空间和类定义：首先定义了一个命名空间YourNamespace，并在其中创建了一个名为DatabaseHelper的公共类，这个类将包含所有与数据库交互的方法。

连接字符串：在类中定义了一个私有字符串变量connectionString，用于存储数据库连接字符串，你需要将其替换为实际的连接字符串，该字符串通常包含服务器地址、数据库名称、用户名和密码等信息。

获取数据库连接方法：GetConnection方法返回一个SqlConnection对象，用于建立与数据库的连接，在每次需要与数据库交互时，都会调用此方法来获取一个新的连接实例。

执行查询方法：ExecuteQuery方法接受一个SQL查询字符串和一个可选的SqlParameter数组作为参数，它使用SqlDataAdapter将查询结果填充到一个DataTable对象中，并返回该DataTable，这个方法主要用于执行SELECT语句以检索数据。

c# 数据库类模板

执行非查询方法：ExecuteNonQuery方法也接受一个SQL查询字符串和可选的SqlParameter数组作为参数，但它用于执行INSERT、UPDATE或DELETE等非查询操作，该方法打开连接，执行命令，并返回受影响的行数。

使用示例

以下是如何使用上述DatabaseHelper类来执行一些常见的数据库操作的示例：

class Program
{
    static void Main(string[] args)
    {
        DatabaseHelper dbHelper = new DatabaseHelper();
        // 查询数据
        string selectQuery = "SELECT * FROM YourTable";
        DataTable result = dbHelper.ExecuteQuery(selectQuery);
        foreach (DataRow row in result.Rows)
        {
            Console.WriteLine(row["YourColumn"].ToString());
        }
        // 插入数据
        string insertQuery = "INSERT INTO YourTable (Column1, Column2) VALUES (@Value1, @Value2)";
        SqlParameter[] insertParams = new SqlParameter[]
        {
            new SqlParameter("@Value1", "Value1"),
            new SqlParameter("@Value2", "Value2")
        };
        int rowsInserted = dbHelper.ExecuteNonQuery(insertQuery, insertParams);
        Console.WriteLine($"Rows inserted: {rowsInserted}");
        // 更新数据
        string updateQuery = "UPDATE YourTable SET Column1 = @NewValue WHERE Column2 = @OldValue";
        SqlParameter[] updateParams = new SqlParameter[]
        {
            new SqlParameter("@NewValue", "NewValue"),
            new SqlParameter("@OldValue", "OldValue")
        };
        int rowsUpdated = dbHelper.ExecuteNonQuery(updateQuery, updateParams);
        Console.WriteLine($"Rows updated: {rowsUpdated}");
        // 删除数据
        string deleteQuery = "DELETE FROM YourTable WHERE Column1 = @Value";
        SqlParameter[] deleteParams = new SqlParameter[]
        {
            new SqlParameter("@Value", "ValueToDelete")
        };
        int rowsDeleted = dbHelper.ExecuteNonQuery(deleteQuery, deleteParams);
        Console.WriteLine($"Rows deleted: {rowsDeleted}");
    }
}

在这个示例中，我们创建了一个DatabaseHelper类的实例，并使用它来执行各种数据库操作，我们分别演示了如何查询、插入、更新和删除数据，并将结果显示在控制台上。