DBJobManager Class Reference

List of all members.

---

Detailed Description

DataBase operations for job package.

Author:

S.Butterworth

Version:

Date

2006-11-13 19:59:09 +0000 (Mon, 13 Nov 2006)

Revision

1308

Definition at line 31 of file DBJobManager.java.

Static Public Member Functions
synchronized void	addLogfile (LogFile log) throws JetWebException
synchronized void	selectFromDBbyName (LogFile log) throws JetWebException
synchronized boolean	selectFromDB (CutCollection cuts) throws JetWebException
synchronized boolean	addToDB (CutCollection cuts) throws JetWebException
synchronized boolean	selectFromDB (Cut cut) throws JetWebException
synchronized boolean	addToDB (Cut cut) throws JetWebException
synchronized void	selectFromDB (PendingJob job) throws JetWebException
synchronized Enumeration< PendingJob >	selectPendingJobs () throws JetWebException
synchronized PendingJob	reserveJobName (String suggestion) throws JetWebException
synchronized void	updateStatus (LogFile log) throws JetWebException
synchronized void	checkStatus (LogFile log) throws JetWebException
void	removeLogFile (LogFile log)
synchronized int	countJobs (String hostname) throws JetWebException
synchronized int	countCompletedJobs (String hostname) throws JetWebException
synchronized void	selectFromDB (LogFile log) throws JetWebException
synchronized Vector< LogFile >	getLogFiles (int runSeriesId) throws JetWebException
synchronized int	getNLogs (int runSeriesId) throws JetWebException
Static Public Attributes
final String	SUCCESS = "Operation Completed Successfully"
Static Private Member Functions
synchronized boolean	fillById (CutCollection cuts) throws SQLException
synchronized boolean	fillByCuts (CutCollection cuts) throws SQLException, JetWebException
synchronized boolean	writeCheckedCutCollection (CutCollection cuts) throws SQLException, JetWebException
synchronized boolean	fillById (Cut cut) throws SQLException
synchronized boolean	fillByValue (Cut cut) throws SQLException
synchronized void	writeCheckedCut (Cut cut) throws SQLException
String	selectNearestCut (Cut cut)
void	fillLog (ResultSet rs, LogFile log) throws SQLException, JetWebException

---

Member Function Documentation

synchronized void addLogfile (  LogFile  log  )  throws JetWebException [static]

Adds new logfile record to the database Parameters: log  to be inserted to the database Exceptions: JetWebException  Definition at line 45 of file DBJobManager.java. { String ins = ""; try { Statement stmt = DBConfig.getConnection().createStatement(); //add the CutCollection for this logfile to the DB log.getGenerator().getCutCollection().store(); // add a row to the logfile table. if (log.getId() > 0) { ins = "UPDATE logfile SET file='" + log.getFile() + "',runseries_id=" + log.getRunSeries().getId() + ",status=" + log.getStatus() + ",lumi=" + log.getLumi() + ", cross_section=" +log.getCrossSection() + ",cut_collection_id=" + log.getGenerator().getCutCollection().getId()+ " WHERE log_id=" + log.getId(); } else { String select = "SELECT MAX(log_id) FROM logfile"; ResultSet rs = stmt.executeQuery(select); int newId = 1; while(rs.next()){ newId = rs.getInt(1); ++newId; } log.setId(newId); ins = "INSERT INTO logfile " + "(log_id, " + "file, " + "runseries_id, " + "status, " + "lumi, " + "cross_section," + "cut_collection_id)" + "values(" + log.getId() + ", '" + log.getFile() + "'," + log.getRunSeries().getId() + "," + log.getStatus() + "," + log.getLumi() + "," + log.getCrossSection() + "," + log.getGenerator().getCutCollection().getId() + ")"; } int rowsChanged = stmt.executeUpdate(ins); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); log.setStatus(LogFile.ERROR); throw new JetWebDBException(E, ins, "LogfileId:" + log.getId()); } }

synchronized boolean addToDB (  Cut  cut  )  throws JetWebException [static]

Definition at line 441 of file DBJobManager.java. { boolean hasId = cut.getId() > 0; boolean hasName = !cut.getName().equals(""); boolean hasValue = !(cut.getValue()==null); try{ if(hasId){ //check that a cut with this Id doesn't already exist. //If it does already exist, do nothing if(fillById(cut)) return false; } if(hasName&&hasValue){ if(fillByValue(cut)) return false; // if we get here then the cut has a value and a name // and is not present in the DB writeCheckedCut(cut); return true; } }catch(SQLException err){ throw new JetWebException(err); } return false; }

synchronized boolean addToDB (  CutCollection  cuts  )  throws JetWebException [static]

Definition at line 182 of file DBJobManager.java. { boolean hasId = (cuts.getId()>0); boolean hasCuts = (cuts.getCuts().size()!=0); try{ //If the collection has an id that is already present in the DB // then fill the collection object from the DB and return false if(hasId){ if(fillById(cuts)) return false; } if(hasCuts){ // if the same collection of cuts already exists in the // DB then just fill the Id and return false if(fillByCuts(cuts)) return false; return writeCheckedCutCollection(cuts); } }catch(SQLException err){ throw new JetWebException(err); } return false; }

synchronized void checkStatus (  LogFile  log  )  throws JetWebException [static]

Checks whether this logfile is already in the DB, setting the status field on the logfile object accordingly. Parameters: log  Exceptions: JetWebException  Definition at line 715 of file DBJobManager.java. { JetWebFile lf = log.getFile(); if(lf == null) return; String query = "SELECT status FROM logfile WHERE file LIKE '%" + lf + "%'"; //String query = "SELECT status FROM logfile WHERE file='" + // lf.getPath() + "'"; try { // See if the file is in there. Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(query); while (rs.next()) { Integer dbStatus = rs.getInt("status"); dbStatus = (dbStatus.equals(LogFile.SUBMITTED)&& log.hasAidaFile())? LogFile.RUN: dbStatus; log.setStatus(dbStatus); } // Finish up & return. rs.close(); stmt.close(); } catch (SQLException E) { System.out.println("DBFitManager.checkStatus"); System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, query, "LogFile:" + log.getId()); } }

synchronized int countCompletedJobs (  String  hostname  )  throws JetWebException [static]

Counts completed jobs in table "logfile" with given value of field "host". Parameters: hostname  Returns: Number of jobs completed by specified host. Exceptions: JetWebException  Definition at line 818 of file DBJobManager.java. { String query = "SELECT COUNT(log_id) count_rows FROM logfile WHERE status=1" + " AND host='" + hostname + "'"; int nJobs = 0; try { // First see if the file is in there. Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(query); rs.next(); nJobs = rs.getInt("count_rows"); // Finish up & return. rs.close(); stmt.close(); } catch (SQLException E) { System.out.println("DBFitManager.countCompletedJobs"); System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, query, "Error counting completed jobs"); } return nJobs; }

synchronized int countJobs (  String  hostname  )  throws JetWebException [static]

Counts jobs in table "logfile" with given value of field "host". Parameters: hostname  Returns: Number of jobs submitted to specified host. Exceptions: JetWebException  Definition at line 784 of file DBJobManager.java. { String query = "SELECT COUNT(log_id) count_rows FROM logfile WHERE host='" + hostname + "'"; int nJobs = 0; try { // First see if the file is in there. Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(query); rs.next(); nJobs = rs.getInt("count_rows"); // Finish up & return. rs.close(); stmt.close(); } catch (SQLException E) { System.out.println("DBFitManager.countJobs"); System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, query, "Error counting jobs"); } return nJobs; }

synchronized boolean fillByCuts (  CutCollection  cuts  )  throws SQLException, JetWebException [static, private]

Matches a CutCollection to a CutCollection in the DB using the Cut Ids (not the CutCollection Id) Definition at line 247 of file DBJobManager.java. { Vector<Integer> foundIds = new Vector<Integer>(); Vector<Integer> cutIds = new Vector<Integer>(); Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs; boolean firstCut = true; //loop over all cuts for(Cut cut: cuts.getCuts()){ Integer id = cut.getId(); //retrieve the cut id if necessary (and possible) if(id<0){ cut.retrieve(); id=cut.getId(); if(id<0) return false; } cutIds.add(id); //get all CutCollections that contain that cut String query = "SELECT cut_collection_id FROM cut_collection WHERE cut_id=" + id; rs = stmt.executeQuery(query); Vector<Integer> newIds = new Vector<Integer>(); while(rs.next()){ newIds.add(rs.getInt(1)); } // Find the list of CutCollections that contains the current cut // and all previous cuts (unless this is the first cut) Vector<Integer> tmpIds = new Vector<Integer>(); if(firstCut){ tmpIds = newIds; firstCut = false; }else{ for(Integer i: newIds){ if(foundIds.contains(i)){ tmpIds.add(i); } } } //if no CutCollection contains all previous cuts then there is no //matching CutCollection in the DB if(tmpIds.size()==0) return false; foundIds = tmpIds; } //Of the found CutCollections, look for one that matches exactly //i.e. contains ^only^ this set of cuts for(Integer Id: foundIds){ String select = "SELECT cut_id FROM cut_collection WHERE cut_collection_id=" + Id; rs = stmt.executeQuery(select); boolean carryOn = true; Integer numCuts = 0; while(rs.next() && carryOn){ if(!cutIds.contains(new Integer(rs.getInt(1)))) carryOn = false; ++numCuts; } if(carryOn && numCuts==cutIds.size()){ cuts.setId(Id); return true; } } return false; }

synchronized boolean fillById (  Cut  cut  )  throws SQLException [static, private]

Fills a cut based on the Id of that cut (which must already be there) returns true if filled succesfully Definition at line 478 of file DBJobManager.java. { String select = "SELECT * FROM cut WHERE cut_id="+cut.getId(); Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(select); if(!rs.next()) return false; cut.setValue(rs.getDouble("value")); cut.setName(rs.getString("name")); return true; }

synchronized boolean fillById (  CutCollection  cuts  )  throws SQLException [static, private]

Definition at line 213 of file DBJobManager.java. { Integer id = new Integer(cuts.getId()); String select = "SELECT cut_id FROM cut_collection WHERE cut_collection_id=" + id; Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(select); cuts.clear(); boolean filled = false; while(rs.next()){ filled = true; Cut cut = new Cut(rs.getInt(1)); cuts.addCut(cut); } //reset the CutCollection Id because adding cuts sets it to default // cuts.setId(id); return filled; }

synchronized boolean fillByValue (  Cut  cut  )  throws SQLException [static, private]

Fills a cut's Id based on the value and name of that cut. returns true if filled successfully. Definition at line 499 of file DBJobManager.java. { String select = selectNearestCut(cut); Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(select); if(!rs.next())return false; if(!Match.compareDouble(cut.getValue(), rs.getDouble("value"))) return false; cut.setId(rs.getInt("cut_id")); cut.setValue(rs.getDouble("value")); cut.setName(rs.getString("name")); return true; }

void fillLog (  ResultSet  rs, LogFile  log )  throws SQLException, JetWebException [static, private]

Definition at line 877 of file DBJobManager.java. References JetWebFile.XML. { int rsid = rs.getInt("runseries_id"); int status = rs.getInt("status"); Double cs = rs.getDouble("cross_section"); //if(rsid!=0)log.setRunSeriesId(rsid); // If the LogFile status is reserved then no info has been filled // apart from the file name and log id if(status!=LogFile.RESERVED&&rsid!=0) log.setRunSeriesId(rsid); //log.setRunSeriesId(rs.getInt("runseries_id")); log.setStatus(status); log.setId(rs.getInt("log_id")); log.setCrossSection(cs); String fName = rs.getString("file"); if(!(fName.endsWith(JetWebFile.XML + ".gz") && fName.endsWith(JetWebFile.XML))){ fName = fName + JetWebFile.XML; } JetWebFile testFile = new JetWebFile(fName); if(!testFile.exists()){ System.out.println("DBJobManager: could not find file - using " + testFile); } log.setFile(testFile); }

synchronized Vector<LogFile> getLogFiles (  int  runSeriesId  )  throws JetWebException [static]

Returns Vector of LogFiles associated with this runSeries. Parameters: runseries  the RunSeries object for which logfile names are to be retrieved Returns: a vector of logfile names (strings) Exceptions: JetWebException  Definition at line 918 of file DBJobManager.java. References LogFile.retrieve(). { Vector<LogFile> logs = new Vector<LogFile>(); String findLogs = "SELECT log_id FROM logfile WHERE runseries_id=" + runSeriesId; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(findLogs); while (rs.next()) { LogFile log = new LogFile(rs.getInt("log_id")); log.retrieve(); logs.add(log); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading logfile table " + e); throw new JetWebDBException(e, findLogs, "RunseriesId:" + runSeriesId); } return logs; }

synchronized int getNLogs (  int  runSeriesId  )  throws JetWebException [static]

Counts logfiles associated with this parameter set. Parameters: runseries  the RunSeries object for which logfile count is to be performed Returns: number of logfiles for this RunSeries Exceptions: JetWebException  Definition at line 949 of file DBJobManager.java. { String findLogs = "SELECT COUNT(log_id) count_logs FROM logfile WHERE runseries_id=" + runSeriesId; //System.out.println(findLogs); int n = 0; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(findLogs); rs.next(); n = rs.getInt("count_logs"); rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading logfile table " + e); throw new JetWebDBException(e, findLogs, "runseriesId:" + runSeriesId); } return n; }

void removeLogFile (  LogFile  log  )  [static]

Remove this logfile row from the table. Definition at line 759 of file DBJobManager.java. References LogFile.getFile(). { String name = log.getFile().getPath(); System.out.println("Removing logfile: " + name + " from table"); String del = "delete from logfile where file like '%" + log.getFile() + "%'"; //String del = "delete from logfile where file='" + name + "'"; try { Statement stmt = DBConfig.getConnection().createStatement(); stmt.executeUpdate(del); stmt.close(); } catch (SQLException e) { System.out.println("DBFitManager: Error executing " + del); } }

synchronized PendingJob reserveJobName (  String  suggestion  )  throws JetWebException [static]

Gives a new unique jobname by prepending the logfile number to the suggested stem. Also reserves the place in the logfile table. Parameters: suggestion  stem for the jobname Returns: PendingJob object with the new jobname. Exceptions: JetWebException  Definition at line 626 of file DBJobManager.java. { String name = "invalid"; int id = 0; String query = "SELECT MAX(log_id) FROM logfile"; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(query); while (rs.next()) { id = rs.getInt(1); id++; } //now we do a check for existing files with a name corresponding //to the found log_id. Keep incrementing the name until we //find a free one boolean free = false; DecimalFormat form = new DecimalFormat("00000000000"); while(!free){ name = "n" + form.format(id); JetWebFile testFile = new JetWebFile(name, ".input"); if(testFile.exists()){ ++id; }else{ free = true; } } if (id == 0) { System.out.println ("ResultManager Error allocating Id to " + suggestion); return null; } String ins = "INSERT INTO logfile (log_id,file,runseries_id,status,host) " + "VALUES (" + id + ",'" + name + "',0," + LogFile.RESERVED + ",'" + SubmitScriptHandler.BATCHFACILITY + "')"; int itmp = stmt.executeUpdate(ins); rs.close(); stmt.close(); } catch (SQLException E) { System.out.println("ResultManager.getJobName"); System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, query, "suggestion:" + suggestion); } return new PendingJob(id); }

synchronized void selectFromDB (  LogFile  log  )  throws JetWebException [static]

Populate the given LogFile from the DB. This method assumes the logId is already set. Parameters: int  The unique ID of the logfile. Exceptions: JetWebException  Definition at line 852 of file DBJobManager.java. { String findLog = "SELECT * FROM logfile WHERE log_id=" + log.getId(); int logId = log.getId(); try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(findLog); if (rs.next()) { fillLog(rs, log); } else { System.out.println("No LogFile found with ID=" + logId); throw new JetWebDBException(findLog, "logId:" + logId); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading logfile table " + e); throw new JetWebDBException(e, findLog, "logId:" + logId); } return; }

synchronized void selectFromDB (  PendingJob  job  )  throws JetWebException [static]

Select a PendingJob from the DB. Parameters: job  to be selected and populated. Exceptions: JetWebException  Definition at line 557 of file DBJobManager.java. References Cut.setName(). { String query = "SELECT * FROM logfile WHERE log_id=" + job.getLogId(); try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(query); rs.next(); if (rs.getInt("status") == 0) { job.setValid(true); } else { job.setValid(false); } job.setName(rs.getString("file")); job.setDate(rs.getTimestamp("time")); job.setRunSeriesId(rs.getInt("runseries_id")); job.setScriptName("unknown"); rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("DB access error in selectFromDB for PendingJob" + e); throw new JetWebDBException(e, query, "PendingJob logId:" + job.getLogId()); } }

synchronized boolean selectFromDB (  Cut  cut  )  throws JetWebException [static]

Populate a Cut object from the database. If no entry matches the Cut Id or the Cut Name+value Then store the Cut under a new Id Definition at line 378 of file DBJobManager.java. { String select; int id = cut.getId(); if(id > 0){ select = "SELECT * FROM cut WHERE cut_id="+id; }else{ //select the cut with the same name and nearest value //select = "SELECT * FROM cut where name="+cut.getName()+ //" AND ABS(value-" + cut.getValue() + //")=MIN(ABS(value-" + cut.getValue() + "))"; select = selectNearestCut(cut); } try{ Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(select); //if(rs.isAfterLast()){ if(!rs.next()){ //result set contains no rows - Cut is not in database //if cut name and value present, store it if(cut.getName().equals("") || cut.getValue()==null){ return false; } return cut.store(); } if(id>0){ //rs.next(); cut.setValue(rs.getDouble("value")); cut.setName(rs.getString("name")); return true; }else{ //need to check value in result set matches value of cut rs.next(); Double value = rs.getDouble("value"); if(Match.compareDouble(value, cut.getValue())){ cut.setId(rs.getInt("cut_id")); return true; } //if we get here then there is no row in the DB matching //that value, but there is a cut with that name. if(cut.getValue()!=null&& !cut.getName().equals("")){ return cut.store(); } } }catch(SQLException err){ } return false; }

synchronized boolean selectFromDB (  CutCollection  cuts  )  throws JetWebException [static]

Populate a CutCollection object from the DB If no entry matches the CutCollection id or the list of Cuts Then store this collection Returns: true if CutCollection was succesfully written to the DB Definition at line 160 of file DBJobManager.java. { try{ if(cuts.getIdDontRetrieve()>0){ if(fillById(cuts)) return true; } if(cuts.getCuts().size()!=0){ if(fillByCuts(cuts)) return true; // if we get here then there are some cuts in the collection // but they do not match any collection in the DB return false; } }catch(SQLException err){ throw new JetWebException(err); } return false; }

synchronized void selectFromDBbyName (  LogFile  log  )  throws JetWebException [static]

Fills runseriesId, status and logId of the input logfile. The only data which needs to be filled in the LogFile before this is the File itself. Parameters: log  object to be filled Exceptions: JetWebException  Definition at line 118 of file DBJobManager.java. { String query = "SELECT * from logfile where file like '%" + log.getFile() + "%'"; try { // First see if the file is in there. Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(query); if (rs.next()) { System.out.println ("DBJobManager: found logfile in DB matching file " + log.getFile()); // Read from DB to get runseries id from logfile table. fillLog(rs, log); }else{ System.out.println ("DBJobManager: no file in DB found matching " + log.getFile()); } // Finish up & return. rs.close(); stmt.close(); } catch (SQLException E) { System.out.println("DBFitManager.fillRunSeriesId"); System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, query, "LogfileId:" + log.getId()); } }

String selectNearestCut (  Cut  cut  )  [static, private]

Definition at line 544 of file DBJobManager.java. References Cut.getName(), and Cut.getValue(). { return "SELECT * FROM cut where name='" + cut.getName() + "' AND ABS(value-" + cut.getValue() + ")=(SELECT MIN(ABS(value-" + cut.getValue() + ")) FROM cut)"; }

synchronized Enumeration<PendingJob> selectPendingJobs (   )  throws JetWebException [static]

Retrieves a list of all pending jobs from the database Returns: list of PendingJobs Exceptions: JetWebException  Definition at line 592 of file DBJobManager.java. References PendingJob.isValid(). { Vector<PendingJob> jobs = new Vector<PendingJob>(); String query = "SELECT log_id FROM logfile WHERE status=0"; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(query); while (rs.next()) { PendingJob pj = new PendingJob(rs.getInt("log_id")); if (pj.isValid()) { jobs.add(pj); } } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("DB access error in selectPendingJobs" + e); throw new JetWebDBException(e, query, ""); } return jobs.elements(); }

synchronized void updateStatus (  LogFile  log  )  throws JetWebException [static]

Updates the status in the DB to match the status of the log file Definition at line 691 of file DBJobManager.java. References Cut.getId(). { String update = "UPDATE logfile " + " SET status=" +log.getStatus() + " WHERE log_id="+log.getId(); try{ Statement stmt = DBConfig.getConnection().createStatement(); stmt.executeUpdate(update); }catch(SQLException err){ throw new JetWebException(err); } return; }

synchronized void writeCheckedCut (  Cut  cut  )  throws SQLException [static, private]

Writes a cut that is already known to be safe to write. Definition at line 521 of file DBJobManager.java. { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery("SELECT MAX(cut_id) FROM cut"); int newId = 1; if(rs.next()){ newId = rs.getInt(1); ++newId; } cut.setId(newId); String insert = "INSERT INTO cut(cut_id, name, value)VALUES("+ cut.getId() + ",'" + cut.getName() + "', " + cut.getValue() +")"; stmt.executeUpdate(insert); return; }

synchronized boolean writeCheckedCutCollection (  CutCollection  cuts  )  throws SQLException, JetWebException [static, private]

Definition at line 331 of file DBJobManager.java. { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery ("SELECT MAX(cut_collection_id) FROM cut_collection"); int newId = 1; if(rs.next()){ newId = rs.getInt(1); ++newId; } if(cuts.getId()<newId) cuts.setId(newId); Vector<String> inserts = new Vector<String>(); for(Cut cut:cuts.getCuts()){ Integer Id = cut.getId(); // If any of the cuts in the collection has no id // then we can't write it to the DB if(Id<0){ cut.retrieve(); Id = cut.getId(); if(Id<0) return false; } inserts.add ("INSERT INTO cut_collection(cut_collection_id, cut_id)VALUES("+ cuts.getId() + ", " + cut.getId() + ")"); } for(String insert:inserts){ stmt.executeUpdate(insert); } return true; }

---

Member Data Documentation

final String SUCCESS = "Operation Completed Successfully" [static]

constant to signify successful completion of a DB Fit operation. Definition at line 35 of file DBJobManager.java.

---

The documentation for this class was generated from the following file:

• DBJobManager.java

Generated Wed Jan 17 09:14:27 GMT 2007