Buenas tardes, actualmente estoy rellenando 3 tablas de mi base de datos, por lo que al momento de conseguir los datos estos son ingresados en la primera tabla, obtengo la primary key del primer insert para luego ocuparlo en el relleno de las siguientes dos, probé mi código y funciona todo perfecto Mi duda es como puedo hacer para que los registros solo sean insertados si es que los 3 insert fueron exitosamente llevados a cabo, es decir si el primero tuvo error que no continúe con los otros 2 insert o viceversa si es que se insertó todo bien en la primera tabla pero falló el insert de la tabla 3 que no inserte los datos de las 2 primera tablas dado que tendría fallas en mi información dado tales relaciones entre ellas (foráneas). Existe una manera de hacerlo? Comparto mi código de igual forma, saludos.
public static bool crearPlanificacion(Planificacion recibo)
{
var query = "INSERT INTO ActividadPlanificada (idActividadGenerica, idSucursalEmpresa,anio, mes,descripcionActividadPlanificada) VALUES" +
"(@idActividadGenerica,@idSucursalEmpresa,@anio, @mes,@descripcionActividadPlanificada);SELECT SCOPE_IDENTITY(); ";
var query2 = "INSERT INTO UsuarioEstadoActividadPlanificada (idUsuario, idActividadPlanificada,idEstado) VALUES" +
"(@idUsuario,@idActividadPlanificada,@idEstado)";
var query3 = "INSERT INTO UsuarioActividadPlanificada (idUsuario, idActividadPlanificada,fechaAsignacionResponsable) VALUES" +
"(@idUsuario,@idActividadPlanificada,@fechaAsignacionResponsable)";
String fechaAsignacionResponsable = DateTime.Now.ToString("dd-M-yyyy HH:mm");
SqlConnection connection = new SqlConnection(conexionString);
try
{
connection.Open();
//TANTAS VECES COMO idActividadGenerica VENGAN DESDE EL CLIENTE
for (int i = 0; i < recibo.planificacion.Count ; i++)
{
//Tabla ActividadPlanificada
SqlCommand command = new SqlCommand(query, connection);
command.Parameters.Add(new SqlParameter("@idActividadGenerica", SqlDbType.Int)).Value = recibo.planificacion[i].idActividadGenerica; //desde array json
command.Parameters.Add(new SqlParameter("@idSucursalEmpresa", SqlDbType.Int)).Value = recibo.idSucursalEmpresa;
command.Parameters.Add(new SqlParameter("@anio", SqlDbType.Int)).Value = recibo.anio;
command.Parameters.Add(new SqlParameter("@mes", SqlDbType.Int)).Value = recibo.mes;
command.Parameters.Add(new SqlParameter("@descripcionActividadPlanificada", SqlDbType.Text)).Value = recibo.descripcionActividadPlanificada;
//Ejecutamos la consulta y obtenemos la id de la actividadPlanificada para insertarla en las otras tablas
Int32 pkActividadPlanificada = Convert.ToInt32(command.ExecuteScalar());
//Tabla UsuarioEstadoActividadPlanificada
SqlCommand command2 = new SqlCommand(query2, connection);
command2.Parameters.Add(new SqlParameter("@idUsuario", SqlDbType.Int)).Value = recibo.idUsuarioResponsable;
command2.Parameters.Add(new SqlParameter("@idActividadPlanificada", SqlDbType.Int)).Value = pkActividadPlanificada;
command2.Parameters.Add(new SqlParameter("@idEstado", SqlDbType.Int)).Value = 1; //Por defecto empiezan con estado Pendiente
command2.ExecuteNonQuery();
//Tabla UsuarioActividadPlanificada
SqlCommand command3 = new SqlCommand(query3, connection);
command3.Parameters.Add(new SqlParameter("@idUsuario", SqlDbType.Int)).Value = recibo.idUsuarioResponsable;
command3.Parameters.Add(new SqlParameter("@idActividadPlanificada", SqlDbType.Int)).Value = pkActividadPlanificada;
command3.Parameters.Add(new SqlParameter("@fechaAsignacionResponsable", SqlDbType.DateTime)).Value = fechaAsignacionResponsable;
command3.ExecuteNonQuery();
}
connection.Close();
return true;
}
catch (Exception)
{
return false;
}
}