Homec4science
Diffusion Genome Privacy - SHCS App (SHCS_url) Browse

genopri-shcs/project/PPPCertifiedInstitution/src/database/DBconnectorClient.java
bc9b923eb956SHCS_url

Last Change
Raw File

DBconnectorClient.java
View Options

package database;
import java.sql.Date;
import java.sql.SQLException;
import java.util.ArrayList;
public class DBconnectorClient extends DBconnector {
public DBconnectorClient(DatabaseConfig dbConfig) {
super(dbConfig);
}
public void insertMarker(String rs_code, String risk_allele, String ref_allele, int position, double maf, String chr) throws SQLException{
openConnection();
preparedStatement = connect.prepareStatement("SELECT * FROM " + database + ".markers WHERE rs = ?");
preparedStatement.setString(1, rs_code);
resultSet = preparedStatement.executeQuery();
if(!resultSet.next()){
preparedStatement = connect.prepareStatement("INSERT INTO " + database + ".markers (rs,chr,position,risk_allele,ref_allele,maf) VALUES (?,?,?,?,?,?)");
preparedStatement.setString(1, rs_code);
preparedStatement.setString(2, chr);
preparedStatement.setInt(3, position);
preparedStatement.setString(4, risk_allele);
preparedStatement.setString(5, ref_allele);
preparedStatement.setDouble(6, maf);
preparedStatement.executeUpdate();
closeConnection();
}
closeConnection();
}
public void insertPatient(int ID_p, String name, String last_name, String sex, Date birthdate) throws SQLException{
openConnection();
preparedStatement = connect.prepareStatement("SELECT * FROM " + database + ".patients WHERE ID_p = ?");
preparedStatement.setInt(1, ID_p);
resultSet = preparedStatement.executeQuery();
if(!resultSet.next()){
preparedStatement = connect.prepareStatement("INSERT INTO " + database + ".patients VALUES (?,?,?,?,?)");
preparedStatement.setInt(1, ID_p);
preparedStatement.setString(2, name);
preparedStatement.setString(3, last_name);
preparedStatement.setString(4, sex);
preparedStatement.setDate(5, birthdate);
preparedStatement.executeUpdate();
}
closeConnection();
}
public String[] getAlleles(String rs_code) throws SQLException{
String[] result = new String[3];
// openConnection();
preparedStatement = connect.prepareStatement("SELECT ID_m, risk_allele, ref_allele FROM " + database + ".markers WHERE rs = ?");
preparedStatement.setString(1, rs_code);
resultSet = preparedStatement.executeQuery();
if(resultSet.next()){
result[0] = resultSet.getString("risk_allele");
result[1] = resultSet.getString("ref_allele");
Integer id_m = resultSet.getInt("ID_m");
result[2] = id_m.toString();
}
// closeConnection();
return result;
}
public int getCF(String name) throws SQLException{
int result = -1;
// openConnection();
preparedStatement = connect.prepareStatement("SELECT ID_cf FROM " + database + ".clinical_factors WHERE description = ?");
preparedStatement.setString(1, name);
resultSet = preparedStatement.executeQuery();
if(resultSet.next()){
result = resultSet.getInt(1);
}
// closeConnection();
return result;
}
public ArrayList<String> getCFnames(String name) throws SQLException{
ArrayList<String> result = new ArrayList<>();
openConnection();
preparedStatement = connect.prepareStatement("SELECT cf.description FROM " + database + ".clinical_factors as cf, " + database + ".cf_t as cft, " +
database + ".tests as t WHERE cft.ID_t = t.ID_t AND cft.ID_cf = cf.ID_cf AND t.name = ?");
preparedStatement.setString(1, name);
resultSet = preparedStatement.executeQuery();
while(resultSet.next()){
result.add(resultSet.getString(1));
}
closeConnection();
return result;
}
}
c4science · Help