*/
#include "bacula.h"
-#include "cats.h"
#if HAVE_SQLITE3 || HAVE_MYSQL || HAVE_POSTGRESQL || HAVE_INGRES || HAVE_DBI
int db_list_sql_query(JCR *jcr, B_DB *mdb, const char *query, DB_LIST_HANDLER *sendit,
void *ctx, int verbose, e_list_type type)
{
- LIST_CTX lctx(jcr, mdb, sendit, ctx, type);
-
db_lock(mdb);
-
- if (!db_big_sql_query(mdb, query, list_result, &lctx)) {
+ if (!sql_query(mdb, query, QF_STORE_RESULT)) {
Mmsg(mdb->errmsg, _("Query failed: %s\n"), sql_strerror(mdb));
if (verbose) {
sendit(ctx, mdb->errmsg);
return 0;
}
- lctx.send_dashes();
-
+ list_result(jcr, mdb, sendit, ctx, type);
sql_free_result(mdb);
db_unlock(mdb);
return 1;
DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
{
char esc[MAX_ESCAPE_NAME_LENGTH];
- LIST_CTX lctx(jcr, mdb, sendit, ctx, type);
db_lock(mdb);
mdb->db_escape_string(jcr, esc, pdbr->Name, strlen(pdbr->Name));
}
}
- if (!db_big_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
+ if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
db_unlock(mdb);
return;
}
- lctx.send_dashes();
+ list_result(jcr, mdb, sendit, ctx, type);
sql_free_result(mdb);
db_unlock(mdb);
void
db_list_client_records(JCR *jcr, B_DB *mdb, DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
{
- LIST_CTX lctx(jcr, mdb, sendit, ctx, type);
-
db_lock(mdb);
if (type == VERT_LIST) {
Mmsg(mdb->cmd, "SELECT ClientId,Name,Uname,AutoPrune,FileRetention,"
"FROM Client ORDER BY ClientId");
}
- if (!db_big_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
+ if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
db_unlock(mdb);
return;
}
- lctx.send_dashes();
+
+ list_result(jcr, mdb, sendit, ctx, type);
sql_free_result(mdb);
db_unlock(mdb);
{
char ed1[50];
char esc[MAX_ESCAPE_NAME_LENGTH];
- LIST_CTX lctx(jcr, mdb, sendit, ctx, type);
db_lock(mdb);
mdb->db_escape_string(jcr, esc, mdbr->VolumeName, strlen(mdbr->VolumeName));
}
}
- if (!db_big_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
+ if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
db_unlock(mdb);
return;
}
- lctx.send_dashes();
+ list_result(jcr, mdb, sendit, ctx, type);
sql_free_result(mdb);
db_unlock(mdb);
DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
{
char ed1[50];
- LIST_CTX lctx(jcr, mdb, sendit, ctx, type);
-
db_lock(mdb);
if (type == VERT_LIST) {
if (JobId > 0) { /* do by JobId */
"FROM JobMedia,Media WHERE Media.MediaId=JobMedia.MediaId");
}
}
-
- if (!db_big_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
+ if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
db_unlock(mdb);
return;
}
- lctx.send_dashes();
+ list_result(jcr, mdb, sendit, ctx, type);
sql_free_result(mdb);
db_unlock(mdb);
void db_list_copies_records(JCR *jcr, B_DB *mdb, uint32_t limit, char *JobIds,
DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
{
- LIST_CTX lctx(jcr, mdb, sendit, ctx, type);
POOL_MEM str_limit(PM_MESSAGE);
POOL_MEM str_jobids(PM_MESSAGE);
"WHERE Job.Type = '%c' %s ORDER BY Job.PriorJobId DESC %s",
(char) JT_JOB_COPY, str_jobids.c_str(), str_limit.c_str());
- if (JobIds && JobIds[0]) {
- sendit(ctx, _("These JobIds have copies as follows:\n"));
- } else {
- sendit(ctx, _("The catalog contains copies as follows:\n"));
- }
-
- if (!db_big_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
+ if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
goto bail_out;
}
- lctx.send_dashes();
+ if (sql_num_rows(mdb)) {
+ if (JobIds && JobIds[0]) {
+ sendit(ctx, _("These JobIds have copies as follows:\n"));
+ } else {
+ sendit(ctx, _("The catalog contains copies as follows:\n"));
+ }
+
+ list_result(jcr, mdb, sendit, ctx, type);
+ }
sql_free_result(mdb);
DB_LIST_HANDLER *sendit, void *ctx, e_list_type type)
{
char ed1[50];
- LIST_CTX lctx(jcr, mdb, sendit, ctx, type);
if (JobId <= 0) {
return;
Mmsg(mdb->cmd, "SELECT LogText FROM Log "
"WHERE Log.JobId=%s", edit_int64(JobId, ed1));
}
-
- if (!db_big_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
+ if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
goto bail_out;
}
- lctx.send_dashes();
+ list_result(jcr, mdb, sendit, ctx, type);
sql_free_result(mdb);
char ed1[50];
char limit[100];
char esc[MAX_ESCAPE_NAME_LENGTH];
- LIST_CTX lctx(jcr, mdb, sendit, ctx, type);
db_lock(mdb);
if (jr->limit > 0) {
"FROM Job ORDER BY StartTime,JobId ASC%s", limit);
}
}
-
- if (!db_big_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
+ if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
db_unlock(mdb);
return;
}
- lctx.send_dashes();
+ list_result(jcr, mdb, sendit, ctx, type);
sql_free_result(mdb);
db_unlock(mdb);
void
db_list_job_totals(JCR *jcr, B_DB *mdb, JOB_DBR *jr, DB_LIST_HANDLER *sendit, void *ctx)
{
- LIST_CTX lctx(jcr, mdb, sendit, ctx, HORZ_LIST);
-
db_lock(mdb);
/* List by Job */
Mmsg(mdb->cmd, "SELECT count(*) AS Jobs,sum(JobFiles) "
"AS Files,sum(JobBytes) AS Bytes,Name AS Job FROM Job GROUP BY Name");
- if (!db_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
+ if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
db_unlock(mdb);
return;
}
- lctx.send_dashes();
+
+ list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
sql_free_result(mdb);
Mmsg(mdb->cmd, "SELECT count(*) AS Jobs,sum(JobFiles) "
"AS Files,sum(JobBytes) As Bytes FROM Job");
- lctx.empty();
- if (!db_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
+ if (!QUERY_DB(jcr, mdb, mdb->cmd)) {
db_unlock(mdb);
return;
}
- lctx.send_dashes();
+ list_result(jcr, mdb, sendit, ctx, HORZ_LIST);
sql_free_result(mdb);
db_unlock(mdb);
void
db_list_files_for_job(JCR *jcr, B_DB *mdb, JobId_t jobid, DB_LIST_HANDLER *sendit, void *ctx)
{
- LIST_CTX lctx(jcr, mdb, sendit, ctx, HORZ_LIST);
char ed1[50];
+ LIST_CTX lctx(jcr, mdb, sendit, ctx, HORZ_LIST);
db_lock(mdb);
}
if (!db_big_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
- db_unlock(mdb);
- return;
+ db_unlock(mdb);
+ return;
}
-
+
lctx.send_dashes();
sql_free_result(mdb);
void
db_list_base_files_for_job(JCR *jcr, B_DB *mdb, JobId_t jobid, DB_LIST_HANDLER *sendit, void *ctx)
{
- LIST_CTX lctx(jcr, mdb, sendit, ctx, HORZ_LIST);
char ed1[50];
+ LIST_CTX lctx(jcr, mdb, sendit, ctx, HORZ_LIST);
db_lock(mdb);
}
if (!db_big_sql_query(mdb, mdb->cmd, list_result, &lctx)) {
- db_unlock(mdb);
- return;
+ db_unlock(mdb);
+ return;
}
lctx.send_dashes();