Devart Forums

Code: Select all

static int count = 0;
static void Main(string[] args)
{
            
    OracleMonitor mon = new OracleMonitor() { IsActive = true };
    OracleConnection conn = new OracleConnection("your connection string");
    conn.AutoCommit = true;
    conn.Open();
    string script = "INSERT INTO DEPT VALUES (10,'ACCOUNTING','NEW YORK');" +
        "INSERT INTO DEPT VALUES (20,'RESEARCH','DALLAS');" +
        "INSERT INTO DEPT VALUES (30,'SALES','CHICAGO');" +
        "INSERT INTO DEPT VALUES (40,'OPERATIONS','BOSTON');" +
        "Update Dept set loc='Los Angeles' where deptno>10;" +
        "DELETE FROM SCOTT.DEPT2 WHERE DEPTNO >20;";
    OracleScript myScript = new OracleScript(script, conn);
    myScript.Error += new Devart.Common.ScriptErrorEventHandler(OnError);
    myScript.SqlStatementExecute += new SqlStatementExecuteEventHandler(myScript_SqlStatementExecute);
    myScript.Execute();
    Console.WriteLine("Count = " + count);
    conn.Close();
}

static void myScript_SqlStatementExecute(object sender, SqlStatementExecuteEventArgs e)
{
    if (e.StatementType == Devart.Common.SqlStatementType.Insert || e.StatementType == Devart.Common.SqlStatementType.Update||e.StatementType==Devart.Common.SqlStatementType.Delete)
    {
        var script = (OracleScript)sender;
        e.StatementStatus = Devart.Common.SqlStatementStatus.SkipStatement;
        OracleCommand comm = new OracleCommand();
        comm.Connection = script.Connection;
        comm.CommandText = e.Text;
        count += comm.ExecuteNonQuery();
    }
}

static void OnError(object sender, Devart.Common.ScriptErrorEventArgs e)
{
    e.Ignore = true;
    Console.WriteLine(e.Text);
    Console.WriteLine("  Failed.");
}