1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
;;;; database.scm - store evaluation and build results
;;;
;;; Copyright © 2016 Mathieu Lirzin <mthl@gnu.org>
;;;
;;; This file is part of Cuirass.
;;;
;;; Cuirass is free software; you can redistribute it and/or modify it
;;; under the terms of the GNU General Public License as published by
;;; the Free Software Foundation; either version 3 of the License, or (at
;;; your option) any later version.
;;;
;;; Cuirass 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 General Public License for more details.
;;;
;;; You should have received a copy of the GNU General Public License
;;; along with Cuirass. If not, see <http://www.gnu.org/licenses/>.
(define-module (cuirass database)
#:use-module (cuirass base)
#:use-module (cuirass config)
#:use-module (cuirass job)
#:use-module (sqlite3)
#:export (;; Procedures.
db-init
db-open
db-close
db-add-evaluation
db-get-evaluation
db-delete-evaluation
;; Parameters.
%package-database
;; Macros.
with-database))
(define (sqlite-exec db sql)
"Wrap 'sqlite-prepare', 'sqlite-step', and 'sqlite-finalize'."
(let ((stmt (sqlite-prepare db sql)))
(sqlite-step stmt)
(sqlite-finalize stmt)))
(define %package-database
;; Define to the database file name of this package.
(make-parameter (string-append %localstatedir "/" %package ".db")))
(define (db-init)
"Open the database to store and read jobs and builds informations. Return a
database object."
(let ((db-name (%package-database)))
(when (file-exists? db-name)
(format (current-error-port) "Removing leftover database ~a~%" db-name)
(delete-file db-name))
(let ((db (sqlite-open db-name (logior SQLITE_OPEN_CREATE
SQLITE_OPEN_READWRITE))))
(for-each (λ (sql) (sqlite-exec db sql))
'("PRAGMA foreign_keys=OFF;"
"BEGIN TRANSACTION;"
"COMMIT;"
"
CREATE TABLE job_spec (
name text not null,
url text not null,
branch text not null,
file text not null,
proc text not null,
arguments text not null,
primary key (name)
);"
"
CREATE TABLE build (
id integer primary key autoincrement not null,
job_spec text not null,
drv text not null,
output text
-- foreign key (job_spec) references job_spec(name)
);"))
db)))
(define (db-open)
"Open database to store or read jobs and builds informations. Return a
database object."
(sqlite-open (%package-database) SQLITE_OPEN_READWRITE))
(define (db-close db)
"Close database object DB."
(sqlite-close db))
(define (db-add-evaluation db job)
"Store a derivation result in database DB and return its ID."
(sqlite-exec
db
(format #f "insert into build (job_spec, drv) values ('~A', '~A');"
(job-name job)
(job-derivation job)))
(let* ((stmt (sqlite-prepare db "select last_insert_rowid() from build;"))
(res (sqlite-step stmt)))
(sqlite-finalize stmt)
(vector-ref res 0)))
(define (db-get-evaluation db id)
"Retrieve a job in database DB which corresponds to ID."
(let* ((stmt (sqlite-prepare
db
(format #f "select * from build where id=~A;" id)))
(res (sqlite-step stmt)))
(sqlite-finalize stmt)
res))
(define (db-delete-evaluation db id)
"Delete a job in database DB which corresponds to ID."
(sqlite-exec db
(format #f "delete from build where id=~A;" id)))
(define-syntax-rule (with-database db body ...)
"Run BODY with a connection to the database which is bound to DB in BODY."
(let ((db (db-init)))
(dynamic-wind
(const #t)
(lambda ()
body ...)
(lambda ()
(db-close db)))))
;; (define (db-add-build db id)
;; "Store a build result corresponding to ID in database DB.")
|