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;
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.