write-транзакция в MyDAC

[3D Hunter]

Как в MyDAC организовать транзакцию на несколько команд Insert?
В БД только разбираюсь, пробую так:

try
  FdbConn.StartTransaction;
  for i:=0 to LsTempList.Count-1 do
  begin
    FdbQuery.SQL.Text:=LsTempList[i];
    FdbQuery.ExecSQL;
  end;
  FdbConn.Commit;
except
  FdbConn.Rollback;
end;

Код не работает, в БД ничего не пишется. Поправьте меня пожалуйста и по возможности, киньте ссылками на соответствующую тему прилагательно к Delphi. Спасибо!

[Аватар]

А что значит код не работает? Вываливает ошибку или все Ok, а в базе пусто? Если ошибка, то на какой команде? Кстати сам метод StartTransaction может исключение вызвать и тогда в except вызов Rollback тоже исключение поднимет со всеми вытекающими последствиями. Я к тому, что StartTransaction нужно в отдельный try ... except оформлять.

[3D Hunter]

Код вываливает ошибку, причем молчаливого типа. Поток создается, инициализируется, пытается выполнить функцию с этим кодом. Функцию возвращает false. Поток проверяет результат и в случае краха уничтожается с закрытием соединения и уничтожением всех своих объектов.
Поясните пожалуйста, почему StartTransaction требует отдельного контроля? И корректен ли вообще приведенный мною код?

[Аватар]

Основное назначение StartTransaction послать в СУБД соответствующую SQL-команду старта транзакции, которая по разным причинам может не выполниться. Хотя бы из-за того, что соединение разорвано. Вот и возможная причина исключения. В остальном на глаз не вижу проблем. Точно установите на какой команде проблема. Возможно причина в содержимом LsTempList. Можно показать какие там команды?

[3D Hunter]

В этот список помещаются запросы на выполнение. Все запросы корректы. Специально их логгировал в файл и выполнял на той же БД в навикате. Суть в том, что при комментировании этих 3х строк с StartTransaction, Commit и Rollback код работает сутками 24/7. Но дело в том что выполняется несколько инсертов в цикле в этой функции, которая считается атомарной по логике приложения. Если не выполнятся не все запросы по разным причинам, то данные в них будут потеряны. Потому и встала задача толкать список инсертов транзакцией.
Код функции записи в БД:

//записывает в БД результаты запросов ASQLQuery (если удалось, то true)
function SaveDB(const ASQLQuery:AnsiString):Boolean;
...
function TTCPClientThread.SaveDB(const ASQLQuery:AnsiString):Boolean;
var
  i:Integer;
  LsTempList:TStringList;
begin
  Result:=True;
  try
    //если нет подключения к БД, подключаемся
    if (not FdbConn.Connected) then
    with FdbConn,gConfig do
    begin
      try
        Lock;
          Username:=FdbLogin;
          Password:=FdbPass;
          Server:=FdbIP;
          Port:=StrToInt(FdbPort);
          Database:=FdbName;
      finally
        Unlock;
      end;
    end;

    //запись в БД
    try
      LsTempList:=TStringList.Create;
      LsTempList.Text:=ASQLQuery;
//      FdbConn.StartTransaction;
      for i:=0 to LsTempList.Count-1 do
      begin
        FdbQuery.SQL.Text:=LsTempList[i];
        FdbQuery.ExecSQL;
      end;
//      FdbConn.Commit;
    finally
      FreeAndNil(LsTempList);
    end;
  except
    Result:=False;
//    FdbConn.Rollback;
    FOwner.ErrLog('TTCPClientThread.SaveDB'#13#10'Query: '+ASQLQuery);
  end;
end;

[3D Hunter]

Запросы формируются по константным маскам методом наращивания:

const
  cntGpsQueryMask:AnsiString=//маска формирования запроса для таблицы
                  'INSERT INTO `gps` '+
{0}               '(`equip_id`'+
{1}               ',`gps_imei`'+
{const}           ',`gps_fix`'+
{2}               ',`gps_date`'+
{3}               ',`gps_time`'+
{4}               ',`gps_lon`'+
{5}               ',`gps_lat`'+
{6}               ',`gps_alt`'+
{7}               ',`gps_speed`'+
{8}               ',`gps_sat`'+
{9}               ',`gps_kurs`'+
{10}              ',`signal_level`) '+
                  'VALUES (%s,%s,''0'',%s,%s,%s,%s,%s,%s,%s,%s,%s)';

  cntAnlQueryMask:AnsiString=//маска формирования запроса для таблицы
                  'INSERT INTO `data_sens_anal` '+
{0}               '(`equip_id`'+
{const}           ',`equip_num`'+
{1}               ',`date`'+
{2}               ',`time`'+
{3}               ',`indication`'+
{4}               ',`indication1`'+
{5}               ',`indication2`) '+
                  'VALUES (%s,''1'',%s,%s,%s,%s,%s)';

  cntDigQueryMask:AnsiString=//маска формирования запроса для таблицы
                  'INSERT INTO `data_sens_dig` '+
{0}                '(`equip_id`'+
{const}            ',`equip_num`'+
{1}                ',`date`'+
{2}                ',`time`'+
{3}                ',`state`'+
{4}                ',`state1`'+
{5}                ',`state2`'+
{6}                ',`state3`'+
{7}                ',`counter1`'+
{8}                ',`counter2`'+
{9}                ',`counter3`'+
{10}               ',`counter4`) '+
                   'VALUES '+
                   '(%s,''1'',%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)';

Маски корректные, код проверен, отлажен и в стадии тестирования. Интересует выполнение транзакций. По коммерческим причинам не могу привести больше кода. Скажу лишь, что проблем с ним нет, все работает отлично. Тест идет уже 4е сутки без перебоев. Таблицы в БД на движке InnoDB, поддержка транзакций присутствует.
Что можете посоветовать? Может есть какие-то особенности по работе именно с MyDAC?

[3D Hunter]

Если кто-нибудь работает с MyDAC, скажите пожалуйста, как правильно реализововать транзакцию? Возможно, через MyCommand вместо MyQuery?

[3D Hunter]

Проблема решена, тема закрыта.