Line data Source code
1 : /********************************************************************\
2 : * gnc-job-sql.c -- job sql backend *
3 : * *
4 : * This program is free software; you can redistribute it and/or *
5 : * modify it under the terms of the GNU General Public License as *
6 : * published by the Free Software Foundation; either version 2 of *
7 : * the License, or (at your option) any later version. *
8 : * *
9 : * This program is distributed in the hope that it will be useful, *
10 : * but WITHOUT ANY WARRANTY; without even the implied warranty of *
11 : * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
12 : * GNU General Public License for more details. *
13 : * *
14 : * You should have received a copy of the GNU General Public License*
15 : * along with this program; if not, contact: *
16 : * *
17 : * Free Software Foundation Voice: +1-617-542-5942 *
18 : * 51 Franklin Street, Fifth Floor Fax: +1-617-542-2652 *
19 : * Boston, MA 02110-1301, USA gnu@gnu.org *
20 : * *
21 : \********************************************************************/
22 :
23 : /** @file gnc-job-sql.c
24 : * @brief load and save address data to SQL
25 : * @author Copyright (c) 2007-2008 Phil Longstaff <plongstaff@rogers.com>
26 : *
27 : * This file implements the top-level QofBackend API for saving/
28 : * restoring data to/from an SQL database
29 : */
30 : #include <glib.h>
31 :
32 : #include <config.h>
33 :
34 : #include <stdlib.h>
35 : #include <string.h>
36 :
37 : #include "gncJobP.h"
38 :
39 : #include "gnc-sql-connection.hpp"
40 : #include "gnc-sql-backend.hpp"
41 : #include "gnc-sql-object-backend.hpp"
42 : #include "gnc-sql-column-table-entry.hpp"
43 : #include "gnc-slots-sql.h"
44 : #include "gnc-job-sql.h"
45 :
46 : #define _GNC_MOD_NAME GNC_ID_JOB
47 :
48 : G_GNUC_UNUSED static QofLogModule log_module = G_LOG_DOMAIN;
49 :
50 : #define TABLE_NAME "jobs"
51 : #define TABLE_VERSION 1
52 :
53 : #define MAX_ID_LEN 2048
54 : #define MAX_NAME_LEN 2048
55 : #define MAX_REFERENCE_LEN 2048
56 :
57 : static EntryVec col_table
58 : ({
59 : gnc_sql_make_table_entry<CT_GUID>("guid", 0, COL_NNUL | COL_PKEY, "guid"),
60 : gnc_sql_make_table_entry<CT_STRING>("id", MAX_ID_LEN, COL_NNUL,
61 : JOB_ID, true),
62 : gnc_sql_make_table_entry<CT_STRING>("name", MAX_NAME_LEN, COL_NNUL, "name"),
63 : gnc_sql_make_table_entry<CT_STRING>("reference", MAX_REFERENCE_LEN,
64 : COL_NNUL, JOB_REFERENCE, true),
65 : gnc_sql_make_table_entry<CT_BOOLEAN>("active", 0, COL_NNUL,
66 : (QofAccessFunc)gncJobGetActive,
67 : (QofSetterFunc)gncJobSetActive),
68 : gnc_sql_make_table_entry<CT_OWNERREF>("owner", 0, 0,
69 : (QofAccessFunc)gncJobGetOwner,
70 : (QofSetterFunc)gncJobSetOwner),
71 : });
72 :
73 15 : GncSqlJobBackend::GncSqlJobBackend() :
74 30 : GncSqlObjectBackend(TABLE_VERSION, GNC_ID_JOB,
75 75 : TABLE_NAME, col_table) {}
76 :
77 : static GncJob*
78 1 : load_single_job (GncSqlBackend* sql_be, GncSqlRow& row)
79 : {
80 : const GncGUID* guid;
81 : GncJob* pJob;
82 :
83 1 : g_return_val_if_fail (sql_be != NULL, NULL);
84 :
85 1 : guid = gnc_sql_load_guid (sql_be, row);
86 1 : pJob = gncJobLookup (sql_be->book(), guid);
87 1 : if (pJob == NULL)
88 : {
89 0 : pJob = gncJobCreate (sql_be->book());
90 : }
91 1 : gnc_sql_load_object (sql_be, row, GNC_ID_JOB, pJob, col_table);
92 1 : qof_instance_mark_clean (QOF_INSTANCE (pJob));
93 :
94 1 : return pJob;
95 : }
96 :
97 : /* Because gncJobLookup has the arguments backwards: */
98 : static inline GncJob*
99 0 : gnc_job_lookup (const GncGUID *guid, const QofBook *book)
100 : {
101 0 : QOF_BOOK_RETURN_ENTITY(book, guid, GNC_ID_JOB, GncJob);
102 : }
103 :
104 : void
105 7 : GncSqlJobBackend::load_all (GncSqlBackend* sql_be)
106 : {
107 7 : g_return_if_fail (sql_be != NULL);
108 :
109 7 : std::string sql("SELECT * FROM " TABLE_NAME);
110 7 : auto stmt = sql_be->create_statement_from_sql(sql);
111 7 : auto result = sql_be->execute_select_statement(stmt);
112 :
113 8 : for (auto row : *result)
114 8 : load_single_job (sql_be, row);
115 :
116 7 : std::string pkey(col_table[0]->name());
117 7 : sql = "SELECT DISTINCT ";
118 7 : sql += pkey + " FROM " TABLE_NAME;
119 7 : gnc_sql_slots_load_for_sql_subquery (sql_be, sql,
120 : (BookLookupFn)gnc_job_lookup);
121 7 : }
122 :
123 : /* ================================================================= */
124 : static gboolean
125 1 : job_should_be_saved (GncJob* job)
126 : {
127 : const char* id;
128 :
129 1 : g_return_val_if_fail (job != NULL, FALSE);
130 :
131 : /* make sure this is a valid job before we save it -- should have an ID */
132 1 : id = gncJobGetID (job);
133 1 : if (id == NULL || *id == '\0')
134 : {
135 0 : return FALSE;
136 : }
137 :
138 1 : return TRUE;
139 : }
140 :
141 : static void
142 1 : write_single_job (QofInstance* term_p, gpointer data_p)
143 : {
144 1 : auto s = reinterpret_cast<write_objects_t*>(data_p);
145 :
146 1 : g_return_if_fail (term_p != NULL);
147 1 : g_return_if_fail (GNC_IS_JOB (term_p));
148 1 : g_return_if_fail (data_p != NULL);
149 :
150 1 : if (s->is_ok && job_should_be_saved (GNC_JOB (term_p)))
151 : {
152 1 : s->commit (term_p);
153 : }
154 : }
155 :
156 : bool
157 6 : GncSqlJobBackend::write (GncSqlBackend* sql_be)
158 : {
159 6 : g_return_val_if_fail (sql_be != NULL, FALSE);
160 6 : write_objects_t data{sql_be, true, this};
161 :
162 6 : qof_object_foreach (GNC_ID_JOB, sql_be->book(), write_single_job, &data);
163 :
164 6 : return data.is_ok;
165 : }
166 :
167 : /* ========================== END OF FILE ===================== */
|
