DBPlotManager Class Reference

List of all members.

---

Detailed Description

DataBase operations for paper and plot packages; PaperBank, Paper,DataPlot, PlotSelection.

Author:

S.Butterworth

Version:

Date

2007-01-12 18:57:03 +0000 (Fri, 12 Jan 2007)

Revision

1339

Definition at line 37 of file DBPlotManager.java.

Static Public Member Functions
synchronized Collection< RealPaper >	getRealPapers () throws JetWebException
synchronized Collection< Paper >	getPapers () throws JetWebException
synchronized void	fillRealPaper (RealPaper paper) throws JetWebException
synchronized void	fillPaper (Paper paper) throws JetWebException
synchronized int	getPaperId (String dirName) throws JetWebException
synchronized void	fillPlots (RealPaper paper) throws JetWebException
synchronized void	fillPlots (Paper paper) throws JetWebException
synchronized void	fromDB (String ConName, RealPlot plot) throws JetWebException
synchronized void	fromDB (RealPlot plot) throws JetWebException
synchronized boolean	addRealPaper (RealPaper paper) throws JetWebException
synchronized boolean	addPaper (Paper paper) throws JetWebException
synchronized Vector< DataPoint >	getDataPoints (DataPlot plot) throws JetWebException
synchronized HashMap< Integer, Paper >	getPredictedPapers (Model model) throws JetWebException
synchronized void	updateCrossSectionPoints (DataPlot plot) throws JetWebException
synchronized void	insertData (DataPlot plot) throws JetWebException
synchronized void	insertCrossSection (String ConName, RealPlot plot, int paperId) throws JetWebException
synchronized void	insertCrossSection (RealPlot plot, int paperId) throws JetWebException
synchronized void	updateCrossSectionLabels (RealPlot plot) throws JetWebException
synchronized void	insertFittedPrediction (FittedPlot plot) throws JetWebException
synchronized int	getPlotId (String ConName, int paperId, int plotNumber) throws JetWebException
synchronized int	getPlotId (int paperId, int plotNumber) throws JetWebException
synchronized List< Integer >	getCSSIds (int csnId, boolean sorted) throws JetWebException
synchronized List< Integer >	getCsnIds (int cssId, boolean sorted) throws JetWebException
synchronized int	getMaxCssId () throws JetWebException
synchronized void	insertCrossSectionSet (Iterator< Integer > plotIds, int cssId) throws JetWebException
synchronized boolean	plotExists (DataPlot plot, RunSeries runSeries) throws JetWebException
synchronized void	populateSelection (PlotSelection selection) throws JetWebException
double[]	getChi2 (int plotId, int fitId)
void	selectPlotSwitch (PlotSwitch plotSwitch) throws JetWebException
HashSet< PlotSwitch >	getSwitches (int plotId) throws JetWebException
int	getProcId (int runSeriesId) throws JetWebException
void	update (PlotSwitch ps) throws JetWebException
void	add (PlotSwitch ps) throws JetWebException
synchronized void	delete (PlotSwitch ps) throws JetWebException
synchronized void	delete (RealPlot plot) throws JetWebException
synchronized void	delete (Paper paper) throws JetWebException
Vector< PlotSwitch >	getMatchedSwitches (int plotId, Generator gen) throws JetWebException
Static Public Attributes
final String	REAL = "data_point"
final String	PREDICTED = "predicted_point"
final String	FITTED = "fitted_point"
Static Private Member Functions
void	initData ()
void	initRetrievePaper ()
void	checkInserts ()
void	fill (RealPaper paper, ResultSet dbrs) throws SQLException, JetWebException
void	fill (Paper paper, ResultSet dbrs) throws SQLException, JetWebException
void	fill (RealPlot plot, ResultSet csrs) throws SQLException, JetWebException
String	getQueryString (DataPlot plot)
String	getDeleteString (DataPlot plot)
Static Private Attributes
PreparedStatement	insertRealData_
PreparedStatement	insertPredictedData_
PreparedStatement	insertFittedData_
PreparedStatement	retrieveRealPaper_
PreparedStatement	selectPlotsForPaper_
boolean	initialisedData_ = false
boolean	initialisedRetrievePaper_ = false

---

Member Function Documentation

void add (  PlotSwitch  ps  )  throws JetWebException [static]

Definition at line 1711 of file DBPlotManager.java. { String ins1 = "Insert into cross_section_switches (csn_id, process_id, "; String ins2 = "values('" + ps.getPlotId() + "','" + ps.getMCProcessTypeId() + "','"; if (ps.getParameterName() != null) { ins1 = ins1 + " parameter_name,"; ins2 = ins2 + ps.getParameterName() + "','"; } if (ps.getParameterValueHigh() != Double.POSITIVE_INFINITY) { ins1 = ins1 + " parameter_value_high,"; ins2 = ins2 + ps.getParameterValueHigh() + "','"; } if (ps.getParameterValueLow() != Double.NEGATIVE_INFINITY) { ins1 = ins1 + " parameter_value_low,"; ins2 = ins2 + ps.getParameterValueLow() + "','"; } if (ps.getGeneratorName() != null) { ins1 = ins1 + " generator_name,"; ins2 = ins2 + ps.getGeneratorName() + "','"; } ins1 = ins1 + " generator_version)"; ins2 = ins2 + ps.getGeneratorVersion() + "')"; try { Statement stmt = DBConfig.getConnection().createStatement(); int rowsChanged = stmt.executeUpdate(ins1 + ins2); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, ins1 + ins2, "oh dear"); } }

synchronized boolean addPaper (  Paper  paper  )  throws JetWebException [static]

Updates the database, adding a new paper record or amending an existing one if a record already exists for the supplied paper. The plots associated with a paper (if any) are not affected. Parameters: paper  the paper to add / amend in the database Returns: true for update, false for add Exceptions: JetWebException  Definition at line 537 of file DBPlotManager.java. { boolean paperExisted = false; if (paper.getId() > 0) { paperExisted = true; String query = "SELECT * from paper where paper_id=" + paper.getId(); try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet pprrs = stmt.executeQuery(query); while (pprrs.next()) { Statement stmt2 = DBConfig.getConnection().createStatement(); String mod = "UPDATE paper SET title='" + paper.getTitle() + "',reference='" + paper.getReference() + "', directory='" + paper.getDirName() + "', collaboration='" + paper.getCollaboration() + "', code_author='" + paper.getCodeAuthor() + "', code_contact='" + paper.getContact() + "', accelerator='" + paper.getAccelerator() + "', spires_id='" + paper.getIRN() + "' where paper_id=" + paper.getId(); int rowsChanged = stmt2.executeUpdate(mod); stmt2.close(); } pprrs.close(); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, query, "PaperId:" + paper.getId()); } } else { String ins = "Insert into paper (title, reference, directory, collaboration, accelerator, code_contact, code_author, spires_id)" + "values('" + paper.getTitle() + "','" + paper.getReference() + "','" + paper.getDirName() + "','" + paper.getCollaboration() + "','" + paper.getAccelerator() + "','" + paper.getContact() + "','" + paper.getCodeAuthor() + ","+paper.getIRN()+"')"; try { Statement stmt = DBConfig.getConnection().createStatement(); 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()); throw new JetWebDBException(E, ins, "PaperId:" + paper.getId()); } } return paperExisted; }

synchronized boolean addRealPaper (  RealPaper  paper  )  throws JetWebException [static]

Definition at line 458 of file DBPlotManager.java. { boolean paperExisted = false; String query = ""; if(paper.getId()>0){ paperExisted = true; query = "SELECT * FROM paper WHERE paper_id="+paper.getId(); try{ Statement stmt = DBConfig.getConnection().createStatement(); ResultSet pprrs = stmt.executeQuery(query); while(pprrs.next()){ Statement stmt2 = DBConfig.getConnection().createStatement(); String mod = "UPDATE paper set title='" + paper.getTitle() + "', " + "reference='" + paper.getReference()+"', " + "directory='" + paper.getDirName()+"', " + "collaboration='" + paper.getCollaboration() + "', " + "code_author='" + paper.getCodeAuthor() + "', " + "code_contact='" + paper.getCodeContact() + "', " + "accelerator='" + paper.getAccelerator() + "'," + "spires_id='" + paper.getIRN() + "', " + "WHERE paper_id=" + paper.getId(); Integer rowsChanged = stmt2.executeUpdate(mod); stmt2.close(); } pprrs.close(); stmt.close(); }catch(SQLException err){ System.out.println("SQLException: " + err.getMessage()); System.out.println("SQLState: " + err.getSQLState()); System.out.println("VendorError: " + err.getErrorCode()); throw new JetWebDBException(err, query, "PaperId:" + paper.getId()); } }else{ String ins = "Insert into paper " + "(title, reference, directory, collaboration, " + "accelerator, code_contact, code_author, spires_id)" + "values('" + paper.getTitle() + "','" + paper.getReference() + "','" + paper.getDirName() + "','" + paper.getCollaboration() + "','" + paper.getAccelerator() + "','" + paper.getCodeContact() + "','" + paper.getCodeAuthor() + "," + paper.getIRN()+"')"; try { Statement stmt = DBConfig.getConnection().createStatement(); 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()); throw new JetWebDBException(E, ins, "PaperId:" + paper.getId()); } } return paperExisted; }

void checkInserts (   )  [static, private]

Definition at line 124 of file DBPlotManager.java. { boolean start = initialisedData_; initData(); if(start!=initialisedData_) return; //Just a test because sometimes we drop the preparedstatement //if we lose the connection to the DB try{ try{ insertRealData_.setInt(1, 1); }catch(NullPointerException err){ //presume DB connection is lost if we get here :( System.out.println ("Lost DB connection! Getting new PreparedStatements"); insertRealData_.close(); insertPredictedData_.close(); insertFittedData_.close(); initialisedData_ = false; initData(); } }catch(SQLException sqlErr){ System.out.println ("DBPlotManager: unable to check status of DB connection"); System.out.println(sqlErr.getMessage()); sqlErr.printStackTrace(); } return; }

synchronized void delete (  Paper  paper  )  throws JetWebException [static]

Delete this paper from the data base. Definition at line 1801 of file DBPlotManager.java. { try { Connection con = DBConfig.getConnection(); Statement stmt = con.createStatement(); stmt.executeUpdate("DELETE FROM paper WHERE paper_id="+paper.getId()); stmt.close(); } catch (SQLException e) { System.out.println("Error deleting plot"); throw new JetWebDBException(e, "lots of SQL", "PaperId:" + paper.getId()); } paper=null; }

synchronized void delete (  RealPlot  plot  )  throws JetWebException [static]

Delete this plot from the data base and remove all record of it from the paper. Also delete all predictions and fits for this plot. Definition at line 1777 of file DBPlotManager.java. { try { Connection con = DBConfig.getConnection(); con.setAutoCommit(false); Statement stmt = con.createStatement(); stmt.executeUpdate("DELETE FROM data_point WHERE csn_id="+plot.getId()); stmt.executeUpdate("DELETE FROM predicted_point WHERE csn_id="+plot.getId()); stmt.executeUpdate("DELETE FROM fitted_point WHERE csn_id="+plot.getId()); stmt.executeUpdate("DELETE FROM cross_section_switches WHERE csn_id="+plot.getId()); stmt.executeUpdate("DELETE FROM cross_section WHERE csn_id="+plot.getId()); stmt.executeUpdate("DELETE FROM cross_section_set WHERE csn_id="+plot.getId()); stmt.close(); con.commit(); } catch (SQLException e) { System.out.println("Error deleting plot"); throw new JetWebDBException(e, "lots of SQL", "CsnId:" + plot.getId()); } plot=null; }

synchronized void delete (  PlotSwitch  ps  )  throws JetWebException [static]

Clears down an existing PlotSwitch from the DB. Parameters: ps  PlotSwitch to be deleted Exceptions: JetWebException  Definition at line 1757 of file DBPlotManager.java. References CutCollection.getId(). { String deleteString = "DELETE FROM cross_section_switches WHERE switch_id=" + ps.getId(); try { Statement stmt = DBConfig.getConnection().createStatement(); stmt.executeUpdate(deleteString); stmt.close(); } catch (SQLException e) { System.out.println("Error deleting PlotSwitch"); throw new JetWebDBException(e, deleteString, "PlotSwitchId:" + ps.getId()); } }

void fill (  RealPlot  plot, ResultSet  csrs )  throws SQLException, JetWebException [static, private]

Definition at line 594 of file DBPlotManager.java. { plot.setPaperId(csrs.getInt("paper_id")); plot.setNumber(csrs.getInt("plot_number")); plot.setTitle(csrs.getString("title")); plot.setXLabel(csrs.getString("x_axis_title")); plot.setYLabel(csrs.getString("y_axis_title")); plot.setId(csrs.getInt("csn_id")); plot.setShape(csrs.getInt("is_shape") == 1); Integer cutId = csrs.getInt("cut_collection_id"); if(cutId!=null){ CutCollection cuts = new CutCollection(cutId); plot.setCutCollection(cuts); } if (csrs.getInt("in_default") >= 1) { plot.setDefaultSum(true); } if (csrs.getInt("in_default") == 2) { plot.setDefaultFit(true); } if (csrs.getString("y_axis_type").equals("log")) { plot.setLogarithmic(true); } else { plot.setLogarithmic(false); } plot.setSysScale(csrs.getFloat("scale_factor")); plot.setCollisionId(csrs.getInt("collision_id")); if (!plot.populateDBData()) { System.out.println("WARNING: datapoints not filled for DataPlot " + plot.getNumber()); } }

void fill (  Paper  paper, ResultSet  dbrs )  throws SQLException, JetWebException [static, private]

Definition at line 319 of file DBPlotManager.java. { if (paper.isReal()) { paper.setAccelerator(dbrs.getString("accelerator")); paper.setDirName(dbrs.getString("directory")); paper.setReference(dbrs.getString("reference")); paper.setTitle(dbrs.getString("title")); paper.setID(dbrs.getInt("paper_id")); paper.setCollaboration(dbrs.getString("collaboration")); paper.setCodeAuthor(dbrs.getString("code_author")); paper.setContact(dbrs.getString("code_contact")); paper.setIRN(dbrs.getInt("spires_id")); // Now the plots. fillPlots(paper); } else { throw new JetWebDBException("Attempt to fill MC Paper from DB is not valid", "PaperId:" + paper.getId()); } }

void fill (  RealPaper  paper, ResultSet  dbrs )  throws SQLException, JetWebException [static, private]

Definition at line 304 of file DBPlotManager.java. { paper.setAccelerator(dbrs.getString("accelerator")); paper.setDirName(dbrs.getString("directory")); paper.setReference(dbrs.getString("reference")); paper.setTitle(dbrs.getString("title")); paper.setId(dbrs.getInt("paper_id")); paper.setCollaboration(dbrs.getString("collaboration")); paper.setCodeAuthor(dbrs.getString("code_author")); paper.setCodeContact(dbrs.getString("code_contact")); paper.setIRN(dbrs.getInt("spires_id")); fillPlots(paper); return; }

synchronized void fillPaper (  Paper  paper  )  throws JetWebException [static]

Retrieve the data for a Paper from the DataBase. Exceptions: JetWebException  Definition at line 246 of file DBPlotManager.java. { String selectString = "SELECT * from paper where paper_id=" + paper.getId(); boolean filled = false; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet dbrs = stmt.executeQuery(selectString); while (dbrs.next()) { fill(paper, dbrs); filled = true; } dbrs.close(); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, selectString, ""); } if (!filled) { throw new JetWebException("Paper not filled.", " "); } }

synchronized void fillPlots (  Paper  paper  )  throws JetWebException [static]

Finds all the plots for the specified paper. Adds them to the collection on the paper. Parameters: paper  for which plots are to be retrieved Definition at line 371 of file DBPlotManager.java. { // Run a query looking for all plots in the cross_section table which // match this paper_id. String query = "SELECT * from cross_section where paper_id=" + Integer.toString(paper.getId()); try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet csrs = stmt.executeQuery(query); while (csrs.next()) { RealPlot plot = new RealPlot(); //System.out.println("plot got"); fill(plot, csrs); paper.addPlot(plot); } csrs.close(); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, query, "PaperId:" + paper.getId()); } }

synchronized void fillPlots (  RealPaper  paper  )  throws JetWebException [static]

Finds all plots for the given RealPaper and adds them to it Definition at line 344 of file DBPlotManager.java. { initRetrievePaper(); try{ selectPlotsForPaper_.setInt(1, paper.getId()); ResultSet csrs = selectPlotsForPaper_.executeQuery(); while(csrs.next()){ RealPlot plot = new RealPlot(); fill(plot, csrs); paper.addPlot(plot); } selectPlotsForPaper_.clearParameters(); }catch(SQLException E){ System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, "SELECT", "PaperId:" + paper.getId()); } }

synchronized void fillRealPaper (  RealPaper  paper  )  throws JetWebException [static]

retrieve the data for a real paper from the database Definition at line 213 of file DBPlotManager.java. { initRetrievePaper(); boolean filled = false; try{ retrieveRealPaper_.setInt(1, paper.getId()); ResultSet dbrs = retrieveRealPaper_.executeQuery(); while(dbrs.next()){ fill(paper, dbrs); filled = true; } dbrs.close(); retrieveRealPaper_.clearParameters(); }catch(SQLException err){ System.out.println("SQLException: " + err.getMessage()); System.out.println("SQLState: " + err.getSQLState()); System.out.println("VendorError: " + err.getErrorCode()); throw new JetWebDBException(err, ((Integer)paper.getId()).toString(), ""); } if(!filled){ throw new JetWebException("Paper not filled."," "); } return; }

synchronized void fromDB (  RealPlot  plot  )  throws JetWebException [static]

Definition at line 430 of file DBPlotManager.java. { // Run a query looking for all plots in the cross_section table which // match this paper_id. String query = "SELECT * from cross_section where csn_id=" + Integer.toString(plot.getId()); try { Statement stmt = DBConfig.getConnection().createStatement(); //Statement stmt = DBConfig.getDBConnectionManager(). //getConnection("hepdata").createStatement(); ResultSet csrs = stmt.executeQuery(query); while (csrs.next()) { //System.out.println("plot got"); fill(plot, csrs); } csrs.close(); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, query, "PlotId:" + plot.getId()); } }

synchronized void fromDB (  String  ConName, RealPlot  plot )  throws JetWebException [static]

Fills a RealPlot from the database. Definition at line 404 of file DBPlotManager.java. { // Run a query looking for all plots in the cross_section table which // match this paper_id. String query = "SELECT * from cross_section where csn_id=" + Integer.toString(plot.getId()); try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet csrs = stmt.executeQuery(query); while (csrs.next()) { //System.out.println("plot got"); fill(plot, csrs); } csrs.close(); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, query, "PlotId:" + plot.getId()); } }

double [] getChi2 (  int  plotId, int  fitId )  [static]

Definition at line 1524 of file DBPlotManager.java. { String queryString = ""; double[] chi2 = { 0.0, 0.0 }; try { Statement stmt = DBConfig.getConnection().createStatement(); queryString = "SELECT * FROM fitted_prediction WHERE fit_id=" + fitId + " AND csn_id=" + plotId; ResultSet rs = stmt.executeQuery(queryString); while (rs.next()) { chi2[0] = rs.getFloat("chi2"); chi2[1] = rs.getFloat("dof"); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading fitted_prediction table "); System.out.println(e); System.out.println("SQL was: " + queryString); //throw new JetWebDBException(e,queryString,"CssId="+cssId); // } catch (JetWebException e) { // throw e; } return chi2; }

synchronized List<Integer> getCsnIds (  int  cssId, boolean  sorted )  throws JetWebException [static]

Retrieves database IDs of all CrossSections belonging to a given CrossSectionSet. Optionally, the list of IDs can be sorted. Parameters: cssId  identifies the crosssectionset sorted  - if true, the list retrieved will be sorted Returns: a List of crossSection Ids (Integer values), optionally sorted Exceptions: JetWebException  Definition at line 1355 of file DBPlotManager.java. { List<Integer> csns = new ArrayList<Integer>(); //find all csns belonging to this set String queryString = "SELECT csn_id FROM cross_section_set WHERE csn_set_id=" + cssId; //+" ORDER BY csn_id"; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(queryString); while (rs.next()) { csns.add(new Integer(rs.getInt("csn_id"))); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading cross_section_set table " + e); throw new JetWebDBException(e, queryString, "CrossSectionSetId:" + cssId); } if (sorted) { Collections.sort(csns); } return csns; }

synchronized List<Integer> getCSSIds (  int  csnId, boolean  sorted )  throws JetWebException [static]

Retrieves database IDs of all CrossSectionSets containing a given CrossSection. Optionally, the list of IDs can be sorted. Parameters: csnId  identifies the crosssection that must be in the sets sorted  - if true, the list retrieved will be sorted Returns: a List of crossSectionSet Ids (Integer values), optionally sorted Exceptions: JetWebException  Definition at line 1317 of file DBPlotManager.java. { List<Integer> sets = new ArrayList<Integer>(); //get all cross section sets for a cross section String queryString = "SELECT csn_set_id FROM cross_section_set WHERE csn_id=" + csnId; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(queryString); while (rs.next()) { sets.add(new Integer(rs.getInt("csn_set_id"))); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading cross_section_set table " + e); throw new JetWebDBException(e, queryString, "CrossSectionId:" + csnId); } if (sorted) { Collections.sort(sets); } return sets; }

synchronized Vector<DataPoint> getDataPoints (  DataPlot  plot  )  throws JetWebException [static]

Retrieves the collection of points for a dataplot from the database. Queries data_point / predicted_point / fitted_point for real / predicted / fitted data. Parameters: plot  for which points are to be retrieved Returns: vector of data point objects Exceptions: JetWebException  Definition at line 641 of file DBPlotManager.java. References DataPoint.add(), DataPoint.getNumber(), DataPoint.setBinWidth(), DataPoint.setChi2(), DataPoint.setNumber(), DataPoint.setX(), DataPoint.setY(), DataPoint.setYDown(), DataPoint.setYUp(), and DataPoint.toString(). { //select records from appropriate table for this cross_section String queryString = getQueryString(plot); System.out.println(queryString); Vector<DataPoint> dataPoints = new Vector<DataPoint>(); HashMap<Integer, DataPoint> pointMap = new HashMap<Integer, DataPoint>(); HashMap<Integer, Boolean> isInCuts = null; if(plot instanceof PredictedPlot){ isInCuts = new HashMap<Integer, Boolean>(); } try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet dsrs = stmt.executeQuery(queryString); while (dsrs.next()) { //check that the runseries for this data_point //generates data in the correct region. boolean inCuts = true; if(plot instanceof PredictedPlot){ Integer rsid = dsrs.getInt("runseries_id"); Boolean foundInCuts = isInCuts.get(rsid); if(foundInCuts==null){ String selectCuts = "SELECT cut_collection_id FROM runseries WHERE " + "runseries_id = " + dsrs.getInt("runseries_id"); System.out.println(selectCuts); Statement cutstmt = DBConfig.getConnection().createStatement(); ResultSet rs = cutstmt.executeQuery(selectCuts); while(rs.next()){ CutCollection runCuts = new CutCollection(rs.getInt(1)); inCuts = plot.getCutCollection().isWithin(runCuts); } isInCuts.put(rsid, inCuts); }else{ inCuts = foundInCuts; } } if(inCuts){ //add a new DataPoint DataPoint point = new DataPoint(); point.setX(dsrs.getFloat("x")); point.setY(dsrs.getFloat("y")); point.setYUp(dsrs.getFloat("dy_up")); point.setYDown(dsrs.getFloat("dy_down")); point.setBinWidth(dsrs.getFloat("bin_width")); point.setNumber(dsrs.getInt("pnt_no")); //0,x 1,y, 2,ye 3,ye 4, bin width 5, chi2 if (plot instanceof FittedPlot){ point.setChi2(dsrs.getFloat("chi2")); } //System.out.println("Read datapoint for plot " + // plot.getId() + // point.toString()); //Integer pointNumber = dsrs.getInt("pnt_no"); Integer pointNumber = point.getNumber(); DataPoint existingPoint = pointMap.get(pointNumber); if(existingPoint != null ){ System.out.println("Found existing point: " + existingPoint.toString()); point.add(existingPoint); } pointMap.put(pointNumber, point); //dataPoints.add(point); } } dataPoints = new Vector<DataPoint>(pointMap.values()); dsrs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading data points " + e); throw new JetWebDBException(e, queryString, "DataPlot.id:" + plot.getId()); } Collections.sort(dataPoints); return dataPoints; }

String getDeleteString (  DataPlot  plot  )  [static, private]

Definition at line 952 of file DBPlotManager.java. References DataPlot.getId(). { String rtn = ""; if (plot instanceof PredictedPlot) { rtn = "DELETE FROM " + PREDICTED + " WHERE csn_id=" + plot.getId() + " and runseries_id=" + ((PredictedPlot) plot).getRunSeriesId(); } else if (plot instanceof FittedPlot) { rtn = "DELETE FROM " + FITTED + " WHERE csn_id=" + plot.getId() + " and fitted_id=" + ((FittedPlot) plot).getFit().getId(); } else if (plot instanceof RealPlot) { rtn = "DELETE FROM " + REAL + " WHERE csn_id=" + plot.getId(); } return rtn; }

Vector<PlotSwitch> getMatchedSwitches (  int  plotId, Generator  gen )  throws JetWebException [static]

Return the PlotSwitches (in a Vector) for this plotId which most specifically match the input RunSeries. That is, those which match both generator and version if specified; if not, those that match the generator and do not specify a version; if not, then those which specify neither generator nor version. Definition at line 1824 of file DBPlotManager.java. { Vector<PlotSwitch> list = new Vector<PlotSwitch>(); String selectString = "SELECT switch_id from cross_section_switches where csn_id=" + plotId + " and generator_name='" + gen.getName() + "' and generator_version='" + gen.getVersion() + "'"; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet dbrs = stmt.executeQuery(selectString); while (dbrs.next()) { PlotSwitch ps = new PlotSwitch(dbrs.getInt("switch_id")); list.add(ps); } dbrs.close(); stmt.close(); if (list.size() == 0) { selectString = "SELECT switch_id from cross_section_switches where csn_id=" + plotId + " and generator_name='" + gen.getName() + "'"; stmt = DBConfig.getConnection().createStatement(); dbrs = stmt.executeQuery(selectString); while (dbrs.next()) { PlotSwitch ps = new PlotSwitch(dbrs.getInt("switch_id")); list.add(ps); } dbrs.close(); stmt.close(); } if (list.size() == 0) { selectString = "SELECT switch_id from cross_section_switches where csn_id=" + plotId; stmt = DBConfig.getConnection().createStatement(); dbrs = stmt.executeQuery(selectString); while (dbrs.next()) { PlotSwitch ps = new PlotSwitch(dbrs.getInt("switch_id")); list.add(ps); } dbrs.close(); stmt.close(); } return list; } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, selectString, ""); } }

synchronized int getMaxCssId (   )  throws JetWebException [static]

Returns highest value CrossSectionSetId. This method is necessary for the generation of new CrossSectionSet IDs because there are no database sequences in mySQL. Returns: largest value of crosssection set id in the database Exceptions: JetWebException  Definition at line 1395 of file DBPlotManager.java. { int cssId = 0; String query = "SELECT MAX(csn_set_id) FROM cross_section_set"; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(query); if (rs.next()) { cssId = rs.getInt(1); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading cross_section_set table " + e); throw new JetWebDBException(e, query, ""); } return cssId; }

synchronized int getPaperId (  String  dirName  )  throws JetWebException [static]

Retrieves ID of a paper, given its directory Parameters: dirname  name of the directory containing files relevant to a paper Returns: paper id from database Exceptions: JetWebException  Definition at line 281 of file DBPlotManager.java. { int paperId = -1; String query = "SELECT paper_id FROM paper WHERE directory='" + dirName + "'"; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(query); if (rs.next()) { paperId = rs.getInt("paper_id"); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Failed to select paperId for dirname:" + dirName + "error:" + e); throw new JetWebDBException(e, query, "Directory:" + dirName); } return paperId; }

synchronized Collection<Paper> getPapers (   )  throws JetWebException [static]

Definition at line 182 of file DBPlotManager.java. { Vector<Paper> papers = new Vector<Paper>(); String selectString = "SELECT * from paper"; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet dbrs = stmt.executeQuery(selectString); while (dbrs.next()) { Paper paper = new Paper(true); fill(paper, dbrs); papers.add(paper); } dbrs.close(); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, selectString, ""); } return papers; }

synchronized int getPlotId (  int  paperId, int  plotNumber )  throws JetWebException [static]

Definition at line 1279 of file DBPlotManager.java. { int csnId = -1; String sqlString = "SELECT csn_id FROM cross_section WHERE paper_id=" + paperId + " AND plot_number=" + plotNumber; System.out.println(sqlString); try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(sqlString); if (rs.next()) { csnId = rs.getInt("csn_id"); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("DB access error in getPlotId:" + e); System.out.println("SQL was: " + sqlString); throw new JetWebDBException(e, sqlString, "PaperId:" + paperId + "plotNumber:" + plotNumber); } return csnId; }

synchronized int getPlotId (  String  ConName, int  paperId, int  plotNumber )  throws JetWebException [static]

Retrieves DB Id of a plot, given the paper and plot number Parameters: ConName  name of data base to query for paper paperId  of paper to which plot belongs plotNumber  number of the plot in the paper Returns: plotId, -1 if not found Exceptions: JetWebException  Definition at line 1252 of file DBPlotManager.java. { int csnId = -1; String sqlString = "SELECT csn_id FROM cross_section WHERE paper_id=" + paperId + " AND plot_number=" + plotNumber; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(sqlString); if (rs.next()) { csnId = rs.getInt("csn_id"); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("DB access error in getPlotId:" + e); System.out.println("SQL was: " + sqlString); throw new JetWebDBException(e, sqlString, "PaperId:" + paperId + "plotNumber:" + plotNumber); } return csnId; }

synchronized HashMap<Integer, Paper> getPredictedPapers (  Model  model  )  throws JetWebException [static]

Definition at line 756 of file DBPlotManager.java. References Paper.addPlot(), CutCollection.isWithin(), RunSeries.Maker(), Paper.setAccelerator(), Paper.setCodeAuthor(), Paper.setCollaboration(), Paper.setContact(), Paper.setDirName(), Paper.setID(), Paper.setIRN(), Paper.setReference(), and Paper.setTitle(). { HashMap<Integer, Paper> foundPapers = new HashMap<Integer, Paper>(); try{ PreparedStatement pstmt = DBConfig.getConnection().prepareStatement ("select cross_section.paper_id, " + "cross_section.cut_collection_id, " + "predicted_point.runseries_id, " + "runseries.cut_collection_id, " + "cross_section.csn_id from " + "cross_section, predicted_point, model, " + "runseries_collection, runseries where " + "runseries.runseries_id = " + "runseries_collection.runseries_id and " + "runseries_collection.runseries_collection_id =" + "model.runseries_collection_id and " + "runseries_collection.runseries_id =" + "predicted_point.runseries_id and " + "predicted_point.csn_id =cross_section.csn_id and " + "model.mdl_id =?"); pstmt.setInt(1, model.getId()); ResultSet rs = pstmt.executeQuery(); HashMap<Integer, PredictedPlot> foundPlots = new HashMap<Integer, PredictedPlot>(); HashMap<Integer, CutCollection> paperCuts = new HashMap<Integer, CutCollection>(); HashMap<Integer, CutCollection> rsCuts = new HashMap<Integer, CutCollection>(); HashMap<Integer, RunSeries> foundRunSeries = new HashMap<Integer, RunSeries>(); PreparedStatement paperStmt = DBConfig.getConnection().prepareStatement ("SELECT * FROM paper where paper_id=?"); PreparedStatement plotStmt = DBConfig.getConnection().prepareStatement ("SELECT * FROM cross_section WHERE csn_id=?"); while(rs.next()){ Integer paperId = rs.getInt(1); Paper mcpaper; Integer paperCutsId = rs.getInt(2); Integer rsId = rs.getInt(3); Integer rsCutsId = rs.getInt(4); Integer plotId = rs.getInt(5); CutCollection paperCut = paperCuts.get(paperCutsId); CutCollection rsCut = rsCuts.get(rsCutsId); if(paperCut==null){ paperCut = new CutCollection(paperCutsId); paperCuts.put(paperCutsId, paperCut); } if(rsCut==null){ rsCut = new CutCollection(rsCutsId); rsCuts.put(rsCutsId, rsCut); } boolean inCuts = paperCut.isWithin(rsCut); if(inCuts){ if(!foundPapers.containsKey(paperId)){ mcpaper = new Paper(false); paperStmt.setInt(1, paperId); ResultSet paperRs = paperStmt.executeQuery(); if(paperRs.next()){ mcpaper.setAccelerator(paperRs.getString("accelerator")); mcpaper.setDirName(paperRs.getString("directory")); mcpaper.setReference(paperRs.getString("reference")); mcpaper.setTitle(paperRs.getString("title")); mcpaper.setID(paperId); mcpaper.setCollaboration (paperRs.getString("collaboration")); mcpaper.setCodeAuthor(paperRs.getString("code_author")); mcpaper.setContact(paperRs.getString("code_contact")); mcpaper.setIRN(paperRs.getInt("spires_id")); foundPapers.put(paperId, mcpaper); } }else{ mcpaper = foundPapers.get(paperId); } PredictedPlot plot = foundPlots.get(plotId); if(plot==null){ RealPlot compPlot = new RealPlot(); plotStmt.setInt(1, plotId); ResultSet plotRs = plotStmt.executeQuery(); if(plotRs.next()){ fill(compPlot, plotRs); RunSeries runseries = foundRunSeries.get(rsId); if(runseries==null){ runseries = RunSeries.Maker(rsId); } plot = new PredictedPlot(compPlot, runseries); foundPlots.put(plotId, plot); } mcpaper.addPlot(plot); } } } }catch(SQLException err){ throw new JetWebException(err); } return foundPapers; }

int getProcId (  int  runSeriesId  )  throws JetWebException [static]

Return the MCProcessId for the given RunSeriesId. Exceptions: JetWebException  Definition at line 1643 of file DBPlotManager.java. { int procId; String selectString = "SELECT process_id from runseries WHERE runseries_id=" + runSeriesId; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet dbrs = stmt.executeQuery(selectString); dbrs.next(); procId = dbrs.getInt("process_id"); dbrs.close(); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, selectString, ""); } return procId; }

String getQueryString (  DataPlot  plot  )  [static, private]

Definition at line 881 of file DBPlotManager.java. References DataPlot.getId(). { String rtn = ""; if (plot instanceof PredictedPlot) { /* rtn = "SELECT * FROM " + PREDICTED + " where csn_id=" + plot.getId() + " and runseries_id=" + ((PredictedPlot) plot).getRunSeriesId(); */ rtn = "SELECT " + PREDICTED + ".* FROM " + PREDICTED + ", runseries_collection " + "WHERE " + PREDICTED + ".csn_id = " + plot.getId() + " AND " + PREDICTED + ".runseries_id=runseries_collection.runseries_id AND " + "runseries_collection.runseries_collection_id = " + "(SELECT runseries_collection_id FROM runseries_collection " + "WHERE runseries_id = " + ((PredictedPlot) plot).getRunSeriesId() + ")"; } else if (plot instanceof RealPlot) { rtn = "SELECT * FROM " + REAL + " where csn_id=" + plot.getId(); } else if (plot instanceof FittedPlot) { rtn = "SELECT * FROM " + FITTED + " where csn_id=" + plot.getId() + " and fit_id=" + ((FittedPlot) plot).getFit().getId(); } //System.out.println(rtn); return rtn; }

synchronized Collection<RealPaper> getRealPapers (   )  throws JetWebException [static]

Definition at line 154 of file DBPlotManager.java. { Vector<RealPaper> papers = new Vector<RealPaper>(); String selectString = "SELECT * FROM paper"; try{ Statement stmt = DBConfig.getConnection().createStatement(); ResultSet dbrs = stmt.executeQuery(selectString); while (dbrs.next()) { RealPaper paper = new RealPaper(); fill(paper, dbrs); papers.add(paper); } dbrs.close(); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, selectString, ""); } return papers; }

HashSet<PlotSwitch> getSwitches (  int  plotId  )  throws JetWebException [static]

Return Enumeration of the switches associated with this plot. Definition at line 1614 of file DBPlotManager.java. { HashSet<PlotSwitch> switches = new HashSet<PlotSwitch>(); // Get all PlotSwitches for a cross section String queryString = "SELECT switch_id FROM cross_section_switches WHERE csn_id=" + plotId; try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(queryString); while (rs.next()) { switches.add(new PlotSwitch(rs.getInt("switch_id"))); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading cross_section_switches table " + e); throw new JetWebDBException(e, queryString, "CrossSectionId:" + plotId); } return switches; }

void initData (   )  [static, private]

Definition at line 70 of file DBPlotManager.java. { if(initialisedData_)return; initialisedData_ = true; try{ insertRealData_ = DBConfig.getConnection().prepareStatement ("INSERT INTO data_point"+ "(csn_id,pnt_no,x,y,dy_up,dy_down,bin_width) VALUES" + "(?,?,?,?,?,?,?)"); insertPredictedData_ = DBConfig.getConnection().prepareStatement ("INSERT INTO predicted_point" + "(runseries_id,csn_id,pnt_no,x,y,dy_up,dy_down,bin_width) "+ "VALUES" + "(?,?,?,?,?,?,?,?)"); insertFittedData_ = DBConfig.getConnection().prepareStatement ("INSERT INTO fitted_point" + "(fit_id,chi2,csn_id,pnt_no,x,y,dy_up,dy_down,bin_width) VALUES" + "(?,?,?,?,?,?,?,?,?)"); }catch(SQLException err){ System.out.println ("Error: cannot initialse prepared statements "+ "for inserting data in DB"); System.out.println(err.getMessage()); err.printStackTrace(); } return; }

void initRetrievePaper (   )  [static, private]

Definition at line 103 of file DBPlotManager.java. { if(initialisedRetrievePaper_) return; initialisedRetrievePaper_ = true; try{ retrieveRealPaper_ = DBConfig.getConnection().prepareStatement ("SELECT * FROM paper WHERE paper_id=?"); selectPlotsForPaper_ = DBConfig.getConnection().prepareStatement ("SELECT * FROM cross_section where paper_id=?"); }catch(SQLException err){ System.out.println ("Error: cannot initialise prepared statements " + "for retrieving real papers from DB"); System.out.println(err.getMessage()); err.printStackTrace(); } }

synchronized void insertCrossSection (  RealPlot  plot, int  paperId )  throws JetWebException [static]

Definition at line 1148 of file DBPlotManager.java. { insertCrossSection(DBConfig.JETWEB, plot, paperId); }

synchronized void insertCrossSection (  String  ConName, RealPlot  plot, int  paperId )  throws JetWebException [static]

Insert new DB record for this RealData plot. Parameters: plot  - plot to be added to database paperId  - DB id for paper to which this plot belongs Exceptions: JetWebException  Definition at line 1077 of file DBPlotManager.java. References DataPlot.getCutCollection(), CutCollection.getId(), CutCollection.setId(), and CutCollection.store(). { int inDefault = 0; if (plot.isDefaultSum()) { inDefault += 1; } if (plot.isDefaultFit()) { inDefault += 1; } String yAxisType = "lin"; if (plot.isLogarithmic()) { yAxisType = "log"; } int shape = 0; if (plot.isShape()) { shape = 1; } Integer cutId=-1; if(plot.getCutCollection()!=null){ plot.getCutCollection().store(); cutId = plot.getCutCollection().getId(); } String sqlString = "INSERT INTO cross_section " + "(paper_id," + "title,x_axis_title," + "y_axis_title," + "in_default," + "plot_number," + "scale_factor," + "y_axis_type," + "is_shape," + "collision_id," + "cut_collection_id)" + " VALUES (" + paperId + ",'" + plot.getTitle() + "','" + plot.getXLabel() + "','" + plot.getYLabel() + "'," + inDefault + "," + plot.getNumber() + "," + plot.getSysScale() + ",'" + yAxisType + "'," + shape + "," + plot.getCollisionId() + "," + cutId + ")"; System.out.println(sqlString); try { Statement stmt = DBConfig.getConnection().createStatement(); int rtn = stmt.executeUpdate(sqlString); stmt.close(); } catch (SQLException e) { System.out.println("DB access error in insertCrossSection" + e); System.out.println("SQL String was: " + sqlString); throw new JetWebDBException(e, sqlString, "plotId:" + plot.getId() + " paperId:" + paperId); } // Now get the new ID. plot.setId(getPlotId(paperId, plot.getNumber())); // Now add the plot switches. plot.storeSwitches(); }

synchronized void insertCrossSectionSet (  Iterator< Integer >  plotIds, int  cssId )  throws JetWebException [static]

Inserts a new cross_section_set record into the database. Parameters: plotIds  list(Integers) of all the plots belonging to the new set cssId  for the new cross_sectionset record Exceptions: JetWebException  Definition at line 1424 of file DBPlotManager.java. { String ins = ""; try { Statement stmt = DBConfig.getConnection().createStatement(); while (plotIds.hasNext()) { ins = "INSERT INTO cross_section_set (csn_id,csn_set_id) VALUES(" + (plotIds.next()).toString() + "," + cssId + ")"; int i = stmt.executeUpdate(ins); } stmt.close(); } catch (SQLException e) { System.out.println("Error inserting data into cross_section_set table "); System.out.println(e); System.out.println("SQL was: " + ins); throw new JetWebDBException(e, ins, "CrossSectionSetId:" + cssId); } }

synchronized void insertData (  DataPlot  plot  )  throws JetWebException [static]

Insert data points for this real/predicted/fitted data plot to the DB Parameters: plot  object containing pointed to be inserted Exceptions: JetWebException  Definition at line 974 of file DBPlotManager.java. References DataPlot.getDataPoints(), and DataPoint.getX(). { //System.out.println("Inserting data for plot " + plot.getId()); //initData(); checkInserts(); Enumeration<DataPoint> unsortedPoints = plot.getDataPoints().elements(); int pointNo = 0; TreeMap<Double, DataPoint> sortedPoints = new TreeMap<Double, DataPoint>(); while(unsortedPoints.hasMoreElements()){ DataPoint pt = unsortedPoints.nextElement(); sortedPoints.put(pt.getX(), pt); } PreparedStatement pstmt = insertRealData_; boolean isFitted = false; Integer startIndex = 1; try{ if(plot instanceof PredictedPlot){ pstmt = insertPredictedData_; pstmt.setInt(1, ((PredictedPlot) plot).getRunSeriesId()); startIndex = 2; }else if(plot instanceof FittedPlot){ pstmt = insertFittedData_; pstmt.setInt(1, ((FittedPlot) plot).getFit().getId()); startIndex = 3; } pstmt.setInt(startIndex, plot.getId()); }catch(SQLException err){ System.out.println("Error: DBPlotManager.insertData(DataPlot) "+ "unable to set plot data in PreparedStatement"); err.printStackTrace(); throw new JetWebException(err); } ++startIndex; //while (points.hasMoreElements()) { //System.out.println("Number of data points to add = " + // sortedPoints.size()); for(DataPoint point: sortedPoints.values()){ pointNo++; //DataPoint point = points.nextElement(); Integer pIndex = startIndex; try{ if(plot instanceof FittedPlot){ pstmt.setDouble(2, point.getChi2()); } pstmt.setInt(pIndex, pointNo); ++pIndex; pstmt.setDouble(pIndex, point.getX()); ++pIndex; pstmt.setDouble(pIndex, point.getY()); ++pIndex; pstmt.setDouble(pIndex, point.getYUp()); ++pIndex; pstmt.setDouble(pIndex, point.getYDown()); ++pIndex; pstmt.setDouble(pIndex, point.getBinWidth()); pstmt.executeUpdate(); }catch(SQLException err){ System.out.println("insertDataPlot failed: " + err); System.out.println("Data: pIndex = "+pIndex); throw new JetWebException(err); } } try{ pstmt.clearParameters(); //pstmt.close(); }catch(SQLException err){ System.out.println ("DBPlotManager.insertData: " + "unable to clear prepared statement"); System.out.println("Data: "+pstmt); throw new JetWebException(err); } return; }

synchronized void insertFittedPrediction (  FittedPlot  plot  )  throws JetWebException [static]

Adds a fitted prediction to the database Parameters: plot  for which fitted prediction is to be inserted Exceptions: JetWebException  Definition at line 1225 of file DBPlotManager.java. References CutCollection.getId(). { String ins1 = "INSERT INTO fitted_prediction (fit_id,csn_id,chi2,dof) VALUES(" + plot.getFit().getId() + "," + plot.getId() + "," + plot.getChi2()[0] + "," + plot.getChi2()[1] + ")"; try { Statement stmt = DBConfig.getConnection().createStatement(); stmt.executeUpdate(ins1); stmt.close(); } catch (SQLException e) { System.out.println("insertFittedPrediction failed: " + e); throw new JetWebDBException(e, ins1, "FittedPlot.id:" + plot.getId()); } }

synchronized boolean plotExists (  DataPlot  plot, RunSeries  runSeries )  throws JetWebException [static]

Checks existance of a predicted plot matching a given runSeries and a given RealPlot. Parameters: RealPlot  RunSeries  Returns: true if the plot exists, otherwise false Exceptions: JEtWebDBException  Definition at line 1455 of file DBPlotManager.java. References CutCollection.getId(). { int plotId = plot.getId(); int runSeriesId = runSeries.getId(); boolean exists = false; String queryString = ""; try { Statement stmt = DBConfig.getConnection().createStatement(); queryString = "SELECT COUNT(runseries_id) count_plots " + "FROM predicted_point WHERE runseries_id=" + runSeriesId + " AND csn_id=" + plotId; ResultSet rs = stmt.executeQuery(queryString); if (rs.next()) { int n = rs.getInt("count_plots"); if (n > 0) { exists = true; } } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading predicted_points table "); System.out.println(e); System.out.println("SQL was: " + queryString); throw new JetWebDBException(e, queryString, "PlotId:" + plotId + " runSeriesId:" + runSeriesId); } return exists; }

synchronized void populateSelection (  PlotSelection  selection  )  throws JetWebException [static]

Definition at line 1493 of file DBPlotManager.java. References CutCollection.getId(). { String queryString = ""; int cssId = -1; selection.clearFitPlots(); try { cssId = selection.getId(); Statement stmt = DBConfig.getConnection().createStatement(); queryString = "SELECT csn_id " + "FROM cross_section_set WHERE csn_set_id=" + cssId; ResultSet rs = stmt.executeQuery(queryString); while (rs.next()) { selection.addFitPlot(PaperBank.getPlot(rs.getInt("csn_id"))); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading predicted_points table "); System.out.println(e); System.out.println("SQL was: " + queryString); throw new JetWebDBException(e, queryString, "CssId=" + cssId); } catch (JetWebException e) { throw e; } }

void selectPlotSwitch (  PlotSwitch  plotSwitch  )  throws JetWebException [static]

Fill the fields of this plotSwitch from the DB. The ID must be set in advance. Definition at line 1559 of file DBPlotManager.java. References CutCollection.getId(). { // Get all PlotSwitches for a cross section String queryString = "SELECT * FROM cross_section_switches WHERE switch_id=" + plotSwitch.getId(); try { Statement stmt = DBConfig.getConnection().createStatement(); ResultSet rs = stmt.executeQuery(queryString); while (rs.next()) { plotSwitch.setGeneratorName(rs.getString("generator_name")); plotSwitch.setGeneratorVersion(rs.getFloat("generator_version")); plotSwitch.setParameterName(rs.getString("parameter_name")); //Double tmp = rs.getFloat("parameter_value_high"); Double tmp = rs.getDouble("parameter_value_high"); String stringTmp = rs.getString("parameter_value_high"); if (rs.wasNull() || stringTmp.equals("null")) { plotSwitch.setParameterValueHigh(Double.POSITIVE_INFINITY); } else { plotSwitch.setParameterValueHigh(tmp); } //tmp = rs.getFloat("parameter_value_low"); tmp = rs.getDouble("parameter_value_low"); stringTmp = rs.getString("parameter_value_low"); if (rs.wasNull()||stringTmp.equals("null")) { plotSwitch.setParameterValueLow(Double.NEGATIVE_INFINITY); } else { plotSwitch.setParameterValueLow(tmp); } plotSwitch.setMCProcessTypeId(rs.getInt("process_id")); plotSwitch.setPlotId(rs.getInt("csn_id")); } rs.close(); stmt.close(); } catch (SQLException e) { System.out.println("Error reading cross_section_switches table " + e); throw new JetWebDBException(e, queryString, "Switch Id :" + plotSwitch.getId()); } }

void update (  PlotSwitch  ps  )  throws JetWebException [static]

Store this PlotSwitch to the database. Definition at line 1668 of file DBPlotManager.java. References CutCollection.getId(). { // first delete it. String deleteIt = "DELETE FROM cross_section_switches WHERE switch_id='" +ps.getId()+"'"; StringBuffer ud = new StringBuffer("INSERT INTO cross_section_switches SET process_id='" + ps.getMCProcessTypeId()); if (ps.getParameterName() != null) { ud.append("',parameter_name='" + ps.getParameterName()); if (ps.getParameterValueHigh() != Double.POSITIVE_INFINITY) { ud.append("', parameter_value_high='" + ps.getParameterValueHigh()); } if (ps.getParameterValueLow() != Double.NEGATIVE_INFINITY) { ud.append("', parameter_value_low='" + ps.getParameterValueLow()); } } if (ps.getGeneratorName() != null) { ud.append("', generator_name='" + ps.getGeneratorName()); } ud.append("', generator_version='" + ps.getGeneratorVersion() + "',switch_id='" + ps.getId()); ud.append("', csn_id='"+ps.getPlotId()+"'"); //System.out.println(ud.toString()); try { Statement stmt = DBConfig.getConnection().createStatement(); int rowsChanged = stmt.executeUpdate(deleteIt); rowsChanged = stmt.executeUpdate(ud.toString()); stmt.close(); } catch (SQLException E) { System.out.println("SQLException: " + E.getMessage()); System.out.println("SQLState: " + E.getSQLState()); System.out.println("VendorError: " + E.getErrorCode()); throw new JetWebDBException(E, ud.toString(), "oh dear"); } }

synchronized void updateCrossSectionLabels (  RealPlot  plot  )  throws JetWebException [static]

Update DB record for this RealData plot labels & switches Parameters: plot  - plot to be added to database Exceptions: JetWebException  Definition at line 1159 of file DBPlotManager.java. References CutCollection.getId(), and CutCollection.store(). { int inDefault = 0; if (plot.isDefaultSum()) { inDefault += 1; } if (plot.isDefaultFit()) { inDefault += 1; } String yAxisType = "lin"; if (plot.isLogarithmic()) { yAxisType = "log"; } int shape = 0; if (plot.isShape()) { shape = 1; } int cutId = -1; if(plot.getCutCollection()!=null){ plot.getCutCollection().store(); cutId = plot.getCutCollection().getId(); } String sqlString = "UPDATE cross_section SET paper_id='" + plot.getPaperId() + "',title='" + plot.getTitle() + "',x_axis_title='" + plot.getXLabel() + "',y_axis_title='" + plot.getYLabel() + "',in_default='" + inDefault + "',plot_number='" + plot.getNumber() + "',scale_factor='" + plot.getSysScale() + "',y_axis_type='" + yAxisType + "',is_shape='" + shape + "',collision_id='" + plot.getCollisionId() + "',cut_collection_id=" + cutId + " where csn_id=" + plot.getId(); try { Statement stmt = DBConfig.getConnection().createStatement(); int rtn = stmt.executeUpdate(sqlString); stmt.close(); } catch (SQLException e) { System.out.println("DB access error in updateCrossSectionLabels" + e); System.out.println("SQL String was: " + sqlString); throw new JetWebDBException(e, sqlString, "plotId:" + plot.getId() + " paperId:" + plot.getPaperId()); } // Now add/update the plot switches. plot.storeSwitches(); }

synchronized void updateCrossSectionPoints (  DataPlot  plot  )  throws JetWebException [static]

Update real/predicted/fitted data points in the database for an existing plot delete existing data points and repopulate Parameters: plot  object representing the plot to be updated Exceptions: JetWebException  Definition at line 917 of file DBPlotManager.java. { String sqlString = getDeleteString(plot); try { Statement stmt = DBConfig.getConnection().createStatement(); int rtn = stmt.executeUpdate(sqlString); stmt.close(); } catch (SQLException e) { System.out.println("DB access error in updateCross_Section (delete data points):" + e); System.out.println("SQL was:" + sqlString); throw new JetWebDBException(e, sqlString, "DataPlot.id:" + plot.getId()); } try { insertData(plot); } catch (JetWebException j) { // insertDataPlot throws an exception if it failed. If we // did not manage to insert the data, we should tidy up by // deleting any other data for this plot. try { sqlString = getDeleteString(plot); Statement stmt = DBConfig.getConnection().createStatement(); int rtn = stmt.executeUpdate(sqlString); stmt.close(); } catch (SQLException e) { System.out.println("DB access error in updateCrossSection (delete data points):" + e); System.out.println("SQL was:" + sqlString); throw new JetWebDBException(e, sqlString, "DataPlot.id:" + plot.getId()); } } }

---

Member Data Documentation

final String FITTED = "fitted_point" [static]

specifies Fitted data Definition at line 52 of file DBPlotManager.java.

boolean initialisedData_ = false [static, private]

Definition at line 66 of file DBPlotManager.java.

boolean initialisedRetrievePaper_ = false [static, private]

Definition at line 67 of file DBPlotManager.java.

PreparedStatement insertFittedData_ [static, private]

Definition at line 63 of file DBPlotManager.java.

PreparedStatement insertPredictedData_ [static, private]

Definition at line 62 of file DBPlotManager.java.

PreparedStatement insertRealData_ [static, private]

Initialises the PaperBank database. Returns: enumeration of all papers in the database Exceptions: JetWebException  Definition at line 61 of file DBPlotManager.java.

final String PREDICTED = "predicted_point" [static]

specifies Predicted data Definition at line 47 of file DBPlotManager.java.

final String REAL = "data_point" [static]

specifies Real data Definition at line 42 of file DBPlotManager.java.

PreparedStatement retrieveRealPaper_ [static, private]

Definition at line 64 of file DBPlotManager.java.

PreparedStatement selectPlotsForPaper_ [static, private]

Definition at line 65 of file DBPlotManager.java.

---

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

• DBPlotManager.java

Generated Wed Jan 17 09:14:27 GMT 2007