2 * Bacula Catalog Database Update record interface routines
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
11 * Kern Sibbald, January MMI
18 Copyright (C) 2001-2003 Kern Sibbald and John Walker
20 This program is free software; you can redistribute it and/or
21 modify it under the terms of the GNU General Public License as
22 published by the Free Software Foundation; either version 2 of
23 the License, or (at your option) any later version.
25 This program is distributed in the hope that it will be useful,
26 but WITHOUT ANY WARRANTY; without even the implied warranty of
27 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
28 General Public License for more details.
30 You should have received a copy of the GNU General Public
31 License along with this program; if not, write to the Free
32 Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
38 /* The following is necessary so that we do not include
39 * the dummy external definition of DB.
41 #define __SQL_C /* indicate that this is sql.c */
49 /* Forward referenced functions */
51 /* -----------------------------------------------------------------------
53 * Bacula specific defines and subroutines
55 * -----------------------------------------------------------------------
60 * This is called at Job start time to add the
61 * most current start fields to the job record.
62 * It is assumed that you did a db_create_job_record() already.
64 int db_update_job_start_record(JCR *jcr, B_DB *mdb, JOB_DBR *jr)
71 Dmsg0(200, "In db_update_job_start_record\n");
73 memcpy(&ojr, jr, len);
75 if (!db_get_job_record(jcr, mdb, &ojr)) {
81 fseek(mdb->jobfd, ojr.rec_addr, SEEK_SET);
82 if (fwrite(jr, len, 1, mdb->jobfd) != 1) {
83 Mmsg1(&mdb->errmsg, _("Error updating DB Job file. ERR=%s\n"), strerror(errno));
93 * This is called at Job termination time to add all the
94 * other fields to the job record.
96 int db_update_job_end_record(JCR *jcr, B_DB *mdb, JOB_DBR *jr)
103 Dmsg0(200, "In db_update_job_start_record\n");
105 memcpy(&ojr, jr, len);
107 if (!db_get_job_record(jcr, mdb, &ojr)) {
112 fseek(mdb->jobfd, ojr.rec_addr, SEEK_SET);
113 if (fwrite(jr, len, 1, mdb->jobfd) != 1) {
114 Mmsg1(&mdb->errmsg, _("Error updating DB Job file. ERR=%s\n"), strerror(errno));
124 int db_update_media_record(JCR *jcr, B_DB *mdb, MEDIA_DBR *mr)
131 Dmsg0(200, "In db_update_media_record\n");
134 memcpy(&omr, mr, len);
136 if (!db_get_media_record(jcr, mdb, &omr)) {
142 /* Don't allow some fields to change by copying from master record */
143 strcpy(mr->VolumeName, omr.VolumeName);
144 strcpy(mr->MediaType, omr.MediaType);
145 mr->MediaId = omr.MediaId;
146 mr->PoolId = omr.PoolId;
147 mr->MaxVolBytes = omr.MaxVolBytes;
148 mr->VolCapacityBytes = omr.VolCapacityBytes;
149 mr->Recycle = omr.Recycle;
151 fseek(mdb->mediafd, omr.rec_addr, SEEK_SET);
152 if (fwrite(mr, len, 1, mdb->mediafd) != 1) {
153 Mmsg1(&mdb->errmsg, _("Error updating DB Media file. ERR=%s\n"), strerror(errno));
156 fflush(mdb->mediafd);
162 int db_update_pool_record(JCR *jcr, B_DB *mdb, POOL_DBR *pr)
169 Dmsg0(200, "In db_update_pool_record\n");
171 memcpy(&opr, pr, len);
173 if (!db_get_pool_record(jcr, mdb, &opr)) {
179 /* Update specific fields */
180 opr.NumVols = pr->NumVols;
181 opr.MaxVols = pr->MaxVols;
182 opr.UseOnce = pr->UseOnce;
183 opr.UseCatalog = pr->UseCatalog;
184 opr.AcceptAnyVolume = pr->AcceptAnyVolume;
185 strcpy(opr.LabelFormat, pr->LabelFormat);
187 fseek(mdb->poolfd, opr.rec_addr, SEEK_SET);
188 if (fwrite(&opr, len, 1, mdb->poolfd) != 1) {
189 Mmsg1(&mdb->errmsg, _("Error updating DB Media file. ERR=%s\n"), strerror(errno));
192 memcpy(pr, &opr, len); /* return record written */
200 int db_add_SIG_to_file_record(JCR *jcr, B_DB *mdb, FileId_t FileId, char *SIG, int type)
205 int db_mark_file_record(JCR *jcr, B_DB *mdb, FileId_t FileId, JobId_t JobId)
210 int db_update_client_record(JCR *jcr, B_DB *mdb, CLIENT_DBR *cr)
215 int db_update_counter_record(JCR *jcr, B_DB *mdb, COUNTER_DBR *cr)
221 #endif /* HAVE_BACULA_DB */