presto(八)——restful api之query

上一篇文章我们提到：SqlQueryManager。他是管理query语句创建、语法解析、查询状态的跟踪。

1、查询语句入口

@Path("/v1/query")
public class QueryResource
{
｝
省略
 @POST
 @Produces(MediaType.APPLICATION_JSON)
 public Response createQuery(
       String statement,
       @Context HttpServletRequest servletRequest,
       @Context UriInfo uriInfo)
       Session session = createSessionForRequest(servletRequest, transactionManager, accessControl, sessionPropertyManager, queryIdGenerator.createNextQueryId());
        //调用SqlQueryManager的createQuery
      QueryInfo queryInfo = queryManager.createQuery(session, statement);
{

也就是说，这一层是基于SqlQueryManager来对外提供接口。
包括提供查询单个query的状态信息也是通过SqlQueryManager来获取。

比较特别的地方就是有一个Session，它到底是干嘛的呢？

2、Session到底是什么货

来看看session的状态：

 private final QueryId queryId;
    private final Optional<TransactionId> transactionId;
    private final boolean clientTransactionSupport;
    private final Identity identity;
    private final Optional<String> source;
    private final Optional<String> catalog;
    private final Optional<String> schema;
    private final TimeZoneKey timeZoneKey;
    private final Locale locale;
    private final Optional<String> remoteUserAddress;
    private final Optional<String> userAgent;
    private final long startTime;
    private final Map<String, String> systemProperties;
    private final Map<ConnectorId, Map<String, String>> connectorProperties;
    private final Map<String, Map<String, String>> unprocessedCatalogProperties;
    private final SessionPropertyManager sessionPropertyManager;
    private final Map<String, String> preparedStatements;

1、每一次创建query查询，都会创建一个新的session。
2、对session进行权限校验
3、保存preparedStatements，比如：

Session session = Session.builder(getSession())
                .addPreparedStatement("my_query", "SELECT * FROM orders where orderkey < ?")
                .build();
        MaterializedResult result = computeActual(session, "EXPLAIN (TYPE LOGICAL) EXECUTE my_query USING 7");
        assertEquals(getOnlyElement(result.getOnlyColumnAsSet()), getExplainPlan("SELECT * FROM orders where orderkey < 7", LOGICAL));

在session期间定义一个preparedStatement，然后可以自行填充带补充的字段。

三、只有协调器节点才有

看CoordinatorModule类中才有一下初始化QueryResource地方：

protected void setup(Binder binder){
   jaxrsBinder(binder).bind(QueryResource.class);

也就是说，只有协调器节点能提交语句，创建session，查询语句状态。