--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Database.java 2014/04/30 14:18:43 2149 +++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Database.java 2014/05/07 07:39:26 2150 @@ -1,14 +1,11 @@ package dk.daoas.fulddaekning; -import java.io.IOException; import java.sql.Connection; -import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; -import java.util.Properties; import java.util.Queue; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.logging.Logger; @@ -19,52 +16,16 @@ Connection conn; - Connection writeConn; - PreparedStatement saveStmt; - public Database(Properties conf) throws SQLException,IOException { - conn = getConnection(conf); - conn.setReadOnly(true); - - writeConn = getConnection(conf); - + public Database(Connection conn) throws SQLException { + this.conn = conn; String sql = "INSERT INTO fulddaekning.afstand_anden_rute_thn (orgId,orgPostnr, orgAdresse,orgGadeid,orgHusnr,orgHusnrBogstav,orgLatitude,orgLongitude,orgRute,id,postnr,adresse,gadeid,husnr,husnrbogstav,latitude,longitude,rute,afstand,`timestamp`) "+ "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?, now() )"; - saveStmt = writeConn.prepareStatement(sql); - - } - - public void resetResultTable() throws SQLException { - logger.info("Truncating result table"); - String sql = "TRUNCATE TABLE fulddaekning.afstand_anden_rute_thn"; - writeConn.createStatement().executeUpdate(sql); - - } - - public Connection getConnection(Properties conf) throws SQLException, IOException { - - String db_host = conf.getProperty("DB_HOST"); - String db_user = conf.getProperty("DB_USER"); - String db_pass = conf.getProperty("DB_PASS"); - + saveStmt = conn.prepareStatement(sql); - - - Connection conn = null; - Properties connectionProps = new Properties(); - connectionProps.put("user", db_user); - connectionProps.put("password", db_pass); - - conn = DriverManager.getConnection( - "jdbc:mysql://" + - db_host + - ":3306/", - connectionProps); - logger.info("Connected to database"); - return conn; } public BoundingBox getBoundingbox(int postnr) throws SQLException {