This is an automated email from the ASF dual-hosted git repository. smarru pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/airavata-sandbox.git
commit b1320cef005d06cb8bd44a2892023dab8d86ec6b Author: Bhavesh Asanabada <asanabhav...@gmail.com> AuthorDate: Mon Jun 27 14:16:25 2022 +0530 Added CRUD methods to MolData --- .../java/com/smiles/calcinfo/CalcInfoImpl.java | 2 - .../java/com/smiles/calcinfo/CalcInfoRepo.java | 2 +- .../java/com/smiles/calcprops/CalcPropsEntity.java | 2 + .../java/com/smiles/calcprops/CalcPropsImpl.java | 15 ++-- .../java/com/smiles/calcprops/CalcPropsRepo.java | 4 +- .../com/smiles/calctopology/CalcTopologyImpl.java | 4 +- .../main/java/com/smiles/molData/MoleculeImpl.java | 82 +++++++++++++++++++++- 7 files changed, 98 insertions(+), 13 deletions(-) diff --git a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcinfo/CalcInfoImpl.java b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcinfo/CalcInfoImpl.java index 3798ca5e..221bf9cc 100644 --- a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcinfo/CalcInfoImpl.java +++ b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcinfo/CalcInfoImpl.java @@ -77,7 +77,6 @@ public class CalcInfoImpl extends CalcInfoServiceGrpc.CalcInfoServiceImplBase { responseObserver.onCompleted(); } - @Override public void deleteCalcInfo(com.smiles.CalcInfoRequest request, io.grpc.stub.StreamObserver<com.smiles.CalcInfo> responseObserver) { @@ -87,5 +86,4 @@ public class CalcInfoImpl extends CalcInfoServiceGrpc.CalcInfoServiceImplBase { responseObserver.onNext(calcInfo); responseObserver.onCompleted(); } - } diff --git a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcinfo/CalcInfoRepo.java b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcinfo/CalcInfoRepo.java index 37611c92..2abe1fb0 100644 --- a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcinfo/CalcInfoRepo.java +++ b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcinfo/CalcInfoRepo.java @@ -4,7 +4,7 @@ import org.springframework.data.mongodb.repository.MongoRepository; public interface CalcInfoRepo extends MongoRepository<CalcInfoEntity, String> { - public CalcInfoEntity findByNalpha(long nalpha); +// public CalcInfoEntity findByNalpha(long nalpha); public CalcInfoEntity findBySMILES(String SMILES); diff --git a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsEntity.java b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsEntity.java index e9b495c3..dbcbb1bd 100644 --- a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsEntity.java +++ b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsEntity.java @@ -1,11 +1,13 @@ package com.smiles.calcprops; import org.springframework.data.annotation.Id; +import org.springframework.data.mongodb.core.mapping.Document; import java.lang.reflect.Array; import java.util.ArrayList; import java.util.List; +@Document("calcProps") public class CalcPropsEntity { @Id diff --git a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsImpl.java b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsImpl.java index 3aec2474..47ca39c7 100644 --- a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsImpl.java +++ b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsImpl.java @@ -15,8 +15,8 @@ public class CalcPropsImpl extends CalcPropsServiceGrpc.CalcPropsServiceImplBase public void getCalcProps(CalcPropsRequest request, StreamObserver<CalcProps> responseObserver) { // super.getCalcInfo(request, responseObserver); - CalcPropsEntity calcProps = repo1.findByPDB(request.getCalcPropsQuery()); - System.out.println(calcProps); + CalcPropsEntity calcProps = repo1.findBySMILES(request.getCalcPropsQuery()); + System.out.println(calcProps.toString()); CalcProps reply = CalcProps.newBuilder() .setInChI(calcProps.getInChI()) @@ -69,7 +69,9 @@ public class CalcPropsImpl extends CalcPropsServiceGrpc.CalcPropsServiceImplBase calcProps.getOtherinfo(), calcProps.getComments(), calcProps.getNAtom(), calcProps.getHomosList(), calcProps.getScfEnergiesList(), calcProps.getMoEnergiesList(), calcProps.getAtomCoordsList(), calcProps.getNmo(), calcProps.getNBasis()); - + repo1.save(c2001); + responseObserver.onNext(calcProps); + responseObserver.onCompleted(); } @Override @@ -77,7 +79,7 @@ public class CalcPropsImpl extends CalcPropsServiceGrpc.CalcPropsServiceImplBase // super.updateCalcProps(request, responseObserver); CalcProps calcProps = request.getCalcProp(); System.out.println(request.getAllFields()); - CalcPropsEntity c2001 = (CalcPropsEntity) repo1.findByPDB(calcProps.getPDB()); + CalcPropsEntity c2001 = (CalcPropsEntity) repo1.findBySMILES(calcProps.getSMILES()); System.out.println(c2001.getId()); c2001.setInChI(calcProps.getInChI()); c2001.setInChIKey(calcProps.getInChIKey()); @@ -134,13 +136,16 @@ public class CalcPropsImpl extends CalcPropsServiceGrpc.CalcPropsServiceImplBase c2001.setNAtom(calcProps.getNAtom()); c2001.setNmo(calcProps.getNmo()); c2001.setNBasis(calcProps.getNBasis()); + repo1.save(c2001); + responseObserver.onNext(calcProps); + responseObserver.onCompleted(); } @Override public void deleteCalcProps(CalcPropsRequest request, StreamObserver<CalcProps> responseObserver) { // super.deleteCalcProps(request, responseObserver); CalcProps calcProps = request.getCalcProp(); - CalcPropsEntity c2001 = (CalcPropsEntity) repo1.findByPDB(calcProps.getSDF()); + CalcPropsEntity c2001 = (CalcPropsEntity) repo1.findBySMILES(calcProps.getSMILES()); repo1.delete(c2001); responseObserver.onNext(calcProps); responseObserver.onCompleted(); diff --git a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsRepo.java b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsRepo.java index aa084e0a..ef71a7e6 100644 --- a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsRepo.java +++ b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calcprops/CalcPropsRepo.java @@ -4,5 +4,7 @@ import org.springframework.data.mongodb.repository.MongoRepository; public interface CalcPropsRepo extends MongoRepository<CalcPropsEntity, String> { - public CalcPropsEntity findByPDB(String PDB); +// public CalcPropsEntity findByPDB(String PDB); + public CalcPropsEntity findBySMILES(String SMILES); + } diff --git a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calctopology/CalcTopologyImpl.java b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calctopology/CalcTopologyImpl.java index a12aa07d..2b143010 100644 --- a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calctopology/CalcTopologyImpl.java +++ b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/calctopology/CalcTopologyImpl.java @@ -16,7 +16,7 @@ public class CalcTopologyImpl extends CalcTopologyServiceGrpc.CalcTopologyServic // super.getCalcTopology(request, responseObserver); System.out.println(request.getAllFields()); - CalcTopologyEntity calcTopology = repo.findBySymbols(request.getCalcTopologyQuery()); + CalcTopologyEntity calcTopology = repo.findBySymbols(request.getcalcTopologyQuery()); System.out.println(calcTopology.toString()); CalcTopology reply = CalcTopology.newBuilder() @@ -37,7 +37,7 @@ public class CalcTopologyImpl extends CalcTopologyServiceGrpc.CalcTopologyServic // super.createCalcTopology(request, responseObserver); CalcTopology calcTopology = request.getCalcTopology(); System.out.println(request.getAllFields()); - + } @Override diff --git a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/molData/MoleculeImpl.java b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/molData/MoleculeImpl.java index 782ed68c..6cf4a7b5 100644 --- a/gsoc2022/smilesdb/Server/src/main/java/com/smiles/molData/MoleculeImpl.java +++ b/gsoc2022/smilesdb/Server/src/main/java/com/smiles/molData/MoleculeImpl.java @@ -87,11 +87,89 @@ public class MoleculeImpl extends MoleculeServiceGrpc.MoleculeServiceImplBase { @Override public void updateMolecule(MoleculeRequest request, StreamObserver<Molecule> responseObserver) { - super.updateMolecule(request, responseObserver); +// super.updateMolecule(request, responseObserver); + Molecule molecule = request.getMolecule(); + System.out.println(request.getAllFields()); + MoleculeEntity c4001 = (MoleculeEntity) repo.findBySmiles(molecule.getSmiles()); + System.out.println(c4001.getId()); + c4001.setCas_nr(molecule.getCasNr()); + c4001.setSmiles(molecule.getSmiles()); + c4001.setSmiles_stereo(molecule.getSmilesStereo()); + c4001.setInchi(molecule.getInchi()); + c4001.setMolfile_blob_source(molecule.getMolfileBlobSource()); + c4001.setEmp_formula(molecule.getEmpFormula()); + c4001.setEmp_formula_sort(molecule.getEmpFormulaSort()); + c4001.setEmp_formula_source(molecule.getEmpFormulaSource()); + c4001.setMw(molecule.getMw()); + c4001.setMw_monoiso(molecule.getMwMonoiso()); + c4001.setRdb(molecule.getRdb()); + c4001.setMw_source(molecule.getMwSource()); + c4001.setValidated_by(molecule.getValidatedBy()); + c4001.setJournal(molecule.getJournal()); + c4001.setAuth_of_intr(molecule.getAuthOfIntr()); + c4001.setJour_cit(molecule.getJourCit()); + c4001.setYear_publ(molecule.getYearPubl()); + c4001.setDoi_link(molecule.getDoiLink()); + c4001.setComp_class(molecule.getCompClass()); + c4001.setCuniq(molecule.getCuniq()); + c4001.setCalc_perf(molecule.getCalcPerf()); + c4001.setOrg_met(molecule.getOrgMet()); + c4001.setMol_chrg(molecule.getMolChrg()); + c4001.setState_ofmat(molecule.getStateOfmat()); + c4001.setColor_white(molecule.getColorWhite()); + c4001.setColor_uv(molecule.getColorUv()); + c4001.setAbsorb_max(molecule.getAbsorbMax()); + c4001.setSolvent_ae(molecule.getSolventAe()); + c4001.setAbsorb(molecule.getAbsorb()); + c4001.setConc(molecule.getConc()); + c4001.setExtinc(molecule.getExtinc()); + c4001.setEmis_max(molecule.getEmisMax()); + c4001.setTemp_abs(molecule.getTempAbs()); + c4001.setEmis_qy(molecule.getEmisQy()); + c4001.setTemp_ems(molecule.getTempEms()); + c4001.setLifetime(molecule.getLifetime()); + c4001.setTemp_cv(molecule.getTempCv()); + c4001.setReduc_pot(molecule.getReducPot()); + c4001.setHw_or_pk_rp(molecule.getHwOrPkRp()); + c4001.setOxid_pot(molecule.getOxidPot()); + c4001.setHw_or_pk_op(molecule.getHwOrPkOp()); + c4001.setSolvent_cv(molecule.getSolventCv()); + c4001.setElectrolyte(molecule.getElectrolyte()); + c4001.setRef_electrd(molecule.getRefElectrd()); + c4001.setInter_thngs(molecule.getInterThngs()); + c4001.setDensity_20(molecule.getDensity20()); + c4001.setDensity_20_source(molecule.getDensity20Source()); + c4001.setDefault_warn_level(molecule.getDefaultWarnLevel()); + c4001.setN_20(molecule.getN20()); + c4001.setN_20_source(molecule.getN20Source()); + c4001.setMp_low(molecule.getMpLow()); + c4001.setMp_high(molecule.getMpHigh()); + c4001.setMp_source(molecule.getMpSource()); + c4001.setBp_low(molecule.getBpLow()); + c4001.setBp_high(molecule.getBpHigh()); + c4001.setBp_press(molecule.getBpPress()); + c4001.setPress_unit(molecule.getPressUnit()); + c4001.setBp_source(molecule.getBpSource()); + c4001.setSafety_r(molecule.getSafetyR()); + c4001.setSafety_h(molecule.getSafetyH()); + c4001.setSafety_s(molecule.getSafetyS()); + c4001.setSafety_p(molecule.getSafetyP()); + c4001.setSafety_text(molecule.getSafetyText()); + c4001.setSafety_sym(molecule.getSafetySym()); + c4001.setSafety_sym_ghs(molecule.getSafetySymGhs()); + c4001.setComment_mol(molecule.getCommentMol()); + repo.save(c4001); + responseObserver.onNext(molecule); + responseObserver.onCompleted(); } @Override public void deleteMolecule(MoleculeRequest request, StreamObserver<Molecule> responseObserver) { - super.deleteMolecule(request, responseObserver); +// super.deleteMolecule(request, responseObserver); + Molecule molecule = request.getMolecule(); + MoleculeEntity c4001 = (MoleculeEntity) repo.findBySmiles(molecule.getSmiles()); + repo.delete(c4001); + responseObserver.onNext(molecule); + responseObserver.onCompleted(); } }