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