Hallo Freunde der Code läuft, das Programm läuft doch nach dem 1667 eintrag meckert er rum und zwar wirft er diese Fehlermeldung aus.
java.lang.IllegalStateException: Content has been consumed
at org.apache.http.entity.BasicHttpEntity.getContent(BasicHttpEntity.java:84)
at org.apache.http.conn.BasicManagedEntity.getContent(BasicManagedEntity.java:89)
at org.ektorp.http.StdHttpResponse.releaseConnection(StdHttpResponse.java:93)
at org.ektorp.http.StdHttpResponse$ConnectionReleasingInputStream.close(StdHttpResponse.java:118)
at sun.nio.cs.StreamDecoder.implClose(Unknown Source)
at sun.nio.cs.StreamDecoder.close(Unknown Source)
at java.io.InputStreamReader.close(Unknown Source)
at java.io.BufferedReader.close(Unknown Source)
at org.ektorp.StreamingViewResult$StreamingViewResultIterator.hasNext(StreamingViewResult.java:100)
at Twitterdb.fink.App.main(App.java:44)
Der Code ist der gleiche hier
Hat jemand wieder vielleicht ein tip???
java.lang.IllegalStateException: Content has been consumed
at org.apache.http.entity.BasicHttpEntity.getContent(BasicHttpEntity.java:84)
at org.apache.http.conn.BasicManagedEntity.getContent(BasicManagedEntity.java:89)
at org.ektorp.http.StdHttpResponse.releaseConnection(StdHttpResponse.java:93)
at org.ektorp.http.StdHttpResponse$ConnectionReleasingInputStream.close(StdHttpResponse.java:118)
at sun.nio.cs.StreamDecoder.implClose(Unknown Source)
at sun.nio.cs.StreamDecoder.close(Unknown Source)
at java.io.InputStreamReader.close(Unknown Source)
at java.io.BufferedReader.close(Unknown Source)
at org.ektorp.StreamingViewResult$StreamingViewResultIterator.hasNext(StreamingViewResult.java:100)
at Twitterdb.fink.App.main(App.java:44)
Der Code ist der gleiche hier
Java:
package Twitterdb.fink;
import java.net.MalformedURLException;
import java.io.FileWriter;
import org.ektorp.CouchDbConnector;
import org.ektorp.CouchDbInstance;
import org.ektorp.StreamingViewResult;
import org.ektorp.ViewQuery;
import org.ektorp.ViewResult.Row;
import org.ektorp.http.HttpClient;
import org.ektorp.http.StdHttpClient;
import org.ektorp.impl.StdCouchDbConnector;
import org.ektorp.impl.StdCouchDbInstance;
import com.opencsv.CSVWriter;
public class App
{
public static void main( String[] args ) throws MalformedURLException
{
HttpClient httpclient = new org.ektorp.http.StdHttpClient.Builder().url("http://localhost:5984").build();
CouchDbInstance dbInstance = new StdCouchDbInstance(httpclient);
CouchDbConnector db = new StdCouchDbConnector("twitterdb",dbInstance);
ViewQuery query = new ViewQuery().designDocId("_design/tweetzahl").viewName("tweetzahl").group(true);
StreamingViewResult data = db.queryForStreamingView(query);
{
try{
CSVWriter writer = new CSVWriter(new FileWriter("C:\\Users\\Sei_Erfolgreich\\Desktop\\Test.csv"));
long counter = 1;
String [] read = new String [] {"UserID","tweetzahl"};
writer.writeNext(read);
//close the writer
writer.flush();
for (Row row : data) {
read = new String[] {row.getKey(),row.getValue()};
writer.writeNext(read);
writer.flush();
System.out.println(counter);
counter++;
}
System.out.println("tamam ya");
data.close();
writer.close();
}catch (Exception e){
e.printStackTrace();
}
}
}
}
Hat jemand wieder vielleicht ein tip???