Homec4science
Diffusion Genome Privacy - SHCS App (SHCS_url) Browse

genopri-shcs/project/PPPCertifiedInstitution/src/database/DBconnector_server.java
a46d2cf9b756SHCS_url

Last Change
Raw File

DBconnector_server.java
View Options

/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package database;
import java.math.BigInteger;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/**
*
* @author raisaro
*/
public class DBconnector_server {
private Connection connect = null;
private PreparedStatement preparedStatement = null;
private ResultSet resultSet = null;
private final String database = "pharmacogenomics_server_test";
public DBconnector_server() {}
public BigInteger[] getPublicKey(int ID_p) throws SQLException{
// openConnection();
BigInteger[] plk = new BigInteger[3];
preparedStatement = connect.prepareStatement("SELECT value FROM " + database + ".cryptokeys WHERE ID_p = ? AND isPublic = 1");
preparedStatement.setInt(1, ID_p);
resultSet = preparedStatement.executeQuery();
if(resultSet.next()){
String[] pub_key = resultSet.getString("value").split(";");
plk[0] = new BigInteger(pub_key[0]);
plk[1] = new BigInteger(pub_key[1]);
plk[2] = new BigInteger(pub_key[2]);
}
// closeConnection();
return plk;
}
public void insertEncryptedMarkers(int ID_p, int ID_m, BigInteger enc_gen_1, BigInteger enc_gen_2, BigInteger enc_gen2_1, BigInteger enc_gen2_2) throws SQLException{
// openConnection();
if(enc_gen2_1 == null){
preparedStatement = connect.prepareStatement("INSERT INTO " + database + ".m_p (ID_p, ID_m, enc_genotype_1, enc_genotype_2) VALUES (?,?,?,?)");
preparedStatement.setInt(1, ID_p);
preparedStatement.setInt(2, ID_m);
preparedStatement.setString(3, enc_gen_1.toString());
preparedStatement.setString(4, enc_gen_2.toString());
}else{
preparedStatement = connect.prepareStatement("INSERT INTO " + database + ".m_p VALUES (?,?,?,?,?,?)");
preparedStatement.setInt(1, ID_p);
preparedStatement.setInt(2, ID_m);
preparedStatement.setString(3, enc_gen_1.toString());
preparedStatement.setString(4, enc_gen_2.toString());
preparedStatement.setString(5, enc_gen2_1.toString());
preparedStatement.setString(6, enc_gen2_2.toString());
}
preparedStatement.executeUpdate();
// closeConnection();
}
public void insertEncryptedHLA(int ID_p, BigInteger a1, BigInteger a2, BigInteger b1, BigInteger b2, BigInteger c1, BigInteger c2 ) throws SQLException{
openConnection();
preparedStatement = connect.prepareStatement("INSERT INTO " + database + ".hla_p VALUES (?,?,?,?,?,?,?)");
preparedStatement.setInt(1, ID_p);
preparedStatement.setString(2, a1.toString());
preparedStatement.setString(3, a2.toString());
preparedStatement.setString(4, b1.toString());
preparedStatement.setString(5, b2.toString());
preparedStatement.setString(6, c1.toString());
preparedStatement.setString(7, c2.toString());
preparedStatement.executeUpdate();
closeConnection();
}
public void insertEncryptedCF(int ID_p, int ID_cf, BigInteger enc_cf_1, BigInteger enc_cf_2, BigInteger enc_cf2_1, BigInteger enc_cf2_2)throws SQLException{
preparedStatement = connect.prepareStatement("Select ID_p FROM " + database + ".cf_p where ID_p = ? AND ID_cf = ?");
preparedStatement.setInt(1, ID_p);
preparedStatement.setInt(2, ID_cf);
if(preparedStatement.executeQuery().next()){
if(enc_cf2_1 == null){
preparedStatement = connect.prepareStatement("UPDATE " + database + ".cf_p SET enc_cf_1 = ?, enc_cf_2 = ? WHERE ID_p = ? AND ID_cf = ?");
preparedStatement.setString(1, enc_cf_1.toString());
preparedStatement.setString(2, enc_cf_2.toString());
preparedStatement.setInt(3, ID_p);
preparedStatement.setInt(4, ID_cf);
}else{
preparedStatement = connect.prepareStatement("UPDATE " + database + ".cf_p SET enc_cf_1 = ?, enc_cf_2 = ?, enc_cf2_1 = ?, enc_cf2_2 = ? WHERE ID_p = ? AND ID_cf = ?");
preparedStatement.setString(1, enc_cf_1.toString());
preparedStatement.setString(2, enc_cf_2.toString());
preparedStatement.setString(3, enc_cf2_1.toString());
preparedStatement.setString(4, enc_cf2_2.toString());
preparedStatement.setInt(5, ID_p);
preparedStatement.setInt(6, ID_cf);
}
}else{
if(enc_cf2_1 == null){
preparedStatement = connect.prepareStatement("INSERT INTO " + database + ".cf_p (ID_p, ID_cf, enc_cf_1, enc_cf_2) VALUES (?,?,?,?)");
preparedStatement.setInt(1, ID_p);
preparedStatement.setInt(2, ID_cf);
preparedStatement.setString(3, enc_cf_1.toString());
preparedStatement.setString(4, enc_cf_2.toString());
}else{
preparedStatement = connect.prepareStatement("INSERT INTO " + database + ".cf_p VALUES (?,?,?,?,?,?)");
preparedStatement.setInt(1, ID_p);
preparedStatement.setInt(2, ID_cf);
preparedStatement.setString(3, enc_cf_1.toString());
preparedStatement.setString(4, enc_cf_2.toString());
preparedStatement.setString(5, enc_cf2_1.toString());
preparedStatement.setString(6, enc_cf2_2.toString());
}
preparedStatement.executeUpdate();
}
}
public void insertKey(int ID_p, String key, boolean flag ) throws SQLException{
openConnection();
preparedStatement = connect.prepareStatement("SELECT ID_p FROM " + database + ".cryptokeys WHERE ID_p = ?");
preparedStatement.setInt(1, ID_p);
resultSet = preparedStatement.executeQuery();
if(!resultSet.next()){
preparedStatement = connect.prepareStatement("INSERT INTO " + database + ".cryptokeys (ID_p,value,isPublic) VALUES (?,?,?)");
preparedStatement.setInt(1, ID_p);
preparedStatement.setString(2, key);
preparedStatement.setBoolean(3, flag);
preparedStatement.executeUpdate();
}
closeConnection();
}
/**
* This method set up the connection to the PharmacoGenomics database
*/
public void openConnection(){
try {
// This will load the MySQL driver, each DB has its own driver
Class.forName("com.mysql.jdbc.Driver");
// Setup the connection with the DB
connect = DriverManager.getConnection("jdbc:mysql://128.178.151.209/" + database + "?"
+ "user=root&password=admin");
} catch (SQLException e) {
System.out.println("Connection Failed");
} catch (ClassNotFoundException e) {
System.out.println("Connection Failed");
}
}
/**
* This method close the connection to any database
*/
public void closeConnection() {
try {
if (resultSet != null) {
resultSet.close();
}
if (connect != null) {
connect.close();
}
} catch (Exception e) {
}
}
}
c4science · Help