/* ===========================================================
* WFDB Java : Interface to WFDB Applications.
*
* ===========================================================
*
* (C) Copyright 2012, by Ikaro Silva
*
* Project Info:
* Code: http://code.google.com/p/wfdb-java/
* WFDB: http://www.physionet.org/physiotools/wfdb.shtml
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*
*
* Original Author: Ikaro Silva
* Contributor(s): -;
*
* Changes
* -------
* Check: http://code.google.com/p/wfdb-java/list
*/
package org.physionet.wfdb.physiobank;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.List;
import java.util.logging.Logger;
public class PhysioNetDB {
private String name;
private String info;
private URL url;
private static final String DB_URL="http://physionet.org/physiobank/database/pbi/";
private static final String DB_LIST="http://physionet.org/physiobank/database/DBS";
private ArrayList<PhysioNetRecord> dbRecordList;
private static Logger logger =
Logger.getLogger(PhysioNetRecord.class.getName());
public PhysioNetDB(String Name){
name=Name;
url=setDBURL();
info=setInfo();
dbRecordList = new ArrayList<PhysioNetRecord>();
}
private PhysioNetDB(String Name,String Info){
name=Name;
info=Info;
url=setDBURL();
dbRecordList = new ArrayList<PhysioNetRecord>();
}
public String getname() {
return name;
}
public ArrayList<PhysioNetRecord> getDBRecordList() throws Exception{
if(dbRecordList.isEmpty()){
this.setDBRecordList();
}
return dbRecordList;
}
public String getinfo() {
return info;
}
public URL getURL() {
return url;
}
public static List<PhysioNetDB> getPhysioNetDBList(){
String inputLine;
BufferedReader in = null;
List<PhysioNetDB> physionetDBList = new ArrayList<PhysioNetDB>();
try {
URL oracle = new URL(DB_LIST);
in = new BufferedReader(
new InputStreamReader(oracle.openStream()));
String[] tmpStr;
String tmpname;
String tmpInfo;
while ((inputLine = in.readLine()) != null){
logger.finest("\n\t***Reading URL: \n\t" + inputLine);
tmpStr=inputLine.split("\\t");
tmpname=tmpStr[0];
tmpInfo=(inputLine.replaceFirst(tmpname,"")).replaceAll("\\t","");
physionetDBList.add(new PhysioNetDB(tmpname,tmpInfo));
}
logger.fine("\n\t*** physionetDBList Size: \n\t" +
physionetDBList.size());
in.close();
} catch (IOException e) {
e.printStackTrace();
}
return physionetDBList;
}
public static HashMap<String,PhysioNetDB> getPhysioNetDBMap(){
String inputLine;
BufferedReader in = null;
HashMap<String,PhysioNetDB> physionetDBMap= new HashMap<String,PhysioNetDB>();
try {
URL oracle = new URL(DB_LIST);
in = new BufferedReader(
new InputStreamReader(oracle.openStream()));
String[] tmpStr;
String tmpname;
String tmpInfo;
while ((inputLine = in.readLine()) != null){
logger.finest("\n\t***Reading URL: \n\t" + inputLine);
tmpStr=inputLine.split("\\t");
tmpname=tmpStr[0];
tmpInfo=(inputLine.replaceFirst(tmpname,"")).replaceAll("\\t","");
physionetDBMap.put(tmpname,new PhysioNetDB(tmpname,tmpInfo));
}
in.close();
logger.fine("\n\t*** physionetDBMap Size: \n\t" +
physionetDBMap.size());
} catch (IOException e) {
e.printStackTrace();
}
return physionetDBMap;
}
public void printDBInfo(){
System.out.println(name);
System.out.println("\tDescription: "+ info);
System.out.println("\tURL: "+ url);
}
public String getDBInfo(){
String str=name + "\n\tDescription: "+ info + "\n\tURL: "+ url;
return str;
}
public void printDBRecordList() throws Exception{
this.getDBRecordList();
this.printDBInfo();
for(PhysioNetRecord rec : dbRecordList){
rec.printRecord();
}
}
public static void printDBList(List<PhysioNetDB> pnDB ) {
// Prints information regarding all databases in pnDB
List<PhysioNetDB> pnDBList = PhysioNetDB.getPhysioNetDBList();
for(PhysioNetDB db : pnDBList){
db.printDBInfo();
}
}
public static void printDBList() {
// Prints information regarding all databases
// Currently available at PhysioNet
List<PhysioNetDB> pnDBList = PhysioNetDB.getPhysioNetDBList();
Collections.sort(pnDBList,PhysioNetDB.DBNameComparator);
for(PhysioNetDB db : pnDBList){
db.printDBInfo();
}
}
private URL setDBURL() {
logger.finer("\n\t***URL Input: \n\t" + name);
try {
URL url=new URL(DB_URL + name.replaceAll("/","_"));
logger.finer("\n\t***Parsed URL: \n\t" + url.toString());
return url;
} catch (MalformedURLException e) {
e.printStackTrace();
return null;
}
}
private String setInfo() {
String inputLine;
BufferedReader in = null;
String desc="";
try {
URL pnb = new URL(DB_LIST);
in = new BufferedReader(
new InputStreamReader(pnb.openStream()));
String[] tmpStr;
while ((inputLine = in.readLine()) != null){
tmpStr=inputLine.split("\\t");
if(tmpStr[0].compareTo(name)==0){
desc=(inputLine.replaceFirst(tmpStr[0],"")).replaceAll("\\t","");
break;
}
}
in.close();
} catch (IOException e) {
e.printStackTrace();
}
return desc;
}
public void setDBRecordList() throws Exception{
String inputLine;
BufferedReader in = null;
String[] tmpStr;
String recname="";
ArrayList<String> recList = null;
logger.finest("\n\t***Getting record list from: \n\t" + url);
try {
in = new BufferedReader(
new InputStreamReader(url.openStream()));
while ((inputLine = in.readLine()) != null){
tmpStr=inputLine.split("\\t");
logger.finest("\n\t***Reading record data: \n\t" + inputLine);
if(tmpStr[0].compareTo(recname) != 0){
//New record, save the last one and
if(!recname.isEmpty()){
dbRecordList.add(new PhysioNetRecord(tmpStr[0]));
}
recname=tmpStr[0];
recList=null;
recList=new ArrayList<String>();
}
// Same, record, append to the signal list
recList.add(new String(inputLine.replaceFirst(recname,"")));
}
in.close();
logger.fine("\n\t***Rec List Size: \n\t" + recList.size());
} catch (IOException e) {
e.printStackTrace();
}
}
public static Comparator<PhysioNetDB> DBNameComparator = new Comparator<PhysioNetDB>() {
public int compare(PhysioNetDB db, PhysioNetDB anotherDB) {
String Name1 = db.getname().toUpperCase();
String Name2 = anotherDB.getname().toUpperCase();
if (!(Name1.equals(Name2)))
return Name1.compareTo(Name2);
else
return Name1.compareTo(Name2);
}
};
public static List<PhysioNetDB> main() {
// Prints information regarding all databases
// Currently available at PhysioNet
return PhysioNetDB.getPhysioNetDBList();
}
}