Skip to content

Commit

Permalink
Sync protofiles
Browse files Browse the repository at this point in the history
  • Loading branch information
gartens committed Apr 19, 2024
1 parent 65d6f12 commit 27695b7
Show file tree
Hide file tree
Showing 6 changed files with 0 additions and 102 deletions.
32 changes: 0 additions & 32 deletions src/main/java/org/polypheny/jdbc/PrismInterfaceClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,6 @@
import java.util.stream.Collectors;
import org.polypheny.db.protointerface.proto.ClientInfoProperties;
import org.polypheny.db.protointerface.proto.ClientInfoPropertiesRequest;
import org.polypheny.db.protointerface.proto.ClientInfoPropertyMeta;
import org.polypheny.db.protointerface.proto.ClientInfoPropertyMetaRequest;
import org.polypheny.db.protointerface.proto.CloseResultRequest;
import org.polypheny.db.protointerface.proto.CloseStatementRequest;
import org.polypheny.db.protointerface.proto.CommitRequest;
Expand All @@ -49,9 +47,7 @@
import org.polypheny.db.protointerface.proto.Function;
import org.polypheny.db.protointerface.proto.FunctionsRequest;
import org.polypheny.db.protointerface.proto.IndexedParameters;
import org.polypheny.db.protointerface.proto.LanguageRequest;
import org.polypheny.db.protointerface.proto.Namespace;
import org.polypheny.db.protointerface.proto.NamespaceRequest;
import org.polypheny.db.protointerface.proto.NamespacesRequest;
import org.polypheny.db.protointerface.proto.PrepareStatementRequest;
import org.polypheny.db.protointerface.proto.PreparedStatementSignature;
Expand All @@ -70,8 +66,6 @@
import org.polypheny.db.protointerface.proto.TableTypesRequest;
import org.polypheny.db.protointerface.proto.Type;
import org.polypheny.db.protointerface.proto.TypesRequest;
import org.polypheny.db.protointerface.proto.UserDefinedType;
import org.polypheny.db.protointerface.proto.UserDefinedTypesRequest;
import org.polypheny.jdbc.properties.PolyphenyConnectionProperties;
import org.polypheny.jdbc.transport.PlainTransport;
import org.polypheny.jdbc.transport.Transport;
Expand Down Expand Up @@ -114,12 +108,6 @@ public boolean checkConnection( int timeout ) {
}


public List<String> requestSupportedLanguages( int timeout ) {
LanguageRequest languageRequest = LanguageRequest.newBuilder().build();
throw new RuntimeException( "Not yet implemented" );
}


public ConnectionResponse register( PolyphenyConnectionProperties connectionProperties, int timeout ) throws PrismInterfaceServiceException {
ConnectionRequest.Builder requestBuilder = ConnectionRequest.newBuilder();
Optional.ofNullable( connectionProperties.getUsername() ).ifPresent( requestBuilder::setUsername );
Expand Down Expand Up @@ -286,11 +274,6 @@ public String getDefaultNamespace( int timeout ) throws PrismInterfaceServiceExc
}


public List<ClientInfoPropertyMeta> getClientInfoPropertyMetas( int timeout ) throws PrismInterfaceServiceException {
return rpc.getClientInfoPropertiesMetas( ClientInfoPropertyMetaRequest.newBuilder().build(), timeout ).getClientInfoPropertyMetasList();
}


public List<Type> getTypes( int timeout ) throws PrismInterfaceServiceException {
return rpc.getTypes( TypesRequest.newBuilder().build(), timeout ).getTypesList();
}
Expand Down Expand Up @@ -365,21 +348,6 @@ public List<TableType> getTablesTypes( int timeout ) throws PrismInterfaceServic
}


public Namespace getNamespace( String namespaceName, int timeout ) throws PrismInterfaceServiceException {
NamespaceRequest.Builder requestBuilder = NamespaceRequest.newBuilder();
requestBuilder.setNamespaceName( namespaceName );

throw new RuntimeException( "Not yet implemented" );
}


public List<UserDefinedType> getUserDefinedTypes( int timeout ) throws PrismInterfaceServiceException {
UserDefinedTypesRequest.Builder requestBuilder = UserDefinedTypesRequest.newBuilder();

return rpc.getUserDefinedTypes( requestBuilder.build(), timeout ).getUserDefinedTypesList();
}


public void setClientInfoProperties( Properties properties, int timeout ) throws PrismInterfaceServiceException {
ClientInfoProperties.Builder requestBuilder = ClientInfoProperties.newBuilder();
properties.stringPropertyNames()
Expand Down
17 changes: 0 additions & 17 deletions src/main/java/org/polypheny/jdbc/RpcService.java
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
import org.polypheny.db.protointerface.proto.ClientInfoProperties;
import org.polypheny.db.protointerface.proto.ClientInfoPropertiesRequest;
import org.polypheny.db.protointerface.proto.ClientInfoPropertiesResponse;
import org.polypheny.db.protointerface.proto.ClientInfoPropertyMetaRequest;
import org.polypheny.db.protointerface.proto.ClientInfoPropertyMetaResponse;
import org.polypheny.db.protointerface.proto.CloseResultRequest;
import org.polypheny.db.protointerface.proto.CloseResultResponse;
Expand Down Expand Up @@ -84,8 +83,6 @@
import org.polypheny.db.protointerface.proto.TableTypesResponse;
import org.polypheny.db.protointerface.proto.TypesRequest;
import org.polypheny.db.protointerface.proto.TypesResponse;
import org.polypheny.db.protointerface.proto.UserDefinedTypesRequest;
import org.polypheny.db.protointerface.proto.UserDefinedTypesResponse;
import org.polypheny.jdbc.transport.Transport;
import org.polypheny.jdbc.utils.CallbackQueue;

Expand Down Expand Up @@ -272,27 +269,13 @@ DefaultNamespaceResponse defaultNamespaceRequest( DefaultNamespaceRequest msg, i
}


ClientInfoPropertyMetaResponse getClientInfoPropertiesMetas( ClientInfoPropertyMetaRequest msg, int timeout ) throws PrismInterfaceServiceException {
Request.Builder req = newMessage();
req.setClientInfoPropertyMetaRequest( msg );
return completeSynchronously( req, timeout ).getClientInfoPropertyMetaResponse();
}


TableTypesResponse getTableTypes( TableTypesRequest msg, int timeout ) throws PrismInterfaceServiceException {
Request.Builder req = newMessage();
req.setTableTypesRequest( msg );
return completeSynchronously( req, timeout ).getTableTypesResponse();
}


UserDefinedTypesResponse getUserDefinedTypes( UserDefinedTypesRequest msg, int timeout ) throws PrismInterfaceServiceException {
Request.Builder req = newMessage();
req.setUserDefinedTypesRequest( msg );
return completeSynchronously( req, timeout ).getUserDefinedTypesResponse();
}


TypesResponse getTypes( TypesRequest msg, int timeout ) throws PrismInterfaceServiceException {
Request.Builder req = newMessage();
req.setTypesRequest( msg );
Expand Down
22 changes: 0 additions & 22 deletions src/main/proto/polyprism/meta_requests.proto
Original file line number Diff line number Diff line change
Expand Up @@ -18,13 +18,6 @@ This message does not contain any fields. It simply acts as an indicator to prom
message DbmsVersionRequest {
}

/*
The LanguageRequest message facilitates the retrieval of supported query languages that can be used for constructing statements.
This message does not contain any fields. It acts as a request for the server to return the list of supported query languages in a LanguageResponse.
*/
message LanguageRequest {
}

/* Request the default namespace */
message DefaultNamespaceRequest {
}
Expand All @@ -44,14 +37,6 @@ This message does not contain any fields. It simply prompts the server to return
message TypesRequest {
}

/*
The UserDefinedTypesRequest message facilitates the retrieval of user-defined data types present in the database.
These custom data types can be crafted to meet specific needs not met by standard types.
This message is devoid of fields. It acts as a signal for the server to provide details of user-defined data types in a UserDefinedTypesResponse.
*/
message UserDefinedTypesRequest {
}

/*
The SqlStringFunctionsRequest message is used to solicit information about the string functions supported by the SQL implementation of the DBMS.
This message is field less and prompts the server to return details of the available string functions in an SqlStringFunctionsResponse.
Expand Down Expand Up @@ -111,13 +96,6 @@ It acts as a directive for the server to provide the associated client informati
message ClientInfoPropertiesRequest {
}

/*
The ClientInfoPropertyMetaRequest message aids in extracting metadata about the client information properties present in the database.
This fieldless message prompts the server to detail metadata concerning client information properties in a ClientInfoPropertyMetaResponse.
*/
message ClientInfoPropertyMetaRequest {
}

/*
The FunctionsRequest message is wielded to obtain a list of functions from the database based on the specified query language and function category.
*/
Expand Down
16 changes: 0 additions & 16 deletions src/main/proto/polyprism/meta_responses.proto
Original file line number Diff line number Diff line change
Expand Up @@ -24,14 +24,6 @@ message DbmsVersionResponse {
int32 minor_version = 4;
}

/*
The LanguageResponse message offers a list of query languages supported by the system.
*/
message LanguageResponse {
// A list containing the names of all supported query languages.
repeated string language_names = 1;
}

/* The default namespace */
message DefaultNamespaceResponse {
string default_namespace = 1;
Expand Down Expand Up @@ -87,14 +79,6 @@ message Type {
int32 radix = 10;
}

/*
The UserDefinedTypesResponse message offers a list of user-defined data types present in the system.
*/
message UserDefinedTypesResponse {
// A list of UserDefinedType objects detailing each user-defined data type in the system.
repeated UserDefinedType user_defined_types = 1;
}

/*
The UserDefinedType message encapsulates details about a specific user-defined data type.
*/
Expand Down
8 changes: 0 additions & 8 deletions src/main/proto/polyprism/namespace_meta_requests.proto
Original file line number Diff line number Diff line change
Expand Up @@ -10,14 +10,6 @@ option java_outer_classname = "NamespaceMeta";

package polypheny.protointerface;

/*
The NamespaceRequest message is designed for querying specific details about a specific namespace.
*/
message NamespaceRequest {
// The name of the namespace for which details are being requested.
string namespace_name = 1;
}

/*
The NamespacesRequest message allows querying for namespaces based on specific patterns in their names as well as their types.
*/
Expand Down
7 changes: 0 additions & 7 deletions src/main/proto/polyprism/protointerface.proto
Original file line number Diff line number Diff line change
Expand Up @@ -32,16 +32,12 @@ message Request {
uint64 id = 1;
oneof type {
DbmsVersionRequest dbms_version_request = 2;
LanguageRequest language_request = 3;
DefaultNamespaceRequest default_namespace_request = 4;
TableTypesRequest table_types_request = 5;
TypesRequest types_request = 6;
UserDefinedTypesRequest user_defined_types_request = 7;
ClientInfoPropertyMetaRequest client_info_property_meta_request = 8;
ProceduresRequest procedures_request = 9;
FunctionsRequest functions_request = 10;
NamespacesRequest namespaces_request = 11;
NamespaceRequest namespace_request = 12;
EntitiesRequest entities_request = 13;
SqlStringFunctionsRequest sql_string_functions_request = 14;
SqlSystemFunctionsRequest sql_system_functions_request = 15;
Expand Down Expand Up @@ -88,12 +84,9 @@ message Response {
oneof type {
ErrorResponse error_response = 256;
DbmsVersionResponse dbms_version_response = 3;
LanguageResponse language_response = 4;
DefaultNamespaceResponse default_namespace_response = 24;
TableTypesResponse table_types_response = 5;
TypesResponse types_response = 26;
UserDefinedTypesResponse user_defined_types_response = 6;
ClientInfoPropertyMetaResponse client_info_property_meta_response = 27;
ProceduresResponse procedures_response = 7;
FunctionsResponse functions_response = 29;
NamespacesResponse namespaces_response = 8;
Expand Down

0 comments on commit 27695b7

Please sign in to comment.