c#数据库 数据输入

在C#中进行数据库数据输入是一个常见的操作，通常涉及到与数据库的连接、SQL命令的执行以及数据的插入等步骤，以下是关于C#数据库数据输入的详细内容：

一、准备工作

1、安装和配置数据库：确保已经安装并配置了要使用的数据库系统，如SQL Server、MySQL、SQLite等，需要创建相应的数据库和表结构，以便存储数据。

2、添加引用：在C#项目中，需要添加对数据库访问相关命名空间的引用，对于SQL Server，可以添加System.Data.SqlClient；对于MySQL，可以添加MySql.Data.MySqlClient（需先通过NuGet包管理器安装）；对于SQLite，可以添加System.Data.SQLite（同样需先安装）。

3、建立数据库连接：使用适当的连接字符串来建立与数据库的连接，连接字符串通常包含服务器地址、数据库名称、用户名和密码等信息，对于SQL Server，连接字符串可能如下：

 string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";

然后可以使用SqlConnection类来创建连接对象，并打开连接：

 using (SqlConnection connection = new SqlConnection(connectionString))
   {
       connection.Open();
       // 后续的数据输入操作
   }

二、数据输入方式

1、使用参数化查询插入数据：这是一种较为安全和常用的数据输入方式，可以防止SQL注入攻击，以下是一个示例代码，演示如何使用参数化查询向SQL Server数据库的表中插入数据：

 using (SqlConnection connection = new SqlConnection(connectionString))
   {
       connection.Open();
       string sql = "INSERT INTO Students (Name, Age, Grade) VALUES (@Name, @Age, @Grade)";
       using (SqlCommand command = new SqlCommand(sql, connection))
       {
           command.Parameters.AddWithValue("@Name", "Tom");
           command.Parameters.AddWithValue("@Age", 20);
           command.Parameters.AddWithValue("@Grade", "Sophomore");
           int rowsAffected = command.ExecuteNonQuery();
           Console.WriteLine($"Rows affected: {rowsAffected}");
       }
   }

在这个示例中，首先创建了一个SqlCommand对象，并指定了要执行的SQL插入语句，通过Parameters.AddWithValue方法为SQL语句中的参数赋值，调用ExecuteNonQuery方法执行SQL命令，并返回受影响的行数。

2、 ：当需要一次性插入多条数据时，可以先将数据填充到DataTable中，然后使用SqlDataAdapter的Update方法将数据批量插入到数据库中，以下是一个示例：

 using (SqlConnection connection = new SqlConnection(connectionString))
   {
       DataTable dataTable = new DataTable("Students");
       dataTable.Columns.Add("Name", typeof(string));
       dataTable.Columns.Add("Age", typeof(int));
       dataTable.Columns.Add("Grade", typeof(string));
       // 添加多条数据到DataTable中
       dataTable.Rows.Add("Tom", 20, "Sophomore");
       dataTable.Rows.Add("Jerry", 22, "Senior");
       // ...
       SqlDataAdapter adapter = new SqlDataAdapter("SELECT * FROM Students WHERE 1=0", connection);
       SqlCommandBuilder builder = new SqlCommandBuilder(adapter);
       adapter.InsertCommand = builder.GetInsertCommand();
       adapter.Update(dataTable);
   }

在这个示例中，首先创建了一个DataTable对象，并定义了与数据库表对应的列，向DataTable中添加了多条数据，创建了一个SqlDataAdapter对象，并设置其InsertCommand属性为由SqlCommandBuilder生成的插入命令，调用Update方法将DataTable中的数据批量插入到数据库中。

三、错误处理

在进行数据库数据输入操作时，可能会遇到各种错误，如连接失败、SQL语法错误、数据违反约束等，需要进行适当的错误处理，以提高程序的健壮性和用户体验，以下是一个示例代码，演示了如何在数据输入过程中进行错误处理：

 using (SqlConnection connection = new SqlConnection(connectionString))
   {
       try
       {
           connection.Open();
           string sql = "INSERT INTO Students (Name, Age, Grade) VALUES (@Name, @Age, @Grade)";
           using (SqlCommand command = new SqlCommand(sql, connection))
           {
               command.Parameters.AddWithValue("@Name", "Tom");
               command.Parameters.AddWithValue("@Age", 20);
               command.Parameters.AddWithValue("@Grade", "Sophomore");
               int rowsAffected = command.ExecuteNonQuery();
               Console.WriteLine($"Rows affected: {rowsAffected}");
           }
       }
       catch (SqlException ex)
       {
           Console.WriteLine($"SQL Error: {ex.Message}");
           // 可以根据具体的错误信息进行相应的处理，如提示用户重新输入数据等
       }
       catch (Exception ex)
       {
           Console.WriteLine($"General Error: {ex.Message}");
           // 处理其他可能的异常情况
       }
   }

在这个示例中，使用了try-catch块来捕获可能出现的异常，如果发生SqlException，则输出SQL错误信息；如果发生其他异常，则输出通用错误信息，根据具体的错误情况，可以进行相应的处理，如提示用户重新输入数据、记录日志等。

四、事务处理

在某些情况下，可能需要在一个原子操作中执行多个数据库操作，以确保数据的一致性，这时，可以使用事务来管理这些操作，以下是一个示例代码，演示了如何在数据输入过程中使用事务：

 using (SqlConnection connection = new SqlConnection(connectionString))
   {
       connection.Open();
       SqlTransaction transaction = connection.BeginTransaction();
       try
       {
           string sql1 = "INSERT INTO Students (Name, Age, Grade) VALUES (@Name1, @Age1, @Grade1)";
           using (SqlCommand command1 = new SqlCommand(sql1, connection, transaction))
           {
               command1.Parameters.AddWithValue("@Name1", "Tom");
               command1.Parameters.AddWithValue("@Age1", 20);
               command1.Parameters.AddWithValue("@Grade1", "Sophomore");
               command1.ExecuteNonQuery();
           }
           string sql2 = "INSERT INTO Courses (CourseName, Credits) VALUES (@CourseName, @Credits)";
           using (SqlCommand command2 = new SqlCommand(sql2, connection, transaction))
           {
               command2.Parameters.AddWithValue("@CourseName", "Math");
               command2.Parameters.AddWithValue("@Credits", 4);
               command2.ExecuteNonQuery();
           }
           transaction.Commit();
           Console.WriteLine("Transaction committed successfully");
       }
       catch (Exception ex)
       {
           transaction.Rollback();
           Console.WriteLine($"Transaction rolled back due to error: {ex.Message}");
       }
   }

在这个示例中，首先开始了一个事务，然后在事务的上下文中执行了两个插入操作，如果所有操作都成功执行，则提交事务；如果在执行过程中发生任何错误，则回滚事务，以确保数据的一致性。

在C#中进行数据库数据输入需要掌握数据库连接、SQL命令执行、参数化查询、错误处理和事务管理等相关知识和技术，通过合理地运用这些技术，可以高效、安全地向数据库中输入数据，满足各种业务需求。