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

   1 /*
   2  * Bacula Catalog Database Find record interface routines
   3  *
   4  *  Note, generally, these routines are more complicated
   5  *        that a simple search by name or id. Such simple
   6  *        request are in get.c
   7  *
   8  *    Kern Sibbald, December 2000
   9  *
  10  *    Version $Id$
  11  */
  12
  13 /*
  14    Copyright (C) 2000-2004 Kern Sibbald and John Walker
  15
  16    This program is free software; you can redistribute it and/or
  17    modify it under the terms of the GNU General Public License as
  18    published by the Free Software Foundation; either version 2 of
  19    the License, or (at your option) any later version.
  20
  21    This program is distributed in the hope that it will be useful,
  22    but WITHOUT ANY WARRANTY; without even the implied warranty of
  23    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  24    General Public License for more details.
  25
  26    You should have received a copy of the GNU General Public
  27    License along with this program; if not, write to the Free
  28    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  29    MA 02111-1307, USA.
  30
  31  */
  32
  33
  34 /* The following is necessary so that we do not include
  35  * the dummy external definition of DB.
  36  */
  37 #define __SQL_C                       /* indicate that this is sql.c */
  38
  39 #include "bacula.h"
  40 #include "cats.h"
  41
  42 #if    HAVE_MYSQL || HAVE_SQLITE || HAVE_POSTGRESQL
  43
  44 /* -----------------------------------------------------------------------
  45  *
  46  *   Generic Routines (or almost generic)
  47  *
  48  * -----------------------------------------------------------------------
  49  */
  50
  51 /* Imported subroutines */
  52 extern void print_result(B_DB *mdb);
  53 extern int QueryDB(const char *file, int line, JCR *jcr, B_DB *db, char *select_cmd);
  54
  55 /*
  56  * Find job start time if JobId specified, otherwise
  57  * find last full save for Incremental and Differential saves.
  58  *
  59  *  StartTime is returned in stime
  60  *
  61  * Returns: 0 on failure
  62  *          1 on success, jr is unchanged, but stime is set
  63  */
  64 int
  65 db_find_job_start_time(JCR *jcr, B_DB *mdb, JOB_DBR *jr, POOLMEM **stime)
  66 {
  67    SQL_ROW row;
  68
  69    db_lock(mdb);
  70
  71    pm_strcpy(stime, "0000-00-00 00:00:00");   /* default */
  72    /* If no Id given, we must find corresponding job */
  73    if (jr->JobId == 0) {
  74       /* Differential is since last Full backup */
  75          Mmsg(mdb->cmd,
  76 "SELECT StartTime FROM Job WHERE JobStatus='T' AND Type='%c' AND "
  77 "Level='%c' AND Name='%s' AND ClientId=%u AND FileSetId=%u "
  78 "ORDER BY StartTime DESC LIMIT 1",
  79            jr->JobType, L_FULL, jr->Name, jr->ClientId, jr->FileSetId);
  80
  81       if (jr->JobLevel == L_DIFFERENTIAL) {
  82          /* SQL cmd for Differential backup already edited above */
  83
  84       /* Incremental is since last Full, Incremental, or Differential */
  85       } else if (jr->JobLevel == L_INCREMENTAL) {
  86          /*
  87           * For an Incremental job, we must first ensure
  88           *  that a Full backup was done (cmd edited above)
  89           *  then we do a second look to find the most recent
  90           *  backup
  91           */
  92          if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
  93             Mmsg2(&mdb->errmsg, _("Query error for start time request: ERR=%s\nCMD=%s\n"),
  94                sql_strerror(mdb), mdb->cmd);
  95             db_unlock(mdb);
  96             return 0;
  97          }
  98          if ((row = sql_fetch_row(mdb)) == NULL) {
  99             sql_free_result(mdb);
 100             Mmsg(mdb->errmsg, _("No prior Full backup Job record found.\n"));
 101             db_unlock(mdb);
 102             return 0;
 103          }
 104          sql_free_result(mdb);
 105          /* Now edit SQL command for Incremental Job */
 106          Mmsg(mdb->cmd,
 107 "SELECT StartTime FROM Job WHERE JobStatus='T' AND Type='%c' AND "
 108 "Level IN ('%c','%c','%c') AND Name='%s' AND ClientId=%u "
 109 "AND FileSetId=%u ORDER BY StartTime DESC LIMIT 1",
 110             jr->JobType, L_INCREMENTAL, L_DIFFERENTIAL, L_FULL, jr->Name,
 111             jr->ClientId, jr->FileSetId);
 112       } else {
 113          Mmsg1(&mdb->errmsg, _("Unknown level=%d\n"), jr->JobLevel);
 114          db_unlock(mdb);
 115          return 0;
 116       }
 117    } else {
 118       Dmsg1(100, "Submitting: %s\n", mdb->cmd);
 119       Mmsg(mdb->cmd, "SELECT StartTime FROM Job WHERE Job.JobId=%u", jr->JobId);
 120    }
 121
 122    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
 123       pm_strcpy(stime, "");                   /* set EOS */
 124       Mmsg2(&mdb->errmsg, _("Query error for start time request: ERR=%s\nCMD=%s\n"),
 125          sql_strerror(mdb),  mdb->cmd);
 126       db_unlock(mdb);
 127       return 0;
 128    }
 129
 130    if ((row = sql_fetch_row(mdb)) == NULL) {
 131       Mmsg2(&mdb->errmsg, _("No Job record found: ERR=%s\nCMD=%s\n"),
 132          sql_strerror(mdb),  mdb->cmd);
 133       sql_free_result(mdb);
 134       db_unlock(mdb);
 135       return 0;
 136    }
 137    Dmsg1(100, "Got start time: %s\n", row[0]);
 138    pm_strcpy(stime, row[0]);
 139
 140    sql_free_result(mdb);
 141
 142    db_unlock(mdb);
 143    return 1;
 144 }
 145
 146 /*
 147  * Find JobId of last job that ran.  E.g. for
 148  *   VERIFY_CATALOG we want the JobId of the last INIT.
 149  *   For VERIFY_VOLUME_TO_CATALOG, we want the JobId of the last Job.
 150  *
 151  * Returns: 1 on success
 152  *          0 on failure
 153  */
 154 int
 155 db_find_last_jobid(JCR *jcr, B_DB *mdb, const char *Name, JOB_DBR *jr)
 156 {
 157    SQL_ROW row;
 158
 159    /* Find last full */
 160    db_lock(mdb);
 161    if (jr->JobLevel == L_VERIFY_CATALOG) {
 162       Mmsg(mdb->cmd,
 163 "SELECT JobId FROM Job WHERE Type='V' AND Level='%c' AND "
 164 " JobStatus='T' AND Name='%s' AND "
 165 "ClientId=%u ORDER BY StartTime DESC LIMIT 1",
 166            L_VERIFY_INIT, jr->Name, jr->ClientId);
 167    } else if (jr->JobLevel == L_VERIFY_VOLUME_TO_CATALOG ||
 168               jr->JobLevel == L_VERIFY_DISK_TO_CATALOG) {
 169       if (Name) {
 170          Mmsg(mdb->cmd,
 171 "SELECT JobId FROM Job WHERE Type='B' AND JobStatus='T' AND "
 172 "Name='%s' ORDER BY StartTime DESC LIMIT 1", Name);
 173       } else {
 174          Mmsg(mdb->cmd,
 175 "SELECT JobId FROM Job WHERE Type='B' AND JobStatus='T' AND "
 176 "ClientId=%u ORDER BY StartTime DESC LIMIT 1", jr->ClientId);
 177       }
 178    } else {
 179       Mmsg1(&mdb->errmsg, _("Unknown Job level=%c\n"), jr->JobLevel);
 180       db_unlock(mdb);
 181       return 0;
 182    }
 183    Dmsg1(100, "Query: %s\n", mdb->cmd);
 184    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
 185       db_unlock(mdb);
 186       return 0;
 187    }
 188    if ((row = sql_fetch_row(mdb)) == NULL) {
 189       Mmsg1(&mdb->errmsg, _("No Job found for: %s.\n"), mdb->cmd);
 190       sql_free_result(mdb);
 191       db_unlock(mdb);
 192       return 0;
 193    }
 194
 195    jr->JobId = atoi(row[0]);
 196    sql_free_result(mdb);
 197
 198    Dmsg1(100, "db_get_last_jobid: got JobId=%d\n", jr->JobId);
 199    if (jr->JobId <= 0) {
 200       Mmsg1(&mdb->errmsg, _("No Job found for: %s\n"), mdb->cmd);
 201       db_unlock(mdb);
 202       return 0;
 203    }
 204
 205    db_unlock(mdb);
 206    return 1;
 207 }
 208
 209 /*
 210  * Find Available Media (Volume) for Pool
 211  *
 212  * Find a Volume for a given PoolId, MediaType, and Status.
 213  *
 214  * Returns: 0 on failure
 215  *          numrows on success
 216  */
 217 int
 218 db_find_next_volume(JCR *jcr, B_DB *mdb, int item, bool InChanger, MEDIA_DBR *mr)
 219 {
 220    SQL_ROW row;
 221    int numrows;
 222    const char *changer, *order;
 223
 224    db_lock(mdb);
 225    if (item == -1) {       /* find oldest volume */
 226       /* Find oldest volume */
 227       Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,VolJobs,VolFiles,VolBlocks,"
 228           "VolBytes,VolMounts,VolErrors,VolWrites,MaxVolBytes,VolCapacityBytes,"
 229           "VolRetention,VolUseDuration,MaxVolJobs,MaxVolFiles,Recycle,Slot,"
 230           "FirstWritten,LastWritten,VolStatus,InChanger "
 231           "FROM Media WHERE PoolId=%u AND MediaType='%s' AND VolStatus IN ('Full',"
 232           "'Recycle','Purged','Used','Append') "
 233           "ORDER BY LastWritten LIMIT 1", mr->PoolId, mr->MediaType);
 234      item = 1;
 235    } else {
 236       /* Find next available volume */
 237       if (InChanger) {
 238          changer = "AND InChanger=1";
 239       } else {
 240          changer = "";
 241       }
 242       if (strcmp(mr->VolStatus, "Recycled") == 0 ||
 243           strcmp(mr->VolStatus, "Purged") == 0) {
 244          order = "ORDER BY LastWritten ASC,MediaId";  /* take oldest */
 245       } else {
 246          order = "ORDER BY LastWritten IS NULL,LastWritten DESC,MediaId";   /* take most recently written */
 247       }
 248       Mmsg(mdb->cmd, "SELECT MediaId,VolumeName,VolJobs,VolFiles,VolBlocks,"
 249           "VolBytes,VolMounts,VolErrors,VolWrites,MaxVolBytes,VolCapacityBytes,"
 250           "VolRetention,VolUseDuration,MaxVolJobs,MaxVolFiles,Recycle,Slot,"
 251           "FirstWritten,LastWritten,VolStatus,InChanger "
 252           "FROM Media WHERE PoolId=%u AND MediaType='%s' AND VolStatus='%s' "
 253           "%s "
 254           "%s LIMIT %d",
 255           mr->PoolId, mr->MediaType, mr->VolStatus, changer, order, item);
 256    }
 257    if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
 258       db_unlock(mdb);
 259       return 0;
 260    }
 261
 262    numrows = sql_num_rows(mdb);
 263    if (item > numrows) {
 264       Mmsg2(&mdb->errmsg, _("Request for Volume item %d greater than max %d\n"),
 265          item, numrows);
 266       db_unlock(mdb);
 267       return 0;
 268    }
 269
 270    /* Seek to desired item
 271     * Note, we use base 1; SQL uses base 0
 272     */
 273    sql_data_seek(mdb, item-1);
 274
 275    if ((row = sql_fetch_row(mdb)) == NULL) {
 276       Mmsg1(&mdb->errmsg, _("No Volume record found for item %d.\n"), item);
 277       sql_free_result(mdb);
 278       db_unlock(mdb);
 279       return 0;
 280    }
 281
 282    /* Return fields in Media Record */
 283    mr->MediaId = str_to_int64(row[0]);
 284    bstrncpy(mr->VolumeName, row[1], sizeof(mr->VolumeName));
 285    mr->VolJobs = str_to_int64(row[2]);
 286    mr->VolFiles = str_to_int64(row[3]);
 287    mr->VolBlocks = str_to_int64(row[4]);
 288    mr->VolBytes = str_to_uint64(row[5]);
 289    mr->VolMounts = str_to_int64(row[6]);
 290    mr->VolErrors = str_to_int64(row[7]);
 291    mr->VolWrites = str_to_int64(row[8]);
 292    mr->MaxVolBytes = str_to_uint64(row[9]);
 293    mr->VolCapacityBytes = str_to_uint64(row[10]);
 294    mr->VolRetention = str_to_uint64(row[11]);
 295    mr->VolUseDuration = str_to_uint64(row[12]);
 296    mr->MaxVolJobs = str_to_int64(row[13]);
 297    mr->MaxVolFiles = str_to_int64(row[14]);
 298    mr->Recycle = str_to_int64(row[15]);
 299    mr->Slot = str_to_int64(row[16]);
 300    bstrncpy(mr->cFirstWritten, row[17]!=NULL?row[17]:"", sizeof(mr->cFirstWritten));
 301    mr->FirstWritten = (time_t)str_to_utime(mr->cFirstWritten);
 302    bstrncpy(mr->cLastWritten, row[18]!=NULL?row[18]:"", sizeof(mr->cLastWritten));
 303    mr->LastWritten = (time_t)str_to_utime(mr->cLastWritten);
 304    bstrncpy(mr->VolStatus, row[19], sizeof(mr->VolStatus));
 305    mr->InChanger = str_to_int64(row[20]);
 306    sql_free_result(mdb);
 307
 308    db_unlock(mdb);
 309    return numrows;
 310 }
 311
 312
 313 #endif /* HAVE_MYSQL || HAVE_SQLITE || HAVE_POSTGRESQL */