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 /*
  10    Copyright (C) 2000, 2001, 2002 Kern Sibbald and John Walker
  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_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(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 "
  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             "FROM Media WHERE Media.VolumeName='%s'", mdbr->VolumeName);
 145       } else {
 146          Mmsg(&mdb->cmd, "SELECT MediaId,VolumeName,Slot,PoolId,"
 147             "MediaType,FirstWritten,LastWritten,LabelDate,VolJobs,"
 148             "VolFiles,VolBlocks,VolMounts,VolBytes,VolErrors,VolWrites,"
 149             "VolCapacityBytes,VolStatus,Recycle,VolRetention,"
 150             "VolUseDuration,MaxVolJobs,MaxVolFiles,MaxVolBytes,InChanger "
 151             "FROM Media WHERE Media.PoolId=%u ORDER BY MediaId", mdbr->PoolId);
 152       }
 153    } else {
 154       if (mdbr->VolumeName[0] != 0) {
 155          Mmsg(&mdb->cmd, "SELECT MediaId,VolumeName,VolStatus,"
 156             "VolBytes,VolFiles,VolRetention,Recycle,Slot,MediaType,LastWritten "
 157             "FROM Media WHERE Media.VolumeName='%s'", mdbr->VolumeName);
 158       } else {
 159          Mmsg(&mdb->cmd, "SELECT MediaId,VolumeName,VolStatus,"
 160             "VolBytes,VolFiles,VolRetention,Recycle,Slot,MediaType,LastWritten "
 161             "FROM Media WHERE Media.PoolId=%u ORDER BY MediaId", mdbr->PoolId);
 162       }
 163    }
 164
 165    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
 166       db_unlock(mdb);
 167       return;
 168    }
 169
 170    list_result(jcr, mdb, sendit, ctx, type);
 171
 172    sql_free_result(mdb);
 173    db_unlock(mdb);
 174 }
 175
 176 void db_list_jobmedia_records(JCR *jcr, B_DB *mdb, uint32_t JobId,
 177                               DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
 178 {
 179    db_lock(mdb);
 180    if (type == VERT_LIST) {
 181       if (JobId > 0) {                   /* do by JobId */
 182          Mmsg(&mdb->cmd, "SELECT JobMediaId,JobId,MediaId,Media.VolumeName,"
 183             "FirstIndex,LastIndex,StartFile,EndFile,StartBlock,EndBlock "
 184             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId "
 185             "AND JobMedia.JobId=%u", JobId);
 186       } else {
 187          Mmsg(&mdb->cmd, "SELECT JobMediaId,JobId,MediaId,Media.VolumeName,"
 188             "FirstIndex,LastIndex,StartFile,EndFile,StartBlock,EndBlock "
 189             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId");
 190       }
 191
 192    } else {
 193       if (JobId > 0) {                   /* do by JobId */
 194          Mmsg(&mdb->cmd, "SELECT JobId,Media.VolumeName,FirstIndex,LastIndex "
 195             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId "
 196             "AND JobMedia.JobId=%u", JobId);
 197       } else {
 198          Mmsg(&mdb->cmd, "SELECT JobId,Media.VolumeName,FirstIndex,LastIndex "
 199             "FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId");
 200       }
 201    }
 202    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
 203       db_unlock(mdb);
 204       return;
 205    }
 206
 207    list_result(jcr, mdb, sendit, ctx, type);
 208
 209    sql_free_result(mdb);
 210    db_unlock(mdb);
 211 }
 212
 213
 214
 215 /*
 216  * List Job record(s) that match JOB_DBR
 217  *
 218  *  Currently, we return all jobs or if jr->JobId is set,
 219  *  only the job with the specified id.
 220  */
 221 void
 222 db_list_job_records(JCR *jcr, B_DB *mdb, JOB_DBR *jr, DB_LIST_HANDLER *sendit,
 223                     void *ctx, e_list_type type)
 224 {
 225    db_lock(mdb);
 226    if (type == VERT_LIST) {
 227       if (jr->JobId == 0 && jr->Job[0] == 0) {
 228          Mmsg(&mdb->cmd,
 229             "SELECT JobId,Job,Job.Name,PurgedFiles,Type,Level,"
 230             "Job.ClientId,Client.Name,JobStatus,SchedTime,"
 231             "StartTime,EndTime,JobTDate,"
 232             "VolSessionId,VolSessionTime,JobFiles,JobErrors,"
 233             "JobMissingFiles,Job.PoolId,Pool.Name,Job.FileSetId,FileSet.FileSet "
 234             "FROM Job,Client,Pool,FileSet WHERE "
 235             "Client.ClientId=Job.ClientId AND Pool.PoolId=Job.PoolId "
 236             "AND FileSet.FileSetId=Job.FileSetId  ORDER BY StartTime");
 237       } else {                           /* single record */
 238          Mmsg(&mdb->cmd,
 239             "SELECT JobId,Job,Job.Name,PurgedFiles,Type,Level,"
 240             "Job.ClientId,Client.Name,JobStatus,SchedTime,"
 241             "StartTime,EndTime,JobTDate,"
 242             "VolSessionId,VolSessionTime,JobFiles,JobErrors,"
 243             "JobMissingFiles,Job.PoolId,Pool.Name,Job.FileSetId,FileSet.FileSet "
 244             "FROM Job,Client,Pool,FileSet WHERE Job.JobId=%u AND "
 245             "Client.ClientId=Job.ClientId AND Pool.PoolId=Job.PoolId "
 246             "AND FileSet.FileSetId=Job.FileSetId", jr->JobId);
 247       }
 248    } else {
 249       if (jr->JobId == 0 && jr->Job[0] == 0) {
 250          Mmsg(&mdb->cmd,
 251            "SELECT JobId,Name,StartTime,Type,Level,JobFiles,JobBytes,JobStatus "
 252            "FROM Job ORDER BY StartTime");
 253       } else {                           /* single record */
 254          Mmsg(&mdb->cmd, "SELECT JobId,Name,StartTime,Type,Level,"
 255             "JobFiles,JobBytes,JobStatus FROM Job WHERE JobId=%u", jr->JobId);
 256       }
 257    }
 258    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
 259       db_unlock(mdb);
 260       return;
 261    }
 262    list_result(jcr, mdb, sendit, ctx, type);
 263
 264    sql_free_result(mdb);
 265    db_unlock(mdb);
 266 }
 267
 268 /*
 269  * List Job totals
 270  *
 271  */
 272 void
 273 db_list_job_totals(JCR *jcr, B_DB *mdb, JOB_DBR *jr, DB_LIST_HANDLER *sendit, void *ctx)
 274 {
 275    db_lock(mdb);
 276
 277    /* List by Job */
 278    Mmsg(&mdb->cmd, "SELECT  count(*) AS Jobs,sum(JobFiles) "
 279       "AS Files,sum(JobBytes) AS Bytes,Name AS Job FROM Job GROUP BY Name");
 280
 281    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
 282       db_unlock(mdb);
 283       return;
 284    }
 285
 286    list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
 287
 288    sql_free_result(mdb);
 289
 290    /* Do Grand Total */
 291    Mmsg(&mdb->cmd, "SELECT count(*) AS Jobs,sum(JobFiles) \
 292 AS Files,sum(JobBytes) As Bytes FROM Job");
 293
 294    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
 295       db_unlock(mdb);
 296       return;
 297    }
 298
 299    list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
 300
 301    sql_free_result(mdb);
 302    db_unlock(mdb);
 303 }
 304
 305 /*
 306  * Stupid MySQL is NON-STANDARD !
 307  */
 308 #ifdef HAVE_MYSQL
 309 #define FN "CONCAT(Path.Path,Filename.Name)"
 310 #else
 311 #define FN "Path.Path||Filename.Name"
 312 #endif
 313
 314 void
 315 db_list_files_for_job(JCR *jcr, B_DB *mdb, uint32_t jobid, DB_LIST_HANDLER *sendit, void *ctx)
 316 {
 317    db_lock(mdb);
 318
 319    Mmsg(&mdb->cmd, "SELECT " FN " AS Filename FROM File,"
 320 "Filename,Path WHERE File.JobId=%u AND Filename.FilenameId=File.FilenameId "
 321 "AND Path.PathId=File.PathId",
 322       jobid);
 323
 324    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
 325       db_unlock(mdb);
 326       return;
 327    }
 328
 329    list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
 330
 331    sql_free_result(mdb);
 332    db_unlock(mdb);
 333 }
 334
 335
 336 #endif /* HAVE_MYSQL || HAVE_SQLITE || HAVE_POSTGRESQL */