Homec4science
Diffusion Genome Privacy - SHCS App (master) Browse

genopri-shcs/project/PPPCertifiedInstitution/src/database/DBconnectorServer.java
bc9b923eb956master

Last Change
Raw File

DBconnectorServer.java
View Options

package database;
import java.math.BigInteger;
import java.sql.SQLException;
/**
*
* @author raisaro
*/
public class DBconnectorServer extends DBconnector {
public DBconnectorServer(DatabaseConfig dbConfig) {
super(dbConfig);
}
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();
}
}
}
c4science · Help