tm = command.getTransactionManager();
pm = tm.getDataObjectTransaction().getPersistenceManager();
QBuilder qb = new QBuilder(pm.getSchema());
tm.begin();
QAssetFeature qAssetFeature = qb.table(QAssetFeature. class );
QDelete delete = qb.delete(qAssetFeature).where(qb.expr(qAssetFeature.VALUE_ASSET_ID, assetRefId));
PreparedDelete pd = SQLQueryBuilder.preparedDelete(delete, tm.getConnection(), qAssetFeature, null );
try {
int changes = pd.execute();
logger.info( "Delete " + changes + " asset features where value_asset_id = " + assetRefId);
}
finally {
pd.close();
}
tm.end();
|