使用事务提交步骤非常简单:
1:建立连接
2:开启事务
3:批量操作
4:提交事务
5:关闭连接
直接上最简洁的代码,此例子为往数据库中插入5万行数据,速度还可以,完全可以在一般的项目上使用,代码如下:
//连接字符串语句,根据实际情况赋值
string connString = "server = localhost; port = 3306; database = lalala; username = root; password = ankerla;";
MySqlConnection conn = new MySqlConnection(connString);
conn.Open();
MySqlTransaction transaction = conn.BeginTransaction();//开启一个事务
try
{
for (int i = 0; i < 50000; i++)
{
//处理语句
string sql = "insert into userlogin (UserName, Password, DateTimes) values ('"+ "anker" +"', '"+ "pass" +"', '"+ "202303271606" +"')";
MySqlCommand cmd = new MySqlCommand(sql, conn);
cmd.ExecuteNonQuery();//执行操作
}
}
catch (MySqlException ex)
{
Console.WriteLine(ex.Message);
transaction.Rollback();//如果执行失败,回滚操作,避免数据出现错误
conn.Close();
}
finally
{
if (conn.State != ConnectionState.Closed)
{
transaction.Commit();//提交事务,操作完成
conn.Close();//关闭数据库连接
}
}