X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=bacula%2Fsrc%2Fcats%2Fsql_update.c;h=520c1b553a10faee2074be66eed5ebaf97f5ccb8;hb=75c8f56ea801b916a43e807e56bb9149b0ecf653;hp=5c646f0ea89ac45538c8a236e5a4442125a17642;hpb=f7fb2261ab648bfc02a32773b7a5a2201783e189;p=bacula%2Fbacula diff --git a/bacula/src/cats/sql_update.c b/bacula/src/cats/sql_update.c index 5c646f0ea8..520c1b553a 100644 --- a/bacula/src/cats/sql_update.c +++ b/bacula/src/cats/sql_update.c @@ -60,21 +60,21 @@ db_add_MD5_to_file_record(B_DB *mdb, FileId_t FileId, char *MD5) int stat; db_lock(mdb); - Mmsg(&mdb->cmd, "UPDATE File SET MD5=\"%s\" WHERE FileId=%d", MD5, FileId); + Mmsg(&mdb->cmd, "UPDATE File SET MD5='%s' WHERE FileId=%u", MD5, FileId); stat = UPDATE_DB(mdb, mdb->cmd); db_unlock(mdb); return stat; } /* Mark the file record as being visited during database - * verify compare. Stuff JobId into FileIndex field + * verify compare. Stuff JobId into MarkedId field */ -int db_mark_file_record(B_DB *mdb, FileId_t FileId, int JobId) +int db_mark_file_record(B_DB *mdb, FileId_t FileId, JobId_t JobId) { int stat; db_lock(mdb); - Mmsg(&mdb->cmd, "UPDATE File SET FileIndex=%d WHERE FileId=%d", JobId, FileId); + Mmsg(&mdb->cmd, "UPDATE File SET MarkId=%u WHERE FileId=%u", JobId, FileId); stat = UPDATE_DB(mdb, mdb->cmd); db_unlock(mdb); return stat; @@ -102,11 +102,12 @@ db_update_job_start_record(B_DB *mdb, JOB_DBR *jr) JobTDate = (btime_t)stime; db_lock(mdb); - Mmsg(&mdb->cmd, "UPDATE Job SET Level='%c', StartTime=\"%s\", \ -ClientId=%d, JobTDate=%s WHERE JobId=%d", + Mmsg(&mdb->cmd, "UPDATE Job SET Level='%c', StartTime='%s', \ +ClientId=%u, JobTDate=%s WHERE JobId=%u", (char)(jr->Level), dt, jr->ClientId, edit_uint64(JobTDate, ed1), jr->JobId); stat = UPDATE_DB(mdb, mdb->cmd); db_unlock(mdb); + mdb->changes = 0; return stat; } @@ -136,8 +137,8 @@ db_update_job_end_record(B_DB *mdb, JOB_DBR *jr) db_lock(mdb); Mmsg(&mdb->cmd, "UPDATE Job SET JobStatus='%c', EndTime='%s', \ -ClientId=%d, JobBytes=%s, JobFiles=%d, JobErrors=%d, VolSessionId=%d, \ -VolSessionTime=%d, PoolId=%d, FileSetId=%d, JobTDate=%s WHERE JobId=%d", +ClientId=%u, JobBytes=%s, JobFiles=%u, JobErrors=%u, VolSessionId=%u, \ +VolSessionTime=%u, PoolId=%u, FileSetId=%u, JobTDate=%s WHERE JobId=%u", (char)(jr->JobStatus), dt, jr->ClientId, edit_uint64(jr->JobBytes, ed1), jr->JobFiles, jr->JobErrors, jr->VolSessionId, jr->VolSessionTime, jr->PoolId, jr->FileSetId, edit_uint64(JobTDate, ed2), jr->JobId); @@ -156,7 +157,7 @@ db_update_pool_record(B_DB *mdb, POOL_DBR *pr) db_lock(mdb); Mmsg(&mdb->cmd, "UPDATE Pool SET NumVols=%d, MaxVols=%d, UseOnce=%d, UseCatalog=%d, \ -AcceptAnyVolume=%d, LabelFormat=\"%s\" WHERE PoolId=%d", +AcceptAnyVolume=%d, LabelFormat='%s' WHERE PoolId=%u", pr->NumVols, pr->MaxVols, pr->UseOnce, pr->UseCatalog, pr->AcceptAnyVolume, pr->LabelFormat, pr->PoolId); @@ -186,20 +187,24 @@ db_update_media_record(B_DB *mdb, MEDIA_DBR *mr) Dmsg1(100, "update_media: FirstWritten=%d\n", mr->FirstWritten); db_lock(mdb); - if (mr->VolMounts == 1) { - Mmsg(&mdb->cmd, "UPDATE Media SET FirstWritten=\"%s\"\ - WHERE VolumeName=\"%s\"", dt, mr->VolumeName); - UPDATE_DB(mdb, mdb->cmd); + if (mr->VolMounts == 1 && mr->VolBlocks==1 && mr->VolWrites==1) { + Dmsg1(400, "Set FirstWritten Vol=%s\n", mr->VolumeName); + Mmsg(&mdb->cmd, "UPDATE Media SET FirstWritten='%s'\ + WHERE VolumeName='%s'", dt, mr->VolumeName); + stat = UPDATE_DB(mdb, mdb->cmd); + Dmsg1(400, "Firstwritten stat=%d\n", stat); } - Mmsg(&mdb->cmd, "UPDATE Media SET VolJobs=%d,\ - VolFiles=%d, VolBlocks=%d, VolBytes=%s, VolMounts=%d, VolErrors=%d,\ - VolWrites=%d, VolMaxBytes=%s, LastWritten=\"%s\", VolStatus=\"%s\" \ - WHERE VolumeName=\"%s\"", + Mmsg(&mdb->cmd, "UPDATE Media SET VolJobs=%u,\ + VolFiles=%u, VolBlocks=%u, VolBytes=%s, VolMounts=%u, VolErrors=%u,\ + VolWrites=%u, VolMaxBytes=%s, LastWritten='%s', VolStatus='%s',\ + Slot=%d WHERE VolumeName='%s'", mr->VolJobs, mr->VolFiles, mr->VolBlocks, edit_uint64(mr->VolBytes, ed1), mr->VolMounts, mr->VolErrors, mr->VolWrites, edit_uint64(mr->VolMaxBytes, ed2), dt, - mr->VolStatus, mr->VolumeName); + mr->VolStatus, mr->Slot, mr->VolumeName); + + Dmsg1(400, "%s\n", mdb->cmd); stat = UPDATE_DB(mdb, mdb->cmd); db_unlock(mdb);