Homec4science
Diffusion Genome Privacy - SHCS App (ms_access_migration) Browse

genopri-shcs/project/PPPClient/src/database/DBconnectorClient.java
9270d993aa95ms_access_migration

Last Change
Raw File

DBconnectorClient.java
View Options

package database;
import java.math.BigInteger;
import java.sql.Date;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.logging.Level;
import java.util.logging.Logger;
import crypto.elgamal.PartialSecret;
import framework.ClinicalFactor;
import framework.Marker;
import framework.WeightedMarker;
import framework.test.TestName;
public class DBconnectorClient extends DBConnection {
private static final Logger LOGGER = Logger.getLogger(DBconnectorClient.class.getName());
public DBconnectorClient(DatabaseConfig dbConfig) {
super(dbConfig, DatabaseDriverName.MYSQL);
}
public LinkedList<Integer> getPatients() throws SQLException{
openConnection();
LinkedList<Integer> patients = new LinkedList<>();
preparedStmt = connect.prepareStatement("SELECT ID_p FROM " + database + ".patients");
resultSet = preparedStmt.executeQuery();
while(resultSet.next()){
patients.add(resultSet.getInt("ID_p"));
}
closeConnection();
return patients;
}
public HashMap<String, ArrayList<TestName>> getRelevantTestsByGroup() throws SQLException {
openConnection();
HashMap<String, ArrayList<TestName>> tests = new HashMap<>();
preparedStmt = connect.prepareStatement("SELECT ID_t, name, grp FROM " + database + ".tests WHERE ID_t < 100");
resultSet = preparedStmt.executeQuery();
while(resultSet.next()){
// retrieve current test
int testId = resultSet.getInt("ID_t");
String testName = resultSet.getString("name");
String testGroup = resultSet.getString("grp");
TestName currentTest = new TestName(testId, testName, testGroup);
// add test to hashmap
if (! tests.containsKey(testGroup)) {
tests.put(testGroup, new ArrayList<TestName>());
}
tests.get(testGroup).add(currentTest);
}
closeConnection();
return tests;
}
public ArrayList<WeightedMarker> getMarkers(int ID_t) throws SQLException{
ArrayList<WeightedMarker> markers = new ArrayList<>();
preparedStmt = connect.prepareStatement("SELECT ID_m, weight FROM " + database + ".m_t WHERE ID_t = ?");
preparedStmt.setInt(1, ID_t);
resultSet = preparedStmt.executeQuery();
while(resultSet.next()){
String markerId = resultSet.getString("ID_m");
double weight = resultSet.getDouble("weight");
markers.add(new WeightedMarker(new Marker(markerId), weight));
}
return markers;
}
public PartialSecret getPrivateKey(int ID_p) throws SQLException{
BigInteger prk = null;
preparedStmt = connect.prepareStatement("SELECT value FROM " + database + ".cryptokeys WHERE ID_p = ? AND isPublic = 0");
preparedStmt.setInt(1, ID_p);
resultSet = preparedStmt.executeQuery();
if(resultSet.next()){
prk = new BigInteger(resultSet.getString("value"));
}
return new PartialSecret(PartialSecret.PART_MU, prk);
}
public void insertResult(int id_p, int id_t, double result) {
openConnection();
LOGGER.log(Level.FINER, "putting result");
try {
preparedStmt = connect
.prepareStatement("INSERT INTO " + database + ".results (ID_t, ID_p, result, date) VALUES (?,?,?,?)");
preparedStmt.setInt(1, id_t);
preparedStmt.setInt(2, id_p);
preparedStmt.setDouble(3, result);
preparedStmt.setDate(4, new Date(System.currentTimeMillis()));
preparedStmt.executeUpdate();
} catch (SQLException e) {
Logger.getLogger(DBconnectorClient.class.getName()).log(Level.SEVERE, null, e);
e.printStackTrace();
}
closeConnection();
}
public ArrayList<ClinicalFactor> getCFs(int ID_t) {
ArrayList<ClinicalFactor> cfs = new ArrayList<>();
try{
preparedStmt = connect.prepareStatement("SELECT ID_cf, weight FROM " + database + ".cf_t WHERE ID_t = ?");
preparedStmt.setInt(1, ID_t);
resultSet = preparedStmt.executeQuery();
while (resultSet.next()) {
int cfId = resultSet.getInt("ID_cf");
double weight = resultSet.getDouble("weight");
cfs.add(new ClinicalFactor(cfId, weight));
}
}catch(SQLException e) {
Logger.getLogger(DBconnectorClient.class.getName()).log(Level.SEVERE, null, e);
e.printStackTrace();
}
return cfs;
}
}
c4science · Help