Club Delphi  
    Paypal   FTP   CCD     Buscar   Trucos   Trabajo   Foros

Retroceder   Foros Club Delphi > Principal > Conexión con bases de datos
Registrarse FAQ Miembros Calendario Guía de estilo Temas de Hoy

Conexión con bases de datos

 
 
Herramientas Buscar en Tema Desplegado
  #21  
Antiguo 25-02-2016
jars jars is offline
Miembro
 
Registrado: mar 2004
Posts: 283
Poder: 23
jars Va por buen camino
Voy a tratar de hacerme entender.
El programa recolecta información desde otro módulo a un ritmo de 2 veces por segundo, procesa esa información, la vuelca en el registro en cuestion y envía ese registro a distintos puestos via tcp. Esto viene funcionando hace años y bien.
La cosa es que ahora se necesita cada tanto tiempo (pej. 1 minuto) bajar ese registro a la BBDD para que en caso de corte de luz o cualquier otro problema, no se pierda la información acumulada hasta el momento. Este programa lleva una estadística diaria y no se puede perder es por eso que se necesita resguardarla en BBDD para que a lo sumo se pierda el último minuto y no todo.
El registro tiene un tamaño de 230K (si, es grande), logre comprimirlo y lo deja en aproximadamente 10.5 k.
Mi última prueba fue de no manejar una tabla en memoria, directamente tomar el registro, comprimirlo y hacer un comando SQL Insert pero me encuentro que al llegar al registro 359 siempre se cuelga con un Acces violation en una direccion 005a2000 no hay nada ahi. Este es el código que estoy probando:

Código Delphi [-]

type
  TPos = packed record
    PosNumber: Word;
    AgentId: string[10];
    AgentName: string[30];
    State: Byte;               
    ChatState: TChatState;
    PosFlags: set of TPosFlag;
    SkillSet: TSkillSet;           
    SkillsDistribution: TSkillsDist;
    CurrentCallSkill: Byte;         
    IMRSessions: string[250];    
    CurrentStateTime: Word;     
    PosIdleTime: Word;             
    PosLockedTime: Word;        
    PosLockedAnswTime: Word; 
    ......
end;

// tamaño total 230.000

procedure TRecord2BlobForm.btnUpdClick(Sender: TObject);
var
  i: Integer;
  s, zip: TMemoryStream;
begin
  Q.SQL.Add('INSERT INTO SESSION_DATA VALUES(:ID, ATA)');
  Q.Prepare;

  Sched.StartTransaction;
  for i := 0 to 999 do
    with Pos[i] do
    begin
      s   := TMemoryStream.Create;
      zip := TMemoryStream.Create;

      try
        s.Write(Pos[i], SizeOf(TPos));
        s.Position := 0;
        ZCompressStream(s, zip, zcMax);
        Q.ParamByName('ID').Value := i;
        Q.ParamByName('DATA').LoadFromStream(zip, ftBlob) ;
        Q.ExecSQL;
      finally
        FreeAndNil(s);
        FreeAndNil(zip);
      end;
      if i mod 50 = 0 then
      begin
        Sched.Commit;
        Sched.StartTransaction;
      end;
    end;
  if Sched.InTransaction then Sched.Commit;
end;

Espero me haberme hecho entender.
Gracias.
Responder Con Cita
 



Normas de Publicación
no Puedes crear nuevos temas
no Puedes responder a temas
no Puedes adjuntar archivos
no Puedes editar tus mensajes

El código vB está habilitado
Las caritas están habilitado
Código [IMG] está habilitado
Código HTML está deshabilitado
Saltar a Foro

Temas Similares
Tema Autor Foro Respuestas Último mensaje
Mover datos de tabla en memoria a tabla mysql webmasterplc SQL 0 07-04-2014 05:12:33
Problema con Stored Procedure para actualizar tabla con datos de otra tabla. Adrian Murua MySQL 4 04-02-2012 02:54:49
Actualizar tabla con datos de otra tabla mediante UPDATE Rockin Firebird e Interbase 18 28-11-2007 19:15:42
Como actualizar una tabla cada cierto tiempo leodenis784 Conexión con bases de datos 4 01-08-2006 13:58:38
Una Transacción por cada Tabla???? AGAG4 Conexión con bases de datos 5 22-12-2004 03:24:44


La franja horaria es GMT +2. Ahora son las 01:01:00.


Powered by vBulletin® Version 3.6.8
Copyright ©2000 - 2026, Jelsoft Enterprises Ltd.
Traducción al castellano por el equipo de moderadores del Club Delphi
Copyright 1996-2007 Club Delphi