package compbio.cassandra;
import java.io.BufferedReader;
+import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import compbio.cassandra.JpredParser;
public class JpredParserHTTP implements JpredParser {
- private CassandraCreate cc = new CassandraCreate();
+ private CassandraNativeConnector cc = new CassandraNativeConnector();
private String dirprefix;
JpredParserHTTP() {
dirprefix = newsourceprefix;
}
- public void Parsing(String source, int nDays) {
+ public void Parsing(String source, int nDays) throws IOException {
Calendar cal = Calendar.getInstance();
cal.add(Calendar.DATE, -nDays);
for (int i = 0; i < nDays; ++i) {
int year = cal.get(Calendar.YEAR);
int day = cal.get(Calendar.DATE);
String date = year + "/" + month + "/" + day;
- if (0 < ParsingForDate(source, date)) {
- cc.flushData();
- }
+ ParsingForDate(source, date);
}
}
final FastaSequence fs = fr.next();
if (fs.getId().equals("QUERY") || fs.getId().equals(id))
newprotein = fs.getSequence().replaceAll("\n", "");
- else
+ else if (fs.getId().equals("jnetpred") || fs.getId().equals("JNETPRED")) {
seqs.add(fs);
+ }
}
if (newprotein.equals("")) {
countUnclearFASTAid++;
++countinsertions;
++njobs;
// flush every 50 insertions
- if (0 == countinsertions % 50) {
- cc.flushData();
- njobs -= 50;
- }
+ //if (0 == countinsertions % 50) {
+ // cc.flushData();
+ // njobs -= 50;
+ //}
}
} catch (IOException e) {
e.printStackTrace();