|
9 | 9 | import org.zstack.core.cloudbus.MessageSafe; |
10 | 10 | import org.zstack.core.db.Q; |
11 | 11 | import org.zstack.core.db.SQL; |
| 12 | +import org.zstack.core.db.SQLBatch; |
12 | 13 | import org.zstack.core.thread.ChainTask; |
13 | 14 | import org.zstack.core.thread.SyncTaskChain; |
14 | 15 | import org.zstack.core.thread.ThreadFacade; |
@@ -430,14 +431,19 @@ private void handle(ResetVmTpmMsg msg) { |
430 | 431 | ResetVmTpmReply reply = new ResetVmTpmReply(); |
431 | 432 |
|
432 | 433 | String vmUuid = msg.getVmInstanceUuid(); |
433 | | - SQL.New(VmHostFileVO.class) |
434 | | - .eq(VmHostFileVO_.vmInstanceUuid, vmUuid) |
435 | | - .eq(VmHostFileVO_.type, VmHostFileType.TpmState) |
436 | | - .delete(); |
437 | | - SQL.New(VmHostBackupFileVO.class) |
438 | | - .eq(VmHostBackupFileVO_.resourceUuid, vmUuid) |
439 | | - .eq(VmHostBackupFileVO_.type, VmHostFileType.TpmState) |
440 | | - .delete(); |
| 434 | + new SQLBatch() { |
| 435 | + @Override |
| 436 | + protected void scripts() { |
| 437 | + sql(VmHostFileVO.class) |
| 438 | + .eq(VmHostFileVO_.vmInstanceUuid, vmUuid) |
| 439 | + .eq(VmHostFileVO_.type, VmHostFileType.TpmState) |
| 440 | + .delete(); |
| 441 | + sql(VmHostBackupFileVO.class) |
| 442 | + .eq(VmHostBackupFileVO_.resourceUuid, vmUuid) |
| 443 | + .eq(VmHostBackupFileVO_.type, VmHostFileType.TpmState) |
| 444 | + .delete(); |
| 445 | + } |
| 446 | + }.execute(); |
441 | 447 |
|
442 | 448 | bus.reply(msg, reply); |
443 | 449 | } |
|
0 commit comments