Транзации, PDO и MSSQL

[Василий М.]

$dbh = new PDO("sqlsrv:Server=$hostname;Database=$dbname","$username","$pw");
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

try {
    $sql = 'select top 10 * from [med_Pay]';
    $stmt = $dbh->prepare($sql);
    $stmt->execute();

    $dbh->beginTransaction();

//     и не в этом дело даже....
//     while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
//             echo $row['id'] . "\n";  
//     }

    $dbh->commit();
  
} catch (Exception $e) {
    echo $e->getMessage();
    //$dbh->rollBack();
}

New transaction is not allowed because there are other threads running in the session.

куда копать? надо в транзацию обернуть как insert's, так и выборки.

 

[AnrDaemon]

Оборачивай, в чём проблема?

 

[Василий М.]

Оборачивай, в чём проблема?

я хотел это сделать средствами PDO
и вот этот пример не работает
я не могу понять почему

 

[Adelf]

а ты не хочешь ее начать ДО того как select выполнишь?

 

[Василий М.]

а ты не хочешь ее начать ДО того как select выполнишь?

допустим, я этого НЕ хочу.
у меня на каждый цикл должна быть транзакция. не вставилась запись по какой-то - причине - откат и идем далее:

while ($row = $stmt2->fetch(PDO::FETCH_ASSOC))
// begin trans
// do...
// commit

 

[Adelf]

Ну если я прав, то ты открыл курсор(это я терминами Оракл оперирую.. в мскуле может по другому называться), потом, не закрыв его, хочешь начать транзакцию. Что СУБД не очень хочет делать о чем и говорит.
Если хочешь делать как ты описал - получи все данные, закрой курсор и потом только открывай транзакцию.

 

[Василий М.]

@Adelf, я так и думал(( спасибо, помогло

 

[AnrDaemon]

допустим, я этого НЕ хочу.

Поговорку про "вредно не хотеть" помнишь? Это как раз твой случай.
Выборка на транзакцию не влияет.

 

[Василий М.]

Поговорку про "вредно не хотеть" помнишь? Это как раз твой случай.
Выборка на транзакцию не влияет.

почему мой случай? Вот проблему реального кода я решил, но я не могу понять причину отказа данного примера. Там курсор не задействован ещё (по идее). Мне трудно понять внутренний механизм работы в данном примере.

 

[Adelf]

$stmt->execute(); - вот здесь создается курсор. Некий проводник данных между твоей программой и СУБД. Он должен создаться либо внутри транзакции, либо должен быть уничтожен до ее открытия. Нельзя трнзакцию создавать когда курсор открыт. Ибо создается ситуация когда он открыт в одной транзакции, а используется в другой.

 

[Василий М.]

Получается, "уничтожение" курсора - это прогон по результирующему набору. Так и есть:

try {
  $sql = 'select top 10 * from [med_Pay]';
  $stmt = $dbh->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
  $stmt->execute();

  // Не сработает - не прошел через весь результирующий ряд
  // $stmt->fetchColumn();
 
  //  Так будет правильно
  while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {}

  $dbh->beginTransaction();
 
  $dbh->commit();
 
} catch (Exception $e) {
  echo $e->getMessage();
  $dbh->rollBack();
}

 

[Adelf]

обычно там есть явное закрытие.. типа close. Но, наверно оно может и само закрывать после последней строки...

 

[Василий М.]

Кстати, все зависит от типа PDO::ATTR_CURSOR в prepare:

PDO::CURSOR_SCROLL - ок
PDO::CURSOR_FWDONLY - exception

 

[AnrDaemon]

Я не понимаю, зачем ты так страдаешь?
Включи транзакцию до начала блока, с которым ты работаешь.
Либо используй fetchAll() уже.