Einzelnen Beitrag anzeigen

delphinub23

Registriert seit: 27. Okt 2010
Ort: Chemnitz
110 Beiträge
 
Delphi XE3 Professional
 
#1

InterBase - DBX-Fehler Hersteller-Fehler

  Alt 20. Mai 2013, 20:29
Datenbank: InterBase • Version: XE3 • Zugriff über: TSQLConnection
Hallo Delphianer,

ich habe Informationen in einer Log-Datei stehen, die in eine Datenbank geschrieben werden müssen.
Den Inhalt einer Textdatei lade ich in eine TStringList, welche ich dann iterativ durchgehe und die Informationen von einer Zeile in die Datenbank schreibe.
Ich führe in dieser Prozedur mehrere Anfragen an die Datenbank aus, weshalb ich vor jede Query ein BeginTransaction rufe.
Leider bekomme ich nach rund 4000 Datensätzen einen DBX-Fehler Hersteller-Fehler zugeworfen und kann damit nichts anfangen.

Wofür steht der Fehler? Oder, sind meine Routinen der eigentliche Auslöser für den Absturz der DB?

Das sind die Funktionen, die ich rufe, um SQL Queries an die DB zu schicken
Delphi-Quellcode:
function TStatisticsDataModule.SQLSelect(var ResultSet: TDataSet;
  const Fields, From: string; const Where: string = ''; const GroupBy: string = '';
  const OrderBy: string = ''): Integer;
var
  sqlQuery: string;
  selectClause: string;
  fromClause: string;
  whereClause: string;
  groupByClause: string;
  orderByClause: string;
  Transaction: TDBXTransaction;
begin
  selectClause := Format('SELECT %s', [Fields]);
  fromClause := Format('FROM %s', [From]);
  whereClause := Format('WHERE %s', [Where]);
  groupByClause := Format('GROUP BY %s', [GroupBy]);
  orderByClause := Format('ORDER BY %s', [OrderBy]);
  sqlQuery := Format('%s %s', [selectClause, fromClause]);
  if Length(Where) > 0 then
    sqlQuery := Format('%s %s', [sqlQuery, whereClause]);
  if Length(GroupBy) > 0 then
    sqlQuery := Format('%s %s', [sqlQuery, groupByClause]);
  if Length(OrderBy) > 0 then
    sqlQuery := Format('%s %s', [sqlQuery, groupByClause]);

  Transaction := FSQLConnection.BeginTransaction;
  try
    Result := FSQLConnection.Execute(sqlQuery, nil, ResultSet);
  finally
    FSQLConnection.CommitFreeAndNil(Transaction);
  end;
end;

function TStatisticsDataModule.SQLUpdate(const Table: string;
  const FieldsAndValues: string;
  const Where: string = ''): Integer;
var
  sqlQuery: string;
  updateClause: string;
  setClause: string;
  whereClause: string;
  Transaction: TDBXTransaction;
begin
  updateClause := Format('UPDATE %s', [Table]);
  setClause := Format('SET %s', [FieldsAndValues]);
  whereClause := Format('WHERE %s', [Where]);
  sqlQuery := Format('%s %s', [updateClause, setClause]);
  if Length(Where) > 0 then
    sqlQuery := Format('%s %s', [sqlQuery, whereClause]);

  Transaction := FSQLConnection.BeginTransaction;
  try
    Result := FSQLConnection.ExecuteDirect(sqlQuery);
  finally
    FSQLConnection.CommitFreeAndNil(Transaction);
  end;
end;

function TStatisticsDataModule.SQLInsert(const Table: string;
  const Values: string;
  const Where: string = ''): Integer;
var
  sqlQuery: string;
  insertClause: string;
  valuesClause: string;
  whereClause: string;
  Transaction: TDBXTransaction;

  sl: TStrings;
begin
  insertClause := Format('INSERT INTO %s', [Table]);
  valuesClause := Format('VALUES (%s)', [Values]);
  whereClause := Format('WHERE %s', [Where]);
  sqlQuery := Format('%s %s', [insertClause, valuesClause]);
  if Length(Where) > 0 then
    sqlQuery := Format('%s %s', [sqlQuery, whereClause]);

  Transaction := FSQLConnection.BeginTransaction;
  try
    Result := FSQLConnection.ExecuteDirect(sqlQuery);
  finally
    FSQLConnection.CommitFreeAndNil(Transaction);
  end;
und das der ein PSEUDO-Aufruf:
Delphi-Quellcode:
  for Entry in LogFile.Content do
  begin
    SQLSelect({DS},{WERT1},...);
    SQLUpdate({WERT1},...);
    SQLInsert({WERT1},...);
  end;
  Mit Zitat antworten Zitat