DBconnector.java
09691ea9bb9edowngrade_java6

DBconnector.java
View Options

			package database;

			import java.math.BigInteger;
			import java.sql.SQLException;

			import org.bouncycastle.math.ec.ECPoint;

			public class DBconnector extends DBConnection {

			public DBconnector(DatabaseConfig dbConfig) {
			super(dbConfig, DatabaseDriverName.MYSQL);
			}

			public void insertPubKey(int ID_p, ECPoint pubKey) throws SQLException {
			preparedStmt = connect.prepareStatement("SELECT ID_p FROM " + database + ".cryptokeys WHERE ID_p = ? AND isPublic = 1");
			preparedStmt.setInt(1, ID_p);
			resultSet = preparedStmt.executeQuery();
			if(!resultSet.next()){
			preparedStmt = connect.prepareStatement("INSERT INTO " + database + ".cryptokeys (ID_p,value,isPublic) VALUES (?,?,?)");
			preparedStmt.setInt(1, ID_p);
			preparedStmt.setBytes(2, pubKey.getEncoded());
			preparedStmt.setBoolean(3, true);

			preparedStmt.executeUpdate();
			}
			}

			public void insertPrivKey(int ID_p, BigInteger privKey) throws SQLException {
			preparedStmt = connect.prepareStatement("SELECT ID_p FROM " + database + ".cryptokeys WHERE ID_p = ? AND isPublic = 0");
			preparedStmt.setInt(1, ID_p);
			resultSet = preparedStmt.executeQuery();
			if(!resultSet.next()){
			preparedStmt = connect.prepareStatement("INSERT INTO " + database + ".cryptokeys (ID_p,value,isPublic) VALUES (?,?,?)");
			preparedStmt.setInt(1, ID_p);
			preparedStmt.setString(2, privKey.toString());
			preparedStmt.setBoolean(3, false);

			preparedStmt.executeUpdate();
			}
			}

			}