This blog explains about performing customized audit s on a specific tables
Scenario : Audit only modified columns associated data into Audit table, rather than unmodified field values into history/audit table.
- get only modified attribute name, old value and new value for an entity
- get the table name associated to an entity
- get the database column name associated to an entity
- store only modified columns associated data into audit table.
Implementation
- Create a BaseEntityImpl class which extends to oracle.jbo.server.EntityImpl, override doDML() method as shown below
- Get the entity state, based on the entity state perform database CRUD operations.
Scenario : Audit only modified columns associated data into Audit table, rather than unmodified field values into history/audit table.
- get only modified attribute name, old value and new value for an entity
- get the table name associated to an entity
- get the database column name associated to an entity
- store only modified columns associated data into audit table.
Implementation
- Create a BaseEntityImpl class which extends to oracle.jbo.server.EntityImpl, override doDML() method as shown below
- Get the entity state, based on the entity state perform database CRUD operations.
@Override
protected void doDML(int i, TransactionEvent transactionEvent) {
String userName =
ADFContext.getCurrent().getSecurityContext().getUserName();
SimpleDateFormat sdf = new SimpleDateFormat("d-MMM-yyyy HH:mm:ss");
String currentTime = sdf.format(System.currentTimeMillis());
if (EntityImpl.DML_DELETE == i) {
System.out.println("Delete operation");
Long timeInMillis = System.currentTimeMillis();
try {
String sql =
"INSERT INTO XXATDTPR_HISTORY_DATA(ID,TABLE_NAME,KEY_NAME,KEY_VALUE,OPERATION,CREATED_BY,CREATED_ON,UPDATED_BY,UPDATED_ON) VALUES(" +
timeInMillis + ",'" + this.getEntityDef().getSource() +
"','" +
((BaseDefImpl)this.getEntityDef()).getPrimaryKeys()[0].getColumnName() +
"','" +
getAttribute(((BaseDefImpl)this.getEntityDef()).getPrimaryKeys()[0].getIndex()) +
"','" + "DELETE" + "','" + userName + "','" + currentTime +
"','" + userName + "','" + userName + "')";
System.out.println("SQL :: " + sql);
getDBTransaction().executeCommand(sql);
} catch (Exception e) {
e.printStackTrace();
}
} else if (EntityImpl.DML_INSERT == i) {
System.out.println("Insert operation");
Long timeInMillis = System.currentTimeMillis();
try {
String sql =
"INSERT INTO XXATDTPR_HISTORY_DATA(ID,TABLE_NAME,KEY_NAME,KEY_VALUE,OPERATION,CREATED_BY,CREATED_ON,UPDATED_BY,UPDATED_ON) VALUES(" +
timeInMillis + ",'" + this.getEntityDef().getSource() +
"','" +
((BaseDefImpl)this.getEntityDef()).getPrimaryKeys()[0].getColumnName() +
"','" +
getAttribute(((BaseDefImpl)this.getEntityDef()).getPrimaryKeys()[0].getIndex()) +
"','" + "INSERT" + "','" + userName + "','" + currentTime +
"','" + userName + "','" + userName + "')";
System.out.println("SQL :: " + sql);
getDBTransaction().executeCommand(sql);
} catch (Exception e) {
e.printStackTrace();
}
} else if (EntityImpl.DML_UPDATE == i) {
System.out.println("Update operation");
AttributeDef[] attributeDefs =
this.getEntityDef().getAttributeDefs();
for (AttributeDef attributeDef : attributeDefs) {
if (isAttributeChanged(attributeDef.getIndex())) {
Object oldValue =
getPostedAttribute(attributeDef.getIndex());
Object newValue = getAttribute(attributeDef.getIndex());
//use sequence generator here to generate unique prmary key
try {
Thread.sleep(10);
} catch (InterruptedException e) {
}
Long timeInMillis = System.currentTimeMillis();
try {
String sql =
"INSERT INTO XXATDTPR_HISTORY_DATA(ID,TABLE_NAME,KEY_NAME,KEY_VALUE,COLUMN_NAME,OLD_VALUE,NEW_VALUE,OPERATION,CREATED_BY,CREATED_ON,UPDATED_BY,UPDATED_ON) VALUES(" +
timeInMillis + ",'" +
this.getEntityDef().getSource() + "','" +
((BaseDefImpl)this.getEntityDef()).getPrimaryKeys()[0].getColumnName() +
"','" +
getAttribute(((BaseDefImpl)this.getEntityDef()).getPrimaryKeys()[0].getIndex()) +
"','" + attributeDef.getName() + "','" +
oldValue.toString() + "','" + newValue.toString() +
"','" + "UPDATE" + "','" + userName + "','" +
currentTime + "','" + userName + "','" + userName +
"')";
System.out.println("SQL :: " + sql);
getDBTransaction().executeCommand(sql);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
super.doDML(i, transactionEvent);
}
