ExtentIndex.java

  1. /**
  2.  * Extent Index
  3.  */
  4. package gov.usgs.earthquake.indexer;

  6. import java.sql.PreparedStatement;
  7. import java.sql.ResultSet;
  8. import java.sql.Types;
  9. import java.sql.SQLException;

  11. /**
  12.  * ExtentIndex is a type of JDBCProductIndex that can also send updates to the
  13.  * extentSummary table.
  14.  */
  15. public class ExtentIndex extends JDBCProductIndex {

  17.   /** Table for extentSummary */
  18.   public static final String EXTENT_TABLE = "extentSummary";
  19.   /** Extent index id - productSummaryIndexId */
  20.   public static final String EXTENT_INDEX_ID = "productSummaryIndexId";
  21.   /** Extent start time */
  22.   public static final String EXTENT_START_TIME = "starttime";
  23.   /** Extent end time */
  24.   public static final String EXTENT_END_TIME = "endtime";
  25.   /** Extent max latitude */
  26.   public static final String EXTENT_MAX_LAT = "maximum_latitude";
  27.   /** Extent minimum latitude */
  28.   public static final String EXTENT_MIN_LAT = "minimum_latitude";
  29.   /** Extent max longitude */
  30.   public static final String EXTENT_MAX_LONG = "maximum_longitude";
  31.   /** Extent min longitude */
  32.   public static final String EXTENT_MIN_LONG = "minimum_longitude";

  34.   /**
  35.    * Default constructor
  36.    * @throws Exception if error occurs
  37.    */
  38.   public ExtentIndex() throws Exception {
  39.     super();
  40.   }

  42.   /**
  43.    * Queries extentSummary table for the largest index id.
  44.    *
  45.    * @return long last extent index id
  46.    * @throws Exception if something goes wrong with database transaction
  47.    */
  48.   public long getLastExtentIndexId() throws Exception {
  49.     long lastIndex;

  51.     //Prepare statement
  52.     String sql = "SELECT MAX("
  53.                  + EXTENT_INDEX_ID
  54.                  + ") AS "
  55.                  + EXTENT_INDEX_ID
  56.                  + " FROM "
  57.                  + EXTENT_TABLE;
  58.     beginTransaction();
  59.     try (PreparedStatement getLastIndex = getConnection().prepareStatement(sql)) {
  60.       //Parse Results
  61.       ResultSet results = getLastIndex.executeQuery();
  62.       if (results.next()) {
  63.         lastIndex = results.getLong(EXTENT_INDEX_ID);
  64.       } else {
  65.         //No index in extentSummary table
  66.         lastIndex = 0;
  67.       }
  68.       commitTransaction();
  69.     } catch (SQLException e) {
  70.       try {
  71.         rollbackTransaction();
  72.       } catch (Exception e2) {}
  73.       //Throws exception with SQL for debugging
  74.       throw new SQLException(e.getMessage() + ". SQL query was: " + sql, e);
  75.     }
  76.     return lastIndex;
  77.   }

  79.   /**
  80.    * Inserts valid ExtentSummary products into extentSummary table
  81.    *
  82.    * @param product the product to be added
  83.    *
  84.    * @throws Exception if something goes wrong with the database transaction
  85.    */
  86.   public void addExtentSummary(ExtentSummary product) throws Exception {
  87.     //Prepare statement
  88.     String sql = "INSERT INTO " + EXTENT_TABLE +
  89.         "(" +
  90.           EXTENT_INDEX_ID + "," +
  91.           EXTENT_START_TIME + "," +
  92.           EXTENT_END_TIME + "," +
  93.           EXTENT_MIN_LAT + "," +
  94.           EXTENT_MAX_LAT + "," +
  95.           EXTENT_MIN_LONG + "," +
  96.           EXTENT_MAX_LONG +
  97.         ") VALUES (?, ?, ?, ?, ?, ?, ?)";

  99.     beginTransaction();
  100.     try (PreparedStatement addProduct = getConnection().prepareStatement(sql)) {
  101.       //Add values
  102.       addProduct.setLong(1, product.getIndexId());
  103.       if (product.getStartTime() != null) {
  104.         addProduct.setLong(2, product.getStartTime().getTime());
  105.       } else {
  106.         addProduct.setNull(2, Types.BIGINT);
  107.       }
  108.       if (product.getEndTime() != null) {
  109.         addProduct.setLong(3, product.getEndTime().getTime());
  110.       } else {
  111.         addProduct.setNull(3, Types.BIGINT);
  112.       }
  113.       if (product.getMinLatitude() != null) {
  114.         addProduct.setBigDecimal(4, product.getMinLatitude());
  115.       } else {
  116.         addProduct.setNull(4, Types.DECIMAL);
  117.       }
  118.       if (product.getMaxLatitude() != null) {
  119.         addProduct.setBigDecimal(5, product.getMaxLatitude());
  120.       } else {
  121.         addProduct.setNull(5, Types.DECIMAL);
  122.       }
  123.       if (product.getMinLongitude() != null) {
  124.         addProduct.setBigDecimal(6, product.getMinLongitude());
  125.       } else {
  126.         addProduct.setNull(6, Types.DECIMAL);
  127.       }
  128.       if (product.getMaxLongitude() != null) {
  129.         addProduct.setBigDecimal(7, product.getMaxLongitude());
  130.       } else {
  131.         addProduct.setNull(7, Types.DECIMAL);
  132.       }

  134.       //Add to extentSummary table
  135.       addProduct.executeUpdate();
  136.       addProduct.clearParameters();
  137.       commitTransaction();
  138.     } catch (Exception e) {
  139.       try {
  140.         rollbackTransaction();
  141.       } catch (Exception e2) {}
  142.       throw e;
  143.     }
  144.   }

  146. }
Created with JaCoCo 0.8.8.202204050719