]> git.sur5r.net Git - bacula/bacula/blob - bacula/src/cats/sql_list.c
Fix merge conflict leftover
[bacula/bacula] / bacula / src / cats / sql_list.c
1 /*
2    Bacula® - The Network Backup Solution
3
4    Copyright (C) 2000-2009 Free Software Foundation Europe e.V.
5
6    The main author of Bacula is Kern Sibbald, with contributions from
7    many others, a complete list can be found in the file AUTHORS.
8    This program is Free Software; you can redistribute it and/or
9    modify it under the terms of version two of the GNU General Public
10    License as published by the Free Software Foundation and included
11    in the file LICENSE.
12
13    This program is distributed in the hope that it will be useful, but
14    WITHOUT ANY WARRANTY; without even the implied warranty of
15    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16    General Public License for more details.
17
18    You should have received a copy of the GNU General Public License
19    along with this program; if not, write to the Free Software
20    Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
21    02110-1301, USA.
22
23    Bacula® is a registered trademark of Kern Sibbald.
24    The licensor of Bacula is the Free Software Foundation Europe
25    (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich,
26    Switzerland, email:ftf@fsfeurope.org.
27 */
28 /*
29  * Bacula Catalog Database List records interface routines
30  *
31  *    Kern Sibbald, March 2000
32  *
33  *    Version $Id$
34  */
35
36
37 /* The following is necessary so that we do not include
38  * the dummy external definition of DB.
39  */
40 #define __SQL_C                       /* indicate that this is sql.c */
41
42 #include "bacula.h"
43 #include "cats.h"
44
45 extern int db_type;
46
47 #if    HAVE_SQLITE3 || HAVE_MYSQL || HAVE_SQLITE || HAVE_POSTGRESQL || HAVE_DBI
48
49 /* -----------------------------------------------------------------------
50  *
51  *   Generic Routines (or almost generic)
52  *
53  * -----------------------------------------------------------------------
54  */
55
56 /*
57  * Submit general SQL query
58  */
59 int db_list_sql_query(JCR *jcr, B_DB *mdb, const char *query, DB_LIST_HANDLER *sendit,
60                       void *ctx, int verbose, e_list_type type)
61 {
62    db_lock(mdb);
63    if (sql_query(mdb, query) != 0) {
64       Mmsg(mdb->errmsg, _("Query failed: %s\n"), sql_strerror(mdb));
65       if (verbose) {
66          sendit(ctx, mdb->errmsg);
67       }
68       db_unlock(mdb);
69       return 0;
70    }
71
72    mdb->result = sql_store_result(mdb);
73
74    if (mdb->result) {
75       list_result(jcr, mdb, sendit, ctx, type);
76       sql_free_result(mdb);
77    }
78    db_unlock(mdb);
79    return 1;
80 }
81
82 void
83 db_list_pool_records(JCR *jcr, B_DB *mdb, POOL_DBR *pdbr,
84                      DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
85 {
86    db_lock(mdb);
87    if (type == VERT_LIST) {
88       if (pdbr->Name[0] != 0) {
89          Mmsg(mdb->cmd, "SELECT PoolId,Name,NumVols,MaxVols,UseOnce,UseCatalog,"
90             "AcceptAnyVolume,VolRetention,VolUseDuration,MaxVolJobs,MaxVolBytes,"
91             "AutoPrune,Recycle,PoolType,LabelFormat,Enabled,ScratchPoolId,"
92             "RecyclePoolId,LabelType "
93             " FROM Pool WHERE Name='%s'", pdbr->Name);
94       } else {
95          Mmsg(mdb->cmd, "SELECT PoolId,Name,NumVols,MaxVols,UseOnce,UseCatalog,"
96             "AcceptAnyVolume,VolRetention,VolUseDuration,MaxVolJobs,MaxVolBytes,"
97             "AutoPrune,Recycle,PoolType,LabelFormat,Enabled,ScratchPoolId,"
98             "RecyclePoolId,LabelType "
99             " FROM Pool ORDER BY PoolId");
100       }
101    } else {
102       if (pdbr->Name[0] != 0) {
103          Mmsg(mdb->cmd, "SELECT PoolId,Name,NumVols,MaxVols,PoolType,LabelFormat "
104            "FROM Pool WHERE Name='%s'", pdbr->Name);
105       } else {
106          Mmsg(mdb->cmd, "SELECT PoolId,Name,NumVols,MaxVols,PoolType,LabelFormat "
107            "FROM Pool ORDER BY PoolId");
108       }
109    }
110
111    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
112       db_unlock(mdb);
113       return;
114    }
115
116    list_result(jcr, mdb, sendit, ctx, type);
117
118    sql_free_result(mdb);
119    db_unlock(mdb);
120 }
121
122 void
123 db_list_client_records(JCR *jcr, B_DB *mdb, DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
124 {
125    db_lock(mdb);
126    if (type == VERT_LIST) {
127       Mmsg(mdb->cmd, "SELECT ClientId,Name,Uname,AutoPrune,FileRetention,"
128          "JobRetention "
129          "FROM Client ORDER BY ClientId");
130    } else {
131       Mmsg(mdb->cmd, "SELECT ClientId,Name,FileRetention,JobRetention "
132          "FROM Client ORDER BY ClientId");
133    }
134
135    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
136       db_unlock(mdb);
137       return;
138    }
139
140    list_result(jcr, mdb, sendit, ctx, type);
141
142    sql_free_result(mdb);
143    db_unlock(mdb);
144 }
145
146
147 /*
148  * If VolumeName is non-zero, list the record for that Volume
149  *   otherwise, list the Volumes in the Pool specified by PoolId
150  */
151 void
152 db_list_media_records(JCR *jcr, B_DB *mdb, MEDIA_DBR *mdbr,
153                       DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
154 {
155    char ed1[50];
156    db_lock(mdb);
157    if (type == VERT_LIST) {
158       if (mdbr->VolumeName[0] != 0) {
159          Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,Slot,PoolId,"
160             "MediaType,FirstWritten,LastWritten,LabelDate,VolJobs,"
161             "VolFiles,VolBlocks,VolMounts,VolBytes,VolErrors,VolWrites,"
162             "VolCapacityBytes,VolStatus,Enabled,Recycle,VolRetention,"
163             "VolUseDuration,MaxVolJobs,MaxVolFiles,MaxVolBytes,InChanger,"
164             "EndFile,EndBlock,VolParts,LabelType,StorageId,DeviceId,"
165             "LocationId,RecycleCount,InitialWrite,ScratchPoolId,RecyclePoolId, "
166             "Comment"
167             " FROM Media WHERE Media.VolumeName='%s'", mdbr->VolumeName);
168       } else {
169          Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,Slot,PoolId,"
170             "MediaType,FirstWritten,LastWritten,LabelDate,VolJobs,"
171             "VolFiles,VolBlocks,VolMounts,VolBytes,VolErrors,VolWrites,"
172             "VolCapacityBytes,VolStatus,Enabled,Recycle,VolRetention,"
173             "VolUseDuration,MaxVolJobs,MaxVolFiles,MaxVolBytes,InChanger,"
174             "EndFile,EndBlock,VolParts,LabelType,StorageId,DeviceId,"
175             "LocationId,RecycleCount,InitialWrite,ScratchPoolId,RecyclePoolId, "
176             "Comment"
177             " FROM Media WHERE Media.PoolId=%s ORDER BY MediaId",
178             edit_int64(mdbr->PoolId, ed1));
179       }
180    } else {
181       if (mdbr->VolumeName[0] != 0) {
182          Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,VolStatus,Enabled,"
183             "VolBytes,VolFiles,VolRetention,Recycle,Slot,InChanger,MediaType,LastWritten "
184             "FROM Media WHERE Media.VolumeName='%s'", mdbr->VolumeName);
185       } else {
186          Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,VolStatus,Enabled,"
187             "VolBytes,VolFiles,VolRetention,Recycle,Slot,InChanger,MediaType,LastWritten "
188             "FROM Media WHERE Media.PoolId=%s ORDER BY MediaId",
189             edit_int64(mdbr->PoolId, ed1));
190       }
191    }
192
193    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
194       db_unlock(mdb);
195       return;
196    }
197
198    list_result(jcr, mdb, sendit, ctx, type);
199
200    sql_free_result(mdb);
201    db_unlock(mdb);
202 }
203
204 void db_list_jobmedia_records(JCR *jcr, B_DB *mdb, uint32_t JobId,
205                               DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
206 {
207    char ed1[50];
208    db_lock(mdb);
209    if (type == VERT_LIST) {
210       if (JobId > 0) {                   /* do by JobId */
211          Mmsg(mdb->cmd, "SELECT JobMediaId,JobId,Media.MediaId,Media.VolumeName,"
212             "FirstIndex,LastIndex,StartFile,JobMedia.EndFile,StartBlock,"
213             "JobMedia.EndBlock,Copy "
214             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId "
215             "AND JobMedia.JobId=%s", edit_int64(JobId, ed1));
216       } else {
217          Mmsg(mdb->cmd, "SELECT JobMediaId,JobId,Media.MediaId,Media.VolumeName,"
218             "FirstIndex,LastIndex,StartFile,JobMedia.EndFile,StartBlock,"
219             "JobMedia.EndBlock,Copy "
220             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId");
221       }
222
223    } else {
224       if (JobId > 0) {                   /* do by JobId */
225          Mmsg(mdb->cmd, "SELECT JobId,Media.VolumeName,FirstIndex,LastIndex "
226             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId "
227             "AND JobMedia.JobId=%s", edit_int64(JobId, ed1));
228       } else {
229          Mmsg(mdb->cmd, "SELECT JobId,Media.VolumeName,FirstIndex,LastIndex "
230             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId");
231       }
232    }
233    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
234       db_unlock(mdb);
235       return;
236    }
237
238    list_result(jcr, mdb, sendit, ctx, type);
239
240    sql_free_result(mdb);
241    db_unlock(mdb);
242 }
243
244
245 void db_list_copies_records(JCR *jcr, B_DB *mdb, uint32_t limit, char *JobIds,
246                             DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
247 {
248    POOL_MEM str_limit(PM_MESSAGE);
249    POOL_MEM str_jobids(PM_MESSAGE);
250
251    if (limit > 0) {
252       Mmsg(str_limit, " LIMIT %d", limit);
253    }
254
255    if (JobIds && JobIds[0]) {
256       Mmsg(str_jobids, " AND (Job.PriorJobId IN (%s) OR Job.JobId IN (%s)) ", 
257            JobIds, JobIds);      
258    }
259
260    db_lock(mdb);
261    Mmsg(mdb->cmd, 
262    "SELECT DISTINCT Job.PriorJobId AS JobId, Job.Job, "
263                    "Job.JobId AS CopyJobId, Media.MediaType "
264      "FROM Job " 
265      "JOIN JobMedia USING (JobId) "
266      "JOIN Media    USING (MediaId) "
267     "WHERE Job.Type = '%c' %s ORDER BY Job.PriorJobId DESC %s",
268         (char) JT_JOB_COPY, str_jobids.c_str(), str_limit.c_str());
269
270    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
271       goto bail_out;
272    }
273
274    if (mdb->result && sql_num_rows(mdb)) {
275       if (JobIds && JobIds[0]) {
276          sendit(ctx, _("These JobIds have copies as follows:\n"));
277       } else {
278          sendit(ctx, _("The catalog contains copies as follows:\n"));
279       }
280
281       list_result(jcr, mdb, sendit, ctx, type);
282    }
283
284    sql_free_result(mdb);
285
286 bail_out:
287    db_unlock(mdb);
288 }
289
290 void db_list_joblog_records(JCR *jcr, B_DB *mdb, uint32_t JobId,
291                               DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
292 {
293    char ed1[50];
294    db_lock(mdb);
295    if (JobId <= 0) {
296       return;
297    }
298    if (type == VERT_LIST) {
299       Mmsg(mdb->cmd, "SELECT Time,LogText FROM Log "
300            "WHERE Log.JobId=%s", edit_int64(JobId, ed1));
301    } else {
302       Mmsg(mdb->cmd, "SELECT LogText FROM Log "
303            "WHERE Log.JobId=%s", edit_int64(JobId, ed1));
304    }
305    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
306       goto bail_out;
307    }
308
309    list_result(jcr, mdb, sendit, ctx, type);
310
311    sql_free_result(mdb);
312
313 bail_out:
314    db_unlock(mdb);
315 }
316
317
318 /*
319  * List Job record(s) that match JOB_DBR
320  *
321  *  Currently, we return all jobs or if jr->JobId is set,
322  *  only the job with the specified id.
323  */
324 void
325 db_list_job_records(JCR *jcr, B_DB *mdb, JOB_DBR *jr, DB_LIST_HANDLER *sendit,
326                     void *ctx, e_list_type type)
327 {
328    char ed1[50];
329    char limit[100];
330    db_lock(mdb);
331    if (jr->limit > 0) {
332       snprintf(limit, sizeof(limit), " LIMIT %d", jr->limit);
333    } else {
334       limit[0] = 0;
335    }
336    if (type == VERT_LIST) {
337       if (jr->JobId == 0 && jr->Job[0] == 0) {
338          Mmsg(mdb->cmd,
339             "SELECT JobId,Job,Job.Name,PurgedFiles,Type,Level,"
340             "Job.ClientId,Client.Name as ClientName,JobStatus,SchedTime,"
341             "StartTime,EndTime,RealEndTime,JobTDate,"
342             "VolSessionId,VolSessionTime,JobFiles,JobErrors,"
343             "JobMissingFiles,Job.PoolId,Pool.Name as PooLname,PriorJobId,"
344             "Job.FileSetId,FileSet.FileSet "
345             "FROM Job,Client,Pool,FileSet WHERE "
346             "Client.ClientId=Job.ClientId AND Pool.PoolId=Job.PoolId "
347             "AND FileSet.FileSetId=Job.FileSetId  ORDER BY StartTime%s", limit);
348       } else {                           /* single record */
349          Mmsg(mdb->cmd,
350             "SELECT JobId,Job,Job.Name,PurgedFiles,Type,Level,"
351             "Job.ClientId,Client.Name,JobStatus,SchedTime,"
352             "StartTime,EndTime,RealEndTime,JobTDate,"
353             "VolSessionId,VolSessionTime,JobFiles,JobErrors,"
354             "JobMissingFiles,Job.PoolId,Pool.Name as PooLname,PriorJobId,"
355             "Job.FileSetId,FileSet.FileSet "
356             "FROM Job,Client,Pool,FileSet WHERE Job.JobId=%s AND "
357             "Client.ClientId=Job.ClientId AND Pool.PoolId=Job.PoolId "
358             "AND FileSet.FileSetId=Job.FileSetId",
359             edit_int64(jr->JobId, ed1));
360       }
361    } else {
362       if (jr->Name[0] != 0) {
363          Mmsg(mdb->cmd,
364             "SELECT JobId,Name,StartTime,Type,Level,JobFiles,JobBytes,JobStatus "
365             "FROM Job WHERE Name='%s' ORDER BY StartTime,JobId ASC", jr->Name);
366       } else if (jr->Job[0] != 0) {
367          Mmsg(mdb->cmd,
368             "SELECT JobId,Name,StartTime,Type,Level,JobFiles,JobBytes,JobStatus "
369             "FROM Job WHERE Job='%s' ORDER BY StartTime,JobId ASC", jr->Job);
370       } else if (jr->JobId != 0) {
371          Mmsg(mdb->cmd,
372             "SELECT JobId,Name,StartTime,Type,Level,JobFiles,JobBytes,JobStatus "
373             "FROM Job WHERE JobId=%s", edit_int64(jr->JobId, ed1));
374       } else {                           /* all records */
375          Mmsg(mdb->cmd,
376            "SELECT JobId,Name,StartTime,Type,Level,JobFiles,JobBytes,JobStatus "
377            "FROM Job ORDER BY StartTime,JobId ASC%s", limit);
378       }
379    }
380    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
381       db_unlock(mdb);
382       return;
383    }
384    list_result(jcr, mdb, sendit, ctx, type);
385
386    sql_free_result(mdb);
387    db_unlock(mdb);
388 }
389
390 /*
391  * List Job totals
392  *
393  */
394 void
395 db_list_job_totals(JCR *jcr, B_DB *mdb, JOB_DBR *jr, DB_LIST_HANDLER *sendit, void *ctx)
396 {
397    db_lock(mdb);
398
399    /* List by Job */
400    Mmsg(mdb->cmd, "SELECT  count(*) AS Jobs,sum(JobFiles) "
401       "AS Files,sum(JobBytes) AS Bytes,Name AS Job FROM Job GROUP BY Name");
402
403    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
404       db_unlock(mdb);
405       return;
406    }
407
408    list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
409
410    sql_free_result(mdb);
411
412    /* Do Grand Total */
413    Mmsg(mdb->cmd, "SELECT count(*) AS Jobs,sum(JobFiles) "
414         "AS Files,sum(JobBytes) As Bytes FROM Job");
415
416    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
417       db_unlock(mdb);
418       return;
419    }
420
421    list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
422
423    sql_free_result(mdb);
424    db_unlock(mdb);
425 }
426
427 void
428 db_list_files_for_job(JCR *jcr, B_DB *mdb, JobId_t jobid, DB_LIST_HANDLER *sendit, void *ctx)
429 {
430    char ed1[50];
431    db_lock(mdb);
432
433    /*
434     * Stupid MySQL is NON-STANDARD !
435     */
436    if (db_type == SQL_TYPE_MYSQL) {
437       Mmsg(mdb->cmd, "SELECT CONCAT(Path.Path,Filename.Name) AS Filename FROM File,"
438    "Filename,Path WHERE File.JobId=%s AND Filename.FilenameId=File.FilenameId "
439    "AND Path.PathId=File.PathId",
440          edit_int64(jobid, ed1));
441    } else {
442       Mmsg(mdb->cmd, "SELECT Path.Path||Filename.Name AS Filename FROM File,"
443    "Filename,Path WHERE File.JobId=%s AND Filename.FilenameId=File.FilenameId "
444    "AND Path.PathId=File.PathId",
445          edit_int64(jobid, ed1));
446    }
447
448    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
449       db_unlock(mdb);
450       return;
451    }
452
453    list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
454
455    sql_free_result(mdb);
456    db_unlock(mdb);
457 }
458
459
460 #endif /* HAVE_SQLITE3 || HAVE_MYSQL || HAVE_SQLITE || HAVE_POSTGRESQL*/