X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=bacula%2Fsrc%2Fcats%2Fsql_delete.c;h=b52c3796515c9dd469f0639efe5e6538ebf16c23;hb=513c2c6cf9c7991273cf3330404575aafae6d8a2;hp=c24c7863178fb02e40e7397f7e46d1254b7a055d;hpb=7232c33915addb5a96a729e9dd1d09cb22127c60;p=bacula%2Fbacula diff --git a/bacula/src/cats/sql_delete.c b/bacula/src/cats/sql_delete.c index c24c786317..b52c379651 100644 --- a/bacula/src/cats/sql_delete.c +++ b/bacula/src/cats/sql_delete.c @@ -1,43 +1,33 @@ /* - * Bacula Catalog Database Delete record interface routines - * - * Kern Sibbald, December 2000 - * - * Version $Id$ - */ + Bacula(R) - The Network Backup Solution -/* - Copyright (C) 2000-2005 Kern Sibbald + Copyright (C) 2000-2016 Kern Sibbald - This program is free software; you can redistribute it and/or - modify it under the terms of the GNU General Public License as - published by the Free Software Foundation; either version 2 of - the License, or (at your option) any later version. + The original author of Bacula is Kern Sibbald, with contributions + from many others, a complete list can be found in the file AUTHORS. - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - General Public License for more details. + You may use this file and others of this release according to the + license defined in the LICENSE file, which includes the Affero General + Public License, v3.0 ("AGPLv3") and some additional permissions and + terms pursuant to its AGPLv3 Section 7. - You should have received a copy of the GNU General Public - License along with this program; if not, write to the Free - Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, - MA 02111-1307, USA. + This notice must be preserved when any source code is + conveyed and/or propagated. + Bacula(R) is a registered trademark of Kern Sibbald. +*/ +/* + * Bacula Catalog Database Delete record interface routines + * + * Written by Kern Sibbald, December 2000-2014 + * */ -/* *****FIXME**** fix fixed length of select_cmd[] and insert_cmd[] */ - -/* The following is necessary so that we do not include - * the dummy external definition of DB. - */ -#define __SQL_C /* indicate that this is sql.c */ - -#include "bacula.h" -#include "cats.h" - +#include "bacula.h" -#if HAVE_SQLITE3 || HAVE_MYSQL || HAVE_SQLITE || HAVE_POSTGRESQL +#if HAVE_SQLITE3 || HAVE_MYSQL || HAVE_POSTGRESQL +#include "cats.h" + /* ----------------------------------------------------------------------- * * Generic Routines (or almost generic) @@ -45,70 +35,63 @@ * ----------------------------------------------------------------------- */ -/* Imported subroutines */ -extern void print_dashes(B_DB *mdb); -extern void print_result(B_DB *mdb); -extern int QueryDB(const char *file, int line, JCR *jcr, B_DB *db, char *select_cmd); -extern int DeleteDB(const char *file, int line, JCR *jcr, B_DB *db, char *delete_cmd); - /* * Delete Pool record, must also delete all associated * Media records. * * Returns: 0 on error - * 1 on success - * PoolId = number of Pools deleted (should be 1) - * NumVols = number of Media records deleted + * 1 on success + * PoolId = number of Pools deleted (should be 1) + * NumVols = number of Media records deleted */ -int -db_delete_pool_record(JCR *jcr, B_DB *mdb, POOL_DBR *pr) +int BDB::bdb_delete_pool_record(JCR *jcr, POOL_DBR *pr) { SQL_ROW row; + char esc[MAX_ESCAPE_NAME_LENGTH]; - db_lock(mdb); - Mmsg(mdb->cmd, "SELECT PoolId FROM Pool WHERE Name='%s'", pr->Name); - Dmsg1(10, "selectpool: %s\n", mdb->cmd); + bdb_lock(); + bdb_escape_string(jcr, esc, pr->Name, strlen(pr->Name)); + Mmsg(cmd, "SELECT PoolId FROM Pool WHERE Name='%s'", esc); + Dmsg1(10, "selectpool: %s\n", cmd); pr->PoolId = pr->NumVols = 0; - if (QUERY_DB(jcr, mdb, mdb->cmd)) { - - mdb->num_rows = sql_num_rows(mdb); - - if (mdb->num_rows == 0) { - Mmsg(mdb->errmsg, _("No pool record %s exists\n"), pr->Name); - sql_free_result(mdb); - db_unlock(mdb); - return 0; - } else if (mdb->num_rows != 1) { - Mmsg(mdb->errmsg, _("Expecting one pool record, got %d\n"), mdb->num_rows); - sql_free_result(mdb); - db_unlock(mdb); - return 0; + if (QueryDB(jcr, cmd)) { + int nrows = sql_num_rows(); + if (nrows == 0) { + Mmsg(errmsg, _("No pool record %s exists\n"), pr->Name); + sql_free_result(); + bdb_unlock(); + return 0; + } else if (nrows != 1) { + Mmsg(errmsg, _("Expecting one pool record, got %d\n"), nrows); + sql_free_result(); + bdb_unlock(); + return 0; } - if ((row = sql_fetch_row(mdb)) == NULL) { - Mmsg1(&mdb->errmsg, _("Error fetching row %s\n"), sql_strerror(mdb)); - db_unlock(mdb); - return 0; + if ((row = sql_fetch_row()) == NULL) { + Mmsg1(&errmsg, _("Error fetching row %s\n"), sql_strerror()); + bdb_unlock(); + return 0; } - pr->PoolId = atoi(row[0]); - sql_free_result(mdb); + pr->PoolId = str_to_int64(row[0]); + sql_free_result(); } /* Delete Media owned by this pool */ - Mmsg(mdb->cmd, + Mmsg(cmd, "DELETE FROM Media WHERE Media.PoolId = %d", pr->PoolId); - pr->NumVols = DELETE_DB(jcr, mdb, mdb->cmd); + pr->NumVols = DeleteDB(jcr, cmd); Dmsg1(200, "Deleted %d Media records\n", pr->NumVols); /* Delete Pool */ - Mmsg(mdb->cmd, + Mmsg(cmd, "DELETE FROM Pool WHERE Pool.PoolId = %d", pr->PoolId); - pr->PoolId = DELETE_DB(jcr, mdb, mdb->cmd); + pr->PoolId = DeleteDB(jcr, cmd); Dmsg1(200, "Deleted %d Pool records\n", pr->PoolId); - db_unlock(mdb); + bdb_unlock(); return 1; } @@ -116,10 +99,10 @@ db_delete_pool_record(JCR *jcr, B_DB *mdb, POOL_DBR *pr) struct s_del_ctx { JobId_t *JobId; - int num_ids; /* ids stored */ - int max_ids; /* size of array */ - int num_del; /* number deleted */ - int tot_ids; /* total to process */ + int num_ids; /* ids stored */ + int max_ids; /* size of array */ + int num_del; /* number deleted */ + int tot_ids; /* total to process */ }; /* @@ -139,7 +122,7 @@ static int delete_handler(void *ctx, int num_fields, char **row) if (del->num_ids == del->max_ids) { del->max_ids = (del->max_ids * 3) / 2; del->JobId = (JobId_t *)brealloc(del->JobId, sizeof(JobId_t) * - del->max_ids); + del->max_ids); } del->JobId[del->num_ids++] = (JobId_t)str_to_int64(row[0]); return 0; @@ -150,8 +133,12 @@ static int delete_handler(void *ctx, int num_fields, char **row) * This routine will purge (delete) all records * associated with a particular Volume. It will * not delete the media record itself. + * TODO: This function is broken and it doesn't purge + * File, BaseFiles, Log, ... + * We call it from relabel and delete volume=, both ensure + * that the volume is properly purged. */ -static int do_media_purge(B_DB *mdb, MEDIA_DBR *mr) +static int do_media_purge(BDB *mdb, MEDIA_DBR *mr) { POOLMEM *query = get_pool_memory(PM_MESSAGE); struct s_del_ctx del; @@ -170,16 +157,16 @@ static int do_media_purge(B_DB *mdb, MEDIA_DBR *mr) del.max_ids = MAX_DEL_LIST_LEN; } del.JobId = (JobId_t *)malloc(sizeof(JobId_t) * del.max_ids); - db_sql_query(mdb, mdb->cmd, delete_handler, (void *)&del); + mdb->bdb_sql_query(mdb->cmd, delete_handler, (void *)&del); for (i=0; i < del.num_ids; i++) { Dmsg1(400, "Delete JobId=%d\n", del.JobId[i]); Mmsg(query, "DELETE FROM Job WHERE JobId=%s", edit_int64(del.JobId[i], ed1)); - db_sql_query(mdb, query, NULL, (void *)NULL); + mdb->bdb_sql_query(query, NULL, (void *)NULL); Mmsg(query, "DELETE FROM File WHERE JobId=%s", edit_int64(del.JobId[i], ed1)); - db_sql_query(mdb, query, NULL, (void *)NULL); + mdb->bdb_sql_query(query, NULL, (void *)NULL); Mmsg(query, "DELETE FROM JobMedia WHERE JobId=%s", edit_int64(del.JobId[i], ed1)); - db_sql_query(mdb, query, NULL, (void *)NULL); + mdb->bdb_sql_query(query, NULL, (void *)NULL); } free(del.JobId); free_pool_memory(query); @@ -189,22 +176,22 @@ static int do_media_purge(B_DB *mdb, MEDIA_DBR *mr) /* Delete Media record and all records that * are associated with it. */ -int db_delete_media_record(JCR *jcr, B_DB *mdb, MEDIA_DBR *mr) +int BDB::bdb_delete_media_record(JCR *jcr, MEDIA_DBR *mr) { - db_lock(mdb); - if (mr->MediaId == 0 && !db_get_media_record(jcr, mdb, mr)) { - db_unlock(mdb); + bdb_lock(); + if (mr->MediaId == 0 && !bdb_get_media_record(jcr, mr)) { + bdb_unlock(); return 0; } /* Do purge if not already purged */ if (strcmp(mr->VolStatus, "Purged") != 0) { /* Delete associated records */ - do_media_purge(mdb, mr); + do_media_purge(this, mr); } - Mmsg(mdb->cmd, "DELETE FROM Media WHERE MediaId=%d", mr->MediaId); - db_sql_query(mdb, mdb->cmd, NULL, (void *)NULL); - db_unlock(mdb); + Mmsg(cmd, "DELETE FROM Media WHERE MediaId=%d", mr->MediaId); + bdb_sql_query(cmd, NULL, (void *)NULL); + bdb_unlock(); return 1; } @@ -214,26 +201,40 @@ int db_delete_media_record(JCR *jcr, B_DB *mdb, MEDIA_DBR *mr) * media record itself. But the media status * is changed to "Purged". */ -int db_purge_media_record(JCR *jcr, B_DB *mdb, MEDIA_DBR *mr) +int BDB::bdb_purge_media_record(JCR *jcr, MEDIA_DBR *mr) { - db_lock(mdb); - if (mr->MediaId == 0 && !db_get_media_record(jcr, mdb, mr)) { - db_unlock(mdb); + bdb_lock(); + if (mr->MediaId == 0 && !bdb_get_media_record(jcr, mr)) { + bdb_unlock(); return 0; } /* Delete associated records */ - do_media_purge(mdb, mr); /* Note, always purge */ + do_media_purge(this, mr); /* Note, always purge */ /* Mark Volume as purged */ strcpy(mr->VolStatus, "Purged"); - if (!db_update_media_record(jcr, mdb, mr)) { - db_unlock(mdb); + if (!bdb_update_media_record(jcr, mr)) { + bdb_unlock(); return 0; } - db_unlock(mdb); + bdb_unlock(); return 1; } +/* Delete Snapshot record */ +int BDB::bdb_delete_snapshot_record(JCR *jcr, SNAPSHOT_DBR *sr) +{ + bdb_lock(); + if (sr->SnapshotId == 0 && !bdb_get_snapshot_record(jcr, sr)) { + bdb_unlock(); + return 0; + } + + Mmsg(cmd, "DELETE FROM Snapshot WHERE SnapshotId=%d", sr->SnapshotId); + bdb_sql_query(cmd, NULL, (void *)NULL); + bdb_unlock(); + return 1; +} -#endif /* HAVE_SQLITE3 || HAVE_MYSQL || HAVE_SQLITE || HAVE_POSTGRESQL*/ +#endif /* HAVE_SQLITE3 || HAVE_MYSQL || HAVE_POSTGRESQL */