senslog1/src/main/java/cz/hsrs/db/model/Observation.java

package cz.hsrs.db.model;
// default package
// Generated 3.6.2008 8:30:06 by Hibernate Tools 3.2.2.GA

import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.logging.Level;

import cz.hsrs.db.DBObject;
import cz.hsrs.db.pool.SQLExecutor;

/**
 * Observation generated by hbm2java
 */
public class Observation implements DBObject {

    //private int id;
    private long sensor_id;
    private Date timeStamp;
    private int gid;
    private long unit_id;
    private Double observedValue;

    private static final SimpleDateFormat FORMATTER = new SimpleDateFormat("yyyy-MM-dd HH:mm:ssZ");
    
    @Override
    public DBObject getDBObject(ResultSet set) throws SQLException {
        return new Observation(set);
    }
    /**
     * Constructor creates object with attributes
     * @param timeStamp - time stamp when observation was measured
     * @param observedValue - observed value, can be NaN
     * @param sensor_id - id of sensor
     * @param unit_id - id of unit
     */
    public Observation(Date timeStamp, Double observedValue, long sensor_id, long unit_id) {
        this.sensor_id = sensor_id;
        this.timeStamp = timeStamp;
        this.unit_id = unit_id;
        this.observedValue = observedValue;
    }

    /**
     * Constructor creates object from ResultSet
     * @param set ResultSet with all mandatory attributes
     * @throws SQLException
     */
    public Observation(ResultSet set) throws SQLException {
        this.sensor_id = set.getLong("sensor_id");
        String time_string =  set.getString("time_stamp");
        try {
            timeStamp =  FORMATTER.parse(time_string+"00");
        } catch (ParseException e) {
            // Should never happpend
            SQLExecutor.logger.log(Level.SEVERE, e.getMessage());
        }
        this.unit_id = set.getLong("unit_id");
        this.observedValue = set.getDouble("observed_value");
        this.gid = set.getInt("gid");
    }

    public Observation() { }

    public long getUnitId(){
        return unit_id;
    }
    
    public long getSensorId(){
        return sensor_id;
    }

    public Date getTimeStamp() {
        return timeStamp;
    }

    public int getGid() {
        return gid;
    }


    public Double getObservedValue() {
        return observedValue;
    }

    public void setObservedValue(Double observedValue) {
        this.observedValue = observedValue;
    }


    public boolean insertToDb() throws SQLException{
        int i = SQLExecutor.executeUpdate(String.format(
                "INSERT INTO observations(time_stamp, observed_value, sensor_id, unit_id) VALUES ('%s', %s, %s, %s);",
                FORMATTER.format(timeStamp), observedValue.isNaN() ? "'NaN'" : observedValue, sensor_id, unit_id
        ));
        return i == 1 || i == 0;
    }
}