tengo inconveniente con una trasaccion con c#, en NCAPAS les explico: tengo 2 tablas tingreso y tdetalleingreso con sus id autoincrementable, al guardarse el idingreso se captura y se guarda en la table tdetalleingreso.
En la clase IngresoDatos el problema lo tengo aqui porque no puedo pasarle la varialbe command y transaccion, me muestra el mensaje no se pude pasar como referencia o salida ya que es esta dentro using
result = det.cd_insertarDetalleIngreso(det, ref command, ref transaction);
quise instanciarla de nuevo en otras varialbes de esta manera y se quitan los errores, cuando ejecuto y doy guardar dice que sql no acepta transacciones paralelas
//SqlConnection sqlcon= new SqlConnection();
//1 sqlcon= connection;
// SqlCommand sqlcmd = new SqlCommand();
// SqlTransaction sqltra = sqlcon.BeginTransaction();
//1 sqlcmd.Connection = sqlcon;
//1 sqlcmd.Transaction = transaction;
al pasarle las variables command y transacciono, pasa el idingreso a la clase Detalleingreso y guarda segun asi creo que seria. talves me hechan una mano en el codigo como solucionarlo.
AL FINAL tengo el codigo de las clase que si funciona la transaccion y guarda en la base de datos en sus respectivas tablas todo lo hace bien. quiero hacerlo conservando la estructura donde utilizo el using(),me siento mas comodo lo veo mas ordenado de esta forma. por eso solicito de su conocimientos
saludos
public class IngresoDatos
{
private int idingreso;
private int idempleado;
private int idproveedor;
private DateTime fecha;
private int tipocomprobante;
private string comprobante;
private int iva;
private string estado;
public int Idingreso
{
get { return idingreso; }
set { idingreso = value; }
}
public int Idempleado
{
get { return idempleado; }
set { idempleado = value; }
}
public int Idproveedor
{
get { return idproveedor; }
set { idproveedor = value; }
}
public DateTime Fecha
{
get { return fecha; }
set { fecha = value; }
}
public int Tipocomprobante
{
get { return tipocomprobante; }
set { tipocomprobante = value; }
}
public string Comprobante
{
get { return comprobante; }
set { comprobante = value; }
}
public int Iva
{
get { return iva; }
set { iva = value; }
}
public string Estado
{
get { return estado; }
set { estado = value; }
}
public IngresoDatos(int idingreso, int idempleado, int idproveedor, DateTime fecha,
int tipocomprobante, string comprobante, int iva, string estado)
{
this.Idingreso = idingreso;
this.Idempleado = idempleado;
this.Idproveedor = idproveedor;
this.Fecha = fecha;
this.Tipocomprobante = tipocomprobante;
this.Comprobante = comprobante;
this.Iva = iva;
this.Estado = estado;
}
//CONSTRUCTOR
public IngresoDatos()
{ }
/****************************************
MEDTODO INSERTAR INGRESO
*****************************************/
public string cd_insertarIngreso(IngresoDatos Ingreso, List<DetalleIngresoDatos> Detalle)
{
using (var connection = ConnectionToSql.getConnection())
{
connection.Open();
string result = "";
using ( SqlTransaction transaction = connection.BeginTransaction() )
{
using (var command = new SqlCommand())
{
command.Connection = connection;
command.Transaction = transaction;
//SqlConnection sqlcon= new SqlConnection();
//2 sqlcon = command.Connection;
//1 sqlcon= connection;
// SqlCommand sqlcmd = new SqlCommand();
// SqlTransaction sqltra = sqlcon.BeginTransaction();
//2 sqltra = command.Transaction;
//1 sqlcmd.Connection = sqlcon;
//1 sqlcmd.Transaction = transaction;
command.CommandType = CommandType.Text;
command.CommandText = "INSERT INTO tingreso (idempleado, idproveedor, fecha, tipocomprobante, comprobante, iva, estado) " +
"VALUES (@idempleado,@idproveedor,@fecha,@tipocomprobante,@comprobante,@iva,@estado) SET @idIngreso=@@IDENTITY;";
SqlParameter ParIdingreso = new SqlParameter();
ParIdingreso.ParameterName = "@idIngreso";
ParIdingreso.SqlDbType = SqlDbType.Int;
ParIdingreso.Direction = ParameterDirection.Output;
command.Parameters.Add(ParIdingreso);
try
{
command.Parameters.AddWithValue("@idempleado", idempleado);
command.Parameters.AddWithValue("@idproveedor", idproveedor);
command.Parameters.AddWithValue("@fecha", fecha);
command.Parameters.AddWithValue("@tipocomprobante", tipocomprobante);
command.Parameters.AddWithValue("@comprobante", comprobante);
command.Parameters.AddWithValue("@iva", iva);
command.Parameters.AddWithValue("@estado", estado);
command.CommandType = CommandType.Text;
result = command.ExecuteNonQuery() == 1 ? "OK" : "UBRO ingresodatos ERROR";
if (result.Equals("OK"))
{
//Obtener el código del ingreso generado
Idingreso = Convert.ToInt32(command.Parameters["@idIngreso"].Value);
foreach (DetalleIngresoDatos det in Detalle)
{
det.Idingreso = Idingreso;
//Llamar al método insertar de la clase DDetalle_Ingreso
result = det.cd_insertarDetalleIngreso(det, ref command, ref transaction);
if (!result.Equals("OK"))
{
break;
}
}
}
if (result.Equals("OK"))
{
transaction.Commit();
}
}
catch (Exception ex)
{
transaction.Rollback();
result = ex.Message;
}
return result;
}
}
}
}
public class DetalleIngresoDatos
{
private int idingreso;
private int idarticulo;
public int Idingreso
{
get { return idingreso; }
set { idingreso = value; }
}
public int Idarticulo
{
get { return idarticulo; }
set { idarticulo = value; }
}
private int preciocompra;
public int Preciocompra
{
get { return preciocompra; }
set { preciocompra = value; }
}
private int precioventa;
public int Precioventa
{
get { return precioventa; }
set { precioventa = value; }
}
private int stockinicial;
public int Stockinicial
{
get { return stockinicial; }
set { stockinicial = value; }
}
private int stockactual;
public int Stockactual
{
get { return stockactual; }
set { stockactual = value; }
}
private DateTime fechaproduccion;
public DateTime Fechaproduccion
{
get { return fechaproduccion; }
set { fechaproduccion = value; }
}
private DateTime fechavencimiento;
public DateTime Fechavencimiento
{
get { return fechavencimiento; }
set { fechavencimiento = value; }
}
public DetalleIngresoDatos(int idingreso, int idarticulo, int preciocompra, int precioventa, int stockinicial, int stockactual, DateTime fechaproduccion, DateTime fechavencimiento)
{
this.idingreso = idingreso;
this.idarticulo = idarticulo;
this.preciocompra = preciocompra;
this.precioventa = precioventa;
this.stockinicial = stockinicial;
this.stockactual = stockactual;
this.fechaproduccion = fechaproduccion;
this.fechavencimiento = fechavencimiento;
}
public DetalleIngresoDatos()
{
}
public IEnumerable<DetalleIngresoDatos> a;
/****************************************
MEDTODO INSERTAR DETALLE INGRESO
*****************************************/
public string cd_insertarDetalleIngreso(DetalleIngresoDatos DIDatos, ref SqlConnection SqlCon, ref SqlTransaction SqlTra)
{
using (var connection = ConnectionToSql.getConnection())
{
connection.Open();
string a = "";
using (SqlTransaction transaction = connection.BeginTransaction())
{
using (var command = new SqlCommand())
{
command.Connection = connection;
command.Transaction = transaction;
command.CommandType = CommandType.Text;
command.CommandText = "INSERT INTO tdetalleingreso (idingreso,idarticulo,preciocompra,precioventa,stockinicial,stockactual,fechaproduccion,fechavencimiento) " +
"VALUES (@idingreso,@idarticulo,@preciocompra,@precioventa,@stockinicial,@stockactual,@fechaproduccion,@fechavencimiento)";
try
{
SqlParameter ParIddetalle_Ingreso = new SqlParameter();
ParIddetalle_Ingreso.ParameterName = "@idDetalleIngreso";
ParIddetalle_Ingreso.SqlDbType = SqlDbType.Int;
ParIddetalle_Ingreso.Direction = ParameterDirection.Output;
command.Parameters.Add(ParIddetalle_Ingreso);
foreach (var item in a)
{
command.Parameters.AddWithValue("@idingreso", idingreso);
command.Parameters.AddWithValue("@idarticulo", idarticulo);
command.Parameters.AddWithValue("@preciocompra", preciocompra);
command.Parameters.AddWithValue("@precioventa", precioventa);
command.Parameters.AddWithValue("@stockinicial", stockinicial);
command.Parameters.AddWithValue("@stockactual", stockactual);
command.Parameters.AddWithValue("@fechaproduccion", fechaproduccion);
command.Parameters.AddWithValue("@fechavencimiento", fechavencimiento);
command.CommandType = CommandType.Text;
a = command.ExecuteNonQuery() == 1 ? "OK" : " ERROR detalleIngreso";
if (a.Equals("OK"))
{
transaction.Commit();
}
}
}
catch (Exception ex)
{
transaction.Rollback();
a = ex.Message;
connection.Close();
throw;
}
return a;
}
}
}
}}}
DE ESTA MANERA SI FUNCIONA
/****************************************
MEDTODO INSERTAR DETALLE INGRESO
*****************************************/
public string cd_insertarDetalleIngreso(DetalleIngresoDatos DIDatos, ref SqlConnection SqlCon, ref SqlTransaction SqlTra)
{
string result = "";
try
{
//Establecer el Comando
SqlCommand SqlCmd = new SqlCommand();
SqlCmd.Connection = SqlCon;
SqlCmd.Transaction = SqlTra;
SqlCmd.CommandType = CommandType.Text;
SqlCmd.CommandText ="INSERT INTO tdetalleingreso (idingreso,idarticulo,preciocompra,precioventa,stockinicial,stockactual,fechaproduccion,fechavencimiento) "+
"VALUES (@idingreso,@idarticulo,@preciocompra,@precioventa,@stockinicial,@stockactual,@fechaproduccion,@fechavencimiento)";
SqlParameter ParIddetalle_Ingreso = new SqlParameter();
ParIddetalle_Ingreso.ParameterName = "@idDetalleIngreso";
ParIddetalle_Ingreso.SqlDbType = SqlDbType.Int;
ParIddetalle_Ingreso.Direction = ParameterDirection.Output;
SqlCmd.Parameters.Add(ParIddetalle_Ingreso);
SqlCmd.Parameters.AddWithValue("@idingreso", idingreso);
SqlCmd.Parameters.AddWithValue("@idarticulo", idarticulo);
SqlCmd.Parameters.AddWithValue("@preciocompra", preciocompra);
SqlCmd.Parameters.AddWithValue("@precioventa", precioventa);
SqlCmd.Parameters.AddWithValue("@stockinicial", stockinicial);
SqlCmd.Parameters.AddWithValue("@stockactual", stockactual);
SqlCmd.Parameters.AddWithValue("@fechaproduccion", fechaproduccion);
SqlCmd.Parameters.AddWithValue("@fechavencimiento", fechavencimiento);
result = SqlCmd.ExecuteNonQuery() == 1 ? "OK" : " ERROR detalleIngreso";
Console.Write(result);
}
catch (Exception ex)
{
result = ex.Message;
}
return result;
}
}}
/****************************************
MEDTODO INSERTAR INGRESO
*****************************************/
public string cd_insertarIngreso(IngresoDatos Ingreso, List<DetalleIngresoDatos> Detalle)
{
string result = "";
SqlConnection SqlCon = new SqlConnection();
try
{
SqlCon.ConnectionString = ConnectionToSql.Cn;
SqlCon.Open();
//Establecer la trasacción
SqlTransaction SqlTra = SqlCon.BeginTransaction();
//Establecer el Comando
SqlCommand SqlCmd = new SqlCommand();
SqlCmd.Connection = SqlCon;
SqlCmd.Transaction = SqlTra;
SqlCmd.CommandText = "INSERT INTO tingreso (idempleado, idproveedor, fecha, tipocomprobante, comprobante, iva, estado) "+
"VALUES (@idempleado,@idproveedor,@fecha,@tipocomprobante,@comprobante,@iva,@estado) SET @idIngreso=@@IDENTITY;";
SqlParameter ParIdingreso = new SqlParameter();
ParIdingreso.ParameterName = "@idIngreso";
ParIdingreso.SqlDbType = SqlDbType.Int;
ParIdingreso.Direction = ParameterDirection.Output;
SqlCmd.Parameters.Add(ParIdingreso);
SqlCmd.Parameters.AddWithValue("@idempleado", idempleado);
SqlCmd.Parameters.AddWithValue("@idproveedor", idproveedor);
SqlCmd.Parameters.AddWithValue("@fecha", fecha);
SqlCmd.Parameters.AddWithValue("@tipocomprobante", tipocomprobante);
SqlCmd.Parameters.AddWithValue("@comprobante", comprobante);
SqlCmd.Parameters.AddWithValue("@iva", iva);
SqlCmd.Parameters.AddWithValue("@estado", estado);
SqlCmd.CommandType = CommandType.Text;
result=SqlCmd.ExecuteNonQuery() == 1 ? "OK" : "UBRO ingresodatos ERROR";
if (result.Equals("OK"))
{
//Obtener el código del ingreso generado
Idingreso = Convert.ToInt32(SqlCmd.Parameters["@idIngreso"].Value);
foreach (DetalleIngresoDatos det in Detalle)
{
det.Idingreso = Idingreso;
//Llamar al método insertar de la clase DDetalle_Ingreso
result = det.cd_insertarDetalleIngreso(det, ref SqlCon, ref SqlTra);
if (!result.Equals("OK"))
{
break;
}
}
}
if(result.Equals("OK"))
{
SqlTra.Commit();
}
else
{
SqlTra.Rollback();
}
}
catch (Exception ex)
{
result = ex.Message;
}
return result;
}}}