summaryrefslogtreecommitdiff
Unidiff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--libopie2/opiedb/osqlitedriver.cpp8
-rw-r--r--libopie2/opiedb/osqlitedriver.h3
-rw-r--r--libopie2/opiepim/backend/ocontactaccessbackend_sql.cpp37
3 files changed, 39 insertions, 9 deletions
diff --git a/libopie2/opiedb/osqlitedriver.cpp b/libopie2/opiedb/osqlitedriver.cpp
index 3ba161e..ccac2f8 100644
--- a/libopie2/opiedb/osqlitedriver.cpp
+++ b/libopie2/opiedb/osqlitedriver.cpp
@@ -1,231 +1,233 @@
1/* 1/*
2                 This file is part of the Opie Project 2                 This file is part of the Opie Project
3 3
4 =. 4 =.
5 .=l. 5 .=l.
6           .>+-= 6           .>+-=
7 _;:,     .>    :=|. This program is free software; you can 7 _;:,     .>    :=|. This program is free software; you can
8.> <`_,   >  .   <= redistribute it and/or modify it under 8.> <`_,   >  .   <= redistribute it and/or modify it under
9:`=1 )Y*s>-.--   : the terms of the GNU Library General Public 9:`=1 )Y*s>-.--   : the terms of the GNU Library General Public
10.="- .-=="i,     .._ License as published by the Free Software 10.="- .-=="i,     .._ License as published by the Free Software
11 - .   .-<_>     .<> Foundation; either version 2 of the License, 11 - .   .-<_>     .<> Foundation; either version 2 of the License,
12     ._= =}       : or (at your option) any later version. 12     ._= =}       : or (at your option) any later version.
13    .%`+i>       _;_. 13    .%`+i>       _;_.
14    .i_,=:_.      -<s. This program is distributed in the hope that 14    .i_,=:_.      -<s. This program is distributed in the hope that
15     +  .  -:.       = it will be useful, but WITHOUT ANY WARRANTY; 15     +  .  -:.       = it will be useful, but WITHOUT ANY WARRANTY;
16    : ..    .:,     . . . without even the implied warranty of 16    : ..    .:,     . . . without even the implied warranty of
17    =_        +     =;=|` MERCHANTABILITY or FITNESS FOR A 17    =_        +     =;=|` MERCHANTABILITY or FITNESS FOR A
18  _.=:.       :    :=>`: PARTICULAR PURPOSE. See the GNU 18  _.=:.       :    :=>`: PARTICULAR PURPOSE. See the GNU
19..}^=.=       =       ; Library General Public License for more 19..}^=.=       =       ; Library General Public License for more
20++=   -.     .`     .: details. 20++=   -.     .`     .: details.
21 :     =  ...= . :.=- 21 :     =  ...= . :.=-
22 -.   .:....=;==+<; You should have received a copy of the GNU 22 -.   .:....=;==+<; You should have received a copy of the GNU
23  -_. . .   )=.  = Library General Public License along with 23  -_. . .   )=.  = Library General Public License along with
24    --        :-=` this library; see the file COPYING.LIB. 24    --        :-=` this library; see the file COPYING.LIB.
25 If not, write to the Free Software Foundation, 25 If not, write to the Free Software Foundation,
26 Inc., 59 Temple Place - Suite 330, 26 Inc., 59 Temple Place - Suite 330,
27 Boston, MA 02111-1307, USA. 27 Boston, MA 02111-1307, USA.
28 28
29*/ 29*/
30 30
31#include "osqlquery.h" 31#include "osqlquery.h"
32#include "osqlitedriver.h" 32#include "osqlitedriver.h"
33 33
34#include <opie2/odebug.h> 34#include <opie2/odebug.h>
35 35
36#include <stdlib.h> 36#include <stdlib.h>
37#include <regex.h>
38#include <stdio.h> 37#include <stdio.h>
39 38
40// fromLocal8Bit() does not work as expected. Thus it 39// fromLocal8Bit() does not work as expected. Thus it
41// is replaced by fromLatin1() (eilers) 40// is replaced by fromLatin1() (eilers)
42#define __BUGGY_LOCAL8BIT_ 41#define __BUGGY_LOCAL8BIT_
43 42
44using namespace Opie::DB; 43namespace Opie {
45using namespace Opie::DB::Internal; 44namespace DB {
45namespace Internal {
46 46
47namespace { 47namespace {
48 struct Query { 48 struct Query {
49 OSQLError::ValueList errors; 49 OSQLError::ValueList errors;
50 OSQLResultItem::ValueList items; 50 OSQLResultItem::ValueList items;
51 OSQLiteDriver *driver; 51 OSQLiteDriver *driver;
52 }; 52 };
53} 53}
54 54
55 55
56OSQLiteDriver::OSQLiteDriver( QLibrary *lib ) 56OSQLiteDriver::OSQLiteDriver( QLibrary *lib )
57 : OSQLDriver( lib ) 57 : OSQLDriver( lib )
58{ 58{
59 m_sqlite = 0l; 59 m_sqlite = 0l;
60} 60}
61 61
62 62
63OSQLiteDriver::~OSQLiteDriver() { 63OSQLiteDriver::~OSQLiteDriver() {
64 close(); 64 close();
65} 65}
66 66
67 67
68QString OSQLiteDriver::id()const { 68QString OSQLiteDriver::id()const {
69 return QString::fromLatin1("SQLite"); 69 return QString::fromLatin1("SQLite");
70} 70}
71 71
72void OSQLiteDriver::setUserName( const QString& ) {} 72void OSQLiteDriver::setUserName( const QString& ) {}
73 73
74 74
75void OSQLiteDriver::setPassword( const QString& ) {} 75void OSQLiteDriver::setPassword( const QString& ) {}
76 76
77 77
78void OSQLiteDriver::setUrl( const QString& url ) { 78void OSQLiteDriver::setUrl( const QString& url ) {
79 m_url = url; 79 m_url = url;
80} 80}
81 81
82 82
83void OSQLiteDriver::setOptions( const QStringList& ) { 83void OSQLiteDriver::setOptions( const QStringList& ) {
84} 84}
85 85
86/* 86/*
87 * Functions to patch a regex search into sqlite 87 * Functions to patch a regex search into sqlite
88 */ 88 */
89int sqliteRlikeCompare(const char *zPattern, const char *zString, sqregex *reg){ 89int sqliteRlikeCompare(const char *zPattern, const char *zString, sqregex *reg){
90 int res; 90 int res;
91 91
92 if (reg->regex_raw == NULL || (strcmp (zPattern, reg->regex_raw) != 0)){ 92 if (reg->regex_raw == NULL || (strcmp (zPattern, reg->regex_raw) != 0)){
93 if (reg->regex_raw != NULL) { 93 if (reg->regex_raw != NULL) {
94 free(reg->regex_raw); 94 free(reg->regex_raw);
95 regfree(&reg->regex_c); 95 regfree(&reg->regex_c);
96 } 96 }
97 reg->regex_raw = (char *)malloc(strlen(zPattern)+1); 97 reg->regex_raw = (char *)malloc(strlen(zPattern)+1);
98 strncpy(reg->regex_raw, zPattern, strlen(zPattern)+1); 98 strncpy(reg->regex_raw, zPattern, strlen(zPattern)+1);
99 res = regcomp(&reg->regex_c, zPattern, REG_EXTENDED); 99 res = regcomp(&reg->regex_c, zPattern, REG_EXTENDED);
100 if ( res != 0 ) { 100 if ( res != 0 ) {
101 printf("Regcomp failed with code %u on string %s\n",res,zPattern); 101 printf("Regcomp failed with code %u on string %s\n",res,zPattern);
102 free(reg->regex_raw); 102 free(reg->regex_raw);
103 reg->regex_raw=NULL; 103 reg->regex_raw=NULL;
104 return 0; 104 return 0;
105 } 105 }
106 } 106 }
107 res = (regexec(&reg->regex_c, zString, 0, NULL, 0)==0); 107 res = (regexec(&reg->regex_c, zString, 0, NULL, 0)==0);
108 return res; 108 return res;
109} 109}
110 110
111void rlikeFunc(sqlite_func *context, int arg, const char **argv){ 111void rlikeFunc(sqlite_func *context, int arg, const char **argv){
112 if( argv[0]==0 || argv[1]==0 || argv[2]==0){ 112 if( argv[0]==0 || argv[1]==0 || argv[2]==0){
113 printf("One of arguments Null!!\n"); 113 printf("One of arguments Null!!\n");
114 return; 114 return;
115 } 115 }
116 sqlite_set_result_int(context, 116 sqlite_set_result_int(context,
117 sqliteRlikeCompare((const char*)argv[0], 117 sqliteRlikeCompare((const char*)argv[0],
118 (const char*)argv[1], (sqregex*)argv[2])); 118 (const char*)argv[1], (sqregex*)argv[2]));
119} 119}
120 120
121/* 121/*
122 * try to open a db specified via setUrl 122 * try to open a db specified via setUrl
123 * and options 123 * and options
124 */ 124 */
125bool OSQLiteDriver::open() { 125bool OSQLiteDriver::open() {
126 char *error; 126 char *error;
127 qDebug("OSQLiteDriver::open: about to open"); 127 qDebug("OSQLiteDriver::open: about to open");
128 m_sqlite = sqlite_open(m_url.local8Bit(), 128 m_sqlite = sqlite_open(m_url.local8Bit(),
129 0, 129 0,
130 &error ); 130 &error );
131 131
132 /* failed to open */ 132 /* failed to open */
133 if (m_sqlite == 0l ) { 133 if (m_sqlite == 0l ) {
134 // FIXME set the last error 134 // FIXME set the last error
135 qWarning("OSQLiteDriver::open: %s", error ); 135 qWarning("OSQLiteDriver::open: %s", error );
136 free( error ); 136 free( error );
137 return false; 137 return false;
138 } 138 }
139 sqlite_create_function(m_sqlite,"rlike",3,rlikeFunc,&sqreg); 139 sqlite_create_function(m_sqlite,"rlike",3,rlikeFunc,&sqreg);
140 return true; 140 return true;
141} 141}
142 142
143 143
144/* close the db 144/* close the db
145 * sqlite closes them without 145 * sqlite closes them without
146 * telling failure or success 146 * telling failure or success
147 */ 147 */
148bool OSQLiteDriver::close() { 148bool OSQLiteDriver::close() {
149 if (m_sqlite ) 149 if (m_sqlite )
150 sqlite_close( m_sqlite ), m_sqlite=0l; 150 sqlite_close( m_sqlite ), m_sqlite=0l;
151 if (sqreg.regex_raw != NULL){ 151 if (sqreg.regex_raw != NULL){
152 free(sqreg.regex_raw); 152 free(sqreg.regex_raw);
153 sqreg.regex_raw=NULL; 153 sqreg.regex_raw=NULL;
154 regfree(&sqreg.regex_c); 154 regfree(&sqreg.regex_c);
155 } 155 }
156 return true; 156 return true;
157} 157}
158 158
159 159
160/* Query */ 160/* Query */
161OSQLResult OSQLiteDriver::query( OSQLQuery* qu) { 161OSQLResult OSQLiteDriver::query( OSQLQuery* qu) {
162 if ( !m_sqlite ) { 162 if ( !m_sqlite ) {
163 // FIXME set error code 163 // FIXME set error code
164 OSQLResult result( OSQLResult::Failure ); 164 OSQLResult result( OSQLResult::Failure );
165 return result; 165 return result;
166 } 166 }
167 Query query; 167 Query query;
168 query.driver = this; 168 query.driver = this;
169 char *err; 169 char *err;
170 /* SQLITE_OK 0 if return code > 0 == failure */ 170 /* SQLITE_OK 0 if return code > 0 == failure */
171 if ( sqlite_exec(m_sqlite, qu->query(),&call_back, &query, &err) > 0 ) { 171 if ( sqlite_exec(m_sqlite, qu->query(),&call_back, &query, &err) > 0 ) {
172 qWarning("OSQLiteDriver::query: Error while executing"); 172 qWarning("OSQLiteDriver::query: Error while executing");
173 free(err ); 173 free(err );
174 // FixMe Errors 174 // FixMe Errors
175 } 175 }
176 176
177 OSQLResult result(OSQLResult::Success, 177 OSQLResult result(OSQLResult::Success,
178 query.items, 178 query.items,
179 query.errors ); 179 query.errors );
180 return result; 180 return result;
181} 181}
182 182
183 183
184OSQLTable::ValueList OSQLiteDriver::tables() const { 184OSQLTable::ValueList OSQLiteDriver::tables() const {
185 185
186} 186}
187 187
188 188
189OSQLError OSQLiteDriver::lastError() { 189OSQLError OSQLiteDriver::lastError() {
190 OSQLError error; 190 OSQLError error;
191 return error; 191 return error;
192}; 192};
193 193
194 194
195/* handle a callback add the row to the global 195/* handle a callback add the row to the global
196 * OSQLResultItem 196 * OSQLResultItem
197 */ 197 */
198int OSQLiteDriver::handleCallBack( int, char**, char** ) { 198int OSQLiteDriver::handleCallBack( int, char**, char** ) {
199 return 0; 199 return 0;
200} 200}
201 201
202 202
203/* callback_handler add the values to the list*/ 203/* callback_handler add the values to the list*/
204int OSQLiteDriver::call_back( void* voi, int argc, 204int OSQLiteDriver::call_back( void* voi, int argc,
205 char** argv, char** columns) { 205 char** argv, char** columns) {
206 Query* qu = (Query*)voi; 206 Query* qu = (Query*)voi;
207 207
208 //copy them over to a OSQLResultItem 208 //copy them over to a OSQLResultItem
209 QMap<QString, QString> tableString; 209 QMap<QString, QString> tableString;
210 QMap<int, QString> tableInt; 210 QMap<int, QString> tableInt;
211 for (int i = 0; i < argc; i++ ) { 211 for (int i = 0; i < argc; i++ ) {
212 212
213#ifdef __BUGGY_LOCAL8BIT_ 213#ifdef __BUGGY_LOCAL8BIT_
214 tableInt.insert( i, QString::fromLatin1( argv[i] ) ); 214 tableInt.insert( i, QString::fromLatin1( argv[i] ) );
215 tableString.insert( QString::fromLatin1( columns[i] ), 215 tableString.insert( QString::fromLatin1( columns[i] ),
216 QString::fromLatin1( argv[i] ) ); 216 QString::fromLatin1( argv[i] ) );
217#else 217#else
218 tableInt.insert( i, QString::fromLocal8Bit( argv[i] ) ); 218 tableInt.insert( i, QString::fromLocal8Bit( argv[i] ) );
219 tableString.insert( QString::fromLocal8Bit( columns[i] ), 219 tableString.insert( QString::fromLocal8Bit( columns[i] ),
220 QString::fromLocal8Bit( argv[i] ) ); 220 QString::fromLocal8Bit( argv[i] ) );
221#endif 221#endif
222 } 222 }
223 OSQLResultItem item( tableString, tableInt ); 223 OSQLResultItem item( tableString, tableInt );
224 qu->items.append( item ); 224 qu->items.append( item );
225 225
226 return ((Query*)voi)->driver->handleCallBack( argc, 226 return ((Query*)voi)->driver->handleCallBack( argc,
227 argv, 227 argv,
228 columns ); 228 columns );
229 229
230 230
231} 231}
232
233}}} // namespace OPIE::DB::Internal
diff --git a/libopie2/opiedb/osqlitedriver.h b/libopie2/opiedb/osqlitedriver.h
index d5ab224..33037b8 100644
--- a/libopie2/opiedb/osqlitedriver.h
+++ b/libopie2/opiedb/osqlitedriver.h
@@ -1,53 +1,56 @@
1#ifndef OSQL_LITE_DRIVER_H 1#ifndef OSQL_LITE_DRIVER_H
2#define OSQL_LITE_DRIVER_H 2#define OSQL_LITE_DRIVER_H
3 3
4#include <sqlite.h> 4#include <sqlite.h>
5#if defined (__GNUC__) && (__GNUC__ < 3) 5#if defined (__GNUC__) && (__GNUC__ < 3)
6#include <sys/types.h> 6#include <sys/types.h>
7#endif 7#endif
8#ifdef Q_OS_MACX
9#include <sys/types.h>
10#endif
8#include <regex.h> 11#include <regex.h>
9 12
10#include "osqldriver.h" 13#include "osqldriver.h"
11#include "osqlerror.h" 14#include "osqlerror.h"
12#include "osqlresult.h" 15#include "osqlresult.h"
13 16
14namespace Opie { 17namespace Opie {
15namespace DB { 18namespace DB {
16namespace Internal { 19namespace Internal {
17 20
18struct sqregex { 21struct sqregex {
19 char *regex_raw; 22 char *regex_raw;
20 regex_t regex_c; 23 regex_t regex_c;
21}; 24};
22 25
23class OSQLiteDriver : public OSQLDriver { 26class OSQLiteDriver : public OSQLDriver {
24 Q_OBJECT 27 Q_OBJECT
25public: 28public:
26 OSQLiteDriver( QLibrary *lib = 0l ); 29 OSQLiteDriver( QLibrary *lib = 0l );
27 ~OSQLiteDriver(); 30 ~OSQLiteDriver();
28 QString id()const; 31 QString id()const;
29 void setUserName( const QString& ); 32 void setUserName( const QString& );
30 void setPassword( const QString& ); 33 void setPassword( const QString& );
31 void setUrl( const QString& url ); 34 void setUrl( const QString& url );
32 void setOptions( const QStringList& ); 35 void setOptions( const QStringList& );
33 bool open(); 36 bool open();
34 bool close(); 37 bool close();
35 OSQLError lastError(); 38 OSQLError lastError();
36 OSQLResult query( OSQLQuery* ); 39 OSQLResult query( OSQLQuery* );
37 OSQLTable::ValueList tables()const; 40 OSQLTable::ValueList tables()const;
38 41
39private: 42private:
40 OSQLError m_lastE; 43 OSQLError m_lastE;
41 OSQLResult m_result; 44 OSQLResult m_result;
42 OSQLResultItem m_items; 45 OSQLResultItem m_items;
43 int handleCallBack( int, char**, char** ); 46 int handleCallBack( int, char**, char** );
44 static int call_back( void*, int, char**, char** ); 47 static int call_back( void*, int, char**, char** );
45 QString m_url; 48 QString m_url;
46 sqlite *m_sqlite; 49 sqlite *m_sqlite;
47 sqregex sqreg; 50 sqregex sqreg;
48}; 51};
49} 52}
50} 53}
51} 54}
52 55
53#endif 56#endif
diff --git a/libopie2/opiepim/backend/ocontactaccessbackend_sql.cpp b/libopie2/opiepim/backend/ocontactaccessbackend_sql.cpp
index 3142f75..bb5c99b 100644
--- a/libopie2/opiepim/backend/ocontactaccessbackend_sql.cpp
+++ b/libopie2/opiepim/backend/ocontactaccessbackend_sql.cpp
@@ -1,826 +1,851 @@
1/* 1/*
2 This file is part of the Opie Project 2 This file is part of the Opie Project
3 Copyright (C) Stefan Eilers <eilers.stefan@epost.de> 3 Copyright (C) Stefan Eilers <eilers.stefan@epost.de>
4 =. Copyright (C) The Opie Team <opie-devel@handhelds.org> 4 =. Copyright (C) The Opie Team <opie-devel@handhelds.org>
5 .=l. 5 .=l.
6 .>+-= 6 .>+-=
7 _;:, .> :=|. This program is free software; you can 7 _;:, .> :=|. This program is free software; you can
8.> <`_, > . <= redistribute it and/or modify it under 8.> <`_, > . <= redistribute it and/or modify it under
9:`=1 )Y*s>-.-- : the terms of the GNU Library General Public 9:`=1 )Y*s>-.-- : the terms of the GNU Library General Public
10.="- .-=="i, .._ License as published by the Free Software 10.="- .-=="i, .._ License as published by the Free Software
11 - . .-<_> .<> Foundation; either version 2 of the License, 11 - . .-<_> .<> Foundation; either version 2 of the License,
12 ._= =} : or (at your option) any later version. 12 ._= =} : or (at your option) any later version.
13 .%`+i> _;_. 13 .%`+i> _;_.
14 .i_,=:_. -<s. This program is distributed in the hope that 14 .i_,=:_. -<s. This program is distributed in the hope that
15 + . -:. = it will be useful, but WITHOUT ANY WARRANTY; 15 + . -:. = it will be useful, but WITHOUT ANY WARRANTY;
16 : .. .:, . . . without even the implied warranty of 16 : .. .:, . . . without even the implied warranty of
17 =_ + =;=|` MERCHANTABILITY or FITNESS FOR A 17 =_ + =;=|` MERCHANTABILITY or FITNESS FOR A
18 _.=:. : :=>`: PARTICULAR PURPOSE. See the GNU 18 _.=:. : :=>`: PARTICULAR PURPOSE. See the GNU
19..}^=.= = ; Library General Public License for more 19..}^=.= = ; Library General Public License for more
20++= -. .` .: details. 20++= -. .` .: details.
21 : = ...= . :.=- 21 : = ...= . :.=-
22 -. .:....=;==+<; You should have received a copy of the GNU 22 -. .:....=;==+<; You should have received a copy of the GNU
23 -_. . . )=. = Library General Public License along with 23 -_. . . )=. = Library General Public License along with
24 -- :-=` this library; see the file COPYING.LIB. 24 -- :-=` this library; see the file COPYING.LIB.
25 If not, write to the Free Software Foundation, 25 If not, write to the Free Software Foundation,
26 Inc., 59 Temple Place - Suite 330, 26 Inc., 59 Temple Place - Suite 330,
27 Boston, MA 02111-1307, USA. 27 Boston, MA 02111-1307, USA.
28*/ 28*/
29/* 29/*
30 * SQL Backend for the OPIE-Contact Database. 30 * SQL Backend for the OPIE-Contact Database.
31 */ 31 */
32 32
33#include "ocontactaccessbackend_sql.h" 33#include "ocontactaccessbackend_sql.h"
34 34
35#include <qarray.h> 35#include <qarray.h>
36#include <qdatetime.h> 36#include <qdatetime.h>
37#include <qstringlist.h> 37#include <qstringlist.h>
38 38
39#include <qpe/global.h> 39#include <qpe/global.h>
40#include <qpe/recordfields.h> 40#include <qpe/recordfields.h>
41 41
42#include <opie2/opimcontact.h> 42#include <opie2/opimcontact.h>
43#include <opie2/opimcontactfields.h> 43#include <opie2/opimcontactfields.h>
44#include <opie2/opimdateconversion.h> 44#include <opie2/opimdateconversion.h>
45#include <opie2/osqldriver.h> 45#include <opie2/osqldriver.h>
46#include <opie2/osqlresult.h> 46#include <opie2/osqlresult.h>
47#include <opie2/osqlmanager.h> 47#include <opie2/osqlmanager.h>
48#include <opie2/osqlquery.h> 48#include <opie2/osqlquery.h>
49 49
50using namespace Opie; 50using namespace Opie;
51using namespace Opie::DB; 51using namespace Opie::DB;
52 52
53 53
54/* 54/*
55 * Implementation of used query types * CREATE query 55 * Implementation of used query types * CREATE query
56 * LOAD query 56 * LOAD query
57 * INSERT 57 * INSERT
58 * REMOVE 58 * REMOVE
59 * CLEAR 59 * CLEAR
60 */ 60 */
61namespace { 61namespace {
62 /** 62 /**
63 * CreateQuery for the Todolist Table 63 * CreateQuery for the Todolist Table
64 */ 64 */
65 class CreateQuery : public OSQLQuery { 65 class CreateQuery : public OSQLQuery {
66 public: 66 public:
67 CreateQuery(); 67 CreateQuery();
68 ~CreateQuery(); 68 ~CreateQuery();
69 QString query()const; 69 QString query()const;
70 }; 70 };
71 71
72 /** 72 /**
73 * Clears (delete) a Table 73 * Clears (delete) a Table
74 */ 74 */
75 class ClearQuery : public OSQLQuery { 75 class ClearQuery : public OSQLQuery {
76 public: 76 public:
77 ClearQuery(); 77 ClearQuery();
78 ~ClearQuery(); 78 ~ClearQuery();
79 QString query()const; 79 QString query()const;
80 80
81 }; 81 };
82 82
83 83
84 /** 84 /**
85 * LoadQuery 85 * LoadQuery
86 * this one queries for all uids 86 * this one queries for all uids
87 */ 87 */
88 class LoadQuery : public OSQLQuery { 88 class LoadQuery : public OSQLQuery {
89 public: 89 public:
90 LoadQuery(); 90 LoadQuery();
91 ~LoadQuery(); 91 ~LoadQuery();
92 QString query()const; 92 QString query()const;
93 }; 93 };
94 94
95 /** 95 /**
96 * inserts/adds a OPimContact to the table 96 * inserts/adds a OPimContact to the table
97 */ 97 */
98 class InsertQuery : public OSQLQuery { 98 class InsertQuery : public OSQLQuery {
99 public: 99 public:
100 InsertQuery(const OPimContact& ); 100 InsertQuery(const OPimContact& );
101 ~InsertQuery(); 101 ~InsertQuery();
102 QString query()const; 102 QString query()const;
103 private: 103 private:
104 OPimContact m_contact; 104 OPimContact m_contact;
105 }; 105 };
106 106
107 107
108 /** 108 /**
109 * removes one from the table 109 * removes one from the table
110 */ 110 */
111 class RemoveQuery : public OSQLQuery { 111 class RemoveQuery : public OSQLQuery {
112 public: 112 public:
113 RemoveQuery(int uid ); 113 RemoveQuery(int uid );
114 ~RemoveQuery(); 114 ~RemoveQuery();
115 QString query()const; 115 QString query()const;
116 private: 116 private:
117 int m_uid; 117 int m_uid;
118 }; 118 };
119 119
120 /** 120 /**
121 * a find query for noncustom elements 121 * a find query for noncustom elements
122 */ 122 */
123 class FindQuery : public OSQLQuery { 123 class FindQuery : public OSQLQuery {
124 public: 124 public:
125 FindQuery(int uid); 125 FindQuery(int uid);
126 FindQuery(const QArray<int>& ); 126 FindQuery(const QArray<int>& );
127 ~FindQuery(); 127 ~FindQuery();
128 QString query()const; 128 QString query()const;
129 private: 129 private:
130 QString single()const; 130 QString single()const;
131 QString multi()const; 131 QString multi()const;
132 QArray<int> m_uids; 132 QArray<int> m_uids;
133 int m_uid; 133 int m_uid;
134 }; 134 };
135 135
136 /** 136 /**
137 * a find query for custom elements 137 * a find query for custom elements
138 */ 138 */
139 class FindCustomQuery : public OSQLQuery { 139 class FindCustomQuery : public OSQLQuery {
140 public: 140 public:
141 FindCustomQuery(int uid); 141 FindCustomQuery(int uid);
142 FindCustomQuery(const QArray<int>& ); 142 FindCustomQuery(const QArray<int>& );
143 ~FindCustomQuery(); 143 ~FindCustomQuery();
144 QString query()const; 144 QString query()const;
145 private: 145 private:
146 QString single()const; 146 QString single()const;
147 QString multi()const; 147 QString multi()const;
148 QArray<int> m_uids; 148 QArray<int> m_uids;
149 int m_uid; 149 int m_uid;
150 }; 150 };
151 151
152 152
153 153
154 // We using two tables to store the information: 154 // We using two tables to store the information:
155 // 1. addressbook : It contains General information about the contact (non custom) 155 // 1. addressbook : It contains General information about the contact (non custom)
156 // 2. custom_data : Not official supported entries 156 // 2. custom_data : Not official supported entries
157 // All tables are connected by the uid of the contact. 157 // All tables are connected by the uid of the contact.
158 // Maybe I should add a table for meta-information ? 158 // Maybe I should add a table for meta-information ?
159 CreateQuery::CreateQuery() : OSQLQuery() {} 159 CreateQuery::CreateQuery() : OSQLQuery() {}
160 CreateQuery::~CreateQuery() {} 160 CreateQuery::~CreateQuery() {}
161 QString CreateQuery::query()const { 161 QString CreateQuery::query()const {
162 QString qu; 162 QString qu;
163 163
164 qu += "create table addressbook( uid PRIMARY KEY "; 164 qu += "create table addressbook( uid PRIMARY KEY ";
165 165
166 QStringList fieldList = OPimContactFields::untrfields( false ); 166 QStringList fieldList = OPimContactFields::untrfields( false );
167 for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){ 167 for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){
168 qu += QString( ",\"%1\" VARCHAR(10)" ).arg( *it ); 168 qu += QString( ",\"%1\" VARCHAR(10)" ).arg( *it );
169 } 169 }
170 qu += " );"; 170 qu += " );";
171 171
172 qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR(10), priority INTEGER, value VARCHAR(10), PRIMARY KEY /* identifier */ (uid, id) );"; 172 qu += "create table custom_data( uid INTEGER, id INTEGER, type VARCHAR(10), priority INTEGER, value VARCHAR(10), PRIMARY KEY /* identifier */ (uid, id) );";
173 173
174 return qu; 174 return qu;
175 } 175 }
176 176
177 ClearQuery::ClearQuery() 177 ClearQuery::ClearQuery()
178 : OSQLQuery() {} 178 : OSQLQuery() {}
179 ClearQuery::~ClearQuery() {} 179 ClearQuery::~ClearQuery() {}
180 QString ClearQuery::query()const { 180 QString ClearQuery::query()const {
181 QString qu = "drop table addressbook;"; 181 QString qu = "drop table addressbook;";
182 qu += "drop table custom_data;"; 182 qu += "drop table custom_data;";
183 // qu += "drop table dates;"; 183 // qu += "drop table dates;";
184 return qu; 184 return qu;
185 } 185 }
186 186
187 187
188 LoadQuery::LoadQuery() : OSQLQuery() {} 188 LoadQuery::LoadQuery() : OSQLQuery() {}
189 LoadQuery::~LoadQuery() {} 189 LoadQuery::~LoadQuery() {}
190 QString LoadQuery::query()const { 190 QString LoadQuery::query()const {
191 QString qu; 191 QString qu;
192 qu += "select uid from addressbook"; 192 qu += "select uid from addressbook";
193 193
194 return qu; 194 return qu;
195 } 195 }
196 196
197 197
198 InsertQuery::InsertQuery( const OPimContact& contact ) 198 InsertQuery::InsertQuery( const OPimContact& contact )
199 : OSQLQuery(), m_contact( contact ) { 199 : OSQLQuery(), m_contact( contact ) {
200 } 200 }
201 201
202 InsertQuery::~InsertQuery() { 202 InsertQuery::~InsertQuery() {
203 } 203 }
204 204
205 /* 205 /*
206 * converts from a OPimContact to a query 206 * converts from a OPimContact to a query
207 */ 207 */
208 QString InsertQuery::query()const{ 208 QString InsertQuery::query()const{
209 209
210 QString qu; 210 QString qu;
211 qu += "insert into addressbook VALUES( " + 211 qu += "insert into addressbook VALUES( " +
212 QString::number( m_contact.uid() ); 212 QString::number( m_contact.uid() );
213 213
214 // Get all information out of the contact-class 214 // Get all information out of the contact-class
215 // Remember: The category is stored in contactMap, too ! 215 // Remember: The category is stored in contactMap, too !
216 QMap<int, QString> contactMap = m_contact.toMap(); 216 QMap<int, QString> contactMap = m_contact.toMap();
217 217
218 QStringList fieldList = OPimContactFields::untrfields( false ); 218 QStringList fieldList = OPimContactFields::untrfields( false );
219 QMap<QString, int> translate = OPimContactFields::untrFieldsToId(); 219 QMap<QString, int> translate = OPimContactFields::untrFieldsToId();
220 for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){ 220 for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){
221 // Convert Column-String to Id and get value for this id.. 221 // Convert Column-String to Id and get value for this id..
222 // Hmmm.. Maybe not very cute solution.. 222 // Hmmm.. Maybe not very cute solution..
223 int id = translate[*it]; 223 int id = translate[*it];
224 switch ( id ){ 224 switch ( id ){
225 case Qtopia::Birthday: 225 case Qtopia::Birthday:
226 case Qtopia::Anniversary:{ 226 case Qtopia::Anniversary:{
227 QDate day; 227 QDate day;
228 if ( id == Qtopia::Birthday ){ 228 if ( id == Qtopia::Birthday ){
229 day = m_contact.birthday(); 229 day = m_contact.birthday();
230 } else { 230 } else {
231 day = m_contact.anniversary(); 231 day = m_contact.anniversary();
232 } 232 }
233 // These entries should stored in a special format 233 // These entries should stored in a special format
234 // year-month-day 234 // year-month-day
235 if ( day.isValid() ){ 235 if ( day.isValid() ){
236 qu += QString(",\"%1-%2-%3\"") 236 qu += QString(",\"%1-%2-%3\"")
237 .arg( QString::number( day.year() ).rightJustify( 4, '0' ) ) 237 .arg( QString::number( day.year() ).rightJustify( 4, '0' ) )
238 .arg( QString::number( day.month() ).rightJustify( 2, '0' ) ) 238 .arg( QString::number( day.month() ).rightJustify( 2, '0' ) )
239 .arg( QString::number( day.day() ).rightJustify( 2, '0' ) ); 239 .arg( QString::number( day.day() ).rightJustify( 2, '0' ) );
240 } else { 240 } else {
241 qu += ",\"\""; 241 qu += ",\"\"";
242 } 242 }
243 } 243 }
244 break; 244 break;
245 default: 245 default:
246 qu += QString( ",\"%1\"" ).arg( contactMap[id] ); 246 qu += QString( ",\"%1\"" ).arg( contactMap[id] );
247 } 247 }
248 } 248 }
249 qu += " );"; 249 qu += " );";
250 250
251 251
252 // Now add custom data.. 252 // Now add custom data..
253 int id = 0; 253 int id = 0;
254 id = 0; 254 id = 0;
255 QMap<QString, QString> customMap = m_contact.toExtraMap(); 255 QMap<QString, QString> customMap = m_contact.toExtraMap();
256 for( QMap<QString, QString>::Iterator it = customMap.begin(); 256 for( QMap<QString, QString>::Iterator it = customMap.begin();
257 it != customMap.end(); ++it ){ 257 it != customMap.end(); ++it ){
258 qu += "insert into custom_data VALUES(" 258 qu += "insert into custom_data VALUES("
259 + QString::number( m_contact.uid() ) 259 + QString::number( m_contact.uid() )
260 + "," 260 + ","
261 + QString::number( id++ ) 261 + QString::number( id++ )
262 + ",'" 262 + ",'"
263 + it.key() 263 + it.key()
264 + "'," 264 + "',"
265 + "0" // Priority for future enhancements 265 + "0" // Priority for future enhancements
266 + ",'" 266 + ",'"
267 + it.data() 267 + it.data()
268 + "');"; 268 + "');";
269 } 269 }
270 // qu += "commit;"; 270 // qu += "commit;";
271 qDebug("add %s", qu.latin1() ); 271 qDebug("add %s", qu.latin1() );
272 return qu; 272 return qu;
273 } 273 }
274 274
275 275
276 RemoveQuery::RemoveQuery(int uid ) 276 RemoveQuery::RemoveQuery(int uid )
277 : OSQLQuery(), m_uid( uid ) {} 277 : OSQLQuery(), m_uid( uid ) {}
278 RemoveQuery::~RemoveQuery() {} 278 RemoveQuery::~RemoveQuery() {}
279 QString RemoveQuery::query()const { 279 QString RemoveQuery::query()const {
280 QString qu = "DELETE from addressbook where uid = " 280 QString qu = "DELETE from addressbook where uid = "
281 + QString::number(m_uid) + ";"; 281 + QString::number(m_uid) + ";";
282 qu += "DELETE from custom_data where uid = " 282 qu += "DELETE from custom_data where uid = "
283 + QString::number(m_uid) + ";"; 283 + QString::number(m_uid) + ";";
284 return qu; 284 return qu;
285 } 285 }
286 286
287 287
288 288
289 289
290 FindQuery::FindQuery(int uid) 290 FindQuery::FindQuery(int uid)
291 : OSQLQuery(), m_uid( uid ) { 291 : OSQLQuery(), m_uid( uid ) {
292 } 292 }
293 FindQuery::FindQuery(const QArray<int>& ints) 293 FindQuery::FindQuery(const QArray<int>& ints)
294 : OSQLQuery(), m_uids( ints ){ 294 : OSQLQuery(), m_uids( ints ){
295 } 295 }
296 FindQuery::~FindQuery() { 296 FindQuery::~FindQuery() {
297 } 297 }
298 QString FindQuery::query()const{ 298 QString FindQuery::query()const{
299 // if ( m_uids.count() == 0 ) 299 // if ( m_uids.count() == 0 )
300 return single(); 300 return single();
301 } 301 }
302 /* 302 /*
303 else 303 else
304 return multi(); 304 return multi();
305 } 305 }
306 QString FindQuery::multi()const { 306 QString FindQuery::multi()const {
307 QString qu = "select uid, type, value from addressbook where"; 307 QString qu = "select uid, type, value from addressbook where";
308 for (uint i = 0; i < m_uids.count(); i++ ) { 308 for (uint i = 0; i < m_uids.count(); i++ ) {
309 qu += " UID = " + QString::number( m_uids[i] ) + " OR"; 309 qu += " UID = " + QString::number( m_uids[i] ) + " OR";
310 } 310 }
311 qu.remove( qu.length()-2, 2 ); // Hmmmm.. 311 qu.remove( qu.length()-2, 2 ); // Hmmmm..
312 return qu; 312 return qu;
313 } 313 }
314 */ 314 */
315 QString FindQuery::single()const{ 315 QString FindQuery::single()const{
316 QString qu = "select *"; 316 QString qu = "select *";
317 qu += " from addressbook where uid = " + QString::number(m_uid); 317 qu += " from addressbook where uid = " + QString::number(m_uid);
318 318
319 // qWarning("find query: %s", qu.latin1() ); 319 // qWarning("find query: %s", qu.latin1() );
320 return qu; 320 return qu;
321 } 321 }
322 322
323 323
324 FindCustomQuery::FindCustomQuery(int uid) 324 FindCustomQuery::FindCustomQuery(int uid)
325 : OSQLQuery(), m_uid( uid ) { 325 : OSQLQuery(), m_uid( uid ) {
326 } 326 }
327 FindCustomQuery::FindCustomQuery(const QArray<int>& ints) 327 FindCustomQuery::FindCustomQuery(const QArray<int>& ints)
328 : OSQLQuery(), m_uids( ints ){ 328 : OSQLQuery(), m_uids( ints ){
329 } 329 }
330 FindCustomQuery::~FindCustomQuery() { 330 FindCustomQuery::~FindCustomQuery() {
331 } 331 }
332 QString FindCustomQuery::query()const{ 332 QString FindCustomQuery::query()const{
333 // if ( m_uids.count() == 0 ) 333 // if ( m_uids.count() == 0 )
334 return single(); 334 return single();
335 } 335 }
336 QString FindCustomQuery::single()const{ 336 QString FindCustomQuery::single()const{
337 QString qu = "select uid, type, value from custom_data where uid = "; 337 QString qu = "select uid, type, value from custom_data where uid = ";
338 qu += QString::number(m_uid); 338 qu += QString::number(m_uid);
339 return qu; 339 return qu;
340 } 340 }
341 341
342}; 342};
343 343
344 344
345/* --------------------------------------------------------------------------- */ 345/* --------------------------------------------------------------------------- */
346 346
347namespace Opie { 347namespace Opie {
348 348
349OPimContactAccessBackend_SQL::OPimContactAccessBackend_SQL ( const QString& /* appname */, 349OPimContactAccessBackend_SQL::OPimContactAccessBackend_SQL ( const QString& /* appname */,
350 const QString& filename ): 350 const QString& filename ):
351 OPimContactAccessBackend(), m_changed(false), m_driver( NULL ) 351 OPimContactAccessBackend(), m_changed(false), m_driver( NULL )
352{ 352{
353 qDebug("C'tor OPimContactAccessBackend_SQL starts"); 353 qDebug("C'tor OPimContactAccessBackend_SQL starts");
354 QTime t; 354 QTime t;
355 t.start(); 355 t.start();
356 356
357 /* Expecting to access the default filename if nothing else is set */ 357 /* Expecting to access the default filename if nothing else is set */
358 if ( filename.isEmpty() ){ 358 if ( filename.isEmpty() ){
359 m_fileName = Global::applicationFileName( "addressbook","addressbook.db" ); 359 m_fileName = Global::applicationFileName( "addressbook","addressbook.db" );
360 } else 360 } else
361 m_fileName = filename; 361 m_fileName = filename;
362 362
363 // Get the standart sql-driver from the OSQLManager.. 363 // Get the standart sql-driver from the OSQLManager..
364 OSQLManager man; 364 OSQLManager man;
365 m_driver = man.standard(); 365 m_driver = man.standard();
366 m_driver->setUrl( m_fileName ); 366 m_driver->setUrl( m_fileName );
367 367
368 load(); 368 load();
369 369
370 qDebug("C'tor OPimContactAccessBackend_SQL ends: %d ms", t.elapsed() ); 370 qDebug("C'tor OPimContactAccessBackend_SQL ends: %d ms", t.elapsed() );
371} 371}
372 372
373OPimContactAccessBackend_SQL::~OPimContactAccessBackend_SQL () 373OPimContactAccessBackend_SQL::~OPimContactAccessBackend_SQL ()
374{ 374{
375 if( m_driver ) 375 if( m_driver )
376 delete m_driver; 376 delete m_driver;
377} 377}
378 378
379bool OPimContactAccessBackend_SQL::load () 379bool OPimContactAccessBackend_SQL::load ()
380{ 380{
381 if (!m_driver->open() ) 381 if (!m_driver->open() )
382 return false; 382 return false;
383 383
384 // Don't expect that the database exists. 384 // Don't expect that the database exists.
385 // It is save here to create the table, even if it 385 // It is save here to create the table, even if it
386 // do exist. ( Is that correct for all databases ?? ) 386 // do exist. ( Is that correct for all databases ?? )
387 CreateQuery creat; 387 CreateQuery creat;
388 OSQLResult res = m_driver->query( &creat ); 388 OSQLResult res = m_driver->query( &creat );
389 389
390 update(); 390 update();
391 391
392 return true; 392 return true;
393 393
394} 394}
395 395
396bool OPimContactAccessBackend_SQL::reload() 396bool OPimContactAccessBackend_SQL::reload()
397{ 397{
398 return load(); 398 return load();
399} 399}
400 400
401bool OPimContactAccessBackend_SQL::save() 401bool OPimContactAccessBackend_SQL::save()
402{ 402{
403 return m_driver->close(); // Shouldn't m_driver->sync be better than close ? (eilers) 403 return m_driver->close(); // Shouldn't m_driver->sync be better than close ? (eilers)
404} 404}
405 405
406 406
407void OPimContactAccessBackend_SQL::clear () 407void OPimContactAccessBackend_SQL::clear ()
408{ 408{
409 ClearQuery cle; 409 ClearQuery cle;
410 OSQLResult res = m_driver->query( &cle ); 410 OSQLResult res = m_driver->query( &cle );
411 411
412 reload(); 412 reload();
413} 413}
414 414
415bool OPimContactAccessBackend_SQL::wasChangedExternally() 415bool OPimContactAccessBackend_SQL::wasChangedExternally()
416{ 416{
417 return false; 417 return false;
418} 418}
419 419
420QArray<int> OPimContactAccessBackend_SQL::allRecords() const 420QArray<int> OPimContactAccessBackend_SQL::allRecords() const
421{ 421{
422 422
423 // FIXME: Think about cute handling of changed tables.. 423 // FIXME: Think about cute handling of changed tables..
424 // Thus, we don't have to call update here... 424 // Thus, we don't have to call update here...
425 if ( m_changed ) 425 if ( m_changed )
426 ((OPimContactAccessBackend_SQL*)this)->update(); 426 ((OPimContactAccessBackend_SQL*)this)->update();
427 427
428 return m_uids; 428 return m_uids;
429} 429}
430 430
431bool OPimContactAccessBackend_SQL::add ( const OPimContact &newcontact ) 431bool OPimContactAccessBackend_SQL::add ( const OPimContact &newcontact )
432{ 432{
433 InsertQuery ins( newcontact ); 433 InsertQuery ins( newcontact );
434 OSQLResult res = m_driver->query( &ins ); 434 OSQLResult res = m_driver->query( &ins );
435 435
436 if ( res.state() == OSQLResult::Failure ) 436 if ( res.state() == OSQLResult::Failure )
437 return false; 437 return false;
438 438
439 int c = m_uids.count(); 439 int c = m_uids.count();
440 m_uids.resize( c+1 ); 440 m_uids.resize( c+1 );
441 m_uids[c] = newcontact.uid(); 441 m_uids[c] = newcontact.uid();
442 442
443 return true; 443 return true;
444} 444}
445 445
446 446
447bool OPimContactAccessBackend_SQL::remove ( int uid ) 447bool OPimContactAccessBackend_SQL::remove ( int uid )
448{ 448{
449 RemoveQuery rem( uid ); 449 RemoveQuery rem( uid );
450 OSQLResult res = m_driver->query(&rem ); 450 OSQLResult res = m_driver->query(&rem );
451 451
452 if ( res.state() == OSQLResult::Failure ) 452 if ( res.state() == OSQLResult::Failure )
453 return false; 453 return false;
454 454
455 m_changed = true; 455 m_changed = true;
456 456
457 return true; 457 return true;
458} 458}
459 459
460bool OPimContactAccessBackend_SQL::replace ( const OPimContact &contact ) 460bool OPimContactAccessBackend_SQL::replace ( const OPimContact &contact )
461{ 461{
462 if ( !remove( contact.uid() ) ) 462 if ( !remove( contact.uid() ) )
463 return false; 463 return false;
464 464
465 return add( contact ); 465 return add( contact );
466} 466}
467 467
468 468
469OPimContact OPimContactAccessBackend_SQL::find ( int uid ) const 469OPimContact OPimContactAccessBackend_SQL::find ( int uid ) const
470{ 470{
471 qDebug("OPimContactAccessBackend_SQL::find()"); 471 qDebug("OPimContactAccessBackend_SQL::find()");
472 QTime t; 472 QTime t;
473 t.start(); 473 t.start();
474 474
475 OPimContact retContact( requestNonCustom( uid ) ); 475 OPimContact retContact( requestNonCustom( uid ) );
476 retContact.setExtraMap( requestCustom( uid ) ); 476 retContact.setExtraMap( requestCustom( uid ) );
477 477
478 qDebug("OPimContactAccessBackend_SQL::find() needed: %d ms", t.elapsed() ); 478 qDebug("OPimContactAccessBackend_SQL::find() needed: %d ms", t.elapsed() );
479 return retContact; 479 return retContact;
480} 480}
481 481
482 482
483 483
484QArray<int> OPimContactAccessBackend_SQL::queryByExample ( const OPimContact &query, int settings, const QDateTime& qd ) 484QArray<int> OPimContactAccessBackend_SQL::queryByExample ( const OPimContact &query, int settings, const QDateTime& qd )
485{ 485{
486 QString qu = "SELECT uid FROM addressbook WHERE"; 486 QString qu = "SELECT uid FROM addressbook WHERE";
487 QString searchQuery =""; 487 QString searchQuery ="";
488 488
489 QDate startDate; 489 QDate startDate;
490 490
491 if ( qd.isValid() ) 491 if ( qd.isValid() )
492 startDate = qd.date(); 492 startDate = qd.date();
493 else 493 else
494 startDate = QDate::currentDate(); 494 startDate = QDate::currentDate();
495 495
496 496
497 QMap<int, QString> queryFields = query.toMap(); 497 QMap<int, QString> queryFields = query.toMap();
498 QStringList fieldList = OPimContactFields::untrfields( false ); 498 QStringList fieldList = OPimContactFields::untrfields( false );
499 QMap<QString, int> translate = OPimContactFields::untrFieldsToId(); 499 QMap<QString, int> translate = OPimContactFields::untrFieldsToId();
500 500
501 // Convert every filled field to a SQL-Query 501 // Convert every filled field to a SQL-Query
502 // bool isAnyFieldSelected = false; 502 // bool isAnyFieldSelected = false;
503 for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){ 503 for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){
504 504
505 int id = translate[*it]; 505 int id = translate[*it];
506 QString queryStr = queryFields[id]; 506 QString queryStr = queryFields[id];
507 QDate* endDate = 0l; 507 QDate* endDate = 0l;
508 508
509 if ( !queryStr.isEmpty() ){ 509 if ( !queryStr.isEmpty() ){
510 // If something is alredy stored in the query, add an "AND" 510 // If something is alredy stored in the query, add an "AND"
511 // to the end of the string to prepare for the next .. 511 // to the end of the string to prepare for the next ..
512 if ( !searchQuery.isEmpty() ) 512 if ( !searchQuery.isEmpty() )
513 searchQuery += " AND"; 513 searchQuery += " AND";
514 514
515 // isAnyFieldSelected = true; 515 // isAnyFieldSelected = true;
516 switch( id ){ 516 switch( id ){
517 case Qtopia::Birthday: 517 case Qtopia::Birthday:
518 endDate = new QDate( query.birthday() ); 518 endDate = new QDate( query.birthday() );
519 // Fall through ! 519 // Fall through !
520 case Qtopia::Anniversary: 520 case Qtopia::Anniversary:
521 if ( endDate == 0l ) 521 if ( endDate == 0l )
522 endDate = new QDate( query.anniversary() ); 522 endDate = new QDate( query.anniversary() );
523 523
524 if ( settings & OPimContactAccess::DateDiff ) { 524 if ( settings & OPimContactAccess::DateDiff ) {
525 searchQuery += QString( " (\"%1\" <= '%2-%3-%4\' AND \"%5\" >= '%6-%7-%8')" ) 525 searchQuery += QString( " (\"%1\" <= '%2-%3-%4\' AND \"%5\" >= '%6-%7-%8')" )
526 .arg( *it ) 526 .arg( *it )
527 .arg( QString::number( endDate->year() ).rightJustify( 4, '0' ) ) 527 .arg( QString::number( endDate->year() ).rightJustify( 4, '0' ) )
528 .arg( QString::number( endDate->month() ).rightJustify( 2, '0' ) ) 528 .arg( QString::number( endDate->month() ).rightJustify( 2, '0' ) )
529 .arg( QString::number( endDate->day() ).rightJustify( 2, '0' ) ) 529 .arg( QString::number( endDate->day() ).rightJustify( 2, '0' ) )
530 .arg( *it ) 530 .arg( *it )
531 .arg( QString::number( startDate.year() ).rightJustify( 4, '0' ) ) 531 .arg( QString::number( startDate.year() ).rightJustify( 4, '0' ) )
532 .arg( QString::number( startDate.month() ).rightJustify( 2, '0' ) ) 532 .arg( QString::number( startDate.month() ).rightJustify( 2, '0' ) )
533 .arg( QString::number( startDate.day() ).rightJustify( 2, '0' ) ) ; 533 .arg( QString::number( startDate.day() ).rightJustify( 2, '0' ) ) ;
534 } 534 }
535 535
536 if ( settings & OPimContactAccess::DateYear ){ 536 if ( settings & OPimContactAccess::DateYear ){
537 if ( settings & OPimContactAccess::DateDiff ) 537 if ( settings & OPimContactAccess::DateDiff )
538 searchQuery += " AND"; 538 searchQuery += " AND";
539 539
540 searchQuery += QString( " (\"%1\" LIKE '%2-%')" ) 540 searchQuery += QString( " (\"%1\" LIKE '%2-%')" )
541 .arg( *it ) 541 .arg( *it )
542 .arg( QString::number( endDate->year() ).rightJustify( 4, '0' ) ); 542 .arg( QString::number( endDate->year() ).rightJustify( 4, '0' ) );
543 } 543 }
544 544
545 if ( settings & OPimContactAccess::DateMonth ){ 545 if ( settings & OPimContactAccess::DateMonth ){
546 if ( ( settings & OPimContactAccess::DateDiff ) 546 if ( ( settings & OPimContactAccess::DateDiff )
547 || ( settings & OPimContactAccess::DateYear ) ) 547 || ( settings & OPimContactAccess::DateYear ) )
548 searchQuery += " AND"; 548 searchQuery += " AND";
549 549
550 searchQuery += QString( " (\"%1\" LIKE '%-%2-%')" ) 550 searchQuery += QString( " (\"%1\" LIKE '%-%2-%')" )
551 .arg( *it ) 551 .arg( *it )
552 .arg( QString::number( endDate->month() ).rightJustify( 2, '0' ) ); 552 .arg( QString::number( endDate->month() ).rightJustify( 2, '0' ) );
553 } 553 }
554 554
555 if ( settings & OPimContactAccess::DateDay ){ 555 if ( settings & OPimContactAccess::DateDay ){
556 if ( ( settings & OPimContactAccess::DateDiff ) 556 if ( ( settings & OPimContactAccess::DateDiff )
557 || ( settings & OPimContactAccess::DateYear ) 557 || ( settings & OPimContactAccess::DateYear )
558 || ( settings & OPimContactAccess::DateMonth ) ) 558 || ( settings & OPimContactAccess::DateMonth ) )
559 searchQuery += " AND"; 559 searchQuery += " AND";
560 560
561 searchQuery += QString( " (\"%1\" LIKE '%-%-%2')" ) 561 searchQuery += QString( " (\"%1\" LIKE '%-%-%2')" )
562 .arg( *it ) 562 .arg( *it )
563 .arg( QString::number( endDate->day() ).rightJustify( 2, '0' ) ); 563 .arg( QString::number( endDate->day() ).rightJustify( 2, '0' ) );
564 } 564 }
565 565
566 break; 566 break;
567 default: 567 default:
568 // Switching between case sensitive and insensitive... 568 // Switching between case sensitive and insensitive...
569 // LIKE is not case sensitive, GLOB is case sensitive 569 // LIKE is not case sensitive, GLOB is case sensitive
570 // Do exist a better solution to switch this ? 570 // Do exist a better solution to switch this ?
571 if ( settings & OPimContactAccess::IgnoreCase ) 571 if ( settings & OPimContactAccess::IgnoreCase )
572 searchQuery += "(\"" + *it + "\"" + " LIKE " + "'" 572 searchQuery += "(\"" + *it + "\"" + " LIKE " + "'"
573 + queryStr.replace(QRegExp("\\*"),"%") + "'" + ")"; 573 + queryStr.replace(QRegExp("\\*"),"%") + "'" + ")";
574 else 574 else
575 searchQuery += "(\"" + *it + "\"" + " GLOB " + "'" 575 searchQuery += "(\"" + *it + "\"" + " GLOB " + "'"
576 + queryStr + "'" + ")"; 576 + queryStr + "'" + ")";
577 577
578 } 578 }
579 } 579 }
580 } 580 }
581 // Skip trailing "AND" 581 // Skip trailing "AND"
582 // if ( isAnyFieldSelected ) 582 // if ( isAnyFieldSelected )
583 // qu = qu.left( qu.length() - 4 ); 583 // qu = qu.left( qu.length() - 4 );
584 584
585 qu += searchQuery; 585 qu += searchQuery;
586 586
587 qDebug( "queryByExample query: %s", qu.latin1() ); 587 qDebug( "queryByExample query: %s", qu.latin1() );
588 588
589 // Execute query and return the received uid's 589 // Execute query and return the received uid's
590 OSQLRawQuery raw( qu ); 590 OSQLRawQuery raw( qu );
591 OSQLResult res = m_driver->query( &raw ); 591 OSQLResult res = m_driver->query( &raw );
592 if ( res.state() != OSQLResult::Success ){ 592 if ( res.state() != OSQLResult::Success ){
593 QArray<int> empty; 593 QArray<int> empty;
594 return empty; 594 return empty;
595 } 595 }
596 596
597 QArray<int> list = extractUids( res ); 597 QArray<int> list = extractUids( res );
598 598
599 return list; 599 return list;
600} 600}
601 601
602QArray<int> OPimContactAccessBackend_SQL::matchRegexp( const QRegExp &r ) const 602QArray<int> OPimContactAccessBackend_SQL::matchRegexp( const QRegExp &r ) const
603{ 603{
604#if 1
604 QArray<int> nix(0); 605 QArray<int> nix(0);
605 return nix; 606 return nix;
607
608#else
609 QString qu = "SELECT uid FROM addressbook WHERE (";
610 QString searchlist;
611
612 QStringList fieldList = OPimContactFields::untrfields( false );
613 // QMap<QString, int> translate = OPimContactFields::untrFieldsToId();
614 for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){
615 if ( !searchlist.isEmpty() )
616 searchlist += " OR ";
617 searchlist += "\"" + *it + "\" rlike(\"" + r.pattern() + "\") ";
618 }
619
620 qu = qu + searchlist + ")";
621
622 qDebug( "query: %s", qu.latin1() );
623
624 OSQLRawQuery raw( qu );
625 OSQLResult res = m_driver->query( &raw );
626
627 return extractUids( res );
628
629
630#endif
606} 631}
607 632
608const uint OPimContactAccessBackend_SQL::querySettings() 633const uint OPimContactAccessBackend_SQL::querySettings()
609{ 634{
610 return OPimContactAccess::IgnoreCase 635 return OPimContactAccess::IgnoreCase
611 || OPimContactAccess::WildCards 636 | OPimContactAccess::WildCards
612 || OPimContactAccess::DateDiff 637 | OPimContactAccess::DateDiff
613 || OPimContactAccess::DateYear 638 | OPimContactAccess::DateYear
614 || OPimContactAccess::DateMonth 639 | OPimContactAccess::DateMonth
615 || OPimContactAccess::DateDay 640 | OPimContactAccess::DateDay
616 ; 641 ;
617} 642}
618 643
619bool OPimContactAccessBackend_SQL::hasQuerySettings (uint querySettings) const 644bool OPimContactAccessBackend_SQL::hasQuerySettings (uint querySettings) const
620{ 645{
621 /* OPimContactAccess::IgnoreCase, DateDiff, DateYear, DateMonth, DateDay 646 /* OPimContactAccess::IgnoreCase, DateDiff, DateYear, DateMonth, DateDay
622 * may be added with any of the other settings. IgnoreCase should never used alone. 647 * may be added with any of the other settings. IgnoreCase should never used alone.
623 * Wildcards, RegExp, ExactMatch should never used at the same time... 648 * Wildcards, RegExp, ExactMatch should never used at the same time...
624 */ 649 */
625 650
626 // Step 1: Check whether the given settings are supported by this backend 651 // Step 1: Check whether the given settings are supported by this backend
627 if ( ( querySettings & ( 652 if ( ( querySettings & (
628 OPimContactAccess::IgnoreCase 653 OPimContactAccess::IgnoreCase
629 | OPimContactAccess::WildCards 654 | OPimContactAccess::WildCards
630 | OPimContactAccess::DateDiff 655 | OPimContactAccess::DateDiff
631 | OPimContactAccess::DateYear 656 | OPimContactAccess::DateYear
632 | OPimContactAccess::DateMonth 657 | OPimContactAccess::DateMonth
633 | OPimContactAccess::DateDay 658 | OPimContactAccess::DateDay
634 // | OPimContactAccess::RegExp 659 // | OPimContactAccess::RegExp
635 // | OPimContactAccess::ExactMatch 660 // | OPimContactAccess::ExactMatch
636 ) ) != querySettings ) 661 ) ) != querySettings )
637 return false; 662 return false;
638 663
639 // Step 2: Check whether the given combinations are ok.. 664 // Step 2: Check whether the given combinations are ok..
640 665
641 // IngoreCase alone is invalid 666 // IngoreCase alone is invalid
642 if ( querySettings == OPimContactAccess::IgnoreCase ) 667 if ( querySettings == OPimContactAccess::IgnoreCase )
643 return false; 668 return false;
644 669
645 // WildCards, RegExp and ExactMatch should never used at the same time 670 // WildCards, RegExp and ExactMatch should never used at the same time
646 switch ( querySettings & ~( OPimContactAccess::IgnoreCase 671 switch ( querySettings & ~( OPimContactAccess::IgnoreCase
647 | OPimContactAccess::DateDiff 672 | OPimContactAccess::DateDiff
648 | OPimContactAccess::DateYear 673 | OPimContactAccess::DateYear
649 | OPimContactAccess::DateMonth 674 | OPimContactAccess::DateMonth
650 | OPimContactAccess::DateDay 675 | OPimContactAccess::DateDay
651 ) 676 )
652 ){ 677 ){
653 case OPimContactAccess::RegExp: 678 case OPimContactAccess::RegExp:
654 return ( true ); 679 return ( true );
655 case OPimContactAccess::WildCards: 680 case OPimContactAccess::WildCards:
656 return ( true ); 681 return ( true );
657 case OPimContactAccess::ExactMatch: 682 case OPimContactAccess::ExactMatch:
658 return ( true ); 683 return ( true );
659 case 0: // one of the upper removed bits were set.. 684 case 0: // one of the upper removed bits were set..
660 return ( true ); 685 return ( true );
661 default: 686 default:
662 return ( false ); 687 return ( false );
663 } 688 }
664 689
665} 690}
666 691
667QArray<int> OPimContactAccessBackend_SQL::sorted( bool asc, int , int , int ) 692QArray<int> OPimContactAccessBackend_SQL::sorted( bool asc, int , int , int )
668{ 693{
669 QTime t; 694 QTime t;
670 t.start(); 695 t.start();
671 696
672 QString query = "SELECT uid FROM addressbook "; 697 QString query = "SELECT uid FROM addressbook ";
673 query += "ORDER BY \"Last Name\" "; 698 query += "ORDER BY \"Last Name\" ";
674 699
675 if ( !asc ) 700 if ( !asc )
676 query += "DESC"; 701 query += "DESC";
677 702
678 // qDebug("sorted query is: %s", query.latin1() ); 703 // qDebug("sorted query is: %s", query.latin1() );
679 704
680 OSQLRawQuery raw( query ); 705 OSQLRawQuery raw( query );
681 OSQLResult res = m_driver->query( &raw ); 706 OSQLResult res = m_driver->query( &raw );
682 if ( res.state() != OSQLResult::Success ){ 707 if ( res.state() != OSQLResult::Success ){
683 QArray<int> empty; 708 QArray<int> empty;
684 return empty; 709 return empty;
685 } 710 }
686 711
687 QArray<int> list = extractUids( res ); 712 QArray<int> list = extractUids( res );
688 713
689 qDebug("sorted needed %d ms!", t.elapsed() ); 714 qDebug("sorted needed %d ms!", t.elapsed() );
690 return list; 715 return list;
691} 716}
692 717
693 718
694void OPimContactAccessBackend_SQL::update() 719void OPimContactAccessBackend_SQL::update()
695{ 720{
696 qDebug("Update starts"); 721 qDebug("Update starts");
697 QTime t; 722 QTime t;
698 t.start(); 723 t.start();
699 724
700 // Now load the database set and extract the uid's 725 // Now load the database set and extract the uid's
701 // which will be held locally 726 // which will be held locally
702 727
703 LoadQuery lo; 728 LoadQuery lo;
704 OSQLResult res = m_driver->query(&lo); 729 OSQLResult res = m_driver->query(&lo);
705 if ( res.state() != OSQLResult::Success ) 730 if ( res.state() != OSQLResult::Success )
706 return; 731 return;
707 732
708 m_uids = extractUids( res ); 733 m_uids = extractUids( res );
709 734
710 m_changed = false; 735 m_changed = false;
711 736
712 qDebug("Update ends %d ms", t.elapsed() ); 737 qDebug("Update ends %d ms", t.elapsed() );
713} 738}
714 739
715QArray<int> OPimContactAccessBackend_SQL::extractUids( OSQLResult& res ) const 740QArray<int> OPimContactAccessBackend_SQL::extractUids( OSQLResult& res ) const
716{ 741{
717 qDebug("extractUids"); 742 qDebug("extractUids");
718 QTime t; 743 QTime t;
719 t.start(); 744 t.start();
720 OSQLResultItem::ValueList list = res.results(); 745 OSQLResultItem::ValueList list = res.results();
721 OSQLResultItem::ValueList::Iterator it; 746 OSQLResultItem::ValueList::Iterator it;
722 QArray<int> ints(list.count() ); 747 QArray<int> ints(list.count() );
723 qDebug(" count = %d", list.count() ); 748 qDebug(" count = %d", list.count() );
724 749
725 int i = 0; 750 int i = 0;
726 for (it = list.begin(); it != list.end(); ++it ) { 751 for (it = list.begin(); it != list.end(); ++it ) {
727 ints[i] = (*it).data("uid").toInt(); 752 ints[i] = (*it).data("uid").toInt();
728 i++; 753 i++;
729 } 754 }
730 qDebug("extractUids ready: count2 = %d needs %d ms", i, t.elapsed() ); 755 qDebug("extractUids ready: count2 = %d needs %d ms", i, t.elapsed() );
731 756
732 return ints; 757 return ints;
733 758
734} 759}
735 760
736QMap<int, QString> OPimContactAccessBackend_SQL::requestNonCustom( int uid ) const 761QMap<int, QString> OPimContactAccessBackend_SQL::requestNonCustom( int uid ) const
737{ 762{
738 QTime t; 763 QTime t;
739 t.start(); 764 t.start();
740 765
741 QMap<int, QString> nonCustomMap; 766 QMap<int, QString> nonCustomMap;
742 767
743 int t2needed = 0; 768 int t2needed = 0;
744 int t3needed = 0; 769 int t3needed = 0;
745 QTime t2; 770 QTime t2;
746 t2.start(); 771 t2.start();
747 FindQuery query( uid ); 772 FindQuery query( uid );
748 OSQLResult res_noncustom = m_driver->query( &query ); 773 OSQLResult res_noncustom = m_driver->query( &query );
749 t2needed = t2.elapsed(); 774 t2needed = t2.elapsed();
750 775
751 OSQLResultItem resItem = res_noncustom.first(); 776 OSQLResultItem resItem = res_noncustom.first();
752 777
753 QTime t3; 778 QTime t3;
754 t3.start(); 779 t3.start();
755 // Now loop through all columns 780 // Now loop through all columns
756 QStringList fieldList = OPimContactFields::untrfields( false ); 781 QStringList fieldList = OPimContactFields::untrfields( false );
757 QMap<QString, int> translate = OPimContactFields::untrFieldsToId(); 782 QMap<QString, int> translate = OPimContactFields::untrFieldsToId();
758 for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){ 783 for ( QStringList::Iterator it = ++fieldList.begin(); it != fieldList.end(); ++it ){
759 // Get data for the selected column and store it with the 784 // Get data for the selected column and store it with the
760 // corresponding id into the map.. 785 // corresponding id into the map..
761 786
762 int id = translate[*it]; 787 int id = translate[*it];
763 QString value = resItem.data( (*it) ); 788 QString value = resItem.data( (*it) );
764 789
765 // qDebug("Reading %s... found: %s", (*it).latin1(), value.latin1() ); 790 // qDebug("Reading %s... found: %s", (*it).latin1(), value.latin1() );
766 791
767 switch( id ){ 792 switch( id ){
768 case Qtopia::Birthday: 793 case Qtopia::Birthday:
769 case Qtopia::Anniversary:{ 794 case Qtopia::Anniversary:{
770 // Birthday and Anniversary are encoded special ( yyyy-mm-dd ) 795 // Birthday and Anniversary are encoded special ( yyyy-mm-dd )
771 QStringList list = QStringList::split( '-', value ); 796 QStringList list = QStringList::split( '-', value );
772 QStringList::Iterator lit = list.begin(); 797 QStringList::Iterator lit = list.begin();
773 int year = (*lit).toInt(); 798 int year = (*lit).toInt();
774 int month = (*(++lit)).toInt(); 799 int month = (*(++lit)).toInt();
775 int day = (*(++lit)).toInt(); 800 int day = (*(++lit)).toInt();
776 if ( ( day != 0 ) && ( month != 0 ) && ( year != 0 ) ){ 801 if ( ( day != 0 ) && ( month != 0 ) && ( year != 0 ) ){
777 QDate date( year, month, day ); 802 QDate date( year, month, day );
778 nonCustomMap.insert( id, OPimDateConversion::dateToString( date ) ); 803 nonCustomMap.insert( id, OPimDateConversion::dateToString( date ) );
779 } 804 }
780 } 805 }
781 break; 806 break;
782 case Qtopia::AddressCategory: 807 case Qtopia::AddressCategory:
783 qDebug("Category is: %s", value.latin1() ); 808 qDebug("Category is: %s", value.latin1() );
784 default: 809 default:
785 nonCustomMap.insert( id, value ); 810 nonCustomMap.insert( id, value );
786 } 811 }
787 } 812 }
788 813
789 // First insert uid 814 // First insert uid
790 nonCustomMap.insert( Qtopia::AddressUid, resItem.data( "uid" ) ); 815 nonCustomMap.insert( Qtopia::AddressUid, resItem.data( "uid" ) );
791 t3needed = t3.elapsed(); 816 t3needed = t3.elapsed();
792 817
793 // qDebug("Adding UID: %s", resItem.data( "uid" ).latin1() ); 818 // qDebug("Adding UID: %s", resItem.data( "uid" ).latin1() );
794 qDebug("RequestNonCustom needed: insg.:%d ms, query: %d ms, mapping: %d ms", 819 qDebug("RequestNonCustom needed: insg.:%d ms, query: %d ms, mapping: %d ms",
795 t.elapsed(), t2needed, t3needed ); 820 t.elapsed(), t2needed, t3needed );
796 821
797 return nonCustomMap; 822 return nonCustomMap;
798} 823}
799 824
800QMap<QString, QString> OPimContactAccessBackend_SQL::requestCustom( int uid ) const 825QMap<QString, QString> OPimContactAccessBackend_SQL::requestCustom( int uid ) const
801{ 826{
802 QTime t; 827 QTime t;
803 t.start(); 828 t.start();
804 829
805 QMap<QString, QString> customMap; 830 QMap<QString, QString> customMap;
806 831
807 FindCustomQuery query( uid ); 832 FindCustomQuery query( uid );
808 OSQLResult res_custom = m_driver->query( &query ); 833 OSQLResult res_custom = m_driver->query( &query );
809 834
810 if ( res_custom.state() == OSQLResult::Failure ) { 835 if ( res_custom.state() == OSQLResult::Failure ) {
811 qWarning("OSQLResult::Failure in find query !!"); 836 qWarning("OSQLResult::Failure in find query !!");
812 QMap<QString, QString> empty; 837 QMap<QString, QString> empty;
813 return empty; 838 return empty;
814 } 839 }
815 840
816 OSQLResultItem::ValueList list = res_custom.results(); 841 OSQLResultItem::ValueList list = res_custom.results();
817 OSQLResultItem::ValueList::Iterator it = list.begin(); 842 OSQLResultItem::ValueList::Iterator it = list.begin();
818 for ( ; it != list.end(); ++it ) { 843 for ( ; it != list.end(); ++it ) {
819 customMap.insert( (*it).data( "type" ), (*it).data( "value" ) ); 844 customMap.insert( (*it).data( "type" ), (*it).data( "value" ) );
820 } 845 }
821 846
822 qDebug("RequestCustom needed: %d ms", t.elapsed() ); 847 qDebug("RequestCustom needed: %d ms", t.elapsed() );
823 return customMap; 848 return customMap;
824} 849}
825 850
826} 851}