-rw-r--r-- | libopie/pim/ocontactaccessbackend_sql.cpp | 5 | ||||
-rw-r--r-- | libopie/pim/ocontactaccessbackend_sql.h | 10 | ||||
-rw-r--r-- | libopie/pim/odatebookaccessbackend_sql.cpp | 4 | ||||
-rw-r--r-- | libopie/pim/odatebookaccessbackend_sql.h | 7 | ||||
-rw-r--r-- | libopie/pim/otodoaccesssql.cpp | 1 | ||||
-rw-r--r-- | libopie/pim/otodoaccesssql.h | 13 |
6 files changed, 31 insertions, 9 deletions
diff --git a/libopie/pim/ocontactaccessbackend_sql.cpp b/libopie/pim/ocontactaccessbackend_sql.cpp index a5be4c8..d20df56 100644 --- a/libopie/pim/ocontactaccessbackend_sql.cpp +++ b/libopie/pim/ocontactaccessbackend_sql.cpp | |||
@@ -1,572 +1,575 @@ | |||
1 | /* | 1 | /* |
2 | * SQL Backend for the OPIE-Contact Database. | 2 | * SQL Backend for the OPIE-Contact Database. |
3 | * | 3 | * |
4 | * Copyright (c) 2002 by Stefan Eilers (Eilers.Stefan@epost.de) | 4 | * Copyright (c) 2002 by Stefan Eilers (Eilers.Stefan@epost.de) |
5 | * | 5 | * |
6 | * ===================================================================== | 6 | * ===================================================================== |
7 | *This program is free software; you can redistribute it and/or | 7 | *This program is free software; you can redistribute it and/or |
8 | *modify it under the terms of the GNU Library General Public | 8 | *modify it under the terms of the GNU Library General Public |
9 | * License as published by the Free Software Foundation; either | 9 | * License as published by the Free Software Foundation; either |
10 | * version 2 of the License, or (at your option) any later version. | 10 | * version 2 of the License, or (at your option) any later version. |
11 | * ===================================================================== | 11 | * ===================================================================== |
12 | * ===================================================================== | 12 | * ===================================================================== |
13 | * Version: $Id$ | 13 | * Version: $Id$ |
14 | * ===================================================================== | 14 | * ===================================================================== |
15 | * History: | 15 | * History: |
16 | * $Log$ | 16 | * $Log$ |
17 | * Revision 1.5 2004/03/14 13:50:35 alwin | ||
18 | * namespace correction | ||
19 | * | ||
17 | * Revision 1.4 2003/12/22 10:19:26 eilers | 20 | * Revision 1.4 2003/12/22 10:19:26 eilers |
18 | * Finishing implementation of sql-backend for datebook. But I have to | 21 | * Finishing implementation of sql-backend for datebook. But I have to |
19 | * port the PIM datebook application to use it, before I could debug the | 22 | * port the PIM datebook application to use it, before I could debug the |
20 | * whole stuff. | 23 | * whole stuff. |
21 | * Thus, PIM-Database backend is finished, but highly experimental. And some | 24 | * Thus, PIM-Database backend is finished, but highly experimental. And some |
22 | * parts are still generic. For instance, the "queryByExample()" methods are | 25 | * parts are still generic. For instance, the "queryByExample()" methods are |
23 | * not (or not fully) implemented. Todo: custom-entries not stored. | 26 | * not (or not fully) implemented. Todo: custom-entries not stored. |
24 | * The big show stopper: matchRegExp() (needed by OpieSearch) needs regular | 27 | * The big show stopper: matchRegExp() (needed by OpieSearch) needs regular |
25 | * expression search in the database, which is not supported by sqlite ! | 28 | * expression search in the database, which is not supported by sqlite ! |
26 | * Therefore we need either an extended sqlite or a workaround which would | 29 | * Therefore we need either an extended sqlite or a workaround which would |
27 | * be very slow and memory consuming.. | 30 | * be very slow and memory consuming.. |
28 | * | 31 | * |
29 | * Revision 1.3 2003/12/08 15:18:10 eilers | 32 | * Revision 1.3 2003/12/08 15:18:10 eilers |
30 | * Committing unfinished sql implementation before merging to libopie2 starts.. | 33 | * Committing unfinished sql implementation before merging to libopie2 starts.. |
31 | * | 34 | * |
32 | * Revision 1.2 2003/09/29 07:44:26 eilers | 35 | * Revision 1.2 2003/09/29 07:44:26 eilers |
33 | * Improvement of PIM-SQL Databases, but search queries are still limited. | 36 | * Improvement of PIM-SQL Databases, but search queries are still limited. |
34 | * Addressbook: Changed table layout. Now, we just need 1/3 of disk-space. | 37 | * Addressbook: Changed table layout. Now, we just need 1/3 of disk-space. |
35 | * Todo: Started to add new attributes. Some type conversions missing. | 38 | * Todo: Started to add new attributes. Some type conversions missing. |
36 | * | 39 | * |
37 | * Revision 1.1 2003/09/22 14:31:16 eilers | 40 | * Revision 1.1 2003/09/22 14:31:16 eilers |
38 | * Added first experimental incarnation of sql-backend for addressbook. | 41 | * Added first experimental incarnation of sql-backend for addressbook. |
39 | * Some modifications to be able to compile the todo sql-backend. | 42 | * Some modifications to be able to compile the todo sql-backend. |
40 | * A lot of changes fill follow... | 43 | * A lot of changes fill follow... |
41 | * | 44 | * |
42 | */ | 45 | */ |
43 | 46 | ||
44 | #include "ocontactaccessbackend_sql.h" | 47 | #include "ocontactaccessbackend_sql.h" |
45 | 48 | ||
46 | #include <qarray.h> | 49 | #include <qarray.h> |
47 | #include <qdatetime.h> | 50 | #include <qdatetime.h> |
48 | #include <qstringlist.h> | 51 | #include <qstringlist.h> |
49 | 52 | ||
50 | #include <qpe/global.h> | 53 | #include <qpe/global.h> |
51 | #include <qpe/recordfields.h> | 54 | #include <qpe/recordfields.h> |
52 | 55 | ||
53 | #include <opie/ocontactfields.h> | 56 | #include <opie/ocontactfields.h> |
54 | #include <opie/oconversion.h> | 57 | #include <opie/oconversion.h> |
55 | #include <opie2/osqldriver.h> | 58 | #include <opie2/osqldriver.h> |
56 | #include <opie2/osqlresult.h> | 59 | #include <opie2/osqlresult.h> |
57 | #include <opie2/osqlmanager.h> | 60 | #include <opie2/osqlmanager.h> |
58 | #include <opie2/osqlquery.h> | 61 | #include <opie2/osqlquery.h> |
59 | 62 | ||
60 | 63 | using namespace Opie::DB; | |
61 | 64 | ||
62 | 65 | ||
63 | // If defined, we use a horizontal table ( uid, attr1, attr2, attr3, ..., attrn ) instead | 66 | // If defined, we use a horizontal table ( uid, attr1, attr2, attr3, ..., attrn ) instead |
64 | // vertical like "uid, type, value". | 67 | // vertical like "uid, type, value". |
65 | // DON'T DEACTIVATE THIS DEFINE IN PRODUCTIVE ENVIRONMENTS !! | 68 | // DON'T DEACTIVATE THIS DEFINE IN PRODUCTIVE ENVIRONMENTS !! |
66 | #define __STORE_HORIZONTAL_ | 69 | #define __STORE_HORIZONTAL_ |
67 | 70 | ||
68 | // Distinct loading is not very fast. If I expect that every person has just | 71 | // Distinct loading is not very fast. If I expect that every person has just |
69 | // one (and always one) 'Last Name', I can request all uid's for existing lastnames, | 72 | // one (and always one) 'Last Name', I can request all uid's for existing lastnames, |
70 | // which is faster.. | 73 | // which is faster.. |
71 | // But this may not be true for all entries, like company contacts.. | 74 | // But this may not be true for all entries, like company contacts.. |
72 | // The current AddressBook application handles this problem, but other may not.. (eilers) | 75 | // The current AddressBook application handles this problem, but other may not.. (eilers) |
73 | #define __USE_SUPERFAST_LOADQUERY | 76 | #define __USE_SUPERFAST_LOADQUERY |
74 | 77 | ||
75 | 78 | ||
76 | /* | 79 | /* |
77 | * Implementation of used query types | 80 | * Implementation of used query types |
78 | * CREATE query | 81 | * CREATE query |
79 | * LOAD query | 82 | * LOAD query |
80 | * INSERT | 83 | * INSERT |
81 | * REMOVE | 84 | * REMOVE |
82 | * CLEAR | 85 | * CLEAR |
83 | */ | 86 | */ |
84 | namespace { | 87 | namespace { |
85 | /** | 88 | /** |
86 | * CreateQuery for the Todolist Table | 89 | * CreateQuery for the Todolist Table |
87 | */ | 90 | */ |
88 | class CreateQuery : public OSQLQuery { | 91 | class CreateQuery : public OSQLQuery { |
89 | public: | 92 | public: |
90 | CreateQuery(); | 93 | CreateQuery(); |
91 | ~CreateQuery(); | 94 | ~CreateQuery(); |
92 | QString query()const; | 95 | QString query()const; |
93 | }; | 96 | }; |
94 | 97 | ||
95 | /** | 98 | /** |
96 | * Clears (delete) a Table | 99 | * Clears (delete) a Table |
97 | */ | 100 | */ |
98 | class ClearQuery : public OSQLQuery { | 101 | class ClearQuery : public OSQLQuery { |
99 | public: | 102 | public: |
100 | ClearQuery(); | 103 | ClearQuery(); |
101 | ~ClearQuery(); | 104 | ~ClearQuery(); |
102 | QString query()const; | 105 | QString query()const; |
103 | 106 | ||
104 | }; | 107 | }; |
105 | 108 | ||
106 | 109 | ||
107 | /** | 110 | /** |
108 | * LoadQuery | 111 | * LoadQuery |
109 | * this one queries for all uids | 112 | * this one queries for all uids |
110 | */ | 113 | */ |
111 | class LoadQuery : public OSQLQuery { | 114 | class LoadQuery : public OSQLQuery { |
112 | public: | 115 | public: |
113 | LoadQuery(); | 116 | LoadQuery(); |
114 | ~LoadQuery(); | 117 | ~LoadQuery(); |
115 | QString query()const; | 118 | QString query()const; |
116 | }; | 119 | }; |
117 | 120 | ||
118 | /** | 121 | /** |
119 | * inserts/adds a OContact to the table | 122 | * inserts/adds a OContact to the table |
120 | */ | 123 | */ |
121 | class InsertQuery : public OSQLQuery { | 124 | class InsertQuery : public OSQLQuery { |
122 | public: | 125 | public: |
123 | InsertQuery(const OContact& ); | 126 | InsertQuery(const OContact& ); |
124 | ~InsertQuery(); | 127 | ~InsertQuery(); |
125 | QString query()const; | 128 | QString query()const; |
126 | private: | 129 | private: |
127 | OContact m_contact; | 130 | OContact m_contact; |
128 | }; | 131 | }; |
129 | 132 | ||
130 | 133 | ||
131 | /** | 134 | /** |
132 | * removes one from the table | 135 | * removes one from the table |
133 | */ | 136 | */ |
134 | class RemoveQuery : public OSQLQuery { | 137 | class RemoveQuery : public OSQLQuery { |
135 | public: | 138 | public: |
136 | RemoveQuery(int uid ); | 139 | RemoveQuery(int uid ); |
137 | ~RemoveQuery(); | 140 | ~RemoveQuery(); |
138 | QString query()const; | 141 | QString query()const; |
139 | private: | 142 | private: |
140 | int m_uid; | 143 | int m_uid; |
141 | }; | 144 | }; |
142 | 145 | ||
143 | /** | 146 | /** |
144 | * a find query for noncustom elements | 147 | * a find query for noncustom elements |
145 | */ | 148 | */ |
146 | class FindQuery : public OSQLQuery { | 149 | class FindQuery : public OSQLQuery { |
147 | public: | 150 | public: |
148 | FindQuery(int uid); | 151 | FindQuery(int uid); |
149 | FindQuery(const QArray<int>& ); | 152 | FindQuery(const QArray<int>& ); |
150 | ~FindQuery(); | 153 | ~FindQuery(); |
151 | QString query()const; | 154 | QString query()const; |
152 | private: | 155 | private: |
153 | QString single()const; | 156 | QString single()const; |
154 | QString multi()const; | 157 | QString multi()const; |
155 | QArray<int> m_uids; | 158 | QArray<int> m_uids; |
156 | int m_uid; | 159 | int m_uid; |
157 | }; | 160 | }; |
158 | 161 | ||
159 | /** | 162 | /** |
160 | * a find query for custom elements | 163 | * a find query for custom elements |
161 | */ | 164 | */ |
162 | class FindCustomQuery : public OSQLQuery { | 165 | class FindCustomQuery : public OSQLQuery { |
163 | public: | 166 | public: |
164 | FindCustomQuery(int uid); | 167 | FindCustomQuery(int uid); |
165 | FindCustomQuery(const QArray<int>& ); | 168 | FindCustomQuery(const QArray<int>& ); |
166 | ~FindCustomQuery(); | 169 | ~FindCustomQuery(); |
167 | QString query()const; | 170 | QString query()const; |
168 | private: | 171 | private: |
169 | QString single()const; | 172 | QString single()const; |
170 | QString multi()const; | 173 | QString multi()const; |
171 | QArray<int> m_uids; | 174 | QArray<int> m_uids; |
172 | int m_uid; | 175 | int m_uid; |
173 | }; | 176 | }; |
174 | 177 | ||
175 | 178 | ||
176 | 179 | ||
177 | // We using three tables to store the information: | 180 | // We using three tables to store the information: |
178 | // 1. addressbook : It contains General information about the contact (non custom) | 181 | // 1. addressbook : It contains General information about the contact (non custom) |
179 | // 2. custom_data : Not official supported entries | 182 | // 2. custom_data : Not official supported entries |
180 | // All tables are connected by the uid of the contact. | 183 | // All tables are connected by the uid of the contact. |
181 | // Maybe I should add a table for meta-information ? | 184 | // Maybe I should add a table for meta-information ? |
182 | CreateQuery::CreateQuery() : OSQLQuery() {} | 185 | CreateQuery::CreateQuery() : OSQLQuery() {} |
183 | CreateQuery::~CreateQuery() {} | 186 | CreateQuery::~CreateQuery() {} |
184 | QString CreateQuery::query()const { | 187 | QString CreateQuery::query()const { |
185 | QString qu; | 188 | QString qu; |
186 | #ifdef __STORE_HORIZONTAL_ | 189 | #ifdef __STORE_HORIZONTAL_ |
187 | 190 | ||
188 | qu += "create table addressbook( uid PRIMARY KEY "; | 191 | qu += "create table addressbook( uid PRIMARY KEY "; |
189 | 192 | ||
190 | QStringList fieldList = OContactFields::untrfields( false ); | 193 | QStringList fieldList = OContactFields::untrfields( false ); |
191 | for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){ | 194 | for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){ |
192 | qu += QString( ",\"%1\" VARCHAR(10)" ).arg( *it ); | 195 | qu += QString( ",\"%1\" VARCHAR(10)" ).arg( *it ); |
193 | } | 196 | } |
194 | qu += " );"; | 197 | qu += " );"; |
195 | 198 | ||
196 | qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR, priority INTEGER, value VARCHAR, PRIMARY KEY /* identifier */ (uid, id) );"; | 199 | qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR, priority INTEGER, value VARCHAR, PRIMARY KEY /* identifier */ (uid, id) );"; |
197 | 200 | ||
198 | #else | 201 | #else |
199 | 202 | ||
200 | qu += "create table addressbook( uid INTEGER, id INTEGER, type VARCHAR, priority INTEGER, value VARCHAR, PRIMARY KEY /* identifier */ (uid, id));"; | 203 | qu += "create table addressbook( uid INTEGER, id INTEGER, type VARCHAR, priority INTEGER, value VARCHAR, PRIMARY KEY /* identifier */ (uid, id));"; |
201 | qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR, priority INTEGER, value VARCHAR, PRIMARY KEY /* identifier */ (uid, id) );"; | 204 | qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR, priority INTEGER, value VARCHAR, PRIMARY KEY /* identifier */ (uid, id) );"; |
202 | // qu += "create table dates( uid PRIMARY KEY, type, day, month, year, hour, minute, second );"; | 205 | // qu += "create table dates( uid PRIMARY KEY, type, day, month, year, hour, minute, second );"; |
203 | 206 | ||
204 | #endif // __STORE_HORIZONTAL_ | 207 | #endif // __STORE_HORIZONTAL_ |
205 | return qu; | 208 | return qu; |
206 | } | 209 | } |
207 | 210 | ||
208 | ClearQuery::ClearQuery() | 211 | ClearQuery::ClearQuery() |
209 | : OSQLQuery() {} | 212 | : OSQLQuery() {} |
210 | ClearQuery::~ClearQuery() {} | 213 | ClearQuery::~ClearQuery() {} |
211 | QString ClearQuery::query()const { | 214 | QString ClearQuery::query()const { |
212 | QString qu = "drop table addressbook;"; | 215 | QString qu = "drop table addressbook;"; |
213 | qu += "drop table custom_data;"; | 216 | qu += "drop table custom_data;"; |
214 | // qu += "drop table dates;"; | 217 | // qu += "drop table dates;"; |
215 | return qu; | 218 | return qu; |
216 | } | 219 | } |
217 | 220 | ||
218 | 221 | ||
219 | LoadQuery::LoadQuery() : OSQLQuery() {} | 222 | LoadQuery::LoadQuery() : OSQLQuery() {} |
220 | LoadQuery::~LoadQuery() {} | 223 | LoadQuery::~LoadQuery() {} |
221 | QString LoadQuery::query()const { | 224 | QString LoadQuery::query()const { |
222 | QString qu; | 225 | QString qu; |
223 | #ifdef __STORE_HORIZONTAL_ | 226 | #ifdef __STORE_HORIZONTAL_ |
224 | qu += "select uid from addressbook"; | 227 | qu += "select uid from addressbook"; |
225 | #else | 228 | #else |
226 | # ifndef __USE_SUPERFAST_LOADQUERY | 229 | # ifndef __USE_SUPERFAST_LOADQUERY |
227 | qu += "select distinct uid from addressbook"; | 230 | qu += "select distinct uid from addressbook"; |
228 | # else | 231 | # else |
229 | qu += "select uid from addressbook where type = 'Last Name'"; | 232 | qu += "select uid from addressbook where type = 'Last Name'"; |
230 | # endif // __USE_SUPERFAST_LOADQUERY | 233 | # endif // __USE_SUPERFAST_LOADQUERY |
231 | #endif // __STORE_HORIZONTAL_ | 234 | #endif // __STORE_HORIZONTAL_ |
232 | 235 | ||
233 | return qu; | 236 | return qu; |
234 | } | 237 | } |
235 | 238 | ||
236 | 239 | ||
237 | InsertQuery::InsertQuery( const OContact& contact ) | 240 | InsertQuery::InsertQuery( const OContact& contact ) |
238 | : OSQLQuery(), m_contact( contact ) { | 241 | : OSQLQuery(), m_contact( contact ) { |
239 | } | 242 | } |
240 | 243 | ||
241 | InsertQuery::~InsertQuery() { | 244 | InsertQuery::~InsertQuery() { |
242 | } | 245 | } |
243 | 246 | ||
244 | /* | 247 | /* |
245 | * converts from a OContact to a query | 248 | * converts from a OContact to a query |
246 | */ | 249 | */ |
247 | QString InsertQuery::query()const{ | 250 | QString InsertQuery::query()const{ |
248 | 251 | ||
249 | #ifdef __STORE_HORIZONTAL_ | 252 | #ifdef __STORE_HORIZONTAL_ |
250 | QString qu; | 253 | QString qu; |
251 | qu += "insert into addressbook VALUES( " + | 254 | qu += "insert into addressbook VALUES( " + |
252 | QString::number( m_contact.uid() ); | 255 | QString::number( m_contact.uid() ); |
253 | 256 | ||
254 | // Get all information out of the contact-class | 257 | // Get all information out of the contact-class |
255 | // Remember: The category is stored in contactMap, too ! | 258 | // Remember: The category is stored in contactMap, too ! |
256 | QMap<int, QString> contactMap = m_contact.toMap(); | 259 | QMap<int, QString> contactMap = m_contact.toMap(); |
257 | 260 | ||
258 | QStringList fieldList = OContactFields::untrfields( false ); | 261 | QStringList fieldList = OContactFields::untrfields( false ); |
259 | QMap<QString, int> translate = OContactFields::untrFieldsToId(); | 262 | QMap<QString, int> translate = OContactFields::untrFieldsToId(); |
260 | for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){ | 263 | for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){ |
261 | // Convert Column-String to Id and get value for this id.. | 264 | // Convert Column-String to Id and get value for this id.. |
262 | // Hmmm.. Maybe not very cute solution.. | 265 | // Hmmm.. Maybe not very cute solution.. |
263 | int id = translate[*it]; | 266 | int id = translate[*it]; |
264 | switch ( id ){ | 267 | switch ( id ){ |
265 | case Qtopia::Birthday:{ | 268 | case Qtopia::Birthday:{ |
266 | // These entries should stored in a special format | 269 | // These entries should stored in a special format |
267 | // year-month-day | 270 | // year-month-day |
268 | QDate day = m_contact.birthday(); | 271 | QDate day = m_contact.birthday(); |
269 | if ( day.isValid() ){ | 272 | if ( day.isValid() ){ |
270 | qu += QString(",\"%1-%2-%3\"") | 273 | qu += QString(",\"%1-%2-%3\"") |
271 | .arg( day.year() ) | 274 | .arg( day.year() ) |
272 | .arg( day.month() ) | 275 | .arg( day.month() ) |
273 | .arg( day.day() ); | 276 | .arg( day.day() ); |
274 | } else { | 277 | } else { |
275 | qu += ",\"\""; | 278 | qu += ",\"\""; |
276 | } | 279 | } |
277 | } | 280 | } |
278 | break; | 281 | break; |
279 | case Qtopia::Anniversary:{ | 282 | case Qtopia::Anniversary:{ |
280 | // These entries should stored in a special format | 283 | // These entries should stored in a special format |
281 | // year-month-day | 284 | // year-month-day |
282 | QDate day = m_contact.anniversary(); | 285 | QDate day = m_contact.anniversary(); |
283 | if ( day.isValid() ){ | 286 | if ( day.isValid() ){ |
284 | qu += QString(",\"%1-%2-%3\"") | 287 | qu += QString(",\"%1-%2-%3\"") |
285 | .arg( day.year() ) | 288 | .arg( day.year() ) |
286 | .arg( day.month() ) | 289 | .arg( day.month() ) |
287 | .arg( day.day() ); | 290 | .arg( day.day() ); |
288 | } else { | 291 | } else { |
289 | qu += ",\"\""; | 292 | qu += ",\"\""; |
290 | } | 293 | } |
291 | } | 294 | } |
292 | break; | 295 | break; |
293 | 296 | ||
294 | default: | 297 | default: |
295 | qu += QString( ",\"%1\"" ).arg( contactMap[id] ); | 298 | qu += QString( ",\"%1\"" ).arg( contactMap[id] ); |
296 | } | 299 | } |
297 | } | 300 | } |
298 | qu += " );"; | 301 | qu += " );"; |
299 | 302 | ||
300 | 303 | ||
301 | #else | 304 | #else |
302 | // Get all information out of the contact-class | 305 | // Get all information out of the contact-class |
303 | // Remember: The category is stored in contactMap, too ! | 306 | // Remember: The category is stored in contactMap, too ! |
304 | QMap<int, QString> contactMap = m_contact.toMap(); | 307 | QMap<int, QString> contactMap = m_contact.toMap(); |
305 | 308 | ||
306 | QMap<QString, QString> addressbook_db; | 309 | QMap<QString, QString> addressbook_db; |
307 | 310 | ||
308 | // Get the translation from the ID to the String | 311 | // Get the translation from the ID to the String |
309 | QMap<int, QString> transMap = OContactFields::idToUntrFields(); | 312 | QMap<int, QString> transMap = OContactFields::idToUntrFields(); |
310 | 313 | ||
311 | for( QMap<int, QString>::Iterator it = contactMap.begin(); | 314 | for( QMap<int, QString>::Iterator it = contactMap.begin(); |
312 | it != contactMap.end(); ++it ){ | 315 | it != contactMap.end(); ++it ){ |
313 | switch ( it.key() ){ | 316 | switch ( it.key() ){ |
314 | case Qtopia::Birthday:{ | 317 | case Qtopia::Birthday:{ |
315 | // These entries should stored in a special format | 318 | // These entries should stored in a special format |
316 | // year-month-day | 319 | // year-month-day |
317 | QDate day = m_contact.birthday(); | 320 | QDate day = m_contact.birthday(); |
318 | addressbook_db.insert( transMap[it.key()], | 321 | addressbook_db.insert( transMap[it.key()], |
319 | QString("%1-%2-%3") | 322 | QString("%1-%2-%3") |
320 | .arg( day.year() ) | 323 | .arg( day.year() ) |
321 | .arg( day.month() ) | 324 | .arg( day.month() ) |
322 | .arg( day.day() ) ); | 325 | .arg( day.day() ) ); |
323 | } | 326 | } |
324 | break; | 327 | break; |
325 | case Qtopia::Anniversary:{ | 328 | case Qtopia::Anniversary:{ |
326 | // These entries should stored in a special format | 329 | // These entries should stored in a special format |
327 | // year-month-day | 330 | // year-month-day |
328 | QDate day = m_contact.anniversary(); | 331 | QDate day = m_contact.anniversary(); |
329 | addressbook_db.insert( transMap[it.key()], | 332 | addressbook_db.insert( transMap[it.key()], |
330 | QString("%1-%2-%3") | 333 | QString("%1-%2-%3") |
331 | .arg( day.year() ) | 334 | .arg( day.year() ) |
332 | .arg( day.month() ) | 335 | .arg( day.month() ) |
333 | .arg( day.day() ) ); | 336 | .arg( day.day() ) ); |
334 | } | 337 | } |
335 | break; | 338 | break; |
336 | case Qtopia::AddressUid: // Ignore UID | 339 | case Qtopia::AddressUid: // Ignore UID |
337 | break; | 340 | break; |
338 | default: // Translate id to String | 341 | default: // Translate id to String |
339 | addressbook_db.insert( transMap[it.key()], it.data() ); | 342 | addressbook_db.insert( transMap[it.key()], it.data() ); |
340 | break; | 343 | break; |
341 | } | 344 | } |
342 | 345 | ||
343 | } | 346 | } |
344 | 347 | ||
345 | // Now convert this whole stuff into a SQL String, beginning with | 348 | // Now convert this whole stuff into a SQL String, beginning with |
346 | // the addressbook table.. | 349 | // the addressbook table.. |
347 | QString qu; | 350 | QString qu; |
348 | // qu += "begin transaction;"; | 351 | // qu += "begin transaction;"; |
349 | int id = 0; | 352 | int id = 0; |
350 | for( QMap<QString, QString>::Iterator it = addressbook_db.begin(); | 353 | for( QMap<QString, QString>::Iterator it = addressbook_db.begin(); |
351 | it != addressbook_db.end(); ++it ){ | 354 | it != addressbook_db.end(); ++it ){ |
352 | qu += "insert into addressbook VALUES(" | 355 | qu += "insert into addressbook VALUES(" |
353 | + QString::number( m_contact.uid() ) | 356 | + QString::number( m_contact.uid() ) |
354 | + "," | 357 | + "," |
355 | + QString::number( id++ ) | 358 | + QString::number( id++ ) |
356 | + ",'" | 359 | + ",'" |
357 | + it.key() //.latin1() | 360 | + it.key() //.latin1() |
358 | + "'," | 361 | + "'," |
359 | + "0" // Priority for future enhancements | 362 | + "0" // Priority for future enhancements |
360 | + ",'" | 363 | + ",'" |
361 | + it.data() //.latin1() | 364 | + it.data() //.latin1() |
362 | + "');"; | 365 | + "');"; |
363 | } | 366 | } |
364 | 367 | ||
365 | #endif //__STORE_HORIZONTAL_ | 368 | #endif //__STORE_HORIZONTAL_ |
366 | // Now add custom data.. | 369 | // Now add custom data.. |
367 | #ifdef __STORE_HORIZONTAL_ | 370 | #ifdef __STORE_HORIZONTAL_ |
368 | int id = 0; | 371 | int id = 0; |
369 | #endif | 372 | #endif |
370 | id = 0; | 373 | id = 0; |
371 | QMap<QString, QString> customMap = m_contact.toExtraMap(); | 374 | QMap<QString, QString> customMap = m_contact.toExtraMap(); |
372 | for( QMap<QString, QString>::Iterator it = customMap.begin(); | 375 | for( QMap<QString, QString>::Iterator it = customMap.begin(); |
373 | it != customMap.end(); ++it ){ | 376 | it != customMap.end(); ++it ){ |
374 | qu += "insert into custom_data VALUES(" | 377 | qu += "insert into custom_data VALUES(" |
375 | + QString::number( m_contact.uid() ) | 378 | + QString::number( m_contact.uid() ) |
376 | + "," | 379 | + "," |
377 | + QString::number( id++ ) | 380 | + QString::number( id++ ) |
378 | + ",'" | 381 | + ",'" |
379 | + it.key() //.latin1() | 382 | + it.key() //.latin1() |
380 | + "'," | 383 | + "'," |
381 | + "0" // Priority for future enhancements | 384 | + "0" // Priority for future enhancements |
382 | + ",'" | 385 | + ",'" |
383 | + it.data() //.latin1() | 386 | + it.data() //.latin1() |
384 | + "');"; | 387 | + "');"; |
385 | } | 388 | } |
386 | // qu += "commit;"; | 389 | // qu += "commit;"; |
387 | qWarning("add %s", qu.latin1() ); | 390 | qWarning("add %s", qu.latin1() ); |
388 | return qu; | 391 | return qu; |
389 | } | 392 | } |
390 | 393 | ||
391 | 394 | ||
392 | RemoveQuery::RemoveQuery(int uid ) | 395 | RemoveQuery::RemoveQuery(int uid ) |
393 | : OSQLQuery(), m_uid( uid ) {} | 396 | : OSQLQuery(), m_uid( uid ) {} |
394 | RemoveQuery::~RemoveQuery() {} | 397 | RemoveQuery::~RemoveQuery() {} |
395 | QString RemoveQuery::query()const { | 398 | QString RemoveQuery::query()const { |
396 | QString qu = "DELETE from addressbook where uid = " | 399 | QString qu = "DELETE from addressbook where uid = " |
397 | + QString::number(m_uid) + ";"; | 400 | + QString::number(m_uid) + ";"; |
398 | qu += "DELETE from custom_data where uid = " | 401 | qu += "DELETE from custom_data where uid = " |
399 | + QString::number(m_uid) + ";"; | 402 | + QString::number(m_uid) + ";"; |
400 | return qu; | 403 | return qu; |
401 | } | 404 | } |
402 | 405 | ||
403 | 406 | ||
404 | 407 | ||
405 | 408 | ||
406 | FindQuery::FindQuery(int uid) | 409 | FindQuery::FindQuery(int uid) |
407 | : OSQLQuery(), m_uid( uid ) { | 410 | : OSQLQuery(), m_uid( uid ) { |
408 | } | 411 | } |
409 | FindQuery::FindQuery(const QArray<int>& ints) | 412 | FindQuery::FindQuery(const QArray<int>& ints) |
410 | : OSQLQuery(), m_uids( ints ){ | 413 | : OSQLQuery(), m_uids( ints ){ |
411 | } | 414 | } |
412 | FindQuery::~FindQuery() { | 415 | FindQuery::~FindQuery() { |
413 | } | 416 | } |
414 | QString FindQuery::query()const{ | 417 | QString FindQuery::query()const{ |
415 | // if ( m_uids.count() == 0 ) | 418 | // if ( m_uids.count() == 0 ) |
416 | return single(); | 419 | return single(); |
417 | } | 420 | } |
418 | /* | 421 | /* |
419 | else | 422 | else |
420 | return multi(); | 423 | return multi(); |
421 | } | 424 | } |
422 | QString FindQuery::multi()const { | 425 | QString FindQuery::multi()const { |
423 | QString qu = "select uid, type, value from addressbook where"; | 426 | QString qu = "select uid, type, value from addressbook where"; |
424 | for (uint i = 0; i < m_uids.count(); i++ ) { | 427 | for (uint i = 0; i < m_uids.count(); i++ ) { |
425 | qu += " UID = " + QString::number( m_uids[i] ) + " OR"; | 428 | qu += " UID = " + QString::number( m_uids[i] ) + " OR"; |
426 | } | 429 | } |
427 | qu.remove( qu.length()-2, 2 ); // Hmmmm.. | 430 | qu.remove( qu.length()-2, 2 ); // Hmmmm.. |
428 | return qu; | 431 | return qu; |
429 | } | 432 | } |
430 | */ | 433 | */ |
431 | #ifdef __STORE_HORIZONTAL_ | 434 | #ifdef __STORE_HORIZONTAL_ |
432 | QString FindQuery::single()const{ | 435 | QString FindQuery::single()const{ |
433 | QString qu = "select *"; | 436 | QString qu = "select *"; |
434 | qu += " from addressbook where uid = " + QString::number(m_uid); | 437 | qu += " from addressbook where uid = " + QString::number(m_uid); |
435 | 438 | ||
436 | // qWarning("find query: %s", qu.latin1() ); | 439 | // qWarning("find query: %s", qu.latin1() ); |
437 | return qu; | 440 | return qu; |
438 | } | 441 | } |
439 | #else | 442 | #else |
440 | QString FindQuery::single()const{ | 443 | QString FindQuery::single()const{ |
441 | QString qu = "select uid, type, value from addressbook where uid = "; | 444 | QString qu = "select uid, type, value from addressbook where uid = "; |
442 | qu += QString::number(m_uid); | 445 | qu += QString::number(m_uid); |
443 | return qu; | 446 | return qu; |
444 | } | 447 | } |
445 | #endif | 448 | #endif |
446 | 449 | ||
447 | 450 | ||
448 | FindCustomQuery::FindCustomQuery(int uid) | 451 | FindCustomQuery::FindCustomQuery(int uid) |
449 | : OSQLQuery(), m_uid( uid ) { | 452 | : OSQLQuery(), m_uid( uid ) { |
450 | } | 453 | } |
451 | FindCustomQuery::FindCustomQuery(const QArray<int>& ints) | 454 | FindCustomQuery::FindCustomQuery(const QArray<int>& ints) |
452 | : OSQLQuery(), m_uids( ints ){ | 455 | : OSQLQuery(), m_uids( ints ){ |
453 | } | 456 | } |
454 | FindCustomQuery::~FindCustomQuery() { | 457 | FindCustomQuery::~FindCustomQuery() { |
455 | } | 458 | } |
456 | QString FindCustomQuery::query()const{ | 459 | QString FindCustomQuery::query()const{ |
457 | // if ( m_uids.count() == 0 ) | 460 | // if ( m_uids.count() == 0 ) |
458 | return single(); | 461 | return single(); |
459 | } | 462 | } |
460 | QString FindCustomQuery::single()const{ | 463 | QString FindCustomQuery::single()const{ |
461 | QString qu = "select uid, type, value from custom_data where uid = "; | 464 | QString qu = "select uid, type, value from custom_data where uid = "; |
462 | qu += QString::number(m_uid); | 465 | qu += QString::number(m_uid); |
463 | return qu; | 466 | return qu; |
464 | } | 467 | } |
465 | 468 | ||
466 | }; | 469 | }; |
467 | 470 | ||
468 | 471 | ||
469 | /* --------------------------------------------------------------------------- */ | 472 | /* --------------------------------------------------------------------------- */ |
470 | 473 | ||
471 | OContactAccessBackend_SQL::OContactAccessBackend_SQL ( const QString& /* appname */, | 474 | OContactAccessBackend_SQL::OContactAccessBackend_SQL ( const QString& /* appname */, |
472 | const QString& filename ): | 475 | const QString& filename ): |
473 | OContactAccessBackend(), m_changed(false), m_driver( NULL ) | 476 | OContactAccessBackend(), m_changed(false), m_driver( NULL ) |
474 | { | 477 | { |
475 | qWarning("C'tor OContactAccessBackend_SQL starts"); | 478 | qWarning("C'tor OContactAccessBackend_SQL starts"); |
476 | QTime t; | 479 | QTime t; |
477 | t.start(); | 480 | t.start(); |
478 | 481 | ||
479 | /* Expecting to access the default filename if nothing else is set */ | 482 | /* Expecting to access the default filename if nothing else is set */ |
480 | if ( filename.isEmpty() ){ | 483 | if ( filename.isEmpty() ){ |
481 | m_fileName = Global::applicationFileName( "addressbook","addressbook.db" ); | 484 | m_fileName = Global::applicationFileName( "addressbook","addressbook.db" ); |
482 | } else | 485 | } else |
483 | m_fileName = filename; | 486 | m_fileName = filename; |
484 | 487 | ||
485 | // Get the standart sql-driver from the OSQLManager.. | 488 | // Get the standart sql-driver from the OSQLManager.. |
486 | OSQLManager man; | 489 | OSQLManager man; |
487 | m_driver = man.standard(); | 490 | m_driver = man.standard(); |
488 | m_driver->setUrl( m_fileName ); | 491 | m_driver->setUrl( m_fileName ); |
489 | 492 | ||
490 | load(); | 493 | load(); |
491 | 494 | ||
492 | qWarning("C'tor OContactAccessBackend_SQL ends: %d ms", t.elapsed() ); | 495 | qWarning("C'tor OContactAccessBackend_SQL ends: %d ms", t.elapsed() ); |
493 | } | 496 | } |
494 | 497 | ||
495 | OContactAccessBackend_SQL::~OContactAccessBackend_SQL () | 498 | OContactAccessBackend_SQL::~OContactAccessBackend_SQL () |
496 | { | 499 | { |
497 | if( m_driver ) | 500 | if( m_driver ) |
498 | delete m_driver; | 501 | delete m_driver; |
499 | } | 502 | } |
500 | 503 | ||
501 | bool OContactAccessBackend_SQL::load () | 504 | bool OContactAccessBackend_SQL::load () |
502 | { | 505 | { |
503 | if (!m_driver->open() ) | 506 | if (!m_driver->open() ) |
504 | return false; | 507 | return false; |
505 | 508 | ||
506 | // Don't expect that the database exists. | 509 | // Don't expect that the database exists. |
507 | // It is save here to create the table, even if it | 510 | // It is save here to create the table, even if it |
508 | // do exist. ( Is that correct for all databases ?? ) | 511 | // do exist. ( Is that correct for all databases ?? ) |
509 | CreateQuery creat; | 512 | CreateQuery creat; |
510 | OSQLResult res = m_driver->query( &creat ); | 513 | OSQLResult res = m_driver->query( &creat ); |
511 | 514 | ||
512 | update(); | 515 | update(); |
513 | 516 | ||
514 | return true; | 517 | return true; |
515 | 518 | ||
516 | } | 519 | } |
517 | 520 | ||
518 | bool OContactAccessBackend_SQL::reload() | 521 | bool OContactAccessBackend_SQL::reload() |
519 | { | 522 | { |
520 | return load(); | 523 | return load(); |
521 | } | 524 | } |
522 | 525 | ||
523 | bool OContactAccessBackend_SQL::save() | 526 | bool OContactAccessBackend_SQL::save() |
524 | { | 527 | { |
525 | return m_driver->close(); // Shouldn't m_driver->sync be better than close ? (eilers) | 528 | return m_driver->close(); // Shouldn't m_driver->sync be better than close ? (eilers) |
526 | } | 529 | } |
527 | 530 | ||
528 | 531 | ||
529 | void OContactAccessBackend_SQL::clear () | 532 | void OContactAccessBackend_SQL::clear () |
530 | { | 533 | { |
531 | ClearQuery cle; | 534 | ClearQuery cle; |
532 | OSQLResult res = m_driver->query( &cle ); | 535 | OSQLResult res = m_driver->query( &cle ); |
533 | 536 | ||
534 | reload(); | 537 | reload(); |
535 | } | 538 | } |
536 | 539 | ||
537 | bool OContactAccessBackend_SQL::wasChangedExternally() | 540 | bool OContactAccessBackend_SQL::wasChangedExternally() |
538 | { | 541 | { |
539 | return false; | 542 | return false; |
540 | } | 543 | } |
541 | 544 | ||
542 | QArray<int> OContactAccessBackend_SQL::allRecords() const | 545 | QArray<int> OContactAccessBackend_SQL::allRecords() const |
543 | { | 546 | { |
544 | 547 | ||
545 | // FIXME: Think about cute handling of changed tables.. | 548 | // FIXME: Think about cute handling of changed tables.. |
546 | // Thus, we don't have to call update here... | 549 | // Thus, we don't have to call update here... |
547 | if ( m_changed ) | 550 | if ( m_changed ) |
548 | ((OContactAccessBackend_SQL*)this)->update(); | 551 | ((OContactAccessBackend_SQL*)this)->update(); |
549 | 552 | ||
550 | return m_uids; | 553 | return m_uids; |
551 | } | 554 | } |
552 | 555 | ||
553 | bool OContactAccessBackend_SQL::add ( const OContact &newcontact ) | 556 | bool OContactAccessBackend_SQL::add ( const OContact &newcontact ) |
554 | { | 557 | { |
555 | InsertQuery ins( newcontact ); | 558 | InsertQuery ins( newcontact ); |
556 | OSQLResult res = m_driver->query( &ins ); | 559 | OSQLResult res = m_driver->query( &ins ); |
557 | 560 | ||
558 | if ( res.state() == OSQLResult::Failure ) | 561 | if ( res.state() == OSQLResult::Failure ) |
559 | return false; | 562 | return false; |
560 | 563 | ||
561 | int c = m_uids.count(); | 564 | int c = m_uids.count(); |
562 | m_uids.resize( c+1 ); | 565 | m_uids.resize( c+1 ); |
563 | m_uids[c] = newcontact.uid(); | 566 | m_uids[c] = newcontact.uid(); |
564 | 567 | ||
565 | return true; | 568 | return true; |
566 | } | 569 | } |
567 | 570 | ||
568 | 571 | ||
569 | bool OContactAccessBackend_SQL::remove ( int uid ) | 572 | bool OContactAccessBackend_SQL::remove ( int uid ) |
570 | { | 573 | { |
571 | RemoveQuery rem( uid ); | 574 | RemoveQuery rem( uid ); |
572 | OSQLResult res = m_driver->query(&rem ); | 575 | OSQLResult res = m_driver->query(&rem ); |
diff --git a/libopie/pim/ocontactaccessbackend_sql.h b/libopie/pim/ocontactaccessbackend_sql.h index b8f1d8d..f553760 100644 --- a/libopie/pim/ocontactaccessbackend_sql.h +++ b/libopie/pim/ocontactaccessbackend_sql.h | |||
@@ -1,101 +1,107 @@ | |||
1 | /* | 1 | /* |
2 | * SQL Backend for the OPIE-Contact Database. | 2 | * SQL Backend for the OPIE-Contact Database. |
3 | * | 3 | * |
4 | * Copyright (c) 2002 by Stefan Eilers (Eilers.Stefan@epost.de) | 4 | * Copyright (c) 2002 by Stefan Eilers (Eilers.Stefan@epost.de) |
5 | * | 5 | * |
6 | * ===================================================================== | 6 | * ===================================================================== |
7 | *This program is free software; you can redistribute it and/or | 7 | *This program is free software; you can redistribute it and/or |
8 | *modify it under the terms of the GNU Library General Public | 8 | *modify it under the terms of the GNU Library General Public |
9 | * License as published by the Free Software Foundation; either | 9 | * License as published by the Free Software Foundation; either |
10 | * version 2 of the License, or (at your option) any later version. | 10 | * version 2 of the License, or (at your option) any later version. |
11 | * ===================================================================== | 11 | * ===================================================================== |
12 | * | 12 | * |
13 | * | 13 | * |
14 | * ===================================================================== | 14 | * ===================================================================== |
15 | * Version: $Id$ | 15 | * Version: $Id$ |
16 | * ===================================================================== | 16 | * ===================================================================== |
17 | * History: | 17 | * History: |
18 | * $Log$ | 18 | * $Log$ |
19 | * Revision 1.3 2004/03/14 13:50:35 alwin | ||
20 | * namespace correction | ||
21 | * | ||
19 | * Revision 1.2 2003/12/08 15:18:11 eilers | 22 | * Revision 1.2 2003/12/08 15:18:11 eilers |
20 | * Committing unfinished sql implementation before merging to libopie2 starts.. | 23 | * Committing unfinished sql implementation before merging to libopie2 starts.. |
21 | * | 24 | * |
22 | * Revision 1.1 2003/09/22 14:31:16 eilers | 25 | * Revision 1.1 2003/09/22 14:31:16 eilers |
23 | * Added first experimental incarnation of sql-backend for addressbook. | 26 | * Added first experimental incarnation of sql-backend for addressbook. |
24 | * Some modifications to be able to compile the todo sql-backend. | 27 | * Some modifications to be able to compile the todo sql-backend. |
25 | * A lot of changes fill follow... | 28 | * A lot of changes fill follow... |
26 | * | 29 | * |
27 | * | 30 | * |
28 | */ | 31 | */ |
29 | 32 | ||
30 | #ifndef _OContactAccessBackend_SQL_ | 33 | #ifndef _OContactAccessBackend_SQL_ |
31 | #define _OContactAccessBackend_SQL_ | 34 | #define _OContactAccessBackend_SQL_ |
32 | 35 | ||
33 | #include "ocontactaccessbackend.h" | 36 | #include "ocontactaccessbackend.h" |
34 | #include "ocontactaccess.h" | 37 | #include "ocontactaccess.h" |
35 | 38 | ||
36 | #include <qlist.h> | 39 | #include <qlist.h> |
37 | #include <qdict.h> | 40 | #include <qdict.h> |
38 | 41 | ||
42 | namespace Opie { namespace DB { | ||
39 | class OSQLDriver; | 43 | class OSQLDriver; |
40 | class OSQLResult; | 44 | class OSQLResult; |
41 | class OSQLResultItem; | 45 | class OSQLResultItem; |
42 | 46 | ||
47 | }} | ||
48 | |||
43 | /* the default xml implementation */ | 49 | /* the default xml implementation */ |
44 | /** | 50 | /** |
45 | * This class is the SQL implementation of a Contact backend | 51 | * This class is the SQL implementation of a Contact backend |
46 | * it does implement everything available for OContact. | 52 | * it does implement everything available for OContact. |
47 | * @see OPimAccessBackend for more information of available methods | 53 | * @see OPimAccessBackend for more information of available methods |
48 | */ | 54 | */ |
49 | class OContactAccessBackend_SQL : public OContactAccessBackend { | 55 | class OContactAccessBackend_SQL : public OContactAccessBackend { |
50 | public: | 56 | public: |
51 | OContactAccessBackend_SQL ( const QString& appname, const QString& filename = QString::null ); | 57 | OContactAccessBackend_SQL ( const QString& appname, const QString& filename = QString::null ); |
52 | 58 | ||
53 | ~OContactAccessBackend_SQL (); | 59 | ~OContactAccessBackend_SQL (); |
54 | 60 | ||
55 | bool save(); | 61 | bool save(); |
56 | 62 | ||
57 | bool load (); | 63 | bool load (); |
58 | 64 | ||
59 | void clear (); | 65 | void clear (); |
60 | 66 | ||
61 | bool wasChangedExternally(); | 67 | bool wasChangedExternally(); |
62 | 68 | ||
63 | QArray<int> allRecords() const; | 69 | QArray<int> allRecords() const; |
64 | 70 | ||
65 | OContact find ( int uid ) const; | 71 | OContact find ( int uid ) const; |
66 | // FIXME: Add lookahead-cache support ! | 72 | // FIXME: Add lookahead-cache support ! |
67 | //OContact find(int uid, const QArray<int>&, uint cur, Frontend::CacheDirection )const; | 73 | //OContact find(int uid, const QArray<int>&, uint cur, Frontend::CacheDirection )const; |
68 | 74 | ||
69 | QArray<int> queryByExample ( const OContact &query, int settings, | 75 | QArray<int> queryByExample ( const OContact &query, int settings, |
70 | const QDateTime& d ); | 76 | const QDateTime& d ); |
71 | 77 | ||
72 | QArray<int> matchRegexp( const QRegExp &r ) const; | 78 | QArray<int> matchRegexp( const QRegExp &r ) const; |
73 | 79 | ||
74 | const uint querySettings(); | 80 | const uint querySettings(); |
75 | 81 | ||
76 | bool hasQuerySettings (uint querySettings) const; | 82 | bool hasQuerySettings (uint querySettings) const; |
77 | 83 | ||
78 | // Currently only asc implemented.. | 84 | // Currently only asc implemented.. |
79 | QArray<int> sorted( bool asc, int , int , int ); | 85 | QArray<int> sorted( bool asc, int , int , int ); |
80 | bool add ( const OContact &newcontact ); | 86 | bool add ( const OContact &newcontact ); |
81 | 87 | ||
82 | bool replace ( const OContact &contact ); | 88 | bool replace ( const OContact &contact ); |
83 | 89 | ||
84 | bool remove ( int uid ); | 90 | bool remove ( int uid ); |
85 | bool reload(); | 91 | bool reload(); |
86 | 92 | ||
87 | private: | 93 | private: |
88 | QArray<int> extractUids( OSQLResult& res ) const; | 94 | QArray<int> extractUids( Opie::DB::OSQLResult& res ) const; |
89 | QMap<int, QString> requestNonCustom( int uid ) const; | 95 | QMap<int, QString> requestNonCustom( int uid ) const; |
90 | QMap<QString, QString> requestCustom( int uid ) const; | 96 | QMap<QString, QString> requestCustom( int uid ) const; |
91 | void update(); | 97 | void update(); |
92 | 98 | ||
93 | protected: | 99 | protected: |
94 | bool m_changed; | 100 | bool m_changed; |
95 | QString m_fileName; | 101 | QString m_fileName; |
96 | QArray<int> m_uids; | 102 | QArray<int> m_uids; |
97 | 103 | ||
98 | OSQLDriver* m_driver; | 104 | Opie::DB::OSQLDriver* m_driver; |
99 | }; | 105 | }; |
100 | 106 | ||
101 | #endif | 107 | #endif |
diff --git a/libopie/pim/odatebookaccessbackend_sql.cpp b/libopie/pim/odatebookaccessbackend_sql.cpp index 756f405..44dd2bc 100644 --- a/libopie/pim/odatebookaccessbackend_sql.cpp +++ b/libopie/pim/odatebookaccessbackend_sql.cpp | |||
@@ -1,367 +1,371 @@ | |||
1 | /* | 1 | /* |
2 | * SQL Backend for the OPIE-Calender Database. | 2 | * SQL Backend for the OPIE-Calender Database. |
3 | * | 3 | * |
4 | * Copyright (c) 2003 by Stefan Eilers (Eilers.Stefan@epost.de) | 4 | * Copyright (c) 2003 by Stefan Eilers (Eilers.Stefan@epost.de) |
5 | * | 5 | * |
6 | * ===================================================================== | 6 | * ===================================================================== |
7 | *This program is free software; you can redistribute it and/or | 7 | *This program is free software; you can redistribute it and/or |
8 | *modify it under the terms of the GNU Library General Public | 8 | *modify it under the terms of the GNU Library General Public |
9 | * License as published by the Free Software Foundation; either | 9 | * License as published by the Free Software Foundation; either |
10 | * version 2 of the License, or (at your option) any later version. | 10 | * version 2 of the License, or (at your option) any later version. |
11 | * ===================================================================== | 11 | * ===================================================================== |
12 | * ===================================================================== | 12 | * ===================================================================== |
13 | * Version: $Id$ | 13 | * Version: $Id$ |
14 | * ===================================================================== | 14 | * ===================================================================== |
15 | * History: | 15 | * History: |
16 | * $Log$ | 16 | * $Log$ |
17 | * Revision 1.4 2004/03/14 13:50:35 alwin | ||
18 | * namespace correction | ||
19 | * | ||
17 | * Revision 1.3 2003/12/22 11:41:39 eilers | 20 | * Revision 1.3 2003/12/22 11:41:39 eilers |
18 | * Fixing stupid bug, found by sourcode review.. | 21 | * Fixing stupid bug, found by sourcode review.. |
19 | * | 22 | * |
20 | * Revision 1.2 2003/12/22 10:19:26 eilers | 23 | * Revision 1.2 2003/12/22 10:19:26 eilers |
21 | * Finishing implementation of sql-backend for datebook. But I have to | 24 | * Finishing implementation of sql-backend for datebook. But I have to |
22 | * port the PIM datebook application to use it, before I could debug the | 25 | * port the PIM datebook application to use it, before I could debug the |
23 | * whole stuff. | 26 | * whole stuff. |
24 | * Thus, PIM-Database backend is finished, but highly experimental. And some | 27 | * Thus, PIM-Database backend is finished, but highly experimental. And some |
25 | * parts are still generic. For instance, the "queryByExample()" methods are | 28 | * parts are still generic. For instance, the "queryByExample()" methods are |
26 | * not (or not fully) implemented. Todo: custom-entries not stored. | 29 | * not (or not fully) implemented. Todo: custom-entries not stored. |
27 | * The big show stopper: matchRegExp() (needed by OpieSearch) needs regular | 30 | * The big show stopper: matchRegExp() (needed by OpieSearch) needs regular |
28 | * expression search in the database, which is not supported by sqlite ! | 31 | * expression search in the database, which is not supported by sqlite ! |
29 | * Therefore we need either an extended sqlite or a workaround which would | 32 | * Therefore we need either an extended sqlite or a workaround which would |
30 | * be very slow and memory consuming.. | 33 | * be very slow and memory consuming.. |
31 | * | 34 | * |
32 | * Revision 1.1 2003/12/08 15:18:12 eilers | 35 | * Revision 1.1 2003/12/08 15:18:12 eilers |
33 | * Committing unfinished sql implementation before merging to libopie2 starts.. | 36 | * Committing unfinished sql implementation before merging to libopie2 starts.. |
34 | * | 37 | * |
35 | * | 38 | * |
36 | */ | 39 | */ |
37 | 40 | ||
38 | #include <stdio.h> | 41 | #include <stdio.h> |
39 | #include <stdlib.h> | 42 | #include <stdlib.h> |
40 | 43 | ||
41 | #include <qarray.h> | 44 | #include <qarray.h> |
42 | #include <qstringlist.h> | 45 | #include <qstringlist.h> |
43 | 46 | ||
44 | #include <qpe/global.h> | 47 | #include <qpe/global.h> |
45 | 48 | ||
46 | #include <opie2/osqldriver.h> | 49 | #include <opie2/osqldriver.h> |
47 | #include <opie2/osqlmanager.h> | 50 | #include <opie2/osqlmanager.h> |
48 | #include <opie2/osqlquery.h> | 51 | #include <opie2/osqlquery.h> |
49 | 52 | ||
50 | #include "orecur.h" | 53 | #include "orecur.h" |
51 | #include "odatebookaccessbackend_sql.h" | 54 | #include "odatebookaccessbackend_sql.h" |
52 | 55 | ||
56 | using namespace Opie::DB; | ||
53 | 57 | ||
54 | 58 | ||
55 | ODateBookAccessBackend_SQL::ODateBookAccessBackend_SQL( const QString& , | 59 | ODateBookAccessBackend_SQL::ODateBookAccessBackend_SQL( const QString& , |
56 | const QString& fileName ) | 60 | const QString& fileName ) |
57 | : ODateBookAccessBackend(), m_driver( NULL ) | 61 | : ODateBookAccessBackend(), m_driver( NULL ) |
58 | { | 62 | { |
59 | m_fileName = fileName.isEmpty() ? Global::applicationFileName( "datebook", "datebook.db" ) : fileName; | 63 | m_fileName = fileName.isEmpty() ? Global::applicationFileName( "datebook", "datebook.db" ) : fileName; |
60 | 64 | ||
61 | // Get the standart sql-driver from the OSQLManager.. | 65 | // Get the standart sql-driver from the OSQLManager.. |
62 | OSQLManager man; | 66 | OSQLManager man; |
63 | m_driver = man.standard(); | 67 | m_driver = man.standard(); |
64 | m_driver->setUrl( m_fileName ); | 68 | m_driver->setUrl( m_fileName ); |
65 | 69 | ||
66 | initFields(); | 70 | initFields(); |
67 | 71 | ||
68 | load(); | 72 | load(); |
69 | } | 73 | } |
70 | 74 | ||
71 | ODateBookAccessBackend_SQL::~ODateBookAccessBackend_SQL() { | 75 | ODateBookAccessBackend_SQL::~ODateBookAccessBackend_SQL() { |
72 | if( m_driver ) | 76 | if( m_driver ) |
73 | delete m_driver; | 77 | delete m_driver; |
74 | } | 78 | } |
75 | 79 | ||
76 | void ODateBookAccessBackend_SQL::initFields() | 80 | void ODateBookAccessBackend_SQL::initFields() |
77 | { | 81 | { |
78 | 82 | ||
79 | // This map contains the translation of the fieldtype id's to | 83 | // This map contains the translation of the fieldtype id's to |
80 | // the names of the table columns | 84 | // the names of the table columns |
81 | m_fieldMap.insert( OEvent::FUid, "uid" ); | 85 | m_fieldMap.insert( OEvent::FUid, "uid" ); |
82 | m_fieldMap.insert( OEvent::FCategories, "Categories" ); | 86 | m_fieldMap.insert( OEvent::FCategories, "Categories" ); |
83 | m_fieldMap.insert( OEvent::FDescription, "Description" ); | 87 | m_fieldMap.insert( OEvent::FDescription, "Description" ); |
84 | m_fieldMap.insert( OEvent::FLocation, "Location" ); | 88 | m_fieldMap.insert( OEvent::FLocation, "Location" ); |
85 | m_fieldMap.insert( OEvent::FType, "Type" ); | 89 | m_fieldMap.insert( OEvent::FType, "Type" ); |
86 | m_fieldMap.insert( OEvent::FAlarm, "Alarm" ); | 90 | m_fieldMap.insert( OEvent::FAlarm, "Alarm" ); |
87 | m_fieldMap.insert( OEvent::FSound, "Sound" ); | 91 | m_fieldMap.insert( OEvent::FSound, "Sound" ); |
88 | m_fieldMap.insert( OEvent::FRType, "RType" ); | 92 | m_fieldMap.insert( OEvent::FRType, "RType" ); |
89 | m_fieldMap.insert( OEvent::FRWeekdays, "RWeekdays" ); | 93 | m_fieldMap.insert( OEvent::FRWeekdays, "RWeekdays" ); |
90 | m_fieldMap.insert( OEvent::FRPosition, "RPosition" ); | 94 | m_fieldMap.insert( OEvent::FRPosition, "RPosition" ); |
91 | m_fieldMap.insert( OEvent::FRFreq, "RFreq" ); | 95 | m_fieldMap.insert( OEvent::FRFreq, "RFreq" ); |
92 | m_fieldMap.insert( OEvent::FRHasEndDate, "RHasEndDate" ); | 96 | m_fieldMap.insert( OEvent::FRHasEndDate, "RHasEndDate" ); |
93 | m_fieldMap.insert( OEvent::FREndDate, "REndDate" ); | 97 | m_fieldMap.insert( OEvent::FREndDate, "REndDate" ); |
94 | m_fieldMap.insert( OEvent::FRCreated, "RCreated" ); | 98 | m_fieldMap.insert( OEvent::FRCreated, "RCreated" ); |
95 | m_fieldMap.insert( OEvent::FRExceptions, "RExceptions" ); | 99 | m_fieldMap.insert( OEvent::FRExceptions, "RExceptions" ); |
96 | m_fieldMap.insert( OEvent::FStart, "Start" ); | 100 | m_fieldMap.insert( OEvent::FStart, "Start" ); |
97 | m_fieldMap.insert( OEvent::FEnd, "End" ); | 101 | m_fieldMap.insert( OEvent::FEnd, "End" ); |
98 | m_fieldMap.insert( OEvent::FNote, "Note" ); | 102 | m_fieldMap.insert( OEvent::FNote, "Note" ); |
99 | m_fieldMap.insert( OEvent::FTimeZone, "TimeZone" ); | 103 | m_fieldMap.insert( OEvent::FTimeZone, "TimeZone" ); |
100 | m_fieldMap.insert( OEvent::FRecParent, "RecParent" ); | 104 | m_fieldMap.insert( OEvent::FRecParent, "RecParent" ); |
101 | m_fieldMap.insert( OEvent::FRecChildren, "Recchildren" ); | 105 | m_fieldMap.insert( OEvent::FRecChildren, "Recchildren" ); |
102 | 106 | ||
103 | // Create a map that maps the column name to the id | 107 | // Create a map that maps the column name to the id |
104 | QMapConstIterator<int, QString> it; | 108 | QMapConstIterator<int, QString> it; |
105 | for ( it = ++m_fieldMap.begin(); it != m_fieldMap.end(); ++it ){ | 109 | for ( it = ++m_fieldMap.begin(); it != m_fieldMap.end(); ++it ){ |
106 | m_reverseFieldMap.insert( it.data(), it.key() ); | 110 | m_reverseFieldMap.insert( it.data(), it.key() ); |
107 | } | 111 | } |
108 | 112 | ||
109 | } | 113 | } |
110 | 114 | ||
111 | bool ODateBookAccessBackend_SQL::load() | 115 | bool ODateBookAccessBackend_SQL::load() |
112 | { | 116 | { |
113 | if (!m_driver->open() ) | 117 | if (!m_driver->open() ) |
114 | return false; | 118 | return false; |
115 | 119 | ||
116 | // Don't expect that the database exists. | 120 | // Don't expect that the database exists. |
117 | // It is save here to create the table, even if it | 121 | // It is save here to create the table, even if it |
118 | // do exist. ( Is that correct for all databases ?? ) | 122 | // do exist. ( Is that correct for all databases ?? ) |
119 | QStringqu = "create table datebook( uid INTEGER PRIMARY KEY "; | 123 | QStringqu = "create table datebook( uid INTEGER PRIMARY KEY "; |
120 | 124 | ||
121 | QMap<int, QString>::Iterator it; | 125 | QMap<int, QString>::Iterator it; |
122 | for ( it = ++m_fieldMap.begin(); it != m_fieldMap.end(); ++it ){ | 126 | for ( it = ++m_fieldMap.begin(); it != m_fieldMap.end(); ++it ){ |
123 | qu += QString( ",%1 VARCHAR(10)" ).arg( it.data() ); | 127 | qu += QString( ",%1 VARCHAR(10)" ).arg( it.data() ); |
124 | } | 128 | } |
125 | qu += " );"; | 129 | qu += " );"; |
126 | 130 | ||
127 | qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR, priority INTEGER, value VARCHAR, PRIMARY KEY /* identifier */ (uid, id) );"; | 131 | qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR, priority INTEGER, value VARCHAR, PRIMARY KEY /* identifier */ (uid, id) );"; |
128 | 132 | ||
129 | qWarning( "command: %s", qu.latin1() ); | 133 | qWarning( "command: %s", qu.latin1() ); |
130 | 134 | ||
131 | OSQLRawQuery raw( qu ); | 135 | OSQLRawQuery raw( qu ); |
132 | OSQLResult res = m_driver->query( &raw ); | 136 | OSQLResult res = m_driver->query( &raw ); |
133 | if ( res.state() != OSQLResult::Success ) | 137 | if ( res.state() != OSQLResult::Success ) |
134 | return false; | 138 | return false; |
135 | 139 | ||
136 | update(); | 140 | update(); |
137 | 141 | ||
138 | return true; | 142 | return true; |
139 | } | 143 | } |
140 | 144 | ||
141 | void ODateBookAccessBackend_SQL::update() | 145 | void ODateBookAccessBackend_SQL::update() |
142 | { | 146 | { |
143 | 147 | ||
144 | QString qu = "select uid from datebook"; | 148 | QString qu = "select uid from datebook"; |
145 | OSQLRawQuery raw( qu ); | 149 | OSQLRawQuery raw( qu ); |
146 | OSQLResult res = m_driver->query( &raw ); | 150 | OSQLResult res = m_driver->query( &raw ); |
147 | if ( res.state() != OSQLResult::Success ){ | 151 | if ( res.state() != OSQLResult::Success ){ |
148 | // m_uids.clear(); | 152 | // m_uids.clear(); |
149 | return; | 153 | return; |
150 | } | 154 | } |
151 | 155 | ||
152 | m_uids = extractUids( res ); | 156 | m_uids = extractUids( res ); |
153 | 157 | ||
154 | } | 158 | } |
155 | 159 | ||
156 | bool ODateBookAccessBackend_SQL::reload() | 160 | bool ODateBookAccessBackend_SQL::reload() |
157 | { | 161 | { |
158 | return load(); | 162 | return load(); |
159 | } | 163 | } |
160 | 164 | ||
161 | bool ODateBookAccessBackend_SQL::save() | 165 | bool ODateBookAccessBackend_SQL::save() |
162 | { | 166 | { |
163 | return m_driver->close(); // Shouldn't m_driver->sync be better than close ? (eilers) | 167 | return m_driver->close(); // Shouldn't m_driver->sync be better than close ? (eilers) |
164 | } | 168 | } |
165 | 169 | ||
166 | QArray<int> ODateBookAccessBackend_SQL::allRecords()const | 170 | QArray<int> ODateBookAccessBackend_SQL::allRecords()const |
167 | { | 171 | { |
168 | return m_uids; | 172 | return m_uids; |
169 | } | 173 | } |
170 | 174 | ||
171 | QArray<int> ODateBookAccessBackend_SQL::queryByExample(const OEvent&, int, const QDateTime& ) { | 175 | QArray<int> ODateBookAccessBackend_SQL::queryByExample(const OEvent&, int, const QDateTime& ) { |
172 | return QArray<int>(); | 176 | return QArray<int>(); |
173 | } | 177 | } |
174 | 178 | ||
175 | void ODateBookAccessBackend_SQL::clear() | 179 | void ODateBookAccessBackend_SQL::clear() |
176 | { | 180 | { |
177 | QString qu = "drop table datebook;"; | 181 | QString qu = "drop table datebook;"; |
178 | qu += "drop table custom_data;"; | 182 | qu += "drop table custom_data;"; |
179 | 183 | ||
180 | OSQLRawQuery raw( qu ); | 184 | OSQLRawQuery raw( qu ); |
181 | OSQLResult res = m_driver->query( &raw ); | 185 | OSQLResult res = m_driver->query( &raw ); |
182 | 186 | ||
183 | reload(); | 187 | reload(); |
184 | } | 188 | } |
185 | 189 | ||
186 | 190 | ||
187 | OEvent ODateBookAccessBackend_SQL::find( int uid ) const{ | 191 | OEvent ODateBookAccessBackend_SQL::find( int uid ) const{ |
188 | QString qu = "select *"; | 192 | QString qu = "select *"; |
189 | qu += "from datebook where uid = " + QString::number(uid); | 193 | qu += "from datebook where uid = " + QString::number(uid); |
190 | 194 | ||
191 | OSQLRawQuery raw( qu ); | 195 | OSQLRawQuery raw( qu ); |
192 | OSQLResult res = m_driver->query( &raw ); | 196 | OSQLResult res = m_driver->query( &raw ); |
193 | 197 | ||
194 | OSQLResultItem resItem = res.first(); | 198 | OSQLResultItem resItem = res.first(); |
195 | 199 | ||
196 | // Create Map for date event and insert UID | 200 | // Create Map for date event and insert UID |
197 | QMap<int,QString> dateEventMap; | 201 | QMap<int,QString> dateEventMap; |
198 | dateEventMap.insert( OEvent::FUid, QString::number( uid ) ); | 202 | dateEventMap.insert( OEvent::FUid, QString::number( uid ) ); |
199 | 203 | ||
200 | // Now insert the data out of the columns into the map. | 204 | // Now insert the data out of the columns into the map. |
201 | QMapConstIterator<int, QString> it; | 205 | QMapConstIterator<int, QString> it; |
202 | for ( it = ++m_fieldMap.begin(); it != m_fieldMap.end(); ++it ){ | 206 | for ( it = ++m_fieldMap.begin(); it != m_fieldMap.end(); ++it ){ |
203 | dateEventMap.insert( m_reverseFieldMap[*it], resItem.data( *it ) ); | 207 | dateEventMap.insert( m_reverseFieldMap[*it], resItem.data( *it ) ); |
204 | } | 208 | } |
205 | 209 | ||
206 | // Last step: Put map into date event and return it | 210 | // Last step: Put map into date event and return it |
207 | OEvent retDate( dateEventMap ); | 211 | OEvent retDate( dateEventMap ); |
208 | 212 | ||
209 | return retDate; | 213 | return retDate; |
210 | } | 214 | } |
211 | 215 | ||
212 | // FIXME: Speed up update of uid's.. | 216 | // FIXME: Speed up update of uid's.. |
213 | bool ODateBookAccessBackend_SQL::add( const OEvent& ev ) | 217 | bool ODateBookAccessBackend_SQL::add( const OEvent& ev ) |
214 | { | 218 | { |
215 | QMap<int,QString> eventMap = ev.toMap(); | 219 | QMap<int,QString> eventMap = ev.toMap(); |
216 | 220 | ||
217 | QString qu = "insert into datebook VALUES( " + QString::number( ev.uid() ); | 221 | QString qu = "insert into datebook VALUES( " + QString::number( ev.uid() ); |
218 | QMap<int, QString>::Iterator it; | 222 | QMap<int, QString>::Iterator it; |
219 | for ( it = ++m_fieldMap.begin(); it != m_fieldMap.end(); ++it ){ | 223 | for ( it = ++m_fieldMap.begin(); it != m_fieldMap.end(); ++it ){ |
220 | if ( !eventMap[it.key()].isEmpty() ) | 224 | if ( !eventMap[it.key()].isEmpty() ) |
221 | qu += QString( ",\"%1\"" ).arg( eventMap[it.key()] ); | 225 | qu += QString( ",\"%1\"" ).arg( eventMap[it.key()] ); |
222 | else | 226 | else |
223 | qu += QString( ",\"\"" ); | 227 | qu += QString( ",\"\"" ); |
224 | } | 228 | } |
225 | qu += " );"; | 229 | qu += " );"; |
226 | 230 | ||
227 | // Add custom entries | 231 | // Add custom entries |
228 | int id = 0; | 232 | int id = 0; |
229 | QMap<QString, QString> customMap = ev.toExtraMap(); | 233 | QMap<QString, QString> customMap = ev.toExtraMap(); |
230 | for( QMap<QString, QString>::Iterator it = customMap.begin(); | 234 | for( QMap<QString, QString>::Iterator it = customMap.begin(); |
231 | it != customMap.end(); ++it ){ | 235 | it != customMap.end(); ++it ){ |
232 | qu += "insert into custom_data VALUES(" | 236 | qu += "insert into custom_data VALUES(" |
233 | + QString::number( ev.uid() ) | 237 | + QString::number( ev.uid() ) |
234 | + "," | 238 | + "," |
235 | + QString::number( id++ ) | 239 | + QString::number( id++ ) |
236 | + ",'" | 240 | + ",'" |
237 | + it.key() //.latin1() | 241 | + it.key() //.latin1() |
238 | + "'," | 242 | + "'," |
239 | + "0" // Priority for future enhancements | 243 | + "0" // Priority for future enhancements |
240 | + ",'" | 244 | + ",'" |
241 | + it.data() //.latin1() | 245 | + it.data() //.latin1() |
242 | + "');"; | 246 | + "');"; |
243 | } | 247 | } |
244 | qWarning("add %s", qu.latin1() ); | 248 | qWarning("add %s", qu.latin1() ); |
245 | 249 | ||
246 | OSQLRawQuery raw( qu ); | 250 | OSQLRawQuery raw( qu ); |
247 | OSQLResult res = m_driver->query( &raw ); | 251 | OSQLResult res = m_driver->query( &raw ); |
248 | if ( res.state() != OSQLResult::Success ){ | 252 | if ( res.state() != OSQLResult::Success ){ |
249 | return false; | 253 | return false; |
250 | } | 254 | } |
251 | 255 | ||
252 | // Update list of uid's | 256 | // Update list of uid's |
253 | update(); | 257 | update(); |
254 | 258 | ||
255 | return true; | 259 | return true; |
256 | } | 260 | } |
257 | 261 | ||
258 | // FIXME: Speed up update of uid's.. | 262 | // FIXME: Speed up update of uid's.. |
259 | bool ODateBookAccessBackend_SQL::remove( int uid ) | 263 | bool ODateBookAccessBackend_SQL::remove( int uid ) |
260 | { | 264 | { |
261 | QString qu = "DELETE from datebook where uid = " | 265 | QString qu = "DELETE from datebook where uid = " |
262 | + QString::number( uid ) + ";"; | 266 | + QString::number( uid ) + ";"; |
263 | qu += "DELETE from custom_data where uid = " | 267 | qu += "DELETE from custom_data where uid = " |
264 | + QString::number( uid ) + ";"; | 268 | + QString::number( uid ) + ";"; |
265 | 269 | ||
266 | OSQLRawQuery raw( qu ); | 270 | OSQLRawQuery raw( qu ); |
267 | OSQLResult res = m_driver->query( &raw ); | 271 | OSQLResult res = m_driver->query( &raw ); |
268 | if ( res.state() != OSQLResult::Success ){ | 272 | if ( res.state() != OSQLResult::Success ){ |
269 | return false; | 273 | return false; |
270 | } | 274 | } |
271 | 275 | ||
272 | // Update list of uid's | 276 | // Update list of uid's |
273 | update(); | 277 | update(); |
274 | 278 | ||
275 | return true; | 279 | return true; |
276 | } | 280 | } |
277 | 281 | ||
278 | bool ODateBookAccessBackend_SQL::replace( const OEvent& ev ) | 282 | bool ODateBookAccessBackend_SQL::replace( const OEvent& ev ) |
279 | { | 283 | { |
280 | remove( ev.uid() ); | 284 | remove( ev.uid() ); |
281 | return add( ev ); | 285 | return add( ev ); |
282 | } | 286 | } |
283 | 287 | ||
284 | QArray<int> ODateBookAccessBackend_SQL::rawEvents()const | 288 | QArray<int> ODateBookAccessBackend_SQL::rawEvents()const |
285 | { | 289 | { |
286 | return allRecords(); | 290 | return allRecords(); |
287 | } | 291 | } |
288 | 292 | ||
289 | QArray<int> ODateBookAccessBackend_SQL::rawRepeats()const | 293 | QArray<int> ODateBookAccessBackend_SQL::rawRepeats()const |
290 | { | 294 | { |
291 | QString qu = "select uid from datebook where RType!=\"\" AND RType!=\"NoRepeat\""; | 295 | QString qu = "select uid from datebook where RType!=\"\" AND RType!=\"NoRepeat\""; |
292 | OSQLRawQuery raw( qu ); | 296 | OSQLRawQuery raw( qu ); |
293 | OSQLResult res = m_driver->query( &raw ); | 297 | OSQLResult res = m_driver->query( &raw ); |
294 | if ( res.state() != OSQLResult::Success ){ | 298 | if ( res.state() != OSQLResult::Success ){ |
295 | QArray<int> nix; | 299 | QArray<int> nix; |
296 | return nix; | 300 | return nix; |
297 | } | 301 | } |
298 | 302 | ||
299 | return extractUids( res ); | 303 | return extractUids( res ); |
300 | } | 304 | } |
301 | 305 | ||
302 | QArray<int> ODateBookAccessBackend_SQL::nonRepeats()const | 306 | QArray<int> ODateBookAccessBackend_SQL::nonRepeats()const |
303 | { | 307 | { |
304 | QString qu = "select uid from datebook where RType=\"\" or RType=\"NoRepeat\""; | 308 | QString qu = "select uid from datebook where RType=\"\" or RType=\"NoRepeat\""; |
305 | OSQLRawQuery raw( qu ); | 309 | OSQLRawQuery raw( qu ); |
306 | OSQLResult res = m_driver->query( &raw ); | 310 | OSQLResult res = m_driver->query( &raw ); |
307 | if ( res.state() != OSQLResult::Success ){ | 311 | if ( res.state() != OSQLResult::Success ){ |
308 | QArray<int> nix; | 312 | QArray<int> nix; |
309 | return nix; | 313 | return nix; |
310 | } | 314 | } |
311 | 315 | ||
312 | return extractUids( res ); | 316 | return extractUids( res ); |
313 | } | 317 | } |
314 | 318 | ||
315 | OEvent::ValueList ODateBookAccessBackend_SQL::directNonRepeats() | 319 | OEvent::ValueList ODateBookAccessBackend_SQL::directNonRepeats() |
316 | { | 320 | { |
317 | QArray<int> nonRepUids = nonRepeats(); | 321 | QArray<int> nonRepUids = nonRepeats(); |
318 | OEvent::ValueList list; | 322 | OEvent::ValueList list; |
319 | 323 | ||
320 | for (uint i = 0; i < nonRepUids.count(); ++i ){ | 324 | for (uint i = 0; i < nonRepUids.count(); ++i ){ |
321 | list.append( find( nonRepUids[i] ) ); | 325 | list.append( find( nonRepUids[i] ) ); |
322 | } | 326 | } |
323 | 327 | ||
324 | return list; | 328 | return list; |
325 | 329 | ||
326 | } | 330 | } |
327 | OEvent::ValueList ODateBookAccessBackend_SQL::directRawRepeats() | 331 | OEvent::ValueList ODateBookAccessBackend_SQL::directRawRepeats() |
328 | { | 332 | { |
329 | QArray<int> rawRepUids = rawRepeats(); | 333 | QArray<int> rawRepUids = rawRepeats(); |
330 | OEvent::ValueList list; | 334 | OEvent::ValueList list; |
331 | 335 | ||
332 | for (uint i = 0; i < rawRepUids.count(); ++i ){ | 336 | for (uint i = 0; i < rawRepUids.count(); ++i ){ |
333 | list.append( find( rawRepUids[i] ) ); | 337 | list.append( find( rawRepUids[i] ) ); |
334 | } | 338 | } |
335 | 339 | ||
336 | return list; | 340 | return list; |
337 | } | 341 | } |
338 | 342 | ||
339 | 343 | ||
340 | QArray<int> ODateBookAccessBackend_SQL::matchRegexp( const QRegExp &r ) const | 344 | QArray<int> ODateBookAccessBackend_SQL::matchRegexp( const QRegExp &r ) const |
341 | { | 345 | { |
342 | QArray<int> null; | 346 | QArray<int> null; |
343 | return null; | 347 | return null; |
344 | } | 348 | } |
345 | 349 | ||
346 | /* ===== Private Functions ========================================== */ | 350 | /* ===== Private Functions ========================================== */ |
347 | 351 | ||
348 | QArray<int> ODateBookAccessBackend_SQL::extractUids( OSQLResult& res ) const | 352 | QArray<int> ODateBookAccessBackend_SQL::extractUids( OSQLResult& res ) const |
349 | { | 353 | { |
350 | qWarning("extractUids"); | 354 | qWarning("extractUids"); |
351 | QTime t; | 355 | QTime t; |
352 | t.start(); | 356 | t.start(); |
353 | OSQLResultItem::ValueList list = res.results(); | 357 | OSQLResultItem::ValueList list = res.results(); |
354 | OSQLResultItem::ValueList::Iterator it; | 358 | OSQLResultItem::ValueList::Iterator it; |
355 | QArray<int> ints(list.count() ); | 359 | QArray<int> ints(list.count() ); |
356 | qWarning(" count = %d", list.count() ); | 360 | qWarning(" count = %d", list.count() ); |
357 | 361 | ||
358 | int i = 0; | 362 | int i = 0; |
359 | for (it = list.begin(); it != list.end(); ++it ) { | 363 | for (it = list.begin(); it != list.end(); ++it ) { |
360 | ints[i] = (*it).data("uid").toInt(); | 364 | ints[i] = (*it).data("uid").toInt(); |
361 | i++; | 365 | i++; |
362 | } | 366 | } |
363 | qWarning("extractUids ready: count2 = %d needs %d ms", i, t.elapsed() ); | 367 | qWarning("extractUids ready: count2 = %d needs %d ms", i, t.elapsed() ); |
364 | 368 | ||
365 | return ints; | 369 | return ints; |
366 | 370 | ||
367 | } | 371 | } |
diff --git a/libopie/pim/odatebookaccessbackend_sql.h b/libopie/pim/odatebookaccessbackend_sql.h index f39e154..ba514bc 100644 --- a/libopie/pim/odatebookaccessbackend_sql.h +++ b/libopie/pim/odatebookaccessbackend_sql.h | |||
@@ -1,62 +1,65 @@ | |||
1 | #ifndef OPIE_DATE_BOOK_ACCESS_BACKEND_SQL__H | 1 | #ifndef OPIE_DATE_BOOK_ACCESS_BACKEND_SQL__H |
2 | #define OPIE_DATE_BOOK_ACCESS_BACKEND_SQL__H | 2 | #define OPIE_DATE_BOOK_ACCESS_BACKEND_SQL__H |
3 | 3 | ||
4 | #include <qmap.h> | 4 | #include <qmap.h> |
5 | #include <opie2/osqlresult.h> | 5 | #include <opie2/osqlresult.h> |
6 | 6 | ||
7 | #include "odatebookaccessbackend.h" | 7 | #include "odatebookaccessbackend.h" |
8 | 8 | ||
9 | namespace Opie { namespace DB { | ||
9 | class OSQLDriver; | 10 | class OSQLDriver; |
10 | 11 | ||
12 | }} | ||
13 | |||
11 | /** | 14 | /** |
12 | * This is the default SQL implementation for DateBoook SQL storage | 15 | * This is the default SQL implementation for DateBoook SQL storage |
13 | * It fully implements the interface | 16 | * It fully implements the interface |
14 | * @see ODateBookAccessBackend | 17 | * @see ODateBookAccessBackend |
15 | * @see OPimAccessBackend | 18 | * @see OPimAccessBackend |
16 | */ | 19 | */ |
17 | class ODateBookAccessBackend_SQL : public ODateBookAccessBackend { | 20 | class ODateBookAccessBackend_SQL : public ODateBookAccessBackend { |
18 | public: | 21 | public: |
19 | ODateBookAccessBackend_SQL( const QString& appName, | 22 | ODateBookAccessBackend_SQL( const QString& appName, |
20 | const QString& fileName = QString::null); | 23 | const QString& fileName = QString::null); |
21 | ~ODateBookAccessBackend_SQL(); | 24 | ~ODateBookAccessBackend_SQL(); |
22 | 25 | ||
23 | bool load(); | 26 | bool load(); |
24 | bool reload(); | 27 | bool reload(); |
25 | bool save(); | 28 | bool save(); |
26 | 29 | ||
27 | QArray<int> allRecords()const; | 30 | QArray<int> allRecords()const; |
28 | QArray<int> matchRegexp(const QRegExp &r) const; | 31 | QArray<int> matchRegexp(const QRegExp &r) const; |
29 | QArray<int> queryByExample( const OEvent&, int, const QDateTime& d = QDateTime() ); | 32 | QArray<int> queryByExample( const OEvent&, int, const QDateTime& d = QDateTime() ); |
30 | OEvent find( int uid )const; | 33 | OEvent find( int uid )const; |
31 | void clear(); | 34 | void clear(); |
32 | bool add( const OEvent& ev ); | 35 | bool add( const OEvent& ev ); |
33 | bool remove( int uid ); | 36 | bool remove( int uid ); |
34 | bool replace( const OEvent& ev ); | 37 | bool replace( const OEvent& ev ); |
35 | 38 | ||
36 | QArray<UID> rawEvents()const; | 39 | QArray<UID> rawEvents()const; |
37 | QArray<UID> rawRepeats()const; | 40 | QArray<UID> rawRepeats()const; |
38 | QArray<UID> nonRepeats()const; | 41 | QArray<UID> nonRepeats()const; |
39 | 42 | ||
40 | OEvent::ValueList directNonRepeats(); | 43 | OEvent::ValueList directNonRepeats(); |
41 | OEvent::ValueList directRawRepeats(); | 44 | OEvent::ValueList directRawRepeats(); |
42 | 45 | ||
43 | private: | 46 | private: |
44 | bool loadFile(); | 47 | bool loadFile(); |
45 | QString m_fileName; | 48 | QString m_fileName; |
46 | QArray<int> m_uids; | 49 | QArray<int> m_uids; |
47 | 50 | ||
48 | QMap<int, QString> m_fieldMap; | 51 | QMap<int, QString> m_fieldMap; |
49 | QMap<QString, int> m_reverseFieldMap; | 52 | QMap<QString, int> m_reverseFieldMap; |
50 | 53 | ||
51 | OSQLDriver* m_driver; | 54 | Opie::DB::OSQLDriver* m_driver; |
52 | 55 | ||
53 | class Private; | 56 | class Private; |
54 | Private *d; | 57 | Private *d; |
55 | 58 | ||
56 | void initFields(); | 59 | void initFields(); |
57 | void update(); | 60 | void update(); |
58 | QArray<int> extractUids( OSQLResult& res ) const; | 61 | QArray<int> extractUids( Opie::DB::OSQLResult& res ) const; |
59 | 62 | ||
60 | }; | 63 | }; |
61 | 64 | ||
62 | #endif | 65 | #endif |
diff --git a/libopie/pim/otodoaccesssql.cpp b/libopie/pim/otodoaccesssql.cpp index 3764c7e..fd01a42 100644 --- a/libopie/pim/otodoaccesssql.cpp +++ b/libopie/pim/otodoaccesssql.cpp | |||
@@ -1,527 +1,528 @@ | |||
1 | 1 | ||
2 | #include <qdatetime.h> | 2 | #include <qdatetime.h> |
3 | 3 | ||
4 | #include <qpe/global.h> | 4 | #include <qpe/global.h> |
5 | 5 | ||
6 | #include <opie2/osqldriver.h> | 6 | #include <opie2/osqldriver.h> |
7 | #include <opie2/osqlresult.h> | 7 | #include <opie2/osqlresult.h> |
8 | #include <opie2/osqlmanager.h> | 8 | #include <opie2/osqlmanager.h> |
9 | #include <opie2/osqlquery.h> | 9 | #include <opie2/osqlquery.h> |
10 | 10 | ||
11 | #include "otodoaccesssql.h" | 11 | #include "otodoaccesssql.h" |
12 | #include "opimstate.h" | 12 | #include "opimstate.h" |
13 | #include "opimnotifymanager.h" | 13 | #include "opimnotifymanager.h" |
14 | #include "orecur.h" | 14 | #include "orecur.h" |
15 | 15 | ||
16 | using namespace Opie::DB; | ||
16 | /* | 17 | /* |
17 | * first some query | 18 | * first some query |
18 | * CREATE query | 19 | * CREATE query |
19 | * LOAD query | 20 | * LOAD query |
20 | * INSERT | 21 | * INSERT |
21 | * REMOVE | 22 | * REMOVE |
22 | * CLEAR | 23 | * CLEAR |
23 | */ | 24 | */ |
24 | namespace { | 25 | namespace { |
25 | /** | 26 | /** |
26 | * CreateQuery for the Todolist Table | 27 | * CreateQuery for the Todolist Table |
27 | */ | 28 | */ |
28 | class CreateQuery : public OSQLQuery { | 29 | class CreateQuery : public OSQLQuery { |
29 | public: | 30 | public: |
30 | CreateQuery(); | 31 | CreateQuery(); |
31 | ~CreateQuery(); | 32 | ~CreateQuery(); |
32 | QString query()const; | 33 | QString query()const; |
33 | }; | 34 | }; |
34 | 35 | ||
35 | /** | 36 | /** |
36 | * LoadQuery | 37 | * LoadQuery |
37 | * this one queries for all uids | 38 | * this one queries for all uids |
38 | */ | 39 | */ |
39 | class LoadQuery : public OSQLQuery { | 40 | class LoadQuery : public OSQLQuery { |
40 | public: | 41 | public: |
41 | LoadQuery(); | 42 | LoadQuery(); |
42 | ~LoadQuery(); | 43 | ~LoadQuery(); |
43 | QString query()const; | 44 | QString query()const; |
44 | }; | 45 | }; |
45 | 46 | ||
46 | /** | 47 | /** |
47 | * inserts/adds a OTodo to the table | 48 | * inserts/adds a OTodo to the table |
48 | */ | 49 | */ |
49 | class InsertQuery : public OSQLQuery { | 50 | class InsertQuery : public OSQLQuery { |
50 | public: | 51 | public: |
51 | InsertQuery(const OTodo& ); | 52 | InsertQuery(const OTodo& ); |
52 | ~InsertQuery(); | 53 | ~InsertQuery(); |
53 | QString query()const; | 54 | QString query()const; |
54 | private: | 55 | private: |
55 | OTodo m_todo; | 56 | OTodo m_todo; |
56 | }; | 57 | }; |
57 | 58 | ||
58 | /** | 59 | /** |
59 | * removes one from the table | 60 | * removes one from the table |
60 | */ | 61 | */ |
61 | class RemoveQuery : public OSQLQuery { | 62 | class RemoveQuery : public OSQLQuery { |
62 | public: | 63 | public: |
63 | RemoveQuery(int uid ); | 64 | RemoveQuery(int uid ); |
64 | ~RemoveQuery(); | 65 | ~RemoveQuery(); |
65 | QString query()const; | 66 | QString query()const; |
66 | private: | 67 | private: |
67 | int m_uid; | 68 | int m_uid; |
68 | }; | 69 | }; |
69 | 70 | ||
70 | /** | 71 | /** |
71 | * Clears (delete) a Table | 72 | * Clears (delete) a Table |
72 | */ | 73 | */ |
73 | class ClearQuery : public OSQLQuery { | 74 | class ClearQuery : public OSQLQuery { |
74 | public: | 75 | public: |
75 | ClearQuery(); | 76 | ClearQuery(); |
76 | ~ClearQuery(); | 77 | ~ClearQuery(); |
77 | QString query()const; | 78 | QString query()const; |
78 | 79 | ||
79 | }; | 80 | }; |
80 | 81 | ||
81 | /** | 82 | /** |
82 | * a find query | 83 | * a find query |
83 | */ | 84 | */ |
84 | class FindQuery : public OSQLQuery { | 85 | class FindQuery : public OSQLQuery { |
85 | public: | 86 | public: |
86 | FindQuery(int uid); | 87 | FindQuery(int uid); |
87 | FindQuery(const QArray<int>& ); | 88 | FindQuery(const QArray<int>& ); |
88 | ~FindQuery(); | 89 | ~FindQuery(); |
89 | QString query()const; | 90 | QString query()const; |
90 | private: | 91 | private: |
91 | QString single()const; | 92 | QString single()const; |
92 | QString multi()const; | 93 | QString multi()const; |
93 | QArray<int> m_uids; | 94 | QArray<int> m_uids; |
94 | int m_uid; | 95 | int m_uid; |
95 | }; | 96 | }; |
96 | 97 | ||
97 | /** | 98 | /** |
98 | * overdue query | 99 | * overdue query |
99 | */ | 100 | */ |
100 | class OverDueQuery : public OSQLQuery { | 101 | class OverDueQuery : public OSQLQuery { |
101 | public: | 102 | public: |
102 | OverDueQuery(); | 103 | OverDueQuery(); |
103 | ~OverDueQuery(); | 104 | ~OverDueQuery(); |
104 | QString query()const; | 105 | QString query()const; |
105 | }; | 106 | }; |
106 | class EffQuery : public OSQLQuery { | 107 | class EffQuery : public OSQLQuery { |
107 | public: | 108 | public: |
108 | EffQuery( const QDate&, const QDate&, bool inc ); | 109 | EffQuery( const QDate&, const QDate&, bool inc ); |
109 | ~EffQuery(); | 110 | ~EffQuery(); |
110 | QString query()const; | 111 | QString query()const; |
111 | private: | 112 | private: |
112 | QString with()const; | 113 | QString with()const; |
113 | QString out()const; | 114 | QString out()const; |
114 | QDate m_start; | 115 | QDate m_start; |
115 | QDate m_end; | 116 | QDate m_end; |
116 | bool m_inc :1; | 117 | bool m_inc :1; |
117 | }; | 118 | }; |
118 | 119 | ||
119 | 120 | ||
120 | CreateQuery::CreateQuery() : OSQLQuery() {} | 121 | CreateQuery::CreateQuery() : OSQLQuery() {} |
121 | CreateQuery::~CreateQuery() {} | 122 | CreateQuery::~CreateQuery() {} |
122 | QString CreateQuery::query()const { | 123 | QString CreateQuery::query()const { |
123 | QString qu; | 124 | QString qu; |
124 | qu += "create table todolist( uid PRIMARY KEY, categories, completed, "; | 125 | qu += "create table todolist( uid PRIMARY KEY, categories, completed, "; |
125 | qu += "description, summary, priority, DueDate, progress , state, "; | 126 | qu += "description, summary, priority, DueDate, progress , state, "; |
126 | // This is the recurrance-stuff .. Exceptions are currently not supported (see ORecur.cpp) ! (eilers) | 127 | // This is the recurrance-stuff .. Exceptions are currently not supported (see ORecur.cpp) ! (eilers) |
127 | qu += "RType, RWeekdays, RPosition, RFreq, RHasEndDate, EndDate, Created, Exceptions, "; | 128 | qu += "RType, RWeekdays, RPosition, RFreq, RHasEndDate, EndDate, Created, Exceptions, "; |
128 | qu += "reminders, alarms, maintainer, startdate, completeddate);"; | 129 | qu += "reminders, alarms, maintainer, startdate, completeddate);"; |
129 | qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR(10), value VARCHAR(10), PRIMARY KEY /* identifier */ (uid, id) );"; | 130 | qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR(10), value VARCHAR(10), PRIMARY KEY /* identifier */ (uid, id) );"; |
130 | return qu; | 131 | return qu; |
131 | } | 132 | } |
132 | 133 | ||
133 | LoadQuery::LoadQuery() : OSQLQuery() {} | 134 | LoadQuery::LoadQuery() : OSQLQuery() {} |
134 | LoadQuery::~LoadQuery() {} | 135 | LoadQuery::~LoadQuery() {} |
135 | QString LoadQuery::query()const { | 136 | QString LoadQuery::query()const { |
136 | QString qu; | 137 | QString qu; |
137 | // We do not need "distinct" here. The primary key is always unique.. | 138 | // We do not need "distinct" here. The primary key is always unique.. |
138 | //qu += "select distinct uid from todolist"; | 139 | //qu += "select distinct uid from todolist"; |
139 | qu += "select uid from todolist"; | 140 | qu += "select uid from todolist"; |
140 | 141 | ||
141 | return qu; | 142 | return qu; |
142 | } | 143 | } |
143 | 144 | ||
144 | InsertQuery::InsertQuery( const OTodo& todo ) | 145 | InsertQuery::InsertQuery( const OTodo& todo ) |
145 | : OSQLQuery(), m_todo( todo ) { | 146 | : OSQLQuery(), m_todo( todo ) { |
146 | } | 147 | } |
147 | InsertQuery::~InsertQuery() { | 148 | InsertQuery::~InsertQuery() { |
148 | } | 149 | } |
149 | /* | 150 | /* |
150 | * converts from a OTodo to a query | 151 | * converts from a OTodo to a query |
151 | * we leave out X-Ref + Alarms | 152 | * we leave out X-Ref + Alarms |
152 | */ | 153 | */ |
153 | QString InsertQuery::query()const{ | 154 | QString InsertQuery::query()const{ |
154 | 155 | ||
155 | int year, month, day; | 156 | int year, month, day; |
156 | year = month = day = 0; | 157 | year = month = day = 0; |
157 | if (m_todo.hasDueDate() ) { | 158 | if (m_todo.hasDueDate() ) { |
158 | QDate date = m_todo.dueDate(); | 159 | QDate date = m_todo.dueDate(); |
159 | year = date.year(); | 160 | year = date.year(); |
160 | month = date.month(); | 161 | month = date.month(); |
161 | day = date.day(); | 162 | day = date.day(); |
162 | } | 163 | } |
163 | int sYear = 0, sMonth = 0, sDay = 0; | 164 | int sYear = 0, sMonth = 0, sDay = 0; |
164 | if( m_todo.hasStartDate() ){ | 165 | if( m_todo.hasStartDate() ){ |
165 | QDate sDate = m_todo.startDate(); | 166 | QDate sDate = m_todo.startDate(); |
166 | sYear = sDate.year(); | 167 | sYear = sDate.year(); |
167 | sMonth= sDate.month(); | 168 | sMonth= sDate.month(); |
168 | sDay = sDate.day(); | 169 | sDay = sDate.day(); |
169 | } | 170 | } |
170 | 171 | ||
171 | int eYear = 0, eMonth = 0, eDay = 0; | 172 | int eYear = 0, eMonth = 0, eDay = 0; |
172 | if( m_todo.hasCompletedDate() ){ | 173 | if( m_todo.hasCompletedDate() ){ |
173 | QDate eDate = m_todo.completedDate(); | 174 | QDate eDate = m_todo.completedDate(); |
174 | eYear = eDate.year(); | 175 | eYear = eDate.year(); |
175 | eMonth= eDate.month(); | 176 | eMonth= eDate.month(); |
176 | eDay = eDate.day(); | 177 | eDay = eDate.day(); |
177 | } | 178 | } |
178 | QString qu; | 179 | QString qu; |
179 | QMap<int, QString> recMap = m_todo.recurrence().toMap(); | 180 | QMap<int, QString> recMap = m_todo.recurrence().toMap(); |
180 | qu = "insert into todolist VALUES(" | 181 | qu = "insert into todolist VALUES(" |
181 | + QString::number( m_todo.uid() ) + "," | 182 | + QString::number( m_todo.uid() ) + "," |
182 | + "'" + m_todo.idsToString( m_todo.categories() ) + "'" + "," | 183 | + "'" + m_todo.idsToString( m_todo.categories() ) + "'" + "," |
183 | + QString::number( m_todo.isCompleted() ) + "," | 184 | + QString::number( m_todo.isCompleted() ) + "," |
184 | + "'" + m_todo.description() + "'" + "," | 185 | + "'" + m_todo.description() + "'" + "," |
185 | + "'" + m_todo.summary() + "'" + "," | 186 | + "'" + m_todo.summary() + "'" + "," |
186 | + QString::number(m_todo.priority() ) + "," | 187 | + QString::number(m_todo.priority() ) + "," |
187 | + "'" + QString::number(year) + "-" | 188 | + "'" + QString::number(year) + "-" |
188 | + QString::number(month) | 189 | + QString::number(month) |
189 | + "-" + QString::number( day ) + "'" + "," | 190 | + "-" + QString::number( day ) + "'" + "," |
190 | + QString::number( m_todo.progress() ) + "," | 191 | + QString::number( m_todo.progress() ) + "," |
191 | + QString::number( m_todo.state().state() ) + "," | 192 | + QString::number( m_todo.state().state() ) + "," |
192 | + "'" + recMap[ ORecur::RType ] + "'" + "," | 193 | + "'" + recMap[ ORecur::RType ] + "'" + "," |
193 | + "'" + recMap[ ORecur::RWeekdays ] + "'" + "," | 194 | + "'" + recMap[ ORecur::RWeekdays ] + "'" + "," |
194 | + "'" + recMap[ ORecur::RPosition ] + "'" + "," | 195 | + "'" + recMap[ ORecur::RPosition ] + "'" + "," |
195 | + "'" + recMap[ ORecur::RFreq ] + "'" + "," | 196 | + "'" + recMap[ ORecur::RFreq ] + "'" + "," |
196 | + "'" + recMap[ ORecur::RHasEndDate ] + "'" + "," | 197 | + "'" + recMap[ ORecur::RHasEndDate ] + "'" + "," |
197 | + "'" + recMap[ ORecur::EndDate ] + "'" + "," | 198 | + "'" + recMap[ ORecur::EndDate ] + "'" + "," |
198 | + "'" + recMap[ ORecur::Created ] + "'" + "," | 199 | + "'" + recMap[ ORecur::Created ] + "'" + "," |
199 | + "'" + recMap[ ORecur::Exceptions ] + "'" + ","; | 200 | + "'" + recMap[ ORecur::Exceptions ] + "'" + ","; |
200 | 201 | ||
201 | if ( m_todo.hasNotifiers() ) { | 202 | if ( m_todo.hasNotifiers() ) { |
202 | OPimNotifyManager manager = m_todo.notifiers(); | 203 | OPimNotifyManager manager = m_todo.notifiers(); |
203 | qu += "'" + manager.remindersToString() + "'" + "," | 204 | qu += "'" + manager.remindersToString() + "'" + "," |
204 | + "'" + manager.alarmsToString() + "'" + ","; | 205 | + "'" + manager.alarmsToString() + "'" + ","; |
205 | } | 206 | } |
206 | else{ | 207 | else{ |
207 | qu += QString( "''" ) + "," | 208 | qu += QString( "''" ) + "," |
208 | + "''" + ","; | 209 | + "''" + ","; |
209 | } | 210 | } |
210 | 211 | ||
211 | qu += QString( "''" ) + QString( "," ) // Maintainers (cur. not supported !) | 212 | qu += QString( "''" ) + QString( "," ) // Maintainers (cur. not supported !) |
212 | + "'" + QString::number(sYear) + "-" | 213 | + "'" + QString::number(sYear) + "-" |
213 | + QString::number(sMonth) | 214 | + QString::number(sMonth) |
214 | + "-" + QString::number(sDay) + "'" + "," | 215 | + "-" + QString::number(sDay) + "'" + "," |
215 | + "'" + QString::number(eYear) + "-" | 216 | + "'" + QString::number(eYear) + "-" |
216 | + QString::number(eMonth) | 217 | + QString::number(eMonth) |
217 | + "-"+QString::number(eDay) + "'" | 218 | + "-"+QString::number(eDay) + "'" |
218 | + ")"; | 219 | + ")"; |
219 | 220 | ||
220 | qWarning("add %s", qu.latin1() ); | 221 | qWarning("add %s", qu.latin1() ); |
221 | return qu; | 222 | return qu; |
222 | } | 223 | } |
223 | 224 | ||
224 | RemoveQuery::RemoveQuery(int uid ) | 225 | RemoveQuery::RemoveQuery(int uid ) |
225 | : OSQLQuery(), m_uid( uid ) {} | 226 | : OSQLQuery(), m_uid( uid ) {} |
226 | RemoveQuery::~RemoveQuery() {} | 227 | RemoveQuery::~RemoveQuery() {} |
227 | QString RemoveQuery::query()const { | 228 | QString RemoveQuery::query()const { |
228 | QString qu = "DELETE from todolist where uid = " + QString::number(m_uid); | 229 | QString qu = "DELETE from todolist where uid = " + QString::number(m_uid); |
229 | return qu; | 230 | return qu; |
230 | } | 231 | } |
231 | 232 | ||
232 | 233 | ||
233 | ClearQuery::ClearQuery() | 234 | ClearQuery::ClearQuery() |
234 | : OSQLQuery() {} | 235 | : OSQLQuery() {} |
235 | ClearQuery::~ClearQuery() {} | 236 | ClearQuery::~ClearQuery() {} |
236 | QString ClearQuery::query()const { | 237 | QString ClearQuery::query()const { |
237 | QString qu = "drop table todolist"; | 238 | QString qu = "drop table todolist"; |
238 | return qu; | 239 | return qu; |
239 | } | 240 | } |
240 | FindQuery::FindQuery(int uid) | 241 | FindQuery::FindQuery(int uid) |
241 | : OSQLQuery(), m_uid(uid ) { | 242 | : OSQLQuery(), m_uid(uid ) { |
242 | } | 243 | } |
243 | FindQuery::FindQuery(const QArray<int>& ints) | 244 | FindQuery::FindQuery(const QArray<int>& ints) |
244 | : OSQLQuery(), m_uids(ints){ | 245 | : OSQLQuery(), m_uids(ints){ |
245 | } | 246 | } |
246 | FindQuery::~FindQuery() { | 247 | FindQuery::~FindQuery() { |
247 | } | 248 | } |
248 | QString FindQuery::query()const{ | 249 | QString FindQuery::query()const{ |
249 | if (m_uids.count() == 0 ) | 250 | if (m_uids.count() == 0 ) |
250 | return single(); | 251 | return single(); |
251 | else | 252 | else |
252 | return multi(); | 253 | return multi(); |
253 | } | 254 | } |
254 | QString FindQuery::single()const{ | 255 | QString FindQuery::single()const{ |
255 | QString qu = "select * from todolist where uid = " + QString::number(m_uid); | 256 | QString qu = "select * from todolist where uid = " + QString::number(m_uid); |
256 | return qu; | 257 | return qu; |
257 | } | 258 | } |
258 | QString FindQuery::multi()const { | 259 | QString FindQuery::multi()const { |
259 | QString qu = "select * from todolist where "; | 260 | QString qu = "select * from todolist where "; |
260 | for (uint i = 0; i < m_uids.count(); i++ ) { | 261 | for (uint i = 0; i < m_uids.count(); i++ ) { |
261 | qu += " UID = " + QString::number( m_uids[i] ) + " OR"; | 262 | qu += " UID = " + QString::number( m_uids[i] ) + " OR"; |
262 | } | 263 | } |
263 | qu.remove( qu.length()-2, 2 ); | 264 | qu.remove( qu.length()-2, 2 ); |
264 | return qu; | 265 | return qu; |
265 | } | 266 | } |
266 | 267 | ||
267 | OverDueQuery::OverDueQuery(): OSQLQuery() {} | 268 | OverDueQuery::OverDueQuery(): OSQLQuery() {} |
268 | OverDueQuery::~OverDueQuery() {} | 269 | OverDueQuery::~OverDueQuery() {} |
269 | QString OverDueQuery::query()const { | 270 | QString OverDueQuery::query()const { |
270 | QDate date = QDate::currentDate(); | 271 | QDate date = QDate::currentDate(); |
271 | QString str; | 272 | QString str; |
272 | str = QString("select uid from todolist where DueDate ='%1-%2-%3'").arg(date.year() ).arg(date.month() ).arg(date.day() ); | 273 | str = QString("select uid from todolist where DueDate ='%1-%2-%3'").arg(date.year() ).arg(date.month() ).arg(date.day() ); |
273 | 274 | ||
274 | return str; | 275 | return str; |
275 | } | 276 | } |
276 | 277 | ||
277 | 278 | ||
278 | EffQuery::EffQuery( const QDate& start, const QDate& end, bool inc ) | 279 | EffQuery::EffQuery( const QDate& start, const QDate& end, bool inc ) |
279 | : OSQLQuery(), m_start( start ), m_end( end ),m_inc(inc) {} | 280 | : OSQLQuery(), m_start( start ), m_end( end ),m_inc(inc) {} |
280 | EffQuery::~EffQuery() {} | 281 | EffQuery::~EffQuery() {} |
281 | QString EffQuery::query()const { | 282 | QString EffQuery::query()const { |
282 | return m_inc ? with() : out(); | 283 | return m_inc ? with() : out(); |
283 | } | 284 | } |
284 | QString EffQuery::with()const { | 285 | QString EffQuery::with()const { |
285 | QString str; | 286 | QString str; |
286 | str = QString("select uid from todolist where ( DueDate >= '%1-%2-%3' AND DueDate <= '%4-%5-%6' ) OR DueDate = '0-0-0' ") | 287 | str = QString("select uid from todolist where ( DueDate >= '%1-%2-%3' AND DueDate <= '%4-%5-%6' ) OR DueDate = '0-0-0' ") |
287 | .arg( m_start.year() ).arg( m_start.month() ).arg( m_start.day() ) | 288 | .arg( m_start.year() ).arg( m_start.month() ).arg( m_start.day() ) |
288 | .arg( m_end .year() ).arg( m_end .month() ).arg( m_end .day() ); | 289 | .arg( m_end .year() ).arg( m_end .month() ).arg( m_end .day() ); |
289 | return str; | 290 | return str; |
290 | } | 291 | } |
291 | QString EffQuery::out()const { | 292 | QString EffQuery::out()const { |
292 | QString str; | 293 | QString str; |
293 | str = QString("select uid from todolist where DueDate >= '%1-%2-%3' AND DueDate <= '%4-%5-%6'") | 294 | str = QString("select uid from todolist where DueDate >= '%1-%2-%3' AND DueDate <= '%4-%5-%6'") |
294 | .arg(m_start.year() ).arg(m_start.month() ).arg( m_start.day() ) | 295 | .arg(m_start.year() ).arg(m_start.month() ).arg( m_start.day() ) |
295 | .arg(m_end. year() ).arg(m_end. month() ).arg(m_end.day() ); | 296 | .arg(m_end. year() ).arg(m_end. month() ).arg(m_end.day() ); |
296 | 297 | ||
297 | return str; | 298 | return str; |
298 | } | 299 | } |
299 | }; | 300 | }; |
300 | 301 | ||
301 | OTodoAccessBackendSQL::OTodoAccessBackendSQL( const QString& file ) | 302 | OTodoAccessBackendSQL::OTodoAccessBackendSQL( const QString& file ) |
302 | : OTodoAccessBackend(), m_dict(15), m_driver(NULL), m_dirty(true) | 303 | : OTodoAccessBackend(), m_dict(15), m_driver(NULL), m_dirty(true) |
303 | { | 304 | { |
304 | QString fi = file; | 305 | QString fi = file; |
305 | if ( fi.isEmpty() ) | 306 | if ( fi.isEmpty() ) |
306 | fi = Global::applicationFileName( "todolist", "todolist.db" ); | 307 | fi = Global::applicationFileName( "todolist", "todolist.db" ); |
307 | OSQLManager man; | 308 | OSQLManager man; |
308 | m_driver = man.standard(); | 309 | m_driver = man.standard(); |
309 | m_driver->setUrl(fi); | 310 | m_driver->setUrl(fi); |
310 | // fillDict(); | 311 | // fillDict(); |
311 | } | 312 | } |
312 | 313 | ||
313 | OTodoAccessBackendSQL::~OTodoAccessBackendSQL(){ | 314 | OTodoAccessBackendSQL::~OTodoAccessBackendSQL(){ |
314 | if( m_driver ) | 315 | if( m_driver ) |
315 | delete m_driver; | 316 | delete m_driver; |
316 | } | 317 | } |
317 | 318 | ||
318 | bool OTodoAccessBackendSQL::load(){ | 319 | bool OTodoAccessBackendSQL::load(){ |
319 | if (!m_driver->open() ) | 320 | if (!m_driver->open() ) |
320 | return false; | 321 | return false; |
321 | 322 | ||
322 | CreateQuery creat; | 323 | CreateQuery creat; |
323 | OSQLResult res = m_driver->query(&creat ); | 324 | OSQLResult res = m_driver->query(&creat ); |
324 | 325 | ||
325 | m_dirty = true; | 326 | m_dirty = true; |
326 | return true; | 327 | return true; |
327 | } | 328 | } |
328 | bool OTodoAccessBackendSQL::reload(){ | 329 | bool OTodoAccessBackendSQL::reload(){ |
329 | return load(); | 330 | return load(); |
330 | } | 331 | } |
331 | 332 | ||
332 | bool OTodoAccessBackendSQL::save(){ | 333 | bool OTodoAccessBackendSQL::save(){ |
333 | return m_driver->close(); // Shouldn't m_driver->sync be better than close ? (eilers) | 334 | return m_driver->close(); // Shouldn't m_driver->sync be better than close ? (eilers) |
334 | } | 335 | } |
335 | QArray<int> OTodoAccessBackendSQL::allRecords()const { | 336 | QArray<int> OTodoAccessBackendSQL::allRecords()const { |
336 | if (m_dirty ) | 337 | if (m_dirty ) |
337 | update(); | 338 | update(); |
338 | 339 | ||
339 | return m_uids; | 340 | return m_uids; |
340 | } | 341 | } |
341 | QArray<int> OTodoAccessBackendSQL::queryByExample( const OTodo& , int, const QDateTime& ){ | 342 | QArray<int> OTodoAccessBackendSQL::queryByExample( const OTodo& , int, const QDateTime& ){ |
342 | QArray<int> ints(0); | 343 | QArray<int> ints(0); |
343 | return ints; | 344 | return ints; |
344 | } | 345 | } |
345 | OTodo OTodoAccessBackendSQL::find(int uid ) const{ | 346 | OTodo OTodoAccessBackendSQL::find(int uid ) const{ |
346 | FindQuery query( uid ); | 347 | FindQuery query( uid ); |
347 | return todo( m_driver->query(&query) ); | 348 | return todo( m_driver->query(&query) ); |
348 | 349 | ||
349 | } | 350 | } |
350 | OTodo OTodoAccessBackendSQL::find( int uid, const QArray<int>& ints, | 351 | OTodo OTodoAccessBackendSQL::find( int uid, const QArray<int>& ints, |
351 | uint cur, Frontend::CacheDirection dir ) const{ | 352 | uint cur, Frontend::CacheDirection dir ) const{ |
352 | uint CACHE = readAhead(); | 353 | uint CACHE = readAhead(); |
353 | qWarning("searching for %d", uid ); | 354 | qWarning("searching for %d", uid ); |
354 | QArray<int> search( CACHE ); | 355 | QArray<int> search( CACHE ); |
355 | uint size =0; | 356 | uint size =0; |
356 | OTodo to; | 357 | OTodo to; |
357 | 358 | ||
358 | // we try to cache CACHE items | 359 | // we try to cache CACHE items |
359 | switch( dir ) { | 360 | switch( dir ) { |
360 | /* forward */ | 361 | /* forward */ |
361 | case 0: // FIXME: Not a good style to use magic numbers here (eilers) | 362 | case 0: // FIXME: Not a good style to use magic numbers here (eilers) |
362 | for (uint i = cur; i < ints.count() && size < CACHE; i++ ) { | 363 | for (uint i = cur; i < ints.count() && size < CACHE; i++ ) { |
363 | qWarning("size %d %d", size, ints[i] ); | 364 | qWarning("size %d %d", size, ints[i] ); |
364 | search[size] = ints[i]; | 365 | search[size] = ints[i]; |
365 | size++; | 366 | size++; |
366 | } | 367 | } |
367 | break; | 368 | break; |
368 | /* reverse */ | 369 | /* reverse */ |
369 | case 1: // FIXME: Not a good style to use magic numbers here (eilers) | 370 | case 1: // FIXME: Not a good style to use magic numbers here (eilers) |
370 | for (uint i = cur; i != 0 && size < CACHE; i-- ) { | 371 | for (uint i = cur; i != 0 && size < CACHE; i-- ) { |
371 | search[size] = ints[i]; | 372 | search[size] = ints[i]; |
372 | size++; | 373 | size++; |
373 | } | 374 | } |
374 | break; | 375 | break; |
375 | } | 376 | } |
376 | search.resize( size ); | 377 | search.resize( size ); |
377 | FindQuery query( search ); | 378 | FindQuery query( search ); |
378 | OSQLResult res = m_driver->query( &query ); | 379 | OSQLResult res = m_driver->query( &query ); |
379 | if ( res.state() != OSQLResult::Success ) | 380 | if ( res.state() != OSQLResult::Success ) |
380 | return to; | 381 | return to; |
381 | 382 | ||
382 | return todo( res ); | 383 | return todo( res ); |
383 | } | 384 | } |
384 | void OTodoAccessBackendSQL::clear() { | 385 | void OTodoAccessBackendSQL::clear() { |
385 | ClearQuery cle; | 386 | ClearQuery cle; |
386 | OSQLResult res = m_driver->query( &cle ); | 387 | OSQLResult res = m_driver->query( &cle ); |
387 | CreateQuery qu; | 388 | CreateQuery qu; |
388 | res = m_driver->query(&qu); | 389 | res = m_driver->query(&qu); |
389 | } | 390 | } |
390 | bool OTodoAccessBackendSQL::add( const OTodo& t) { | 391 | bool OTodoAccessBackendSQL::add( const OTodo& t) { |
391 | InsertQuery ins( t ); | 392 | InsertQuery ins( t ); |
392 | OSQLResult res = m_driver->query( &ins ); | 393 | OSQLResult res = m_driver->query( &ins ); |
393 | 394 | ||
394 | if ( res.state() == OSQLResult::Failure ) | 395 | if ( res.state() == OSQLResult::Failure ) |
395 | return false; | 396 | return false; |
396 | int c = m_uids.count(); | 397 | int c = m_uids.count(); |
397 | m_uids.resize( c+1 ); | 398 | m_uids.resize( c+1 ); |
398 | m_uids[c] = t.uid(); | 399 | m_uids[c] = t.uid(); |
399 | 400 | ||
400 | return true; | 401 | return true; |
401 | } | 402 | } |
402 | bool OTodoAccessBackendSQL::remove( int uid ) { | 403 | bool OTodoAccessBackendSQL::remove( int uid ) { |
403 | RemoveQuery rem( uid ); | 404 | RemoveQuery rem( uid ); |
404 | OSQLResult res = m_driver->query(&rem ); | 405 | OSQLResult res = m_driver->query(&rem ); |
405 | 406 | ||
406 | if ( res.state() == OSQLResult::Failure ) | 407 | if ( res.state() == OSQLResult::Failure ) |
407 | return false; | 408 | return false; |
408 | 409 | ||
409 | m_dirty = true; | 410 | m_dirty = true; |
410 | return true; | 411 | return true; |
411 | } | 412 | } |
412 | /* | 413 | /* |
413 | * FIXME better set query | 414 | * FIXME better set query |
414 | * but we need the cache for that | 415 | * but we need the cache for that |
415 | * now we remove | 416 | * now we remove |
416 | */ | 417 | */ |
417 | bool OTodoAccessBackendSQL::replace( const OTodo& t) { | 418 | bool OTodoAccessBackendSQL::replace( const OTodo& t) { |
418 | remove( t.uid() ); | 419 | remove( t.uid() ); |
419 | bool b= add(t); | 420 | bool b= add(t); |
420 | m_dirty = false; // we changed some stuff but the UID stayed the same | 421 | m_dirty = false; // we changed some stuff but the UID stayed the same |
421 | return b; | 422 | return b; |
422 | } | 423 | } |
423 | QArray<int> OTodoAccessBackendSQL::overDue() { | 424 | QArray<int> OTodoAccessBackendSQL::overDue() { |
424 | OverDueQuery qu; | 425 | OverDueQuery qu; |
425 | return uids( m_driver->query(&qu ) ); | 426 | return uids( m_driver->query(&qu ) ); |
426 | } | 427 | } |
427 | QArray<int> OTodoAccessBackendSQL::effectiveToDos( const QDate& s, | 428 | QArray<int> OTodoAccessBackendSQL::effectiveToDos( const QDate& s, |
428 | const QDate& t, | 429 | const QDate& t, |
429 | bool u) { | 430 | bool u) { |
430 | EffQuery ef(s, t, u ); | 431 | EffQuery ef(s, t, u ); |
431 | return uids (m_driver->query(&ef) ); | 432 | return uids (m_driver->query(&ef) ); |
432 | } | 433 | } |
433 | /* | 434 | /* |
434 | * | 435 | * |
435 | */ | 436 | */ |
436 | QArray<int> OTodoAccessBackendSQL::sorted( bool asc, int sortOrder, | 437 | QArray<int> OTodoAccessBackendSQL::sorted( bool asc, int sortOrder, |
437 | int sortFilter, int cat ) { | 438 | int sortFilter, int cat ) { |
438 | qWarning("sorted %d, %d", asc, sortOrder ); | 439 | qWarning("sorted %d, %d", asc, sortOrder ); |
439 | QString query; | 440 | QString query; |
440 | query = "select uid from todolist WHERE "; | 441 | query = "select uid from todolist WHERE "; |
441 | 442 | ||
442 | /* | 443 | /* |
443 | * Sort Filter stuff | 444 | * Sort Filter stuff |
444 | * not that straight forward | 445 | * not that straight forward |
445 | * FIXME: Replace magic numbers | 446 | * FIXME: Replace magic numbers |
446 | * | 447 | * |
447 | */ | 448 | */ |
448 | /* Category */ | 449 | /* Category */ |
449 | if ( sortFilter & 1 ) { | 450 | if ( sortFilter & 1 ) { |
450 | QString str; | 451 | QString str; |
451 | if (cat != 0 ) str = QString::number( cat ); | 452 | if (cat != 0 ) str = QString::number( cat ); |
452 | query += " categories like '%" +str+"%' AND"; | 453 | query += " categories like '%" +str+"%' AND"; |
453 | } | 454 | } |
454 | /* Show only overdue */ | 455 | /* Show only overdue */ |
455 | if ( sortFilter & 2 ) { | 456 | if ( sortFilter & 2 ) { |
456 | QDate date = QDate::currentDate(); | 457 | QDate date = QDate::currentDate(); |
457 | QString due; | 458 | QString due; |
458 | QString base; | 459 | QString base; |
459 | base = QString("DueDate <= '%1-%2-%3' AND completed = 0").arg( date.year() ).arg( date.month() ).arg( date.day() ); | 460 | base = QString("DueDate <= '%1-%2-%3' AND completed = 0").arg( date.year() ).arg( date.month() ).arg( date.day() ); |
460 | query += " " + base + " AND"; | 461 | query += " " + base + " AND"; |
461 | } | 462 | } |
462 | /* not show completed */ | 463 | /* not show completed */ |
463 | if ( sortFilter & 4 ) { | 464 | if ( sortFilter & 4 ) { |
464 | query += " completed = 0 AND"; | 465 | query += " completed = 0 AND"; |
465 | }else{ | 466 | }else{ |
466 | query += " ( completed = 1 OR completed = 0) AND"; | 467 | query += " ( completed = 1 OR completed = 0) AND"; |
467 | } | 468 | } |
468 | /* srtip the end */ | 469 | /* srtip the end */ |
469 | query = query.remove( query.length()-3, 3 ); | 470 | query = query.remove( query.length()-3, 3 ); |
470 | 471 | ||
471 | 472 | ||
472 | /* | 473 | /* |
473 | * sort order stuff | 474 | * sort order stuff |
474 | * quite straight forward | 475 | * quite straight forward |
475 | */ | 476 | */ |
476 | query += "ORDER BY "; | 477 | query += "ORDER BY "; |
477 | switch( sortOrder ) { | 478 | switch( sortOrder ) { |
478 | /* completed */ | 479 | /* completed */ |
479 | case 0: | 480 | case 0: |
480 | query += "completed"; | 481 | query += "completed"; |
481 | break; | 482 | break; |
482 | case 1: | 483 | case 1: |
483 | query += "priority"; | 484 | query += "priority"; |
484 | break; | 485 | break; |
485 | case 2: | 486 | case 2: |
486 | query += "summary"; | 487 | query += "summary"; |
487 | break; | 488 | break; |
488 | case 3: | 489 | case 3: |
489 | query += "DueDate"; | 490 | query += "DueDate"; |
490 | break; | 491 | break; |
491 | } | 492 | } |
492 | 493 | ||
493 | if ( !asc ) { | 494 | if ( !asc ) { |
494 | qWarning("not ascending!"); | 495 | qWarning("not ascending!"); |
495 | query += " DESC"; | 496 | query += " DESC"; |
496 | } | 497 | } |
497 | 498 | ||
498 | qWarning( query ); | 499 | qWarning( query ); |
499 | OSQLRawQuery raw(query ); | 500 | OSQLRawQuery raw(query ); |
500 | return uids( m_driver->query(&raw) ); | 501 | return uids( m_driver->query(&raw) ); |
501 | } | 502 | } |
502 | bool OTodoAccessBackendSQL::date( QDate& da, const QString& str ) const{ | 503 | bool OTodoAccessBackendSQL::date( QDate& da, const QString& str ) const{ |
503 | if ( str == "0-0-0" ) | 504 | if ( str == "0-0-0" ) |
504 | return false; | 505 | return false; |
505 | else{ | 506 | else{ |
506 | int day, year, month; | 507 | int day, year, month; |
507 | QStringList list = QStringList::split("-", str ); | 508 | QStringList list = QStringList::split("-", str ); |
508 | year = list[0].toInt(); | 509 | year = list[0].toInt(); |
509 | month = list[1].toInt(); | 510 | month = list[1].toInt(); |
510 | day = list[2].toInt(); | 511 | day = list[2].toInt(); |
511 | da.setYMD( year, month, day ); | 512 | da.setYMD( year, month, day ); |
512 | return true; | 513 | return true; |
513 | } | 514 | } |
514 | } | 515 | } |
515 | OTodo OTodoAccessBackendSQL::todo( const OSQLResult& res) const{ | 516 | OTodo OTodoAccessBackendSQL::todo( const OSQLResult& res) const{ |
516 | if ( res.state() == OSQLResult::Failure ) { | 517 | if ( res.state() == OSQLResult::Failure ) { |
517 | OTodo to; | 518 | OTodo to; |
518 | return to; | 519 | return to; |
519 | } | 520 | } |
520 | 521 | ||
521 | OSQLResultItem::ValueList list = res.results(); | 522 | OSQLResultItem::ValueList list = res.results(); |
522 | OSQLResultItem::ValueList::Iterator it = list.begin(); | 523 | OSQLResultItem::ValueList::Iterator it = list.begin(); |
523 | qWarning("todo1"); | 524 | qWarning("todo1"); |
524 | OTodo to = todo( (*it) ); | 525 | OTodo to = todo( (*it) ); |
525 | cache( to ); | 526 | cache( to ); |
526 | ++it; | 527 | ++it; |
527 | 528 | ||
diff --git a/libopie/pim/otodoaccesssql.h b/libopie/pim/otodoaccesssql.h index 1c55567..72214de 100644 --- a/libopie/pim/otodoaccesssql.h +++ b/libopie/pim/otodoaccesssql.h | |||
@@ -1,56 +1,61 @@ | |||
1 | #ifndef OPIE_PIM_ACCESS_SQL_H | 1 | #ifndef OPIE_PIM_ACCESS_SQL_H |
2 | #define OPIE_PIM_ACCESS_SQL_H | 2 | #define OPIE_PIM_ACCESS_SQL_H |
3 | 3 | ||
4 | #include <qasciidict.h> | 4 | #include <qasciidict.h> |
5 | 5 | ||
6 | #include "otodoaccessbackend.h" | 6 | #include "otodoaccessbackend.h" |
7 | 7 | ||
8 | namespace Opie{ | ||
9 | namespace DB { | ||
8 | class OSQLDriver; | 10 | class OSQLDriver; |
9 | class OSQLResult; | 11 | class OSQLResult; |
10 | class OSQLResultItem; | 12 | class OSQLResultItem; |
13 | } | ||
14 | } | ||
15 | |||
11 | class OTodoAccessBackendSQL : public OTodoAccessBackend { | 16 | class OTodoAccessBackendSQL : public OTodoAccessBackend { |
12 | public: | 17 | public: |
13 | OTodoAccessBackendSQL( const QString& file ); | 18 | OTodoAccessBackendSQL( const QString& file ); |
14 | ~OTodoAccessBackendSQL(); | 19 | ~OTodoAccessBackendSQL(); |
15 | 20 | ||
16 | bool load(); | 21 | bool load(); |
17 | bool reload(); | 22 | bool reload(); |
18 | bool save(); | 23 | bool save(); |
19 | QArray<int> allRecords()const; | 24 | QArray<int> allRecords()const; |
20 | 25 | ||
21 | QArray<int> queryByExample( const OTodo& t, int settings, const QDateTime& d = QDateTime() ); | 26 | QArray<int> queryByExample( const OTodo& t, int settings, const QDateTime& d = QDateTime() ); |
22 | OTodo find(int uid)const; | 27 | OTodo find(int uid)const; |
23 | OTodo find(int uid, const QArray<int>&, uint cur, Frontend::CacheDirection )const; | 28 | OTodo find(int uid, const QArray<int>&, uint cur, Frontend::CacheDirection )const; |
24 | void clear(); | 29 | void clear(); |
25 | bool add( const OTodo& t ); | 30 | bool add( const OTodo& t ); |
26 | bool remove( int uid ); | 31 | bool remove( int uid ); |
27 | bool replace( const OTodo& t ); | 32 | bool replace( const OTodo& t ); |
28 | 33 | ||
29 | QArray<int> overDue(); | 34 | QArray<int> overDue(); |
30 | QArray<int> effectiveToDos( const QDate& start, | 35 | QArray<int> effectiveToDos( const QDate& start, |
31 | const QDate& end, bool includeNoDates ); | 36 | const QDate& end, bool includeNoDates ); |
32 | QArray<int> sorted(bool asc, int sortOrder, int sortFilter, int cat ); | 37 | QArray<int> sorted(bool asc, int sortOrder, int sortFilter, int cat ); |
33 | 38 | ||
34 | QBitArray supports()const; | 39 | QBitArray supports()const; |
35 | QArray<int> matchRegexp( const QRegExp &r ) const; | 40 | QArray<int> matchRegexp( const QRegExp &r ) const; |
36 | void removeAllCompleted(); | 41 | void removeAllCompleted(); |
37 | 42 | ||
38 | 43 | ||
39 | private: | 44 | private: |
40 | void update()const; | 45 | void update()const; |
41 | void fillDict(); | 46 | void fillDict(); |
42 | inline bool date( QDate& date, const QString& )const; | 47 | inline bool date( QDate& date, const QString& )const; |
43 | inline OTodo todo( const OSQLResult& )const; | 48 | inline OTodo todo( const Opie::DB::OSQLResult& )const; |
44 | inline OTodo todo( OSQLResultItem& )const; | 49 | inline OTodo todo( Opie::DB::OSQLResultItem& )const; |
45 | inline QArray<int> uids( const OSQLResult& )const; | 50 | inline QArray<int> uids( const Opie::DB::OSQLResult& )const; |
46 | OTodo todo( int uid )const; | 51 | OTodo todo( int uid )const; |
47 | QBitArray sup() const; | 52 | QBitArray sup() const; |
48 | 53 | ||
49 | QAsciiDict<int> m_dict; | 54 | QAsciiDict<int> m_dict; |
50 | OSQLDriver* m_driver; | 55 | Opie::DB::OSQLDriver* m_driver; |
51 | QArray<int> m_uids; | 56 | QArray<int> m_uids; |
52 | bool m_dirty : 1; | 57 | bool m_dirty : 1; |
53 | }; | 58 | }; |
54 | 59 | ||
55 | 60 | ||
56 | #endif | 61 | #endif |