Hi,
I am trying to write a data service inserting, deleting and updating the
following CF.
CREATE COLUMNFAMILY TestMeta (key varchar PRIMARY KEY, id varchar,
CreateTime bigint, UpdateTime bigint, name varchar);
CREATE INDEX TestMeta_index_id ON TestMeta (id);
CREATE INDEX TestMeta_index_name ON TestMeta (name);
Data service queries are the following
<?xml version="1.0" encoding="UTF-8"?>
<data name="SyncShareServices" serviceGroup=""
serviceNamespace="http://ws.ardictech.com/dataservice";>
<config id="Test">
<property
name="org.wso2.ws.dataservice.protocol">jdbc:cassandra://testhost:9160/TEST</property>
<property
name="org.wso2.ws.dataservice.driver">org.apache.cassandra.cql.jdbc.CassandraDriver</property>
</config>
<query id="qryInsertTestMeta" useConfig="Test">
<sql>INSERT INTO TestMeta (KEY,id,CreateTime,UpdateTime,name,owner,vfs)
values (?,?,?,?,?)</sql>
<param name="KEY" ordinal="1" sqlType="STRING" type=""/>
<param name="id" ordinal="2" sqlType="STRING" type=""/>
<param name="CreateTime" ordinal="3" sqlType="BIGINT" type=""/>
<param name="UpdateTime" ordinal="4" sqlType="BIGINT" type=""/>
<param name="name" ordinal="5" sqlType="STRING" type=""/>
</query>
<query id="qryDeleteTestMeta" useConfig="Test">
<sql>DELETE FROM TestMeta where KEY = ?</sql>
<param name="KEY" ordinal="1" sqlType="STRING" type=""/>
</query>
<query id="qryGetTestMeta" useConfig="Test">
<sql>SELECT id,CreateTime,UpdateTime,name from TestMeta where id = ?</sql>
<param name="id" ordinal="1" sqlType="STRING" type=""/>
<result defaultNamespace="" element="resources" rowName="resource">
<attribute column="id" name="id" xsdType="xs:string"/>
<attribute column="CreateTime" name="CreateTime" xsdType="xs:long"/>
<attribute column="UpdateTime" name="UpdateTime" xsdType="xs:long"/>
<attribute column="name" name="name" xsdType="xs:string"/>
</result>
</query>
For get and other operations i have the following exception in the dss
(version stratos 1.5.3)
org.apache.axis2.AxisFault: DS Fault Message: Error in
'SQLQuery.processNormalQuery'
DS Code: DATABASE_ERROR
Source Data Service:-
Name: SyncShareServices
Location: /SyncShareTest.dbs
Description: N/A
Default Namespace: http://ws.ardictech.com/dataservice
Current Request Name: optGetSSMeta
Current Params: {id=testid}
Nested Exception:-
java.sql.SQLNonTransientConnectionException: java.net.SocketException:
Broken pipe
at org.apache.axis2.AxisFault.makeFault(AxisFault.java:430)
at
org.apache.axis2.transport.http.SOAPMessageFormatter.writeTo(SOAPMessageFormatter.java:78)
at
org.apache.axis2.transport.http.CommonsHTTPTransportSender.sendUsingOutputStream(CommonsHTTPTransportSender.java:409)
at
org.apache.axis2.transport.http.CommonsHTTPTransportSender.invoke(CommonsHTTPTransportSender.java:286)
at org.apache.axis2.engine.AxisEngine.send(AxisEngine.java:443)
at
org.apache.axis2.receivers.AbstractInOutSyncMessageReceiver.invokeBusinessLogic(AbstractInOutSyncMessageReceiver.java:45)
at
org.apache.axis2.receivers.AbstractMessageReceiver.receive(AbstractMessageReceiver.java:110)
at org.apache.axis2.engine.AxisEngine.receive(AxisEngine.java:181)
at
org.apache.axis2.transport.http.HTTPTransportUtils.processHTTPPostRequest(HTTPTransportUtils.java:172)
at
org.apache.axis2.transport.http.AxisServlet.doPost(AxisServlet.java:146)
at
org.wso2.carbon.core.transports.CarbonServlet.doPost(CarbonServlet.java:199)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:641)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
at
org.eclipse.equinox.http.servlet.internal.ServletRegistration.handleRequest(ServletRegistration.java:90)
at
org.eclipse.equinox.http.servlet.internal.ProxyServlet.processAlias(ProxyServlet.java:111)
at
org.eclipse.equinox.http.servlet.internal.ProxyServlet.service(ProxyServlet.java:67)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
at org.wso2.carbon.bridge.BridgeServlet.service(BridgeServlet.java:164)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
at sun.reflect.GeneratedMethodAccessor26.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at
org.apache.catalina.security.SecurityUtil$1.run(SecurityUtil.java:273)
at
org.apache.catalina.security.SecurityUtil$1.run(SecurityUtil.java:270)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAsPrivileged(Subject.java:517)
at
org.apache.catalina.security.SecurityUtil.execute(SecurityUtil.java:305)
at
org.apache.catalina.security.SecurityUtil.doAsPrivilege(SecurityUtil.java:165)
at
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:298)
at
org.apache.catalina.core.ApplicationFilterChain.access$000(ApplicationFilterChain.java:57)
at
org.apache.catalina.core.ApplicationFilterChain$1.run(ApplicationFilterChain.java:193)
at
org.apache.catalina.core.ApplicationFilterChain$1.run(ApplicationFilterChain.java:189)
at java.security.AccessController.doPrivileged(Native Method)
at
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:188)
at
org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:240)
at
org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:164)
at
org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:462)
at
org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:164)
at
org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:100)
at
org.wso2.carbon.server.CarbonStuckThreadDetectionValve.invoke(CarbonStuckThreadDetectionValve.java:154)
at org.wso2.carbon.server.TomcatServer$1.invoke(TomcatServer.java:254)
at
org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:563)
at
org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
at
org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:399)
at
org.apache.coyote.http11.Http11NioProcessor.process(Http11NioProcessor.java:396)
at
org.apache.coyote.http11.Http11NioProtocol$Http11ConnectionHandler.process(Http11NioProtocol.java:356)
at
org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.run(NioEndpoint.java:1534)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
Caused by: javax.xml.stream.XMLStreamException: DS Fault Message: Error
in 'SQLQuery.processNormalQuery'
DS Code: DATABASE_ERROR
Source Data Service:-
Name: SyncShareServices
Location: /SyncShareTest.dbs
Description: N/A
Default Namespace: http://ws.ardictech.com/dataservice
Current Request Name: optGetSSMeta
Current Params: {id=testid}
Nested Exception:-
java.sql.SQLNonTransientConnectionException: java.net.SocketException:
Broken pipe
at
org.wso2.carbon.dataservices.core.engine.DSOMDataSource.execute(DSOMDataSource.java:105)
at
org.wso2.carbon.dataservices.core.engine.DSOMDataSource.serialize(DSOMDataSource.java:110)
at
org.apache.axiom.om.impl.llom.OMSourcedElementImpl.internalSerialize(OMSourcedElementImpl.java:691)
at
org.apache.axiom.om.impl.util.OMSerializerUtil.serializeChildren(OMSerializerUtil.java:563)
at
org.apache.axiom.om.impl.llom.OMElementImpl.internalSerialize(OMElementImpl.java:875)
at
org.apache.axiom.soap.impl.llom.SOAPEnvelopeImpl.serializeInternally(SOAPEnvelopeImpl.java:283)
at
org.apache.axiom.soap.impl.llom.SOAPEnvelopeImpl.internalSerialize(SOAPEnvelopeImpl.java:245)
at
org.apache.axiom.om.impl.llom.OMSerializableImpl.serializeAndConsume(OMSerializableImpl.java:193)
at
org.apache.axis2.transport.http.SOAPMessageFormatter.writeTo(SOAPMessageFormatter.java:74)
... 48 more
What causes the broken pipe error? As i know while configuring data
serive dss tries to connect to mentioned host in the configuration tag
and there is no problem with the connection and i can run the queries
just fine from the server.
Thanks
_______________________________________________
User mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/user
