DB Lookup from Standard SAP PI UDF to execute select query and get the records. This UDF can be used to call JDBC channel and execute the select query to fetch the records from database.

DBLookupUDF.java

public String getDBLookupUDF(Container container) throws StreamTransformationException{
  GlobalContainer globalContainer;
  MappingTrace trace;
  java.util.Map map;
  
  trace = container.getTrace();
  globalContainer = container.getGlobalContainer();
  map = globalContainer.getTransformationParameters();
  
  //Variables Used
  String Query = " ";
  Channel channel = null;
  DataBaseAccessor accessor = null;
  DataBaseResult resultSet = null;
  Query = "Select FIELD1, FIELD2 from PIDB_CUSTOMTABLE";
  String returnValue = "";
  try{
	trace.addInfo("Query: " + Query);
	//Make sure the PI DB parameters are properly configured in the channel
	channel = LookupService.getChannel( "BS_PI_SYSTEM","CC_PI_DB_JDBC_RECEIVER"); 
	accessor = LookupService.getDataBaseAccessor(channel);
	resultSet = accessor.execute(Query);
	for(Iterator rows = resultSet.getRows();rows.hasNext();)
	{
		java.util.Map rowMap = (java.util.Map) rows.next();
		returnValue =  returnValue + "FIELD1: " + (String) rowMap.get("FIELD1") + "\r\n";
		returnValue =  returnValue + "FIELD2: " + (String) rowMap.get("FIELD2") + "\r\n";
	}    
  }catch(Exception ee){
    returnValue = "";
  }
  return returnValue;
}