Mercurial > repos > tomnl > mspurity_flagremove
comparison spectralMatching.R @ 11:7e4a5ce0877d draft
planemo upload for repository https://github.com/computational-metabolomics/mspurity-galaxy commit b6b8da66a6eef180ca8e333f98fc4b7575bac7b3
| author | tomnl |
|---|---|
| date | Thu, 27 Jun 2019 12:28:15 -0400 |
| parents | 6bd3ff77063c |
| children | 2c8b5a640a04 |
comparison
equal
deleted
inserted
replaced
| 10:b74303b60450 | 11:7e4a5ce0877d |
|---|---|
| 6 | 6 |
| 7 option_list <- list( | 7 option_list <- list( |
| 8 make_option(c("-o", "--outDir"), type="character"), | 8 make_option(c("-o", "--outDir"), type="character"), |
| 9 make_option("--q_dbPth", type="character"), | 9 make_option("--q_dbPth", type="character"), |
| 10 make_option("--l_dbPth", type="character"), | 10 make_option("--l_dbPth", type="character"), |
| 11 | 11 |
| 12 make_option("--q_msp", type="character", default=NA), | 12 make_option("--q_msp", type="character", default=NA), |
| 13 make_option("--l_msp", type="character", default=NA), | 13 make_option("--l_msp", type="character", default=NA), |
| 14 | 14 |
| 15 make_option("--q_defaultDb", action="store_true"), | 15 make_option("--q_defaultDb", action="store_true"), |
| 16 make_option("--l_defaultDb", action="store_true"), | 16 make_option("--l_defaultDb", action="store_true"), |
| 17 | 17 |
| 18 make_option("--q_ppmPrec", type="double"), | 18 make_option("--q_ppmPrec", type="double"), |
| 19 make_option("--l_ppmPrec", type="double"), | 19 make_option("--l_ppmPrec", type="double"), |
| 20 | 20 |
| 21 make_option("--q_ppmProd", type="double"), | 21 make_option("--q_ppmProd", type="double"), |
| 22 make_option("--l_ppmProd", type="double"), | 22 make_option("--l_ppmProd", type="double"), |
| 23 | 23 |
| 24 make_option("--q_raThres", type="double", default=NA), | 24 make_option("--q_raThres", type="double", default=NA), |
| 25 make_option("--l_raThres", type="double", default=NA), | 25 make_option("--l_raThres", type="double", default=NA), |
| 26 | 26 |
| 27 make_option("--q_polarity", type="character", default=NA), | 27 make_option("--q_polarity", type="character", default=NA), |
| 28 make_option("--l_polarity", type="character", default=NA), | 28 make_option("--l_polarity", type="character", default=NA), |
| 29 | 29 |
| 30 make_option("--q_purity", type="double", default=NA), | 30 make_option("--q_purity", type="double", default=NA), |
| 31 make_option("--l_purity", type="double", default=NA), | 31 make_option("--l_purity", type="double", default=NA), |
| 32 | 32 |
| 33 make_option("--q_xcmsGroups", type="character", default=NA), | 33 make_option("--q_xcmsGroups", type="character", default=NA), |
| 34 make_option("--l_xcmsGroups", type="character", default=NA), | 34 make_option("--l_xcmsGroups", type="character", default=NA), |
| 35 | 35 |
| 36 make_option("--q_pids", type="character", default=NA), | 36 make_option("--q_pids", type="character", default=NA), |
| 37 make_option("--l_pids", type="character", default=NA), | 37 make_option("--l_pids", type="character", default=NA), |
| 38 | 38 |
| 39 make_option("--q_rtrangeMin", type="double", default=NA), | 39 make_option("--q_rtrangeMin", type="double", default=NA), |
| 40 make_option("--l_rtrangeMin", type="double", default=NA), | 40 make_option("--l_rtrangeMin", type="double", default=NA), |
| 41 | 41 |
| 42 make_option("--q_rtrangeMax", type="double", default=NA), | 42 make_option("--q_rtrangeMax", type="double", default=NA), |
| 43 make_option("--l_rtrangeMax", type="double", default=NA), | 43 make_option("--l_rtrangeMax", type="double", default=NA), |
| 44 | 44 |
| 45 make_option("--q_accessions", type="character", default=NA), | 45 make_option("--q_accessions", type="character", default=NA), |
| 46 make_option("--l_accessions", type="character", default=NA), | 46 make_option("--l_accessions", type="character", default=NA), |
| 47 | 47 |
| 48 make_option("--q_sources", type="character", default=NA), | 48 make_option("--q_sources", type="character", default=NA), |
| 49 make_option("--l_sources", type="character", default=NA), | 49 make_option("--l_sources", type="character", default=NA), |
| 50 | 50 |
| 51 make_option("--q_sourcesUser", type="character", default=NA), | 51 make_option("--q_sourcesUser", type="character", default=NA), |
| 52 make_option("--l_sourcesUser", type="character", default=NA), | 52 make_option("--l_sourcesUser", type="character", default=NA), |
| 53 | 53 |
| 54 make_option("--q_instrumentTypes", type="character", default=NA), | 54 make_option("--q_instrumentTypes", type="character", default=NA), |
| 55 make_option("--l_instrumentTypes", type="character", default=NA), | 55 make_option("--l_instrumentTypes", type="character", default=NA), |
| 56 | 56 |
| 57 make_option("--q_instrumentTypesUser", type="character", default=NA), | 57 make_option("--q_instrumentTypesUser", type="character", default=NA), |
| 58 make_option("--l_instrumentTypesUser", type="character", default=NA), | 58 make_option("--l_instrumentTypesUser", type="character", default=NA), |
| 59 | 59 |
| 60 make_option("--q_instruments", type="character", default=NA), | 60 make_option("--q_instruments", type="character", default=NA), |
| 61 make_option("--l_instruments", type="character", default=NA), | 61 make_option("--l_instruments", type="character", default=NA), |
| 62 | 62 |
| 63 make_option("--q_spectraTypes", type="character", default=NA), | 63 make_option("--q_spectraTypes", type="character", default=NA), |
| 64 make_option("--l_spectraTypes", type="character", default=NA), | 64 make_option("--l_spectraTypes", type="character", default=NA), |
| 65 | 65 |
| 66 make_option("--q_spectraFilter", action="store_true"), | 66 make_option("--q_spectraFilter", action="store_true"), |
| 67 make_option("--l_spectraFilter", action="store_true"), | 67 make_option("--l_spectraFilter", action="store_true"), |
| 68 | 68 |
| 69 make_option("--usePrecursors", action="store_true"), | 69 make_option("--usePrecursors", action="store_true"), |
| 70 | 70 |
| 71 make_option("--mzW", type="double"), | 71 make_option("--mzW", type="double"), |
| 72 make_option("--raW", type="double"), | 72 make_option("--raW", type="double"), |
| 73 | 73 |
| 74 make_option("--rttol", type="double", default=NA), | 74 make_option("--rttol", type="double", default=NA), |
| 75 | 75 |
| 76 make_option("--updateDb", action="store_true"), | 76 make_option("--updateDb", action="store_true"), |
| 77 make_option("--copyDb", action="store_true"), | 77 make_option("--copyDb", action="store_true"), |
| 78 make_option("--cores", default=1) | 78 make_option("--cores", default=1) |
| 79 | 79 |
| 80 | 80 |
| 81 ) | 81 ) |
| 82 | 82 |
| 83 # store options | 83 # store options |
| 84 opt<- parse_args(OptionParser(option_list=option_list)) | 84 opt<- parse_args(OptionParser(option_list=option_list)) |
| 85 | 85 |
| 91 param <- param[param != ""] | 91 param <- param[param != ""] |
| 92 }else{ | 92 }else{ |
| 93 param <- NA | 93 param <- NA |
| 94 } | 94 } |
| 95 return(param) | 95 return(param) |
| 96 | 96 |
| 97 } | 97 } |
| 98 | 98 |
| 99 if(!is.null(opt$q_defaultDb)){ | 99 if(!is.null(opt$q_defaultDb)){ |
| 100 q_dbPth <- system.file("extdata", "library_spectra", "library_spectra.db", package="msPurityData") | 100 q_dbPth <- system.file("extdata", "library_spectra", "library_spectra.db", package="msPurityData") |
| 101 }else if (!is.null(opt$q_dbPth)){ | 101 }else if (!is.null(opt$q_dbPth)){ |
| 190 | 190 |
| 191 | 191 |
| 192 | 192 |
| 193 sm <- msPurity::spectralMatching(q_dbPth = q_dbPth, | 193 sm <- msPurity::spectralMatching(q_dbPth = q_dbPth, |
| 194 l_dbPth = l_dbPth, | 194 l_dbPth = l_dbPth, |
| 195 | 195 |
| 196 q_purity = opt$q_purity, | 196 q_purity = opt$q_purity, |
| 197 l_purity = opt$l_purity, | 197 l_purity = opt$l_purity, |
| 198 | 198 |
| 199 q_ppmProd = opt$q_ppmProd, | 199 q_ppmProd = opt$q_ppmProd, |
| 200 l_ppmProd = opt$l_ppmProd, | 200 l_ppmProd = opt$l_ppmProd, |
| 201 | 201 |
| 202 q_ppmPrec = opt$q_ppmPrec, | 202 q_ppmPrec = opt$q_ppmPrec, |
| 203 l_ppmPrec = opt$l_ppmPrec, | 203 l_ppmPrec = opt$l_ppmPrec, |
| 204 | 204 |
| 205 q_raThres = opt$q_raThres, | 205 q_raThres = opt$q_raThres, |
| 206 l_raThres = opt$l_raThres, | 206 l_raThres = opt$l_raThres, |
| 207 | 207 |
| 208 q_pol = q_polarity, | 208 q_pol = q_polarity, |
| 209 l_pol = l_polarity, | 209 l_pol = l_polarity, |
| 210 | 210 |
| 211 q_xcmsGroups = q_xcmsGroups, | 211 q_xcmsGroups = q_xcmsGroups, |
| 212 l_xcmsGroups = l_xcmsGroups, | 212 l_xcmsGroups = l_xcmsGroups, |
| 213 | 213 |
| 214 q_pids = q_pids, | 214 q_pids = q_pids, |
| 215 l_pids = l_pids, | 215 l_pids = l_pids, |
| 216 | 216 |
| 217 q_sources = q_sources, | 217 q_sources = q_sources, |
| 218 l_sources = l_sources, | 218 l_sources = l_sources, |
| 219 | 219 |
| 220 q_instrumentTypes = q_instrumentTypes, | 220 q_instrumentTypes = q_instrumentTypes, |
| 221 l_instrumentTypes = l_instrumentTypes, | 221 l_instrumentTypes = l_instrumentTypes, |
| 222 | 222 |
| 223 q_spectraFilter= q_spectraFilter, | 223 q_spectraFilter= q_spectraFilter, |
| 224 l_spectraFilter= l_spectraFilter, | 224 l_spectraFilter= l_spectraFilter, |
| 225 | 225 |
| 226 l_rtrange=c(l_rtrangeMin, l_rtrangeMax), | 226 l_rtrange=c(l_rtrangeMin, l_rtrangeMax), |
| 227 q_rtrange=c(q_rtrangeMin, q_rtrangeMax), | 227 q_rtrange=c(q_rtrangeMin, q_rtrangeMax), |
| 228 | 228 |
| 229 q_accessions = opt$q_accessions, | 229 q_accessions = opt$q_accessions, |
| 230 l_accessions= opt$l_accessions, | 230 l_accessions= opt$l_accessions, |
| 231 | 231 |
| 232 raW = opt$raW, | 232 raW = opt$raW, |
| 233 mzW = opt$mzW, | 233 mzW = opt$mzW, |
| 234 rttol=opt$rttol, | 234 rttol=opt$rttol, |
| 235 cores=opt$cores, | 235 cores=opt$cores, |
| 236 | 236 |
| 237 copyDb=copyDb, | 237 copyDb=copyDb, |
| 238 updateDb=updateDb, | 238 updateDb=updateDb, |
| 239 outPth = "db_with_spectral_matching.sqlite" | 239 outPth = "db_with_spectral_matching.sqlite" |
| 240 ) | 240 ) |
| 241 | 241 |
| 252 q_con <- DBI::dbConnect(RSQLite::SQLite(),sm$q_dbPth) | 252 q_con <- DBI::dbConnect(RSQLite::SQLite(),sm$q_dbPth) |
| 253 if (DBI::dbExistsTable(q_con, "l_s_peak_meta")){ | 253 if (DBI::dbExistsTable(q_con, "l_s_peak_meta")){ |
| 254 l_s_peak_meta <- DBI::dbGetQuery(q_con, 'SELECT * FROM l_s_peak_meta') | 254 l_s_peak_meta <- DBI::dbGetQuery(q_con, 'SELECT * FROM l_s_peak_meta') |
| 255 colnames(l_s_peak_meta)[1] <- 'pid' | 255 colnames(l_s_peak_meta)[1] <- 'pid' |
| 256 } | 256 } |
| 257 | 257 |
| 258 l_con <- DBI::dbConnect(RSQLite::SQLite(),l_dbPth) | 258 l_con <- DBI::dbConnect(RSQLite::SQLite(),l_dbPth) |
| 259 if (DBI::dbExistsTable(q_con, "s_peaks")){ | 259 if (DBI::dbExistsTable(l_con, "s_peaks")){ |
| 260 l_s_peaks <- DBI::dbGetQuery(q_con, sprintf("SELECT * FROM s_peaks WHERE pid in (%s)", paste(unique(l_s_peak_meta$pid), collapse=','))) | 260 l_s_peaks <- DBI::dbGetQuery(q_con, sprintf("SELECT * FROM s_peaks WHERE pid in (%s)", paste(unique(l_s_peak_meta$pid), collapse=','))) |
| 261 | 261 |
| 262 }else if(DBI::dbExistsTable(q_con, "library_spectra")){ | 262 }else if(DBI::dbExistsTable(l_con, "library_spectra")){ |
| 263 l_s_peaks <- DBI::dbGetQuery(q_con, sprintf("SELECT * FROM library_spectra | 263 l_s_peaks <- DBI::dbGetQuery(l_con, sprintf("SELECT * FROM library_spectra |
| 264 WHERE library_spectra_meta_id in (%s)", paste(unique(l_s_peak_meta$pid), collapse=','))) | 264 WHERE library_spectra_meta_id in (%s)", paste(unique(l_s_peak_meta$pid), collapse=','))) |
| 265 }else{ | 265 }else{ |
| 266 l_s_peaks = NULL | 266 l_s_peaks = NULL |
| 267 } | 267 } |
| 268 | 268 |
| 269 if (DBI::dbExistsTable(q_con, "source")){ | 269 if (DBI::dbExistsTable(l_con, "source")){ |
| 270 l_source <- DBI::dbGetQuery(q_con, 'SELECT * FROM source') | 270 l_source <- DBI::dbGetQuery(l_con, 'SELECT * FROM source') |
| 271 }else if (DBI::dbExistsTable(q_con, "library_spectra_source")) { | 271 }else if (DBI::dbExistsTable(l_con, "library_spectra_source")) { |
| 272 l_source <- DBI::dbGetQuery(q_con, 'library_spectra_source') | 272 l_source <- DBI::dbGetQuery(l_con, 'SELECT * FROM library_spectra_source') |
| 273 }else{ | 273 }else{ |
| 274 l_source = NULL | 274 l_source = NULL |
| 275 } | 275 } |
| 276 | 276 |
| 277 if (!is.null(l_s_peaks)){ | 277 if (!is.null(l_s_peaks)){ |
| 278 DBI::dbWriteTable(q_con, name='l_s_peaks', value=l_s_peaks, row.names=FALSE, append=TRUE) | 278 DBI::dbWriteTable(q_con, name='l_s_peaks', value=l_s_peaks, row.names=FALSE, append=TRUE) |
| 279 } | 279 } |
| 280 | 280 |
| 281 if (!is.null(l_source)){ | 281 if (!is.null(l_source)){ |
| 282 DBI::dbWriteTable(q_con, name='l_source', value=l_source, row.names=FALSE, append=TRUE) | 282 DBI::dbWriteTable(q_con, name='l_source', value=l_source, row.names=FALSE, append=TRUE) |
| 283 } | 283 } |
| 284 | 284 |
| 285 } | 285 } |
| 286 | 286 |
| 287 | 287 |
| 288 | 288 |
| 289 | 289 |
| 290 | 290 |
