// set the Datapool File value
File inputTptpFile = new File(
"/Datapool_Workspace/Common/datapool/TPTP_Datapool.datapool");
System.out.println("Read a TPTP (RPT/RST) format Datapool: " +
inputTptpFile.getAbsolutePath());
try {
// create an IDatapoolFactory object
IDatapoolFactory tptpDatapoolFactory = new Common_DatapoolFactoryImpl();
// create an Datapool object
IDatapool tptpDatapool =
(IDatapool) tptpDatapoolFactory.load(inputTptpFile, true);
// capture the Datapool column header values
int datapoolColumnCount = tptpDatapool.getVariableCount();
String[] header = new String[datapoolColumnCount];
aStringBuilder.append("\nHEADER  :: ");
for (int i = 0; i < datapoolColumnCount; i++) {
header[i] = tptpDatapool.getVariable(i).getName();
aStringBuilder.append(header[i] + " :: ");
}
System.out.println(aStringBuilder.toString());
// Create an IDatapoolIterator object and populate with
//    the Datapool as an iterator
IDatapoolIterator tptpDatapoolIterator = tptpDatapoolFactory.
open(tptpDatapool,
"org.eclipse.hyades.datapool.iterator.DatapoolIteratorSequentialPrivate");
// initialize datapool iterator
tptpDatapoolIterator.dpInitialize(tptpDatapool, 0);
int count = 1; // int counter for demonstration purposes only
while(!tptpDatapoolIterator.dpDone()) {
// reset the temporary container for captured values
aStringBuilder.setLength(0);
aStringBuilder.append("ROW #" + count + "  :: ");
String[] nextRow = new String[datapoolColumnCount];
for (int i = 0; i < datapoolColumnCount; i++) {
/* NOTE: this example assumes value to be of type String
*    value can be captured via:
*    IDatapool.getVariable(int).getSuggestedType() */
nextRow[i] = tptpDatapoolIterator.dpCurrent().getCell(
header[i]).getStringValue();
aStringBuilder.append(nextRow[i] + " :: ");
}
tptpDatapoolIterator.dpNext();
count++;
System.out.println(aStringBuilder.toString());
// unload the Datapool
tptpDatapoolFactory.unload(tptpDatapool);
}
} catch (DatapoolException e) {
e.printStackTrace();
}

        /* NOTE: To update a Datapool the edit version of the classes must be used */
import org.eclipse.hyades.edit.datapool.IDatapool;
import org.eclipse.hyades.edit.datapool.IDatapoolFactory;
//import org.eclipse.hyades.execution.runtime.datapool.IDatapool;
//import org.eclipse.hyades.execution.runtime.datapool.IDatapoolFactory;

        try {
// create an org.eclipse.hyades.edit.datapool.IDatapoolFactory object
IDatapoolFactory tptpDatapoolFactory = new Common_DatapoolFactoryImpl();
// create an org.eclipse.hyades.edit.datapool.IDatapool object
IDatapool tptpDatapool = (IDatapool) tptpDatapoolFactory.loadForEdit(
inputTptpFile, true);

                /* Create an IDatapoolIterator object and populate with the Datapool
*     as an iterator
* NOTE: for edit variations of the IDatapool* objects the IDatapoolFactory
*     must be cast to "Common_DatapoolFactoryImpl" to make the appropriate
* open(IDatapool, String) method visible*/
IDatapoolIterator tptpDatapoolIterator =
((Common_DatapoolFactoryImpl)tptpDatapoolFactory).open(tptpDatapool,
"org.eclipse.hyades.datapool.iterator.DatapoolIteratorSequentialPrivate");

                for (int i = 0; i < datapoolColumnCount; i++) {
// look for the last column in the Datapool -- to be updated
if (i + 1 == tptpDatapool.getVariableCount()) {
// create a new value
String newCellValue = "Updated value for row " + count +
" at " + dateFormat.format(new Date().getTime());
// capture the cell as an IDatapoolCell
IDatapoolCell aCell = (IDatapoolCell)tptpDatapoolIterator.
dpCurrent().getCell(header[i]);
aCell.setCellValue(newCellValue);
// sleep to demonstrate timestamp update in Datapool
Thread.sleep(1000);
}
nextRow[i] = tptpDatapoolIterator.dpCurrent().
getCell(header[i]).getStringValue();

                // save updates to the Datapool file
tptpDatapoolFactory.save(tptpDatapool);
tptpDatapoolFactory.unload(tptpDatapool);