/*
- * Bacula Catalog Database Delete record interface routines
- *
- * Kern Sibbald, December 2000
- *
- * Version $Id$
- */
-
-/*
- Copyright (C) 2000-2006 Kern Sibbald
+ Bacula(R) - The Network Backup Solution
- This program is free software; you can redistribute it and/or
- modify it under the terms of the GNU General Public License
- version 2 as amended with additional clauses defined in the
- file LICENSE in the main source directory.
+ Copyright (C) 2000-2016 Kern Sibbald
- 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
- the file LICENSE for additional details.
+ The original author of Bacula is Kern Sibbald, with contributions
+ from many others, a complete list can be found in the file AUTHORS.
- */
+ 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.
-/* *****FIXME**** fix fixed length of select_cmd[] and insert_cmd[] */
+ This notice must be preserved when any source code is
+ conveyed and/or propagated.
-/* The following is necessary so that we do not include
- * the dummy external definition of DB.
+ Bacula(R) is a registered trademark of Kern Sibbald.
+*/
+/*
+ * Bacula Catalog Database Delete record interface routines
+ *
+ * Written by Kern Sibbald, December 2000-2014
+ *
*/
-#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)
* 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);
+ 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 (mdb->num_rows != 1) {
- Mmsg(mdb->errmsg, _("Expecting one pool record, got %d\n"), mdb->num_rows);
- sql_free_result(mdb);
- db_unlock(mdb);
+ } 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);
+ if ((row = sql_fetch_row()) == NULL) {
+ Mmsg1(&errmsg, _("Error fetching row %s\n"), sql_strerror());
+ bdb_unlock();
return 0;
}
pr->PoolId = str_to_int64(row[0]);
- sql_free_result(mdb);
+ 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;
}
* 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;
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);
/* 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;
}
* 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 */
projects / bacula / bacula / blobdiff