2 * Jalview - A Sequence Alignment Editor and Viewer ($$Version-Rel$$)
3 * Copyright (C) $$Year-Rel$$ The Jalview Authors
5 * This file is part of Jalview.
7 * Jalview is free software: you can redistribute it and/or
8 * modify it under the terms of the GNU General Public License
9 * as published by the Free Software Foundation, either version 3
10 * of the License, or (at your option) any later version.
12 * Jalview is distributed in the hope that it will be useful, but
13 * WITHOUT ANY WARRANTY; without even the implied warranty
14 * of MERCHANTABILITY or FITNESS FOR A PARTICULAR
15 * PURPOSE. See the GNU General Public License for more details.
17 * You should have received a copy of the GNU General Public License
18 * along with Jalview. If not, see <http://www.gnu.org/licenses/>.
19 * The Jalview Authors are detailed in the 'AUTHORS' file.
21 package jalview.ws.seqfetcher;
23 import jalview.bin.Cache;
24 import jalview.datamodel.AlignmentI;
25 import jalview.datamodel.DBRefEntry;
26 import jalview.datamodel.SequenceI;
27 import jalview.util.DBRefUtils;
28 import jalview.util.MessageManager;
29 import jalview.util.QuickSort;
31 import java.util.ArrayList;
32 import java.util.Enumeration;
33 import java.util.HashSet;
34 import java.util.Hashtable;
35 import java.util.Iterator;
36 import java.util.List;
38 import java.util.Stack;
39 import java.util.Vector;
41 public class ASequenceFetcher
45 * set of databases we can retrieve entries from
47 protected Hashtable<String, Map<String, DbSourceProxy>> FETCHABLEDBS;
49 public ASequenceFetcher()
55 * get list of supported Databases
57 * @return database source string for each database - only the latest version
58 * of a source db is bound to each source.
60 public String[] getSupportedDb()
62 if (FETCHABLEDBS == null)
66 String[] sf = new String[FETCHABLEDBS.size()];
67 Enumeration<String> e = FETCHABLEDBS.keys();
69 while (e.hasMoreElements())
71 sf[i++] = e.nextElement();
77 public boolean isFetchable(String source)
79 Enumeration<String> e = FETCHABLEDBS.keys();
80 while (e.hasMoreElements())
82 String db = e.nextElement();
83 if (source.compareToIgnoreCase(db) == 0)
88 Cache.log.warn("isFetchable doesn't know about '" + source
93 public SequenceI[] getSequences(DBRefEntry[] refs)
95 SequenceI[] ret = null;
96 Vector<SequenceI> rseqs = new Vector<SequenceI>();
97 Hashtable<String, List<String>> queries = new Hashtable<String, List<String>>();
98 for (int r = 0; r < refs.length; r++)
100 if (!queries.containsKey(refs[r].getSource()))
102 queries.put(refs[r].getSource(), new ArrayList<String>());
104 List<String> qset = queries.get(refs[r].getSource());
105 if (!qset.contains(refs[r].getAccessionId()))
107 qset.add(refs[r].getAccessionId());
110 Enumeration<String> e = queries.keys();
111 while (e.hasMoreElements())
113 List<String> query = null;
115 db = e.nextElement();
116 query = queries.get(db);
117 if (!isFetchable(db))
119 reportStdError(db, query, new Exception(
120 "Don't know how to fetch from this database :" + db));
123 Iterator<DbSourceProxy> fetchers = getSourceProxy(db).iterator();
124 Stack<String> queriesLeft = new Stack<String>();
125 // List<String> queriesFailed = new ArrayList<String>();
126 queriesLeft.addAll(query);
127 while (fetchers.hasNext())
129 List<String> queriesMade = new ArrayList<String>();
130 HashSet<String> queriesFound = new HashSet<String>();
133 DbSourceProxy fetcher = fetchers.next();
134 boolean doMultiple = fetcher.getAccessionSeparator() != null;
135 // No separator - no Multiple Queries
136 while (!queriesLeft.isEmpty())
138 StringBuffer qsb = new StringBuffer();
141 if (qsb.length() > 0)
143 qsb.append(fetcher.getAccessionSeparator());
145 String q = queriesLeft.pop();
148 } while (doMultiple && !queriesLeft.isEmpty());
150 AlignmentI seqset = null;
153 // create a fetcher and go to it
154 seqset = fetcher.getSequenceRecords(qsb.toString()); // ,
156 } catch (Exception ex)
158 System.err.println("Failed to retrieve the following from "
160 System.err.println(qsb);
161 ex.printStackTrace(System.err);
163 // TODO: Merge alignment together - perhaps
166 SequenceI seqs[] = seqset.getSequencesArray();
169 for (int is = 0; is < seqs.length; is++)
171 rseqs.addElement(seqs[is]);
172 DBRefEntry[] frefs = DBRefUtils.searchRefs(seqs[is]
173 .getDBRef(), new DBRefEntry(db, null, null));
176 for (DBRefEntry dbr : frefs)
178 queriesFound.add(dbr.getAccessionId());
179 queriesMade.remove(dbr.getAccessionId());
187 if (fetcher.getRawRecords() != null)
189 System.out.println("# Retrieved from " + db + ":"
191 StringBuffer rrb = fetcher.getRawRecords();
193 * for (int rr = 0; rr<rrb.length; rr++) {
198 hdr = "# " + db + ":" + qsb.toString();
200 * } else { hdr = "# part "+rr; }
202 System.out.println(hdr);
205 System.out.println(rrb);
207 System.out.println("# end of " + hdr);
214 } catch (Exception ex)
216 reportStdError(db, queriesMade, ex);
218 if (queriesMade.size() > 0)
220 System.out.println("# Adding " + queriesMade.size()
221 + " ids back to queries list for searching again (" + db
223 queriesLeft.addAll(queriesMade);
227 if (rseqs.size() > 0)
229 ret = new SequenceI[rseqs.size()];
230 Enumeration<SequenceI> sqs = rseqs.elements();
232 while (sqs.hasMoreElements())
234 SequenceI s = sqs.nextElement();
242 public void reportStdError(String db, List<String> queriesMade,
246 System.err.println("Failed to retrieve the following references from "
249 for (String qv : queriesMade)
251 System.err.print(" " + qv + ";");
254 System.err.println();
258 System.err.println();
259 ex.printStackTrace();
263 * Retrieve an instance of the proxy for the given source
266 * database source string TODO: add version string/wildcard for
267 * retrieval of specific DB source/version combinations.
268 * @return an instance of DbSourceProxy for that db.
270 public List<DbSourceProxy> getSourceProxy(String db)
272 List<DbSourceProxy> dbs;
273 Map<String, DbSourceProxy> dblist = FETCHABLEDBS.get(db);
276 return new ArrayList<DbSourceProxy>();
279 if (dblist.size() > 1)
281 DbSourceProxy[] l = dblist.values().toArray(new DbSourceProxy[0]);
283 String[] nm = new String[l.length];
284 // make sure standard dbs appear first, followed by reference das sources,
285 // followed by anything else.
286 for (DbSourceProxy s : l)
288 nm[i++] = "" + s.getTier() + s.getDbName().toLowerCase();
290 QuickSort.sort(nm, l);
291 dbs = new ArrayList<DbSourceProxy>();
292 for (i = l.length - 1; i >= 0; i--)
299 dbs = new ArrayList<DbSourceProxy>(dblist.values());
305 * constructs an instance of the proxy and registers it as a valid dbrefsource
307 * @param dbSourceProxy
308 * reference for class implementing
309 * jalview.ws.seqfetcher.DbSourceProxy
311 protected void addDBRefSourceImpl(
312 Class<? extends DbSourceProxy> dbSourceProxy)
313 throws IllegalArgumentException
315 DbSourceProxy proxy = null;
318 DbSourceProxy proxyObj = dbSourceProxy.getConstructor().newInstance();
320 } catch (IllegalArgumentException e)
323 } catch (Exception e)
325 // Serious problems if this happens.
328 .getString("error.dbrefsource_implementation_exception"),
331 addDbRefSourceImpl(proxy);
335 * add the properly initialised DbSourceProxy object 'proxy' to the list of
340 protected void addDbRefSourceImpl(DbSourceProxy proxy)
344 if (FETCHABLEDBS == null)
346 FETCHABLEDBS = new Hashtable<String, Map<String, DbSourceProxy>>();
348 Map<String, DbSourceProxy> slist = FETCHABLEDBS.get(proxy
352 FETCHABLEDBS.put(proxy.getDbSource(),
353 slist = new Hashtable<String, DbSourceProxy>());
355 slist.put(proxy.getDbName(), proxy);
360 * select sources which are implemented by instances of the given class
362 * @param class that implements DbSourceProxy
363 * @return null or vector of source names for fetchers
365 public String[] getDbInstances(Class class1)
367 if (!DbSourceProxy.class.isAssignableFrom(class1))
372 "error.implementation_error_dbinstance_must_implement_interface",
373 new String[] { class1.toString() }));
375 if (FETCHABLEDBS == null)
379 String[] sources = null;
380 Vector<String> src = new Vector<String>();
381 Enumeration<String> dbs = FETCHABLEDBS.keys();
382 while (dbs.hasMoreElements())
384 String dbn = dbs.nextElement();
385 for (DbSourceProxy dbp : FETCHABLEDBS.get(dbn).values())
387 if (class1.isAssignableFrom(dbp.getClass()))
395 src.copyInto(sources = new String[src.size()]);
400 public DbSourceProxy[] getDbSourceProxyInstances(Class class1)
402 List<DbSourceProxy> prlist = new ArrayList<DbSourceProxy>();
403 for (String fetchable : getSupportedDb())
405 for (DbSourceProxy pr : getSourceProxy(fetchable))
407 if (class1.isInstance(pr))
413 if (prlist.size() == 0)
417 return prlist.toArray(new DbSourceProxy[0]);