midsuit
/
core-jgi
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Implement the transaction because very long

This commit is contained in:
vpj-cd 2008-09-05 18:57:31 +00:00
parent cbbb6c101e
commit 48db341e5a
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
base/src/org/eevolution/process/MRPUpdate.java
View File

@ -36,6 +36,7 @@ import org.compiere.process.SvrProcess;
import org.compiere.util.DB; import org.compiere.util.DB;
import org.compiere.util.Env; import org.compiere.util.Env;
import org.compiere.util.Msg; import org.compiere.util.Msg;
import org.compiere.util.Trx;
import org.eevolution.model.MForecastLine; import org.eevolution.model.MForecastLine;
import org.eevolution.model.MPPMRP; import org.eevolution.model.MPPMRP;
import org.eevolution.model.MPPOrder; import org.eevolution.model.MPPOrder;
@ -301,29 +302,35 @@ public class MRPUpdate extends SvrProcess
private void executeUpdate(String sql, List<Object> params) private void executeUpdate(String sql, List<Object> params)
{ {
Trx trx = Trx.get(Trx.createTrxName("Update MRP"), true);
Object[] pa = null; Object[] pa = null;
if (params != null) if (params != null)
pa = params.toArray(new Object[params.size()]); pa = params.toArray(new Object[params.size()]);
else else
pa = new Object[]{}; pa = new Object[]{};
// //
int no = DB.executeUpdateEx(sql, pa, get_TrxName()); int no = DB.executeUpdateEx(sql, pa, trx.getTrxName());
log.fine("#"+no+" -- "+sql); log.fine("#"+no+" -- "+sql);
} trx.commit();
}
private void deletePO(String tableName, String whereClause, List<Object> params) private void deletePO(String tableName, String whereClause, List<Object> params)
{ {
// TODO: refactor this method and move it to org.compiere.model.Query class // TODO: refactor this method and move it to org.compiere.model.Query class
POResultSet<PO> rs = new Query(getCtx(), tableName, whereClause, get_TrxName()) Trx trx = Trx.get(Trx.createTrxName("Delete MRP"), true);
POResultSet<PO> rs = new Query(getCtx(), tableName, whereClause, trx.getTrxName())
.setParameters(params) .setParameters(params)
.scroll(); .scroll();
try { try {
while(rs.hasNext()) { while(rs.hasNext()) {
rs.next().deleteEx(true); rs.next().deleteEx(true);
} }
} }
finally { finally {
trx.commit();
rs.close(); rs.close();
} }
} }