Read Data¶
通过指定通道,使用SQL语句读取数据。
前提条件¶
已创建数据读取通道,且通道已启动。
请求格式¶
POST https://{apigw-address}/data-federation/v2.0/channels/read/{channelId}
请求参数(Header)¶
名称 |
必需/可选 |
数据类型 |
描述 |
---|---|---|---|
Content-Type |
必需 |
String |
内容或文件类型,默认值为 application/json。 |
请求参数(URI)¶
名称 |
位置(Path/Query) |
必需/可选 |
数据类型 |
描述 |
---|---|---|---|---|
orgId |
Query |
必需 |
String |
用户所属的组织ID。如何获取orgId信息>> |
channelId |
Path |
必需 |
String |
通道ID。 |
请求参数(Body)¶
名称 |
必需/可选 |
数据类型 |
描述 |
---|---|---|---|
sqlQuery |
必需 |
String |
数据查询SQL语句。 |
source |
可选 |
String |
在非跨源通道中,指定查询数据源别名。 |
queue |
可选 |
String |
指定数据查询任务的优先级,可选项为:Hot,Warm,Cold。Hot 队列为最高优先级,Warm 队列为中优先级,Cold 队列为最低优先级。 |
itemFormat |
可选 |
String |
预留字段,指定返回 JSON 的数据格式。目前该字段暂未生效。 |
响应参数¶
名称 |
数据类型 |
描述 |
---|---|---|
data |
List<JSONObject> |
通过SQL语句读取到的数据,详见 返回数据结构体 |
返回数据结构体 ¶
名称 |
数据类型 |
描述 |
---|---|---|
columns |
String |
列名。 |
metadata |
String |
元数据。 |
queryState |
String |
数据查询状态。 |
rows |
List<JSONObject> |
数据条目,详见 数据条目结构体 |
数据条目结构体 ¶
名称 |
数据类型 |
描述 |
---|---|---|
COLUMN_NAME |
String |
列名。 |
DATA_TYPE |
String |
数据类型。 |
IS_NULLABLE |
String |
数据类型。 |
示例¶
请求示例¶
url: https://{apigw-address}/data-federation/v2.0/channels/read/{channelId}?orgId={}
method: POST
requestBody:
{
"sqlQuery": "show schemas"
}
返回示例¶
{
"msg": "OK",
"code": 0,
"data": {
"metadata": ["VARCHAR"],
"columns": ["SCHEMA_NAME"],
"queryState": "COMPLETED",
"rows": []
}
}
Java SDK调用示例¶
import com.alibaba.fastjson.JSONObject;
import com.envision.apim.poseidon.config.PConfig;
import com.envision.apim.poseidon.core.Poseidon;
import com.envision.apim.poseidon.request.PoseidonRequest;
import com.google.common.net.HttpHeaders;
import org.apache.commons.codec.binary.Hex;
import org.junit.Test;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
public class Sample {
private static String accessKey = "AccessKey of your APP";
private static String secretKey = "SecretKey of your APP";
private static String orgId = "yourOrgId";
private static String chId = "yourChannelId";
private static String url = "https://{domain_url}";
private static class Request extends PoseidonRequest {
public void setQueryParam(String key, Object value) {
queryEncodeParams().put(key, value);
}
public void setMethod(String method) {
this.method = method;
}
public void setBodyParams(String key, Object value) {
bodyParams().put(key, value);
}
private String method;
@Override
public String baseUri() {
return "";
}
@Override
public String method() {
return method;
}
}
@Test
public void readData() throws InterruptedException {
Request request = new Request();
request.setQueryParam("orgId", orgId);
request.setMethod("POST");
request.headerParams().put(HttpHeaders.CONTENT_TYPE, "application/json");
request.setBodyParams("sqlQuery", "show schemas");
//如果为非跨源通道,需要指定数据源别名
//request.setBodyParams("source", "customerMysql");
request.setBodyParams("queue", null);
request.setBodyParams("itemFormat", null);
try {
JSONObject response = Poseidon.config(PConfig.init().connectTimeout(0).readTimeout(0).writeTimeout(0).appKey(accessKey).appSecret(secretKey).debug())
.url(url + "/data-federation/v2.0/channels/read/" + chId)
.getResponse(request, JSONObject.class);
System.out.println(response);
} catch (Exception e) {
e.printStackTrace();
}
System.out.println(System.currentTimeMillis());
}
}