pkg/trunk/R/db.R

   1
   2 db.start <- function() {
   3     drv <- dbDriver('SQLite')
   4     con <- dbConnect(drv, dbname=file.path(root,'data/cran2deb.db'))
   5     tables <- dbListTables(con)
   6     if (!dbExistsTable(con,'sysreq_override')) {
   7         dbGetQuery(con,paste('CREATE TABLE sysreq_override ('
   8                   ,' debian_name TEXT NOT NULL'
   9                   ,',r_pattern TEXT PRIMARY KEY NOT NULL'
  10                   ,')'))
  11     }
  12     if (!dbExistsTable(con,'license_override')) {
  13         dbGetQuery(con,paste('CREATE TABLE license_override ('
  14                   ,' name TEXT PRIMARY KEY NOT NULL'
  15                   ,',accept INT NOT NULL'
  16                   ,')'))
  17     }
  18     if (!dbExistsTable(con,'license_files')) {
  19         dbGetQuery(con,paste('CREATE TABLE license_files ('
  20                   ,' name TEXT NOT NULL'
  21                   ,',file_sha1 TEXT PRIMARY KEY NOT NULL'
  22                   ,')'))
  23     }
  24     return(con)
  25 }
  26
  27 db.stop <- function(con) {
  28     dbDisconnect(con)
  29 }
  30
  31 db.quote <- function(text) {
  32     return(paste('"',gsub('([^][[:alnum:]*?. ()<>:/=+-])','\\\\\\1',text),'"',sep=''))
  33 }
  34
  35 db.sysreq.override <- function(sysreq_text) {
  36     sysreq_text <- tolower(sysreq_text)
  37     con <- db.start()
  38     results <- dbGetQuery(con,paste(
  39                     'SELECT debian_name FROM sysreq_override WHERE'
  40                             ,db.quote(sysreq_text),'GLOB r_pattern'))
  41     db.stop(con)
  42     if (length(results) == 0) {
  43         return(NA)
  44     }
  45     return(results$debian_name)
  46 }
  47
  48 db.add.sysreq.override <- function(pattern,debian_name) {
  49     pattern <- tolower(pattern)
  50     debian_name <- tolower(debian_name)
  51     con <- db.start()
  52     results <- dbGetQuery(con,paste(
  53                      'INSERT OR REPLACE INTO sysreq_override'
  54                     ,'(debian_name, r_pattern) VALUES ('
  55                     ,' ',db.quote(debian_name)
  56                     ,',',db.quote(pattern)
  57                     ,')'))
  58     db.stop(con)
  59 }
  60
  61 db.sysreq.overrides <- function() {
  62     con <- db.start()
  63     overrides <- dbGetQuery(con,paste('SELECT * FROM sysreq_override'))
  64     db.stop(con)
  65     return(overrides)
  66 }
  67
  68
  69 db.license.override.name <- function(name) {
  70     name <- tolower(name)
  71     con <- db.start()
  72     results <- dbGetQuery(con,paste(
  73                     'SELECT accept FROM license_override WHERE'
  74                             ,db.quote(name),'= name'))
  75     db.stop(con)
  76     if (length(results) == 0) {
  77         return(NA)
  78     }
  79     return(as.logical(results$accept))
  80 }
  81
  82 db.add.license.override <- function(name,accept) {
  83     name <- tolower(name)
  84     message(paste('adding',name,'accept?',accept))
  85     if (accept != TRUE && accept != FALSE) {
  86         stop('accept must be TRUE or FALSE')
  87     }
  88     con <- db.start()
  89     results <- dbGetQuery(con,paste(
  90                      'INSERT OR REPLACE INTO license_override'
  91                     ,'(name, accept) VALUES ('
  92                     ,' ',db.quote(name)
  93                     ,',',as.integer(accept)
  94                     ,')'))
  95     db.stop(con)
  96 }
  97
  98 db.license.override.file <- function(file_sha1) {
  99     file_sha1 <- tolower(file_sha1)
 100     con <- db.start()
 101     results <- dbGetQuery(con,paste(
 102                      'SELECT name,accept FROM license_override'
 103                     ,'INNER JOIN license_files'
 104                     ,'ON license_files.name = license_override.name WHERE'
 105                     ,db.quote(file_sha1),'= license_files.file_sha1'))
 106     db.stop(con)
 107     # TODO: change accept from 0,1 into FALSE,TRUE
 108     # TODO: NULL -> NA
 109     return(results)
 110 }
 111
 112 db.license.overrides <- function() {
 113     con <- db.start()
 114     overrides <- dbGetQuery(con,paste('SELECT * FROM license_override'))
 115     files     <- dbGetQuery(con,paste('SELECT * FROM license_files'))
 116     db.stop(con)
 117     # TODO: change accept from 0,1 into FALSE,TRUE
 118     return(list(overrides=overrides,files=files))
 119 }
 120
 121 db.add.license.file <- function(name,file_sha1) {
 122     name <- tolower(name)
 123     file_sha1 <- tolower(file_sha1)
 124     message(paste('adding file',file_sha1,'for',name))
 125     con <- db.start()
 126     dbGetQuery(con,paste(
 127          'INSERT OR REPLACE INTO license_files'
 128         ,'(name, file_sha1) VALUES ('
 129         ,' ',db.quote(name)
 130         ,',',db.quote(file_sha1)
 131         ,')'))
 132     db.stop(con)
 133 }
 134