Browse Source

init the param of schemaRetrievalUrl;

tags/1.1.0
zhaoguangwei 5 years ago
parent
commit
ee0f2e81bb
2 changed files with 33 additions and 0 deletions
  1. +1
    -0
      source/gateway/src/main/java/com/jd/blockchain/gateway/GatewayServerBooter.java
  2. +32
    -0
      source/gateway/src/main/java/com/jd/blockchain/gateway/web/BlockBrowserController.java

+ 1
- 0
source/gateway/src/main/java/com/jd/blockchain/gateway/GatewayServerBooter.java View File

@@ -129,6 +129,7 @@ public class GatewayServerBooter {
ConsoleUtils.info("\r\n\r\nStart connecting to peer ....");
BlockBrowserController blockBrowserController = appCtx.getBean(BlockBrowserController.class);
blockBrowserController.setDataRetrievalUrl(config.dataRetrievalUrl());
blockBrowserController.setSchemaRetrievalUrl(config.getSchemaRetrievalUrl());
PeerConnector peerConnector = appCtx.getBean(PeerConnector.class);
peerConnector.connect(config.masterPeerAddress(), defaultKeyPair, config.providerConfig().getProviders());
ConsoleUtils.info("Peer[%s] is connected success!", config.masterPeerAddress().toString());


+ 32
- 0
source/gateway/src/main/java/com/jd/blockchain/gateway/web/BlockBrowserController.java View File

@@ -56,6 +56,7 @@ public class BlockBrowserController implements BlockchainExtendQueryService {
private DataRetrievalService dataRetrievalService;

private String dataRetrievalUrl;
private String schemaRetrievalUrl;

private static final long BLOCK_MAX_DISPLAY = 3L;

@@ -511,6 +512,37 @@ public class BlockBrowserController implements BlockchainExtendQueryService {
return result;
}

/**
* querysql;
* @param request
* @return
*/
@RequestMapping(method = RequestMethod.POST, value = "schema/querysql")
public Object queryBySql(HttpServletRequest request,@RequestBody String queryString) {
String result;
if (schemaRetrievalUrl == null || schemaRetrievalUrl.length() <= 0) {
result = "{'message':'OK','data':'" + "schema.retrieval.url is empty" + "'}";
} else {
String queryParams = request.getQueryString() == null ? "": request.getQueryString();
String fullQueryUrl = new StringBuffer(schemaRetrievalUrl)
.append(request.getRequestURI())
.append(BaseConstant.DELIMETER_QUESTION)
.append(queryParams)
.toString();
try {
result = dataRetrievalService.retrievalPost(fullQueryUrl,queryString);
ConsoleUtils.info("request = {%s} \r\n result = {%s} \r\n", fullQueryUrl, result);
} catch (Exception e) {
result = "{'message':'error','data':'" + e.getMessage() + "'}";
}
}
return result;
}

public void setSchemaRetrievalUrl(String schemaRetrievalUrl) {
this.schemaRetrievalUrl = schemaRetrievalUrl;
}

public void setDataRetrievalUrl(String dataRetrievalUrl) {
this.dataRetrievalUrl = dataRetrievalUrl;
}


Loading…
Cancel
Save