git.sur5r.net Git - bacula/bacula/blob - bacula/src/cats/bdb_list.c

   1 /*
   2  * Bacula Catalog Database List records interface routines
   3  *
   4  * Bacula Catalog Database routines written specifically
   5  *  for Bacula.  Note, these routines are VERY dumb and
   6  *  do not provide all the functionality of an SQL database.
   7  *  The purpose of these routines is to ensure that Bacula
   8  *  can limp along if no real database is loaded on the
   9  *  system.
  10  *
  11  *    Kern Sibbald, January MMI
  12  *
  13  *    Version $Id$
  14  */
  15
  16 /*
  17    Copyright (C) 2001-2006 Kern Sibbald
  18
  19    This program is free software; you can redistribute it and/or
  20    modify it under the terms of the GNU General Public License
  21    version 2 as amended with additional clauses defined in the
  22    file LICENSE in the main source directory.
  23
  24    This program is distributed in the hope that it will be useful,
  25    but WITHOUT ANY WARRANTY; without even the implied warranty of
  26    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  27    the file LICENSE for additional details.
  28
  29  */
  30
  31
  32 /* The following is necessary so that we do not include
  33  * the dummy external definition of DB.
  34  */
  35 #define __SQL_C                       /* indicate that this is sql.c */
  36
  37 #include "bacula.h"
  38 #include "cats.h"
  39 #include "bdb.h"
  40
  41 #ifdef HAVE_BACULA_DB
  42
  43 /* Forward referenced functions */
  44
  45 /* -----------------------------------------------------------------------
  46  *
  47  *   Bacula specific defines and subroutines
  48  *
  49  * -----------------------------------------------------------------------
  50  */
  51
  52 /*
  53  * Submit general SQL query
  54  */
  55 int db_list_sql_query(JCR *jcr, B_DB *mdb, const char *query, DB_LIST_HANDLER *sendit,
  56                       void *ctx, int verbose)
  57 {
  58    sendit(ctx, "SQL Queries not implemented with internal database.\n");
  59    return 0;
  60 }
  61
  62
  63 /*
  64  * List all the pool records
  65  */
  66 void db_list_pool_records(JCR *jcr, B_DB *mdb, DB_LIST_HANDLER *sendit, void *ctx)
  67 {
  68    int len;
  69    POOL_DBR pr;
  70
  71    Dmsg0(90, "Enter list_pool_records\n");
  72    db_lock(mdb);
  73    if (!bdb_open_pools_file(mdb)) {
  74       db_unlock(mdb);
  75       return;
  76    }
  77    sendit(ctx, "  PoolId NumVols MaxVols  Type       PoolName\n");
  78    sendit(ctx, "===================================================\n");
  79    fseek(mdb->poolfd, 0L, SEEK_SET);   /* rewind file */
  80    len = sizeof(pr);
  81    while (fread(&pr, len, 1, mdb->poolfd) > 0) {
  82          Mmsg(mdb->cmd, " %7d  %6d  %6d  %-10s %s\n",
  83             pr.PoolId, pr.NumVols, pr.MaxVols, pr.PoolType, pr.Name);
  84          sendit(ctx, mdb->cmd);
  85    }
  86    sendit(ctx, "===================================================\n");
  87    db_unlock(mdb);
  88    Dmsg0(90, "Leave list_pool_records\n");
  89    return;
  90 }
  91
  92
  93 /*
  94  * List Media records
  95  */
  96 void db_list_media_records(JCR *jcr, B_DB *mdb, MEDIA_DBR *mdbr,
  97                            DB_LIST_HANDLER *sendit, void *ctx)
  98 {
  99    char ewc[30];
 100    int len;
 101    MEDIA_DBR mr;
 102
 103    db_lock(mdb);
 104    if (!bdb_open_media_file(mdb)) {
 105       db_unlock(mdb);
 106       return;
 107    }
 108    sendit(ctx, "  Status           VolBytes  MediaType        VolumeName\n");
 109    sendit(ctx, "=============================================================\n");
 110    fseek(mdb->mediafd, 0L, SEEK_SET);   /* rewind file */
 111    len = sizeof(mr);
 112    while (fread(&mr, len, 1, mdb->mediafd) > 0) {
 113          Mmsg(mdb->cmd, " %-10s %17s %-15s  %s\n",
 114             mr.VolStatus, edit_uint64_with_commas(mr.VolBytes, ewc),
 115             mr.MediaType, mr.VolumeName);
 116          sendit(ctx, mdb->cmd);
 117    }
 118    sendit(ctx, "====================================================================\n");
 119    db_unlock(mdb);
 120    return;
 121 }
 122
 123 void db_list_jobmedia_records(JCR *jcr, B_DB *mdb, uint32_t JobId,
 124                               DB_LIST_HANDLER *sendit, void *ctx)
 125 {
 126    JOBMEDIA_DBR jm;
 127    MEDIA_DBR mr;
 128    int jmlen, mrlen;
 129
 130    db_lock(mdb);
 131    if (!bdb_open_jobmedia_file(mdb)) {
 132       db_unlock(mdb);
 133       return;
 134    }
 135    if (!bdb_open_media_file(mdb)) {
 136       db_unlock(mdb);
 137       return;
 138    }
 139    sendit(ctx, "    JobId VolumeName    FirstIndex LastIndex\n");
 140    sendit(ctx, "============================================\n");
 141    jmlen = sizeof(jm);
 142    mrlen = sizeof(mr);
 143    fseek(mdb->jobmediafd, 0L, SEEK_SET); /* rewind the file */
 144    while (fread(&jm, jmlen, 1, mdb->jobmediafd) > 0) {
 145       /* List by JobId */
 146       if (JobId != 0) {
 147          if (jm.JobId == JobId) {
 148             /* Now find VolumeName in corresponding Media record */
 149             fseek(mdb->mediafd, 0L, SEEK_SET);
 150             while (fread(&mr, mrlen, 1, mdb->mediafd) > 0) {
 151                if (mr.MediaId == jm.MediaId) {
 152                   Mmsg(mdb->cmd, " %7d  %-10s %10d %10d\n",
 153                        jm.JobId, mr.VolumeName, jm.FirstIndex, jm.LastIndex);
 154                   sendit(ctx, mdb->cmd);
 155                   break;
 156                }
 157             }
 158          }
 159       } else {
 160          /* List all records */
 161          fseek(mdb->mediafd, 0L, SEEK_SET);
 162          while (fread(&mr, mrlen, 1, mdb->mediafd) > 0) {
 163             if (mr.MediaId == jm.MediaId) {
 164                Mmsg(mdb->cmd, " %7d  %-10s %10d %10d\n",
 165                     jm.JobId, mr.VolumeName, jm.FirstIndex, jm.LastIndex);
 166                sendit(ctx, mdb->cmd);
 167                break;
 168             }
 169          }
 170       }
 171    }
 172
 173    sendit(ctx, "============================================\n");
 174    db_unlock(mdb);
 175    return;
 176 }
 177
 178
 179 /*
 180  * List Job records
 181  */
 182 void db_list_job_records(JCR *jcr, B_DB *mdb, JOB_DBR *jr,
 183                          DB_LIST_HANDLER *sendit, void *ctx)
 184 {
 185    int jrlen;
 186    JOB_DBR ojr;
 187    int done = 0;
 188    char ewc1[30], ewc2[30];
 189    char dt[MAX_TIME_LENGTH];
 190    struct tm tm;
 191
 192    db_lock(mdb);
 193    if (!bdb_open_jobs_file(mdb)) {
 194       db_unlock(mdb);
 195       return;
 196    }
 197    fseek(mdb->jobfd, 0L, SEEK_SET);   /* rewind file */
 198    /*
 199     * Linear search through Job records
 200     */
 201    sendit(ctx, "   JobId   StartTime   Type Level         Bytes      Files Stat JobName\n");
 202    sendit(ctx, "==========================================================================\n");
 203    jrlen = sizeof(ojr);
 204    while (!done && fread(&ojr, jrlen, 1, mdb->jobfd) > 0) {
 205       if (jr->JobId != 0) {
 206          if (jr->JobId == ojr.JobId) {
 207             done = 1;
 208          } else {
 209             continue;
 210          }
 211       }
 212       localtime_r(&ojr.StartTime, &tm);
 213       strftime(dt, sizeof(dt), "%m-%d %H:%M", &tm);
 214       Mmsg(mdb->cmd, " %7d  %-10s   %c    %c   %14s %10s  %c  %s\n",
 215                 ojr.JobId, dt, (char)ojr.JobType, (char)ojr.JobLevel,
 216                 edit_uint64_with_commas(ojr.JobBytes, ewc1),
 217                 edit_uint64_with_commas(ojr.JobFiles, ewc2),
 218                 (char)ojr.JobStatus, ojr.Name);
 219       sendit(ctx, mdb->cmd);
 220    }
 221    sendit(ctx, "============================================================================\n");
 222    db_unlock(mdb);
 223    return;
 224 }
 225
 226
 227 /*
 228  * List Job Totals
 229  */
 230 void db_list_job_totals(JCR *jcr, B_DB *mdb, JOB_DBR *jr,
 231                         DB_LIST_HANDLER *sendit, void *ctx)
 232 {
 233    char ewc1[30], ewc2[30], ewc3[30];
 234    int jrlen;
 235    JOB_DBR ojr;
 236    uint64_t total_bytes = 0;
 237    uint64_t total_files = 0;
 238    uint32_t total_jobs = 0;
 239
 240    db_lock(mdb);
 241    if (!bdb_open_jobs_file(mdb)) {
 242       db_unlock(mdb);
 243       return;
 244    }
 245    fseek(mdb->jobfd, 0L, SEEK_SET);   /* rewind file */
 246    /*
 247     * Linear search through JobStart records
 248     */
 249    sendit(ctx, "   NumJobs   NumFiles          NumBytes\n");
 250    sendit(ctx, "=======================================\n");
 251    jrlen = sizeof(ojr);
 252    while (fread(&ojr, jrlen, 1, mdb->jobfd) > 0) {
 253       total_files += ojr.JobFiles;
 254       total_bytes += ojr.JobBytes;
 255       total_jobs++;
 256    }
 257    Mmsg(mdb->cmd, " %7s  %10s   %15s\n",
 258              edit_uint64_with_commas(total_jobs, ewc1),
 259              edit_uint64_with_commas(total_files, ewc2),
 260              edit_uint64_with_commas(total_bytes, ewc3));
 261    sendit(ctx, mdb->cmd);
 262    sendit(ctx, "=======================================\n");
 263    db_unlock(mdb);
 264    return;
 265 }
 266
 267
 268
 269 void db_list_files_for_job(JCR *jcr, B_DB *mdb, uint32_t jobid, DB_LIST_HANDLER *sendit, void *ctx)
 270 { }
 271
 272 void db_list_client_records(JCR *jcr, B_DB *mdb, DB_LIST_HANDLER *sendit, void *ctx)
 273 { }
 274
 275 int db_list_sql_query(JCR *jcr, B_DB *mdb, const char *query, DB_LIST_HANDLER *sendit,
 276                       void *ctx, int verbose, e_list_type type)
 277 {
 278    return 0;
 279 }
 280
 281 void
 282 db_list_pool_records(JCR *jcr, B_DB *mdb, DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
 283 { }
 284
 285 void
 286 db_list_media_records(JCR *jcr, B_DB *mdb, MEDIA_DBR *mdbr,
 287                       DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
 288 { }
 289
 290 void db_list_jobmedia_records(JCR *jcr, B_DB *mdb, uint32_t JobId,
 291                               DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
 292 { }
 293
 294 void
 295 db_list_job_records(JCR *jcr, B_DB *mdb, JOB_DBR *jr, DB_LIST_HANDLER *sendit,
 296                     void *ctx, e_list_type type)
 297 { }
 298
 299 void
 300 db_list_client_records(JCR *jcr, B_DB *mdb, DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
 301 { }
 302
 303
 304
 305
 306 #endif /* HAVE_BACULA_DB */