Branch data Line data Source code
1 : : /* Copyright (c) 2014, Vsevolod Stakhov
2 : : * All rights reserved.
3 : : *
4 : : * Redistribution and use in source and binary forms, with or without
5 : : * modification, are permitted provided that the following conditions are met:
6 : : * * Redistributions of source code must retain the above copyright
7 : : * notice, this list of conditions and the following disclaimer.
8 : : * * Redistributions in binary form must reproduce the above copyright
9 : : * notice, this list of conditions and the following disclaimer in the
10 : : * documentation and/or other materials provided with the distribution.
11 : : *
12 : : * THIS SOFTWARE IS PROVIDED ''AS IS'' AND ANY
13 : : * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
14 : : * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
15 : : * DISCLAIMED. IN NO EVENT SHALL AUTHOR BE LIABLE FOR ANY
16 : : * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
17 : : * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
18 : : * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
19 : : * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
20 : : * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
21 : : * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
22 : : */
23 : :
24 : : #include <stdlib.h>
25 : : #include <stdio.h>
26 : : #include <stdbool.h>
27 : : #include <string.h>
28 : :
29 : : #include <sqlite3.h>
30 : :
31 : : #include "pkg.h"
32 : : #include "private/event.h"
33 : : #include "private/pkg.h"
34 : : #include "private/pkgdb.h"
35 : : #include "private/utils.h"
36 : : #include "binary_private.h"
37 : :
38 : : static sql_prstmt sql_prepared_statements[PRSTMT_LAST] = {
39 : : [PKG] = {
40 : : NULL,
41 : : "INSERT OR REPLACE INTO packages ("
42 : : "origin, name, version, comment, desc, arch, maintainer, www, "
43 : : "prefix, pkgsize, flatsize, licenselogic, cksum, path, manifestdigest, olddigest, "
44 : : "vital)"
45 : : "VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8, ?9, ?10, ?11, ?12, ?13, ?14, ?15, ?16, ?17)",
46 : : "TTTTTTTTTIIITTTTI",
47 : : },
48 : : [DEPS] = {
49 : : NULL,
50 : : "INSERT OR REPLACE INTO deps (origin, name, version, package_id) "
51 : : "VALUES (?1, ?2, ?3, ?4)",
52 : : "TTTI",
53 : : },
54 : : [CAT1] = {
55 : : NULL,
56 : : "INSERT OR IGNORE INTO categories(name) VALUES(?1)",
57 : : "T",
58 : : },
59 : : [CAT2] = {
60 : : NULL,
61 : : "INSERT OR ROLLBACK INTO pkg_categories(package_id, category_id) "
62 : : "VALUES (?1, (SELECT id FROM categories WHERE name = ?2))",
63 : : "IT",
64 : : },
65 : : [LIC1] = {
66 : : NULL,
67 : : "INSERT OR IGNORE INTO licenses(name) VALUES(?1)",
68 : : "T",
69 : : },
70 : : [LIC2] = {
71 : : NULL,
72 : : "INSERT OR ROLLBACK INTO pkg_licenses(package_id, license_id) "
73 : : "VALUES (?1, (SELECT id FROM licenses WHERE name = ?2))",
74 : : "IT",
75 : : },
76 : : [OPT1] = {
77 : : NULL,
78 : : "INSERT OR IGNORE INTO option(option) "
79 : : "VALUES (?1)",
80 : : "T",
81 : : },
82 : : [OPT2] = {
83 : : NULL,
84 : : "INSERT OR ROLLBACK INTO pkg_option (option_id, value, package_id) "
85 : : "VALUES (( SELECT option_id FROM option WHERE option = ?1), ?2, ?3)",
86 : : "TTI",
87 : : },
88 : : [SHLIB1] = {
89 : : NULL,
90 : : "INSERT OR IGNORE INTO shlibs(name) VALUES(?1)",
91 : : "T",
92 : : },
93 : : [SHLIB_REQD] = {
94 : : NULL,
95 : : "INSERT OR IGNORE INTO pkg_shlibs_required(package_id, shlib_id) "
96 : : "VALUES (?1, (SELECT id FROM shlibs WHERE name = ?2))",
97 : : "IT",
98 : : },
99 : : [SHLIB_PROV] = {
100 : : NULL,
101 : : "INSERT OR IGNORE INTO pkg_shlibs_provided(package_id, shlib_id) "
102 : : "VALUES (?1, (SELECT id FROM shlibs WHERE name = ?2))",
103 : : "IT",
104 : : },
105 : : [EXISTS] = {
106 : : NULL,
107 : : "SELECT count(*) FROM packages WHERE cksum=?1",
108 : : "T",
109 : : },
110 : : [ANNOTATE1] = {
111 : : NULL,
112 : : "INSERT OR IGNORE INTO annotation(annotation) "
113 : : "VALUES (?1)",
114 : : "T",
115 : : },
116 : : [ANNOTATE2] = {
117 : : NULL,
118 : : "INSERT OR ROLLBACK INTO pkg_annotation(package_id, tag_id, value_id) "
119 : : "VALUES (?1,"
120 : : " (SELECT annotation_id FROM annotation WHERE annotation=?2),"
121 : : " (SELECT annotation_id FROM annotation WHERE annotation=?3))",
122 : : "ITT",
123 : : },
124 : : [REPO_VERSION] = {
125 : : NULL,
126 : : "SELECT version FROM packages WHERE origin=?1",
127 : : "T",
128 : : },
129 : : [DELETE] = {
130 : : NULL,
131 : : "DELETE FROM packages WHERE origin=?1;"
132 : : "DELETE FROM pkg_search WHERE origin=?1;",
133 : : "TT",
134 : : },
135 : : [PROVIDE] = {
136 : : NULL,
137 : : "INSERT OR IGNORE INTO provides(provide) VALUES(?1)",
138 : : "T",
139 : : },
140 : : [PROVIDES] = {
141 : : NULL,
142 : : "INSERT OR IGNORE INTO pkg_provides(package_id, provide_id) "
143 : : "VALUES (?1, (SELECT id FROM provides WHERE provide = ?2))",
144 : : "IT",
145 : : },
146 : : [REQUIRE] = {
147 : : NULL,
148 : : "INSERT OR IGNORE INTO requires(require) VALUES(?1)",
149 : : "T",
150 : : },
151 : : [REQUIRES] = {
152 : : NULL,
153 : : "INSERT OR IGNORE INTO pkg_requires(package_id, require_id) "
154 : : "VALUES (?1, (SELECT id FROM requires WHERE require = ?2))",
155 : : "IT",
156 : : },
157 : : /* PRSTMT_LAST */
158 : : };
159 : :
160 : : const char *
161 : 0 : pkg_repo_binary_sql_prstatement(sql_prstmt_index s)
162 : : {
163 [ # # ]: 0 : if (s < PRSTMT_LAST)
164 : 0 : return (sql_prepared_statements[s].sql);
165 : : else
166 : 0 : return ("unknown");
167 : 0 : }
168 : :
169 : : sqlite3_stmt*
170 : 0 : pkg_repo_binary_stmt_prstatement(sql_prstmt_index s)
171 : : {
172 [ # # ]: 0 : if (s < PRSTMT_LAST)
173 : 0 : return (sql_prepared_statements[s].stmt);
174 : : else
175 : 0 : return (NULL);
176 : 0 : }
177 : :
178 : : int
179 : 595 : pkg_repo_binary_init_prstatements(sqlite3 *sqlite)
180 : : {
181 : : sql_prstmt_index i, last;
182 : : int ret;
183 : :
184 : 595 : last = PRSTMT_LAST;
185 : :
186 [ + + ]: 12495 : for (i = 0; i < last; i++) {
187 : 11900 : ret = sqlite3_prepare_v2(sqlite, SQL(i), -1, &STMT(i), NULL);
188 [ - + ]: 11900 : if (ret != SQLITE_OK) {
189 : 0 : ERROR_SQLITE(sqlite, SQL(i));
190 : 0 : return (EPKG_FATAL);
191 : : }
192 : 11900 : }
193 : :
194 : 595 : return (EPKG_OK);
195 : 595 : }
196 : :
197 : : int
198 : 2944 : pkg_repo_binary_run_prstatement(sql_prstmt_index s, ...)
199 : : {
200 : : int retcode; /* Returns SQLITE error code */
201 : : va_list ap;
202 : : sqlite3_stmt *stmt;
203 : : int i;
204 : : const char *argtypes;
205 : :
206 : 2944 : stmt = STMT(s);
207 : 2944 : argtypes = sql_prepared_statements[s].argtypes;
208 : :
209 : 2944 : sqlite3_reset(stmt);
210 : :
211 : 2944 : va_start(ap, s);
212 : :
213 [ + + ]: 15720 : for (i = 0; argtypes[i] != '\0'; i++)
214 : : {
215 [ - + + ]: 12776 : switch (argtypes[i]) {
216 : : case 'T':
217 [ + + ]: 9664 : sqlite3_bind_text(stmt, i + 1, va_arg(ap, const char*),
218 : : -1, SQLITE_STATIC);
219 : 9664 : break;
220 : : case 'I':
221 [ + + ]: 3112 : sqlite3_bind_int64(stmt, i + 1, va_arg(ap, int64_t));
222 : 3112 : break;
223 : : }
224 : 12776 : }
225 : :
226 : 2944 : va_end(ap);
227 : :
228 : 2944 : retcode = sqlite3_step(stmt);
229 : :
230 : 2944 : return (retcode);
231 : : }
232 : :
233 : :
234 : : const char *
235 : 2517 : pkg_repo_binary_get_filename(const char *name)
236 : : {
237 : : static char reponame[MAXPATHLEN];
238 : :
239 : 2517 : snprintf(reponame, sizeof(reponame), REPO_NAME_PREFIX "%s.sqlite",
240 : 2517 : name);
241 : :
242 : 2517 : return (reponame);
243 : : }
244 : :
245 : : void
246 : 781 : pkg_repo_binary_finalize_prstatements(void)
247 : : {
248 : : sql_prstmt_index i, last;
249 : :
250 : 781 : last = PRSTMT_LAST;
251 : :
252 [ + + ]: 16401 : for (i = 0; i < last; i++)
253 : : {
254 [ + + ]: 15620 : if (STMT(i) != NULL) {
255 : 11040 : sqlite3_finalize(STMT(i));
256 : 11040 : STMT(i) = NULL;
257 : 11040 : }
258 : 15620 : }
259 : 781 : return;
260 : : }
|
