Torna al Thread
public void InsertObject()
{
if (ExistKey())
throw new Exception("Chiave Duplicata");
OracleConnection con = _LocalConnection.ConnessioneOracle;
//OracleTransaction oTrans = _LocalConnection.OracleTrans;
using (OracleCommand cmd = new OracleCommand())
{
//if (oTrans != null)
// cmd.Transaction = oTrans;
cmd.Connection = con;
cmd.CommandType = CommandType.Text;
String StrSQL = "INSERT INTO RT_RIGHE_SCARTATE (ID_SESSIONE,ANNO,MESE,PIPELINE,METER,ERRORE,RIGHE_FILE ) values (:ID_SESSIONE,:PRODYEAR,:PRODMONTH,:PIPELINE,:METER,:ERRORE,:RIGHE_FILE)";
cmd.Parameters.Add(new OracleParameter("ID_SESSIONE", OracleType.Number, 4, ParameterDirection.Input, "ID_SESSIONE", System.Data.DataRowVersion.Default, false, _ID_Sessione ));
cmd.Parameters.Add(new OracleParameter("PRODYEAR", OracleType.Number, 4, ParameterDirection.Input, "ANNO", System.Data.DataRowVersion.Default, false, _ProdYear));
cmd.Parameters.Add(new OracleParameter("PRODMONTH", OracleType.Number, 2, ParameterDirection.Input, "MESE", System.Data.DataRowVersion.Default, false, _ProdMonth));
cmd.Parameters.Add(new OracleParameter("PIPELINE", OracleType.VarChar, 12, ParameterDirection.Input, "PIPELINE", System.Data.DataRowVersion.Default, false,_Pipeline));
cmd.Parameters.Add(new OracleParameter("METER", OracleType.VarChar, 32, ParameterDirection.Input, "METER", System.Data.DataRowVersion.Default, false, _Meter));
cmd.Parameters.Add(new OracleParameter("ERRORE", OracleType.VarChar, 400, ParameterDirection.Input, "ERRORE", System.Data.DataRowVersion.Default, false, _Errore));
cmd.CommandText = StrSQL;
OracleParameter oracleParameterClob = new OracleParameter();
oracleParameterClob.OracleType = OracleType.Clob;
oracleParameterClob.Value = _Righe_File;
oracleParameterClob.ParameterName = "RIGHE_FILE";
cmd.Parameters.Add(oracleParameterClob);
cmd.ExecuteNonQuery();
}
}