4 respuestas en este tema

[enecumene]

Pues eso estoy obteniendo un error al intentar actualizar datos con Firebird + ZEOS, aquí el code completo:

delphi

procedure TFAstGen.btn1Click(Sender: TObject);
var
  i,e,j,k: integer;
  FechaIni,FechaFin,EventIni,EventFin: Tdatetime;
  Fecha: string;
begin
 
 //Obtenemos el log completo
 QGetLogs.Close;
 QGetLogs.SQL.Clear;
 QGetLogs.SQL.Text := 'SELECT * FROM LOG_ASISTENCIA';
 QGetLogs.Open;
 
 if QGetLogs.RecordCount > 0 then begin
 
  {*** REGISTRAMOS TODAS LAS FECHAS A PARTIR DE UN RANGO DE FECHA ***}
  ShortDateFormat := 'dd/mm/yyyy';
  fechaIni := Primero;
  fechaFin := Ultimo;
 
  //Obtenemos los empleados activos
  QGetEmp.Close;
  QGetEmp.SQL.Clear;
  QGetEmp.SQL.Text := 'SELECT * FROM EMPLEADOS WHERE EMP_STATUS = 3';
  QGetEmp.Open;
  
  while not QGetEmp.eof do 
  begin
    e := QGetEmp.fieldbyname('EMP_ID').Value;
    for i := trunc(fechaIni) to trunc(FechaFin) do
    begin
      QGetDates.Close;
      QGetDates.SQL.Clear;
      QGetDates.SQL.Text := 'INSERT INTO ASISTENCIA(EMP_ID, AST_FECHA) VALUES(:EMP,:FECHA)';
      QGetDates.ParamByName('EMP').AsInteger := e;
      QGetDates.ParamByName('FECHA').AsDate := i;
      QGetDates.ExecSQL;
    end;
      QGetEmp.Next;
  end;
 {*** FIN ***}
 
 {*** LLENAMOS LAS ENTRADAS Y SALIDAS ***}
 while not QGetLogs.Eof do begin
    if QGetLogs.FieldByName('LOG_STATUS').AsInteger = 1 then begin
      QGetLogData.Close;
      QGetLogData.SQL.Clear;
      QGetLogData.SQL.Text := 'UPDATE ASISTENCIA SET AST_ENT = :ENT WHERE EMP_ID = :EMP AND AST_FECHA = :FECHA';
      QGetLogData.ParamByName('ENT').Value := QGetLogs.FieldByName('LOG_TIME').Value;
      QGetLogData.ParamByName('EMP').Value := QGetLogs.FieldByName('EMP_ID').AsInteger;
      QGetLogData.ParamByName('FECHA').Value := QGetLogs.FieldByName('LOG_FECHA').Value;
      QGetLogData.ExecSQL;
    end else if QGetLogs.FieldByName('LOG_STATUS').AsInteger <> 1 then begin
      //Obtenemos el último registro de salida
      QGetRows.Close;
      QGetRows.SQL.Clear;
      QGetRows.SQL.Text := 'SELECT MAX(LOG_TIME) FROM LOG_ASISTENCIA WHERE EMP_ID = :EMP AND LOG_FECHA = :FECHA';
      QGetRows.ParamByName('EMP').Value := QGetLogs.FieldByName('EMP_ID').AsInteger;
      QGetRows.ParamByName('FECHA').Value := QGetLogs.FieldByName('LOG_FECHA').Value;
      QGetRows.Open;
 
      //registramos las salidas
      QGetLogData.Close;
      QGetLogData.SQL.Clear;
      QGetLogData.SQL.Text := 'UPDATE ASISTENCIA SET AST_SAL = :SAL WHERE EMP_ID = :EMP AND AST_FECHA = :FECHA';
      QGetLogData.ParamByName('SAL').Value := QGetRows.Fields[0].Value;
      QGetLogData.ParamByName('EMP').Value := QGetLogs.FieldByName('EMP_ID').AsInteger;
      QGetLogData.ParamByName('FECHA').Value := QGetLogs.FieldByName('LOG_FECHA').Value;
      QGetLogData.ExecSQL;
    end;
    QGetLogs.Next;
 end;
 {*** FIN ***}
 
 {*** CALCULAMOS LAS AUSENCIAS Y LOS QUE NO SALIERON ***}
 QGetRows.Close;
 QGetRows.SQL.Clear;
 QGetRows.SQL.Text := 'SELECT AST_ENT, AST_SAL FROM ASISTENCIA';
 QGetRows.Open;
 
 while not QGetRows.Eof do begin
   if (QGetRows.Fields[0].IsNull) and (QGetRows.Fields[1].IsNull) then
   begin
        QGetLogUpdate.Close;
        QGetLogUpdate.SQL.Clear;
        QGetLogUpdate.SQL.Text := 'UPDATE ASISTENCIA SET CA_ID = 5 WHERE AST_ENT IS NULL AND AST_SAL IS NULL';
        QGetLogUpdate.ExecSQL;
   end else if (QGetRows.Fields[0].Value <> null ) and (QGetRows.Fields[1].IsNull) then
      begin
        QGetLogUpdate.Close;
        QGetLogUpdate.SQL.Clear;
        QGetLogUpdate.SQL.Text := 'UPDATE ASISTENCIA SET CA_ID = 6 WHERE AST_ENT IS NOT NULL AND AST_SAL IS NULL';
        QGetLogUpdate.ExecSQL;
      end;
    QGetRows.Next;  
 end;
 {*** FIN ***}
 
 {*** GENERAMOS LOS EVENTOS PROGRAMADOS ***}
  //Obtenemos los empleados activos
  QGetEmp.Close;
  QGetEmp.SQL.Clear;
  QGetEmp.SQL.Text := 'SELECT * FROM EMPLEADOS WHERE EMP_STATUS = 3';
  QGetEmp.Open;
 
  while not QGetEmp.Eof do begin
    e := QGetRows.FieldByName('EMP_ID').AsInteger;
 
    //Buscamos causas de este empleado
    QGetRows.Close;
    QGetRows.SQL.Clear;
    QGetRows.SQL.Text := 'SELECT EMP_ID, CA_ID, CA_DESDE, CA_HASTA FROM LOG_CAUSAS WHERE EMP_ID = :EMP';
    QGetRows.ParamByName('EMP').Value := e;
    QGetRows.Open;
 
    if QGetRows.RecordCount > 0 then begin
      EventIni := QGetRows.Fields[2].AsDateTime;
      EventFin := QGetRows.Fields[3].AsDateTime;
 
      for j := Trunc(EventIni) to Trunc(EventFin) do
      begin
        QGetDates.Close;
        QGetDates.SQL.Clear;
        QGetDates.SQL.Text := 'SELECT * FROM ASISTENCIA WHERE EMP_ID = :EMP AND AST_FECHA = :FECHA';
        QGetDates.ParamByName('EMP').Value := e;
        QGetDates.ParamByName('FECHA').Value := j;
        QGetDates.Open;
 
        if QGetDates.RecordCount > 0 then begin
          QGetLogUpdate.Close;
          QGetLogUpdate.SQL.Clear;
          QGetLogUpdate.SQL.Text := 'UPDATE ASISTENCIA SET CA_ID = :CA WHERE EMP_ID = :EMP AND AST_FECHA = :FECHA';
          QGetLogUpdate.ParamByName('CA').Value := QGetDates.FieldByName('CA_ID').AsInteger;
          QGetLogUpdate.ParamByName('EMP').Value := e;
          QGetLogUpdate.ParamByName('fecha').Value := j;
          QGetLogUpdate.ExecSQL;
        end;
      end;
    end;
    QGetEmp.Next;
  end;
  {*** FIN ***}
 end; //primer if
 
  DM.ZData.Commit;
end;

Éste es el error que me da:

delphi

---------------------------
Debugger Exception Notification
---------------------------
Project TimerPunch.exe raised exception class EZSQLException with message 'SQL Error:  deadlock update conflicts with concurrent update concurrent transaction number is 3231. Error Code: -913. deadlock The SQL: UPDATE ASISTENCIA SET AST_ENT = ? WHERE EMP_ID = ? AND AST_FECHA = ?; '. Process stopped. Use Step or Run to continue.
---------------------------
OK   Help   
---------------------------

EL error me lo causa en el último bloque, así que no sé a que se debe. ¿Una manita? 

[Alfredo]

no se el grado de atomicidad que necesites, pero, después del while donde llenas entradas y salidad, ¿te valdria poner un commit?, tengo la impresión que el ultimo bloque esta intentando hacer una actualización a un registro que se actualizó en el bucle llenar entradas y salidas, y por eso te esta arrojando el deadlock

[Rolphy Reyes]

Saludos.

Como bien indica Alfredo puede que necesites realizar un Commit (Commitretaining) después de actualizar los primeros registros.

Una sugerencia, trata de crearte un Stored Procedure en Firebird, es más rápido y mejor e incluso lo puedes utilizar en cualquier lugar que necesites incluyendo si cambias de lenguaje (espero que no suceda ) .  Para tus bucles solo debes de utilizar FOR SELECT.

[Marc]

Hola.

Un deadlock ocurre cuando dos transacciones en curso intentan modificar un mismo registro.

Aquí es donde no entiendo porqué te ocurre.

a) ¿ Tienes más usuarios conectados o conexiones abiertas y alguna de ellas tiene cambios en ejecución, pendientes de confirmar la transacción ?. En ese caso debes finalizar esas transacciones antes de poder ejecutar este procedimiento que va a modificar los mismos registros. NOTA: Como regla general, no dejes nunca transacciones abiertas, cualquier transacción que quede abierta con cambios pendientes de confirmar es una fuente segura de problemas por deadlocks. Las transacciones que modifiquen datos tienen que ser lo más cortas posibles: se abre la transacción, se modifican los datos y se confirma la transacción, no la dejes abierta pendiente de que el usuario cierre el formulario o cualquier cosa por el estilo.

b) Si no tienes más conexiones abiertas, entonces ¿ los querys de actualización de este procedimiento pertenecen a distintas transacciones ?. Tienes que ejecutarlos todos en la misma transacción, de forma que no puedan bloquearse entre ellos en un deadlock.

Como dice Rolphy, para este tipo de acciones es muchísimo mejor un procedimiento almacenado. Sus principales ventajas son :

a) Se ejecuta mucho más rápido. Ya que en tu programa Delphi, vas lanzando consultas que piden datos al servidor, que los sirve a tu programa, el cual los recorre y va lanzando nuevas consultas contra el servidor. En cambio en un procedimiento almacenado no se transporta ninguna información entre el cliente (tu programa) y el servidor, tu solo lanzas el procedimiento almacenado, y todo el procedimiento almacenado se ejecuta en el mismo Servidor Firebird. El hecho de que no se tenga que trasladar continuamente información entre el cliente y el servidor, hace que todo el proceso se ejecuta 10, 20 veces más rápido.

b) Tardas mucho menos en programarlo y se cometen menos errores. Es mucho más fácil y sencillo programar este proceso en un procedimiento almacenado que no hacerlo en un programa Delphi. NOTA: Aunque al principio es conveniente tener la versión completa de IB-Expert, para poder depurar los procedimientos almacenados que escribas.

En http://www.firebird.com.mx hay varios artículos referentes a la programación con prodemientos almacenados, como dice Rolphy, te interesa especialmente usar el bucle for select.

Saludos.

[enecumene]

Gracias, Alfredo, Rolphy y Marc, me costará dominar el asunto de los SP, pero como estoy corto de tiempo no podré hacer los cambios pertinentes. Ya hice los arreglos para que no vuelva ocurrir mientras tanto hasta corregir el asunto, que será en una segunda entrega y si logro dominar y entender los SP pues lo haré con ellos. Gracias a todos.

Saludos.