ExecuteQuery in interoperability

Author: eduard93

isc/py/ens/Operation.cls

@@ -21,6 +21,9 @@ XData MessageMap
   <MapItem MessageType="isc.py.msg.RestoreRequest">
     <Method>RestoreContext</Method>
   </MapItem>
+  <MapItem MessageType="isc.py.msg.QueryRequest">
+    <Method>ExecuteQuery</Method>
+  </MapItem>
 </MapItems>
 }
 
@@ -77,6 +80,15 @@ Method StreamExecute(request As isc.py.msg.StreamExecutionRequest, Output respon
 	quit sc
 }
 
+/// Create pandas dataframe or list form sql.
+Method ExecuteQuery(request As isc.py.msg.QueryRequest, Output response As Ens.Response) As %Status
+{
+	#dim sc As %Status = $$$OK
+	set response = ##class(Ens.Response).%New()	
+	set sc = ##class(isc.py.Main).ExecuteQuery(request.Query, request.Variable, request.Type)
+	quit sc
+}
+
 /// Save context
 Method SaveContext(request As isc.py.msg.SaveRequest, Output response As Ens.StringResponse) As %Status
 {

isc/py/msg/QueryRequest.cls

@@ -0,0 +1,27 @@
+/// Create pandas dataframe or list form sql.
+Class isc.py.msg.QueryRequest Extends Ens.Request
+{
+
+Property Query As %VarString;
+
+Property Variable As %String;
+
+Property Type As %String(VALUELIST = ",dataframe,list") [ InitialExpression = "list" ];
+
+Storage Default
+{
+<Data name="QueryRequestDefaultData">
+<Subscript>"QueryRequest"</Subscript>
+<Value name="1">
+<Value>Query</Value>
+</Value>
+<Value name="2">
+<Value>Variable</Value>
+</Value>
+</Data>
+<DefaultData>QueryRequestDefaultData</DefaultData>
+<Type>%Library.CacheStorage</Type>
+}
+
+}
+