]> git.sur5r.net Git - bacula/bacula/blob - bacula/src/cats/sql_list.c
c6672a288e15bfdd48f5c8cf8bf03043b8378079
[bacula/bacula] / bacula / src / cats / sql_list.c
1 /*
2  * Bacula Catalog Database List records interface routines
3  *
4  *    Kern Sibbald, March 2000
5  *
6  *    Version $Id$
7  */
8
9 /*
10    Copyright (C) 2000-2005 Kern Sibbald
11
12    This program is free software; you can redistribute it and/or
13    modify it under the terms of the GNU General Public License as
14    published by the Free Software Foundation; either version 2 of
15    the License, or (at your option) any later version.
16
17    This program is distributed in the hope that it will be useful,
18    but WITHOUT ANY WARRANTY; without even the implied warranty of
19    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
20    General Public License for more details.
21
22    You should have received a copy of the GNU General Public
23    License along with this program; if not, write to the Free
24    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
25    MA 02111-1307, USA.
26
27  */
28
29 /* The following is necessary so that we do not include
30  * the dummy external definition of DB.
31  */
32 #define __SQL_C                       /* indicate that this is sql.c */
33
34 #include "bacula.h"
35 #include "cats.h"
36
37 #if    HAVE_SQLITE3 || HAVE_MYSQL || HAVE_SQLITE || HAVE_POSTGRESQL
38
39 /* -----------------------------------------------------------------------
40  *
41  *   Generic Routines (or almost generic)
42  *
43  * -----------------------------------------------------------------------
44  */
45
46 /* Imported subroutines */
47 extern void list_result(JCR *jcr, B_DB *mdb, DB_LIST_HANDLER *sendit, void *ctx, e_list_type type);
48 extern int QueryDB(const char *file, int line, JCR *jcr, B_DB *db, char *select_cmd);
49
50
51 /*
52  * Submit general SQL query
53  */
54 int db_list_sql_query(JCR *jcr, B_DB *mdb, char *query, DB_LIST_HANDLER *sendit,
55                       void *ctx, int verbose, e_list_type type)
56 {
57    db_lock(mdb);
58    if (sql_query(mdb, query) != 0) {
59       Mmsg(mdb->errmsg, _("Query failed: %s\n"), sql_strerror(mdb));
60       if (verbose) {
61          sendit(ctx, mdb->errmsg);
62       }
63       db_unlock(mdb);
64       return 0;
65    }
66
67    mdb->result = sql_store_result(mdb);
68
69    if (mdb->result) {
70       list_result(jcr, mdb, sendit, ctx, type);
71       sql_free_result(mdb);
72    }
73    db_unlock(mdb);
74    return 1;
75 }
76
77 void
78 db_list_pool_records(JCR *jcr, B_DB *mdb, DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
79 {
80    db_lock(mdb);
81    if (type == VERT_LIST) {
82       Mmsg(mdb->cmd, "SELECT PoolId,Name,NumVols,MaxVols,UseOnce,UseCatalog,"
83          "AcceptAnyVolume,VolRetention,VolUseDuration,MaxVolJobs,MaxVolBytes,"
84          "AutoPrune,Recycle,PoolType,LabelFormat,Enabled,ScratchPoolId,"
85          "RecyclePoolId,LabelType "
86          " FROM Pool ORDER BY PoolId");
87    } else {
88       Mmsg(mdb->cmd, "SELECT PoolId,Name,NumVols,MaxVols,PoolType,LabelFormat "
89         "FROM Pool ORDER BY PoolId");
90    }
91
92    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
93       db_unlock(mdb);
94       return;
95    }
96
97    list_result(jcr, mdb, sendit, ctx, type);
98
99    sql_free_result(mdb);
100    db_unlock(mdb);
101 }
102
103 void
104 db_list_client_records(JCR *jcr, B_DB *mdb, DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
105 {
106    db_lock(mdb);
107    if (type == VERT_LIST) {
108       Mmsg(mdb->cmd, "SELECT ClientId,Name,Uname,AutoPrune,FileRetention,"
109          "FileRetention,JobRetention "
110          "FROM Client ORDER BY ClientId");
111    } else {
112       Mmsg(mdb->cmd, "SELECT ClientId,Name,FileRetention,JobRetention "
113          "FROM Client ORDER BY ClientId");
114    }
115
116    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
117       db_unlock(mdb);
118       return;
119    }
120
121    list_result(jcr, mdb, sendit, ctx, type);
122
123    sql_free_result(mdb);
124    db_unlock(mdb);
125 }
126
127
128 /*
129  * If VolumeName is non-zero, list the record for that Volume
130  *   otherwise, list the Volumes in the Pool specified by PoolId
131  */
132 void
133 db_list_media_records(JCR *jcr, B_DB *mdb, MEDIA_DBR *mdbr,
134                       DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
135 {
136    db_lock(mdb);
137    if (type == VERT_LIST) {
138       if (mdbr->VolumeName[0] != 0) {
139          Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,Slot,PoolId,"
140             "MediaType,FirstWritten,LastWritten,LabelDate,VolJobs,"
141             "VolFiles,VolBlocks,VolMounts,VolBytes,VolErrors,VolWrites,"
142             "VolCapacityBytes,VolStatus,Recycle,VolRetention,"
143             "VolUseDuration,MaxVolJobs,MaxVolFiles,MaxVolBytes,InChanger,"
144             "EndFile,EndBlock,VolParts,LabelType"
145             " FROM Media WHERE Media.VolumeName='%s'", mdbr->VolumeName);
146       } else {
147          Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,Slot,PoolId,"
148             "MediaType,FirstWritten,LastWritten,LabelDate,VolJobs,"
149             "VolFiles,VolBlocks,VolMounts,VolBytes,VolErrors,VolWrites,"
150             "VolCapacityBytes,VolStatus,Recycle,VolRetention,"
151             "VolUseDuration,MaxVolJobs,MaxVolFiles,MaxVolBytes,InChanger,"
152             "EndFile,EndBlock,VolParts,LabelType"
153             " FROM Media WHERE Media.PoolId=%u ORDER BY MediaId", mdbr->PoolId);
154       }
155    } else {
156       if (mdbr->VolumeName[0] != 0) {
157          Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,VolStatus,"
158             "VolBytes,VolFiles,VolRetention,Recycle,Slot,InChanger,MediaType,LastWritten "
159             "FROM Media WHERE Media.VolumeName='%s'", mdbr->VolumeName);
160       } else {
161          Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,VolStatus,"
162             "VolBytes,VolFiles,VolRetention,Recycle,Slot,InChanger,MediaType,LastWritten "
163             "FROM Media WHERE Media.PoolId=%u ORDER BY MediaId", mdbr->PoolId);
164       }
165    }
166
167    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
168       db_unlock(mdb);
169       return;
170    }
171
172    list_result(jcr, mdb, sendit, ctx, type);
173
174    sql_free_result(mdb);
175    db_unlock(mdb);
176 }
177
178 void db_list_jobmedia_records(JCR *jcr, B_DB *mdb, uint32_t JobId,
179                               DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
180 {
181    db_lock(mdb);
182    if (type == VERT_LIST) {
183       if (JobId > 0) {                   /* do by JobId */
184          Mmsg(mdb->cmd, "SELECT JobMediaId,JobId,Media.MediaId,Media.VolumeName,"
185             "FirstIndex,LastIndex,StartFile,JobMedia.EndFile,StartBlock,"
186             "JobMedia.EndBlock "
187             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId "
188             "AND JobMedia.JobId=%u", JobId);
189       } else {
190          Mmsg(mdb->cmd, "SELECT JobMediaId,JobId,Media.MediaId,Media.VolumeName,"
191             "FirstIndex,LastIndex,StartFile,JobMedia.EndFile,StartBlock,"
192             "JobMedia.EndBlock "
193             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId");
194       }
195
196    } else {
197       if (JobId > 0) {                   /* do by JobId */
198          Mmsg(mdb->cmd, "SELECT JobId,Media.VolumeName,FirstIndex,LastIndex "
199             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId "
200             "AND JobMedia.JobId=%u", JobId);
201       } else {
202          Mmsg(mdb->cmd, "SELECT JobId,Media.VolumeName,FirstIndex,LastIndex "
203             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId");
204       }
205    }
206    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
207       db_unlock(mdb);
208       return;
209    }
210
211    list_result(jcr, mdb, sendit, ctx, type);
212
213    sql_free_result(mdb);
214    db_unlock(mdb);
215 }
216
217
218
219 /*
220  * List Job record(s) that match JOB_DBR
221  *
222  *  Currently, we return all jobs or if jr->JobId is set,
223  *  only the job with the specified id.
224  */
225 void
226 db_list_job_records(JCR *jcr, B_DB *mdb, JOB_DBR *jr, DB_LIST_HANDLER *sendit,
227                     void *ctx, e_list_type type)
228 {
229    db_lock(mdb);
230    if (type == VERT_LIST) {
231       if (jr->JobId == 0 && jr->Job[0] == 0) {
232          Mmsg(mdb->cmd,
233             "SELECT JobId,Job,Job.Name,PurgedFiles,Type,Level,"
234             "Job.ClientId,Client.Name,JobStatus,SchedTime,"
235             "StartTime,EndTime,JobTDate,"
236             "VolSessionId,VolSessionTime,JobFiles,JobErrors,"
237             "JobMissingFiles,Job.PoolId,Pool.Name,Job.FileSetId,FileSet.FileSet "
238             "FROM Job,Client,Pool,FileSet WHERE "
239             "Client.ClientId=Job.ClientId AND Pool.PoolId=Job.PoolId "
240             "AND FileSet.FileSetId=Job.FileSetId  ORDER BY StartTime");
241       } else {                           /* single record */
242          Mmsg(mdb->cmd,
243             "SELECT JobId,Job,Job.Name,PurgedFiles,Type,Level,"
244             "Job.ClientId,Client.Name,JobStatus,SchedTime,"
245             "StartTime,EndTime,JobTDate,"
246             "VolSessionId,VolSessionTime,JobFiles,JobErrors,"
247             "JobMissingFiles,Job.PoolId,Pool.Name,Job.FileSetId,FileSet.FileSet "
248             "FROM Job,Client,Pool,FileSet WHERE Job.JobId=%u AND "
249             "Client.ClientId=Job.ClientId AND Pool.PoolId=Job.PoolId "
250             "AND FileSet.FileSetId=Job.FileSetId", jr->JobId);
251       }
252    } else {
253       if (jr->JobId == 0 && jr->Job[0] == 0) {
254          Mmsg(mdb->cmd,
255            "SELECT JobId,Name,StartTime,Type,Level,JobFiles,JobBytes,JobStatus "
256            "FROM Job ORDER BY StartTime");
257       } else {                           /* single record */
258          Mmsg(mdb->cmd, "SELECT JobId,Name,StartTime,Type,Level,"
259             "JobFiles,JobBytes,JobStatus FROM Job WHERE JobId=%u", jr->JobId);
260       }
261    }
262    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
263       db_unlock(mdb);
264       return;
265    }
266    list_result(jcr, mdb, sendit, ctx, type);
267
268    sql_free_result(mdb);
269    db_unlock(mdb);
270 }
271
272 /*
273  * List Job totals
274  *
275  */
276 void
277 db_list_job_totals(JCR *jcr, B_DB *mdb, JOB_DBR *jr, DB_LIST_HANDLER *sendit, void *ctx)
278 {
279    db_lock(mdb);
280
281    /* List by Job */
282    Mmsg(mdb->cmd, "SELECT  count(*) AS Jobs,sum(JobFiles) "
283       "AS Files,sum(JobBytes) AS Bytes,Name AS Job FROM Job GROUP BY Name");
284
285    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
286       db_unlock(mdb);
287       return;
288    }
289
290    list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
291
292    sql_free_result(mdb);
293
294    /* Do Grand Total */
295    Mmsg(mdb->cmd, "SELECT count(*) AS Jobs,sum(JobFiles) "
296 "AS Files,sum(JobBytes) As Bytes FROM Job");
297
298    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
299       db_unlock(mdb);
300       return;
301    }
302
303    list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
304
305    sql_free_result(mdb);
306    db_unlock(mdb);
307 }
308
309 /*
310  * Stupid MySQL is NON-STANDARD !
311  */
312 #ifdef HAVE_MYSQL
313 #define FN "CONCAT(Path.Path,Filename.Name)"
314 #else
315 #define FN "Path.Path||Filename.Name"
316 #endif
317
318 void
319 db_list_files_for_job(JCR *jcr, B_DB *mdb, uint32_t jobid, DB_LIST_HANDLER *sendit, void *ctx)
320 {
321    db_lock(mdb);
322
323    Mmsg(mdb->cmd, "SELECT " FN " AS Filename FROM File,"
324 "Filename,Path WHERE File.JobId=%u AND Filename.FilenameId=File.FilenameId "
325 "AND Path.PathId=File.PathId",
326       jobid);
327
328    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
329       db_unlock(mdb);
330       return;
331    }
332
333    list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
334
335    sql_free_result(mdb);
336    db_unlock(mdb);
337 }
338
339
340 #endif /* HAVE_SQLITE3 || HAVE_MYSQL || HAVE_SQLITE || HAVE_POSTGRESQL*/