mysqlhelper 返回自增id

using MySql.Data.MySqlClient;
using System;
using System.Data;

public class MySQLHelper
{
    private string connectionString;

    public MySQLHelper(string connectionString)
    {
        this.connectionString = connectionString;
    }

    public int InsertAndGetAutoIncrementId(string sql, params MySqlParameter[] parameters)
    {
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            connection.Open();
            using (MySqlCommand command = new MySqlCommand(sql, connection))
            {
                command.Parameters.AddRange(parameters);
                command.ExecuteNonQuery();
                return (int)command.LastInsertId;
            }
        }
    }
}

// 使用示例
public class Program
{
    public static void Main()
    {
        string connectionString = "server=localhost;database=testdb;user=root;password=root";
        MySQLHelper dbHelper = new MySQLHelper(connectionString);

        string insertSql = "INSERT INTO users (name, email) VALUES (@Name, @Email)";
        MySqlParameter nameParam = new MySqlParameter("@Name", "John Doe");
        MySqlParameter emailParam = new MySqlParameter("@Email", "john.doe@example.com");

        int autoIncrementId = dbHelper.InsertAndGetAutoIncrementId(insertSql, nameParam, emailParam);
        Console.WriteLine("Inserted ID: " + autoIncrementId);
    }
}

int rowsAffected = command.ExecuteNonQuery();
if (rowsAffected > 0)
{
    return (int)command.LastInsertId;
}
else
{
    throw new Exception("Insert operation failed.");
}

using (MySqlTransaction transaction = connection.BeginTransaction())
{
    using (MySqlCommand command = new MySqlCommand(sql, connection, transaction))
    {
        command.Parameters.AddRange(parameters);
        command.ExecuteNonQuery();
        transaction.Commit();
        return (int)command.LastInsertId;
    }
}