倍数连接到Oracle - 多任务

Question

我有，我必须一般来说检查整个基地做东西控制台应用程序...

要做到这一点，我使用Tasks这样的：

static void Main(string[] args) 
{ 
     var dateStart = DateTime.Now.AddDays(-35); 
     var dateEnd = DateTime.Now; 

     var taskList = new List<Task>(); 

     while (dateStart > dateEnd ? dateStart >= dateEnd : dateStart <= dateEnd) 
     { 
      var d = dateStart.Date; 
      var dispositivesBll = new DispositivesBll(); 
      taskList.Add(Task.Run(() => 
             { 
              dispositivesBll.Foo(d); 
             }).ContinueWith(
              x => dispositivesBll.Dispose()) 
           .ContinueWith(x => GC.Collect())); 

      var dispositivesBllNew = new DispositivesBll(); 
      taskList.Add(Task.Run(() => 
             { 
              dispositivesBllNew.Boo(d); 
             }).ContinueWith(
              x => 
              dispositivesBllNew.Dispose()) 
           .ContinueWith(x => GC.Collect())); 

      if (taskList.Count >= 2 * 5) 
      { 
       Task.WaitAll(taskList.ToArray()); 
       taskList.Clear(); 
      } 
      dateStart = dateStart > dateEnd ? dateStart.AddDays(-1) : dateStart.AddDays(1); 
     } 
     Task.WaitAll(taskList.ToArray()); 

所以基本上我想要运行10天一次在if (taskList.Count >= 2 * 5)你可能注意到了，但问题是，我Foo和Boo方法有多个连接到一个Oracle数据库。

public class DispositivesBll : IDisposable 
{ 
    private readonly OracleDal _oracleDal = new OracleDal(); 

    public void Foo(DateTime data) 
    { 

     var t1 = Task.Run(() => 
        { 
         _listSuccess = _oracleDal.GetSuccessList(); 
        }); 

     var t2 = 
      Task.Run(() => 
         { 
          listFailure = _oracleDal.GetFailureList(); 
         }); 

     t1.Wait(); 
     t2.Wait(); 

     foreach (var success in _listSuccess) 
     { 
      //Some logic to insert objects into a "mergeList" 
     } 

     if (mergeList.Any()) 
      Task.Run(() => _oracleDal.MergeList(mergeList)).Wait(); 
    } 

    public void Dispose() 
    { 
     if (_hash != null) 
      _hash.Clear(); 
     _hash = null; 

    } 
} 

和我的合并方法：

public void MergeList(List<MyObject> mergeList) 
    { 
     using (var conn = new OracleConnection(Connection.ConnectionString)) 
     { 
      if (conn.State != ConnectionState.Open) 
       conn.Open(); 
      using (var oCommand = conn.CreateCommand()) 
      { 
       oCommand.CommandType = CommandType.Text; 
       oCommand.CommandText = string.Format(@" 
       MERGE INTO MyTable dgn 
       USING (select id from another_table where field = :xpe) d ON (TO_CHAR(dateHappen, 'DDMMYYYY') = {0} and id = :xId) WHEN MATCHED THEN 
        UPDATE SET OK = :xOk, dateHappen = SYSDATE 
       WHEN NOT MATCHED THEN 
        INSERT (fields....) 
        VALUES (values...)"); 
       oCommand.BindByName = true; 
       oCommand.ArrayBindCount = mergeList.Count; 



       oCommand.Parameters.Add(":xId", OracleDbType.Int32, 
             mergeList.Select(c => Convert.ToInt32(c.Id)).ToArray(), ParameterDirection.Input); 

       oCommand.Parameters.Add(":xPe", OracleDbType.Varchar2, 
             mergeList.Select(c => Convert.ToString(c.Xpe)).ToArray(), ParameterDirection.Input); 


       oCommand.ExecuteNonQuery(); 
      } 
     } 
    } 

的问题是：对于每一个“天”，它tooks约2小时来处理一切......我们有一个计划，每天备份我们的数据库造成该数据库停止大约10分钟...所以它会导致我的过程中锁...

那么我该怎么做？我手动停止这个过程，并再次启动它，避免已经执行的日期。但是如果我打开了20个连接，他们会保持这种方式......所以我必须每次都杀掉这些会话......有没有办法强制所有连接处置？

编辑：

MyTable有50英里行....由ID | STATE | DATE组成......基本上我必须要跨越这些国家与他们的日期...... 因此，最大的延迟它的数据库。 ..它还挺一个已知的问题，我们要重构整个数据库模型....我们要尽快做到这一点...

但不管怎么说，尽管处理时间，如果我可以管理（或强制）连接杀死，它会很好...

任何想法？

Answer 1

好的，为了杀死一个会话，你需要一个DBA，如果你每周做几次，就不会有好的友谊！正如我和其他人指出的那样，不需要为备份而关闭数据库（除了冷备份）或甚至导出数据库，但是如果您有这些较长的合并过程，则一致的导出过程需要很长时间。因此，第一步是教育（很好）DBA如何使数据库处于归档日志模式，并让RMAN管理联机备份。

其次，你需要提高合并条件，以便合并列索引。它很可能是dateHappen被索引，而是因为你是它的合并条件调用一个函数，除非创建一个基于函数的索引不能使用该索引。我指的是

TO_CHAR(dateHappen, 'DDMMYYYY') = {0} 

具体而言;在一般情况下，

USING (select id from another_table where field = :xpe) d 
ON (TO_CHAR(dateHappen, 'DDMMYYYY') = {0} and id = :xId) 

你应该检查，看看是否在another_tableid和field被索引，并创建dateHappen一个基于函数的索引：

create index i_date_string on whatever_table (TO_CHAR(dateHappen, 'DDMMYYYY')) 

为了您的数据库调整，只需调用在SQL工具中自行合并语句以尝试不同的方法;那么你将不必担心杀人合并中途，whicn会在数据库中造成了很多的工作回滚事务等

更新：

OK，我会回答这个问题，而不是提供我的解决方案。 :)

您可以创建一个profile被然后分配给user到会话限制在一个特定的CONNECT_TIME或IDLE_TIME或两者兼而有之。然后，如果用户如果用户超过了CONNECT_TIME或IDLE_TIME会话资源 极限超过时间，根据http://docs.oracle.com/database/121/SQLRF/statements_6012.htm#SQLRF01310

，则数据库回滚当前事务并结束 该会话。当下一个用户进程发出呼叫时，数据库 将返回一个错误。

所以，你可以这样做：

create profile MERGE_PROF limit idle_time 5 connect_time 86400; 
alter user BATCH_MERGER_USER profile MERGE_PROF; 

然后在创建会话时，如果会话闲置5分钟后，甲骨文将杀死会话，如果它是24小时运行实，（24小时内在命令之间运行少于5分钟的命令）Oracle将终止会话。