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