public abstract class JsonService extends AbstractService
Service
that encodes requests and responses as JSON.Service.Base, Service.CatalogsRequest, Service.CloseConnectionRequest, Service.CloseConnectionResponse, Service.CloseStatementRequest, Service.CloseStatementResponse, Service.ColumnsRequest, Service.CommitRequest, Service.CommitResponse, Service.ConnectionSyncRequest, Service.ConnectionSyncResponse, Service.CreateStatementRequest, Service.CreateStatementResponse, Service.DatabasePropertyRequest, Service.DatabasePropertyResponse, Service.ErrorResponse, Service.ExecuteBatchRequest, Service.ExecuteBatchResponse, Service.ExecuteRequest, Service.ExecuteResponse, Service.Factory, Service.FetchRequest, Service.FetchResponse, Service.OpenConnectionRequest, Service.OpenConnectionResponse, Service.PrepareAndExecuteBatchRequest, Service.PrepareAndExecuteRequest, Service.PrepareRequest, Service.PrepareResponse, Service.Request, Service.Response, Service.ResultSetResponse, Service.RollbackRequest, Service.RollbackResponse, Service.RpcMetadataResponse, Service.SchemasRequest, Service.SyncResultsRequest, Service.SyncResultsResponse, Service.TablesRequest, Service.TableTypesRequest, Service.TypeInfoRequest
Modifier and Type | Field and Description |
---|---|
static com.fasterxml.jackson.databind.ObjectMapper |
MAPPER |
Constructor and Description |
---|
JsonService() |
setRpcMetadata
public abstract String apply(String request)
protected static <T> T decode(String response, Class<T> expectedType) throws IOException
IOException
protected static <T> String encode(T request) throws IOException
IOException
protected RuntimeException handle(IOException e)
public Service.ResultSetResponse apply(Service.CatalogsRequest request)
public Service.ResultSetResponse apply(Service.SchemasRequest request)
public Service.ResultSetResponse apply(Service.TablesRequest request)
public Service.ResultSetResponse apply(Service.TableTypesRequest request)
public Service.ResultSetResponse apply(Service.TypeInfoRequest request)
public Service.ResultSetResponse apply(Service.ColumnsRequest request)
public Service.PrepareResponse apply(Service.PrepareRequest request)
public Service.ExecuteResponse apply(Service.PrepareAndExecuteRequest request)
public Service.FetchResponse apply(Service.FetchRequest request)
public Service.ExecuteResponse apply(Service.ExecuteRequest request)
public Service.CreateStatementResponse apply(Service.CreateStatementRequest request)
public Service.CloseStatementResponse apply(Service.CloseStatementRequest request)
public Service.OpenConnectionResponse apply(Service.OpenConnectionRequest request)
public Service.CloseConnectionResponse apply(Service.CloseConnectionRequest request)
public Service.ConnectionSyncResponse apply(Service.ConnectionSyncRequest request)
public Service.DatabasePropertyResponse apply(Service.DatabasePropertyRequest request)
public Service.SyncResultsResponse apply(Service.SyncResultsRequest request)
public Service.CommitResponse apply(Service.CommitRequest request)
public Service.RollbackResponse apply(Service.RollbackRequest request)
public Service.ExecuteBatchResponse apply(Service.PrepareAndExecuteBatchRequest request)
public Service.ExecuteBatchResponse apply(Service.ExecuteBatchRequest request)
Copyright © 2012–2018 The Apache Software Foundation. All rights reserved.