Skip to content

Commit

Permalink
corrections of db name for dev version
Browse files Browse the repository at this point in the history
  • Loading branch information
nicolasmoreau committed Jan 12, 2018
1 parent c93356f commit adf429e
Show file tree
Hide file tree
Showing 9 changed files with 11 additions and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
* VamdcInchikeyExceptions generated by hbm2java
*/
@Entity
@Table(name = "vamdc_inchikey_exceptions", catalog = "vamdc_species")
@Table(name = "vamdc_inchikey_exceptions", catalog = "vamdc_species_dev")
public class VamdcInchikeyExceptions implements java.io.Serializable {

private Integer id;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* VamdcMarkupTypes generated by hbm2java
*/
@Entity
@Table(name = "vamdc_markup_types", catalog = "vamdc_species")
@Table(name = "vamdc_markup_types", catalog = "vamdc_species_dev")
public class VamdcMarkupTypes implements java.io.Serializable {

private int id;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
* VamdcMemberDatabaseIdentifiers generated by hbm2java
*/
@Entity
@Table(name = "vamdc_node_species", catalog = "vamdc_species", uniqueConstraints = @UniqueConstraint(columnNames = {
@Table(name = "vamdc_node_species", catalog = "vamdc_species_dev", uniqueConstraints = @UniqueConstraint(columnNames = {
"species_id", "database_species_id", "member_database_id" }))
public class VamdcMemberDatabaseIdentifiers implements java.io.Serializable {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
* VamdcMemberDatabases generated by hbm2java
*/
@Entity
@Table(name = "vamdc_nodes", catalog = "vamdc_species")
@Table(name = "vamdc_nodes", catalog = "vamdc_species_dev")
public class VamdcMemberDatabases implements java.io.Serializable {

private Integer id;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
* VamdcSpecies generated by hbm2java
*/
@Entity
@Table(name = "vamdc_species", catalog = "vamdc_species", uniqueConstraints = @UniqueConstraint(columnNames = {
@Table(name = "vamdc_species", catalog = "vamdc_species_dev", uniqueConstraints = @UniqueConstraint(columnNames = {
"inchikey" }))
public class VamdcSpecies implements java.io.Serializable {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
* VamdcSpeciesNames generated by hbm2java
*/
@Entity
@Table(name = "vamdc_species_names", catalog = "vamdc_species", uniqueConstraints = @UniqueConstraint(columnNames = {
@Table(name = "vamdc_species_names", catalog = "vamdc_species_dev", uniqueConstraints = @UniqueConstraint(columnNames = {
"species_id", "name", "markup_type_id" }))
public class VamdcSpeciesNames implements java.io.Serializable {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
* VamdcSpeciesStructFormulae generated by hbm2java
*/
@Entity
@Table(name = "vamdc_species_struct_formulae", catalog = "vamdc_species", uniqueConstraints = @UniqueConstraint(columnNames = {
@Table(name = "vamdc_species_struct_formulae", catalog = "vamdc_species_dev", uniqueConstraints = @UniqueConstraint(columnNames = {
"species_id", "formula", "markup_type_id" }))
public class VamdcSpeciesStructFormulae implements java.io.Serializable {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* VamdcSpeciesTypes generated by hbm2java
*/
@Entity
@Table(name = "vamdc_species_types", catalog = "vamdc_species")
@Table(name = "vamdc_species_types", catalog = "vamdc_species_dev")
public class VamdcSpeciesTypes implements java.io.Serializable {

private int id;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -79,20 +79,18 @@ private QueryStoreResponse associateRequest(String token, String userIp) {
try {
String request = this.getRequest(token, this.getUserEmail(),
this.userIp);

// send request while no result or result is empty
while ((result == null || QueryStoreResponse.STATUS_EMPTY.equals(result.getStatus()))
&& count < Settings.QUERYSTORE_MAX_RETRY.getInt()) {
result = this.doRequest(request);
//if(result != null)
Thread.sleep(Settings.QUERYSTORE_RETRY_TIMER.getInt());
count++;
}

} catch (Exception e) {
log.debug(e);
new QueryStoreResponse(QueryStoreResponse.STATUS_ERROR, "", "Error while querying query store");

}
result = new QueryStoreResponse(QueryStoreResponse.STATUS_ERROR, "", "Error while querying query store");
}
return result;
}

Expand Down Expand Up @@ -125,17 +123,14 @@ private QueryStoreResponse doRequest(String requestString)
//SSLHandShakeException (IOException) occurs if missing certificate
HttpResponse response = httpClient.execute(request);
Integer statusCode = response.getStatusLine().getStatusCode();

if ( statusCode == 200) {
BufferedReader rd = new BufferedReader(new InputStreamReader(
response.getEntity().getContent()));

String uuid;
while ((uuid = rd.readLine()) != null) {
result.append(uuid);
}
rd.close();

} else {
// empty response
if (statusCode == 204) {
Expand All @@ -150,7 +145,6 @@ else if (statusCode >= 400 && statusCode < 500) {
return new QueryStoreResponse(QueryStoreResponse.STATUS_ERROR, "", response.getStatusLine().getReasonPhrase());
}
}

// extract uuid from json response
return QueryStoreResponseReader.parseResponse(result.toString());
}
Expand Down

0 comments on commit adf429e

Please sign in to comment.