author | zecke <zecke> | 2002-10-07 09:10:05 (UTC) |
---|---|---|
committer | zecke <zecke> | 2002-10-07 09:10:05 (UTC) |
commit | acd2d0062dd87635feb03927663b1f700305d67b (patch) (unidiff) | |
tree | 179217749ec7ba3217ca71f80a6e1064f249d1b0 | |
parent | de56dc7c5a21cbd70e9d1e66ab68ca95a277c45c (diff) | |
download | opie-acd2d0062dd87635feb03927663b1f700305d67b.zip opie-acd2d0062dd87635feb03927663b1f700305d67b.tar.gz opie-acd2d0062dd87635feb03927663b1f700305d67b.tar.bz2 |
First SQL backend Resource
The DB layout is not fully what we've in mind
but for example I do lack the Categories infrastructure
for that
I've to implement sorted lists and then I'll make
Todolist fast
-rw-r--r-- | libopie/pim/orecordlist.h | 5 | ||||
-rw-r--r-- | libopie/pim/otodoaccess.cpp | 4 | ||||
-rw-r--r-- | libopie/pim/otodoaccesssql.cpp | 397 | ||||
-rw-r--r-- | libopie/pim/otodoaccesssql.h | 46 | ||||
-rw-r--r-- | libopie/pim/otodoaccessxml.cpp | 1 | ||||
-rw-r--r-- | libopie2/opiepim/backend/otodoaccesssql.cpp | 397 | ||||
-rw-r--r-- | libopie2/opiepim/backend/otodoaccesssql.h | 46 | ||||
-rw-r--r-- | libopie2/opiepim/backend/otodoaccessxml.cpp | 1 | ||||
-rw-r--r-- | libopie2/opiepim/core/otodoaccess.cpp | 4 | ||||
-rw-r--r-- | libopie2/opiepim/orecordlist.h | 5 |
10 files changed, 896 insertions, 10 deletions
diff --git a/libopie/pim/orecordlist.h b/libopie/pim/orecordlist.h index 1fd0741..b6fa7fa 100644 --- a/libopie/pim/orecordlist.h +++ b/libopie/pim/orecordlist.h | |||
@@ -93,136 +93,135 @@ public: | |||
93 | ~ORecordList(); | 93 | ~ORecordList(); |
94 | 94 | ||
95 | /** | 95 | /** |
96 | * the first iterator | 96 | * the first iterator |
97 | */ | 97 | */ |
98 | Iterator begin(); | 98 | Iterator begin(); |
99 | 99 | ||
100 | /** | 100 | /** |
101 | * the end | 101 | * the end |
102 | */ | 102 | */ |
103 | Iterator end(); | 103 | Iterator end(); |
104 | 104 | ||
105 | /** | 105 | /** |
106 | * the number of items in the list | 106 | * the number of items in the list |
107 | */ | 107 | */ |
108 | uint count()const; | 108 | uint count()const; |
109 | 109 | ||
110 | T operator[]( uint i ); | 110 | T operator[]( uint i ); |
111 | // FIXME implemenent remove | 111 | // FIXME implemenent remove |
112 | /* | 112 | /* |
113 | ConstIterator begin()const; | 113 | ConstIterator begin()const; |
114 | ConstIterator end()const; | 114 | ConstIterator end()const; |
115 | */ | 115 | */ |
116 | private: | 116 | private: |
117 | QArray<int> m_ids; | 117 | QArray<int> m_ids; |
118 | const Base* m_acc; | 118 | const Base* m_acc; |
119 | }; | 119 | }; |
120 | 120 | ||
121 | /* ok now implement it */ | 121 | /* ok now implement it */ |
122 | template <class T> | 122 | template <class T> |
123 | ORecordListIterator<T>::ORecordListIterator() { | 123 | ORecordListIterator<T>::ORecordListIterator() { |
124 | m_current = 0; | 124 | m_current = 0; |
125 | m_temp = 0l; | 125 | m_temp = 0l; |
126 | m_end = true; | 126 | m_end = true; |
127 | m_record = T(); | 127 | m_record = T(); |
128 | } | 128 | } |
129 | template <class T> | 129 | template <class T> |
130 | ORecordListIterator<T>::~ORecordListIterator() { | 130 | ORecordListIterator<T>::~ORecordListIterator() { |
131 | /* nothing to delete */ | 131 | /* nothing to delete */ |
132 | } | 132 | } |
133 | 133 | ||
134 | template <class T> | 134 | template <class T> |
135 | ORecordListIterator<T>::ORecordListIterator( const ORecordListIterator<T>& it) { | 135 | ORecordListIterator<T>::ORecordListIterator( const ORecordListIterator<T>& it) { |
136 | // qWarning("ORecordListIterator copy c'tor"); | 136 | // qWarning("ORecordListIterator copy c'tor"); |
137 | m_uids = it.m_uids; | 137 | m_uids = it.m_uids; |
138 | m_current = it.m_current; | 138 | m_current = it.m_current; |
139 | m_temp = it.m_temp; | 139 | m_temp = it.m_temp; |
140 | m_end = it.m_end; | 140 | m_end = it.m_end; |
141 | m_record = it.m_record; | 141 | m_record = it.m_record; |
142 | } | 142 | } |
143 | 143 | ||
144 | template <class T> | 144 | template <class T> |
145 | ORecordListIterator<T> &ORecordListIterator<T>::operator=( const ORecordListIterator<T>& it) { | 145 | ORecordListIterator<T> &ORecordListIterator<T>::operator=( const ORecordListIterator<T>& it) { |
146 | m_uids = it.m_uids; | 146 | m_uids = it.m_uids; |
147 | m_current = it.m_current; | 147 | m_current = it.m_current; |
148 | m_temp = it.m_temp; | 148 | m_temp = it.m_temp; |
149 | m_end = it.m_end; | 149 | m_end = it.m_end; |
150 | m_record = it.m_record; | 150 | m_record = it.m_record; |
151 | 151 | ||
152 | return *this; | 152 | return *this; |
153 | } | 153 | } |
154 | 154 | ||
155 | template <class T> | 155 | template <class T> |
156 | T ORecordListIterator<T>::operator*() { | 156 | T ORecordListIterator<T>::operator*() { |
157 | // qWarning("operator* %d %d", m_current, m_uids[m_current] ); | 157 | qWarning("operator* %d %d", m_current, m_uids[m_current] ); |
158 | if (!m_end ) | 158 | if (!m_end ) |
159 | /* FIXME | 159 | /* FIXME |
160 | * until the cache is in place | 160 | * until the cache is in place |
161 | * we do the uid match uid check | 161 | * we do the uid match uid check |
162 | */ | 162 | */ |
163 | if(m_record.uid() != m_uids[m_current] ) | 163 | m_record = m_temp->find( m_uids[m_current] ); |
164 | m_record = m_temp->find( m_uids[m_current] ); | ||
165 | else | 164 | else |
166 | m_record = T(); | 165 | m_record = T(); |
167 | 166 | ||
168 | return m_record; | 167 | return m_record; |
169 | } | 168 | } |
170 | 169 | ||
171 | template <class T> | 170 | template <class T> |
172 | ORecordListIterator<T> &ORecordListIterator<T>::operator++() { | 171 | ORecordListIterator<T> &ORecordListIterator<T>::operator++() { |
173 | if (m_current < m_uids.count() ) { | 172 | if (m_current < m_uids.count() ) { |
174 | m_end = false; | 173 | m_end = false; |
175 | ++m_current; | 174 | ++m_current; |
176 | }else | 175 | }else |
177 | m_end = true; | 176 | m_end = true; |
178 | 177 | ||
179 | return *this; | 178 | return *this; |
180 | } | 179 | } |
181 | template <class T> | 180 | template <class T> |
182 | ORecordListIterator<T> &ORecordListIterator<T>::operator--() { | 181 | ORecordListIterator<T> &ORecordListIterator<T>::operator--() { |
183 | if ( m_current > 0 ) { | 182 | if ( m_current > 0 ) { |
184 | --m_current; | 183 | --m_current; |
185 | m_end = false; | 184 | m_end = false; |
186 | } else | 185 | } else |
187 | m_end = true; | 186 | m_end = true; |
188 | 187 | ||
189 | return *this; | 188 | return *this; |
190 | } | 189 | } |
191 | 190 | ||
192 | template <class T> | 191 | template <class T> |
193 | bool ORecordListIterator<T>::operator==( const ORecordListIterator<T>& it ) { | 192 | bool ORecordListIterator<T>::operator==( const ORecordListIterator<T>& it ) { |
194 | 193 | ||
195 | /* if both are at we're the same.... */ | 194 | /* if both are at we're the same.... */ |
196 | if ( m_end == it.m_end ) return true; | 195 | if ( m_end == it.m_end ) return true; |
197 | 196 | ||
198 | if ( m_uids != it.m_uids ) return false; | 197 | if ( m_uids != it.m_uids ) return false; |
199 | if ( m_current != it.m_current ) return false; | 198 | if ( m_current != it.m_current ) return false; |
200 | if ( m_temp != it.m_temp ) return false; | 199 | if ( m_temp != it.m_temp ) return false; |
201 | 200 | ||
202 | return true; | 201 | return true; |
203 | } | 202 | } |
204 | template <class T> | 203 | template <class T> |
205 | bool ORecordListIterator<T>::operator!=( const ORecordListIterator<T>& it ) { | 204 | bool ORecordListIterator<T>::operator!=( const ORecordListIterator<T>& it ) { |
206 | return !(*this == it ); | 205 | return !(*this == it ); |
207 | } | 206 | } |
208 | template <class T> | 207 | template <class T> |
209 | ORecordListIterator<T>::ORecordListIterator( const QArray<int> uids, | 208 | ORecordListIterator<T>::ORecordListIterator( const QArray<int> uids, |
210 | const Base* t ) | 209 | const Base* t ) |
211 | : m_uids( uids ), m_current( 0 ), m_temp( t ), m_end( false ) | 210 | : m_uids( uids ), m_current( 0 ), m_temp( t ), m_end( false ) |
212 | { | 211 | { |
213 | } | 212 | } |
214 | template <class T> | 213 | template <class T> |
215 | uint ORecordListIterator<T>::current()const { | 214 | uint ORecordListIterator<T>::current()const { |
216 | return m_current; | 215 | return m_current; |
217 | } | 216 | } |
218 | template <class T> | 217 | template <class T> |
219 | void ORecordListIterator<T>::setCurrent( uint cur ) { | 218 | void ORecordListIterator<T>::setCurrent( uint cur ) { |
220 | if( cur < m_uids.count() ) { | 219 | if( cur < m_uids.count() ) { |
221 | m_end = false; | 220 | m_end = false; |
222 | m_current= cur; | 221 | m_current= cur; |
223 | } | 222 | } |
224 | } | 223 | } |
225 | template <class T> | 224 | template <class T> |
226 | uint ORecordListIterator<T>::count()const { | 225 | uint ORecordListIterator<T>::count()const { |
227 | return m_uids.count(); | 226 | return m_uids.count(); |
228 | } | 227 | } |
diff --git a/libopie/pim/otodoaccess.cpp b/libopie/pim/otodoaccess.cpp index f51da29..5990841 100644 --- a/libopie/pim/otodoaccess.cpp +++ b/libopie/pim/otodoaccess.cpp | |||
@@ -1,77 +1,77 @@ | |||
1 | #include <qdatetime.h> | 1 | #include <qdatetime.h> |
2 | 2 | ||
3 | #include <qpe/alarmserver.h> | 3 | #include <qpe/alarmserver.h> |
4 | 4 | ||
5 | #include "otodoaccessxml.h" | 5 | #include "otodoaccesssql.h" |
6 | #include "otodoaccess.h" | 6 | #include "otodoaccess.h" |
7 | 7 | ||
8 | 8 | ||
9 | OTodoAccess::OTodoAccess( OTodoAccessBackend* end ) | 9 | OTodoAccess::OTodoAccess( OTodoAccessBackend* end ) |
10 | : QObject(), OPimAccessTemplate<OTodo>( end ), m_todoBackEnd( end ) | 10 | : QObject(), OPimAccessTemplate<OTodo>( end ), m_todoBackEnd( end ) |
11 | { | 11 | { |
12 | if (end == 0l ) | 12 | if (end == 0l ) |
13 | m_todoBackEnd = new OTodoAccessXML( "Todolist" ); | 13 | m_todoBackEnd = new OTodoAccessBackendSQL( QString::null); |
14 | 14 | ||
15 | setBackEnd( m_todoBackEnd ); | 15 | setBackEnd( m_todoBackEnd ); |
16 | } | 16 | } |
17 | OTodoAccess::~OTodoAccess() { | 17 | OTodoAccess::~OTodoAccess() { |
18 | // qWarning("~OTodoAccess"); | 18 | // qWarning("~OTodoAccess"); |
19 | } | 19 | } |
20 | void OTodoAccess::mergeWith( const QValueList<OTodo>& list ) { | 20 | void OTodoAccess::mergeWith( const QValueList<OTodo>& list ) { |
21 | QValueList<OTodo>::ConstIterator it; | 21 | QValueList<OTodo>::ConstIterator it; |
22 | for ( it = list.begin(); it != list.end(); ++it ) { | 22 | for ( it = list.begin(); it != list.end(); ++it ) { |
23 | replace( (*it) ); | 23 | replace( (*it) ); |
24 | } | 24 | } |
25 | } | 25 | } |
26 | OTodoAccess::List OTodoAccess::effectiveToDos( const QDate& start, | 26 | OTodoAccess::List OTodoAccess::effectiveToDos( const QDate& start, |
27 | const QDate& end, | 27 | const QDate& end, |
28 | bool includeNoDates ) { | 28 | bool includeNoDates ) { |
29 | QArray<int> ints = m_todoBackEnd->effectiveToDos( start, end, includeNoDates ); | 29 | QArray<int> ints = m_todoBackEnd->effectiveToDos( start, end, includeNoDates ); |
30 | 30 | ||
31 | List lis( ints, this ); | 31 | List lis( ints, this ); |
32 | return lis; | 32 | return lis; |
33 | } | 33 | } |
34 | OTodoAccess::List OTodoAccess::effectiveToDos( const QDate& start, | 34 | OTodoAccess::List OTodoAccess::effectiveToDos( const QDate& start, |
35 | bool includeNoDates ) { | 35 | bool includeNoDates ) { |
36 | return effectiveToDos( start, QDate::currentDate(), | 36 | return effectiveToDos( start, QDate::currentDate(), |
37 | includeNoDates ); | 37 | includeNoDates ); |
38 | } | 38 | } |
39 | OTodoAccess::List OTodoAccess::overDue() { | 39 | OTodoAccess::List OTodoAccess::overDue() { |
40 | List lis( m_todoBackEnd->overDue(), this ); | 40 | List lis( m_todoBackEnd->overDue(), this ); |
41 | return lis; | 41 | return lis; |
42 | } | 42 | } |
43 | void OTodoAccess::addAlarm( const OTodo& event) { | 43 | void OTodoAccess::addAlarm( const OTodo& event) { |
44 | if (!event.hasAlarmDateTime() ) | 44 | if (!event.hasAlarmDateTime() ) |
45 | return; | 45 | return; |
46 | 46 | ||
47 | QDateTime now = QDateTime::currentDateTime(); | 47 | QDateTime now = QDateTime::currentDateTime(); |
48 | QDateTime schedule = event.alarmDateTime(); | 48 | QDateTime schedule = event.alarmDateTime(); |
49 | 49 | ||
50 | if ( schedule > now ){ | 50 | if ( schedule > now ){ |
51 | AlarmServer::addAlarm( schedule, | 51 | AlarmServer::addAlarm( schedule, |
52 | "QPE/Application/todolist", | 52 | "QPE/Application/todolist", |
53 | "alarm(QDateTime,int)", event.uid() ); | 53 | "alarm(QDateTime,int)", event.uid() ); |
54 | 54 | ||
55 | } | 55 | } |
56 | } | 56 | } |
57 | void OTodoAccess::delAlarm( int uid) { | 57 | void OTodoAccess::delAlarm( int uid) { |
58 | 58 | ||
59 | QDateTime schedule; // Create null DateTime | 59 | QDateTime schedule; // Create null DateTime |
60 | 60 | ||
61 | // I hope this will remove all scheduled alarms | 61 | // I hope this will remove all scheduled alarms |
62 | // with the given uid !? | 62 | // with the given uid !? |
63 | // If not: I have to rethink how to remove already | 63 | // If not: I have to rethink how to remove already |
64 | // scheduled events... (se) | 64 | // scheduled events... (se) |
65 | // it should be fine -zecke | 65 | // it should be fine -zecke |
66 | // qWarning("Removing alarm for event with uid %d", uid ); | 66 | // qWarning("Removing alarm for event with uid %d", uid ); |
67 | AlarmServer::deleteAlarm( schedule , | 67 | AlarmServer::deleteAlarm( schedule , |
68 | "QPE/Application/todolist", | 68 | "QPE/Application/todolist", |
69 | "alarm(QDateTime,int)", uid ); | 69 | "alarm(QDateTime,int)", uid ); |
70 | } | 70 | } |
71 | /* sort order */ | 71 | /* sort order */ |
72 | OTodoAccess::List OTodoAccess::sorted( bool ascending, int sort,int filter, int cat ) { | 72 | OTodoAccess::List OTodoAccess::sorted( bool ascending, int sort,int filter, int cat ) { |
73 | QArray<int> ints = m_todoBackEnd->sorted( ascending, sort, | 73 | QArray<int> ints = m_todoBackEnd->sorted( ascending, sort, |
74 | filter, cat ); | 74 | filter, cat ); |
75 | OTodoAccess::List list( ints, this ); | 75 | OTodoAccess::List list( ints, this ); |
76 | return list; | 76 | return list; |
77 | } | 77 | } |
diff --git a/libopie/pim/otodoaccesssql.cpp b/libopie/pim/otodoaccesssql.cpp new file mode 100644 index 0000000..209e714 --- a/dev/null +++ b/libopie/pim/otodoaccesssql.cpp | |||
@@ -0,0 +1,397 @@ | |||
1 | |||
2 | #include <qdatetime.h> | ||
3 | |||
4 | #include <qpe/global.h> | ||
5 | |||
6 | #include <opie/osqldriver.h> | ||
7 | #include <opie/osqlresult.h> | ||
8 | #include <opie/osqlmanager.h> | ||
9 | #include <opie/osqlquery.h> | ||
10 | |||
11 | #include "otodoaccesssql.h" | ||
12 | |||
13 | /* | ||
14 | * first some query | ||
15 | * CREATE query | ||
16 | * LOAD query | ||
17 | * INSERT | ||
18 | * REMOVE | ||
19 | * CLEAR | ||
20 | */ | ||
21 | namespace { | ||
22 | /** | ||
23 | * CreateQuery for the Todolist Table | ||
24 | */ | ||
25 | class CreateQuery : public OSQLQuery { | ||
26 | public: | ||
27 | CreateQuery(); | ||
28 | ~CreateQuery(); | ||
29 | QString query()const; | ||
30 | }; | ||
31 | |||
32 | /** | ||
33 | * LoadQuery | ||
34 | * this one queries for all uids | ||
35 | */ | ||
36 | class LoadQuery : public OSQLQuery { | ||
37 | public: | ||
38 | LoadQuery(); | ||
39 | ~LoadQuery(); | ||
40 | QString query()const; | ||
41 | }; | ||
42 | |||
43 | /** | ||
44 | * inserts/adds a OTodo to the table | ||
45 | */ | ||
46 | class InsertQuery : public OSQLQuery { | ||
47 | public: | ||
48 | InsertQuery(const OTodo& ); | ||
49 | ~InsertQuery(); | ||
50 | QString query()const; | ||
51 | private: | ||
52 | OTodo m_todo; | ||
53 | }; | ||
54 | |||
55 | /** | ||
56 | * removes one from the table | ||
57 | */ | ||
58 | class RemoveQuery : public OSQLQuery { | ||
59 | public: | ||
60 | RemoveQuery(int uid ); | ||
61 | ~RemoveQuery(); | ||
62 | QString query()const; | ||
63 | private: | ||
64 | int m_uid; | ||
65 | }; | ||
66 | |||
67 | /** | ||
68 | * Clears (delete) a Table | ||
69 | */ | ||
70 | class ClearQuery : public OSQLQuery { | ||
71 | public: | ||
72 | ClearQuery(); | ||
73 | ~ClearQuery(); | ||
74 | QString query()const; | ||
75 | |||
76 | }; | ||
77 | |||
78 | /** | ||
79 | * a find query | ||
80 | */ | ||
81 | class FindQuery : public OSQLQuery { | ||
82 | public: | ||
83 | FindQuery(int uid); | ||
84 | ~FindQuery(); | ||
85 | QString query()const; | ||
86 | private: | ||
87 | int m_uid; | ||
88 | }; | ||
89 | |||
90 | /** | ||
91 | * overdue query | ||
92 | */ | ||
93 | class OverDueQuery : public OSQLQuery { | ||
94 | public: | ||
95 | OverDueQuery(); | ||
96 | ~OverDueQuery(); | ||
97 | QString query()const; | ||
98 | }; | ||
99 | class EffQuery : public OSQLQuery { | ||
100 | public: | ||
101 | EffQuery( const QDate&, const QDate&, bool inc ); | ||
102 | ~EffQuery(); | ||
103 | QString query()const; | ||
104 | private: | ||
105 | QString with()const; | ||
106 | QString out()const; | ||
107 | QDate m_start; | ||
108 | QDate m_end; | ||
109 | bool m_inc :1; | ||
110 | }; | ||
111 | |||
112 | |||
113 | CreateQuery::CreateQuery() : OSQLQuery() {} | ||
114 | CreateQuery::~CreateQuery() {} | ||
115 | QString CreateQuery::query()const { | ||
116 | QString qu; | ||
117 | qu += "create table todolist( uid, categories, completed, progress, "; | ||
118 | qu += "summary, DueDate, priority, description )"; | ||
119 | return qu; | ||
120 | } | ||
121 | |||
122 | LoadQuery::LoadQuery() : OSQLQuery() {} | ||
123 | LoadQuery::~LoadQuery() {} | ||
124 | QString LoadQuery::query()const { | ||
125 | QString qu; | ||
126 | qu += "select distinct uid from todolist"; | ||
127 | |||
128 | return qu; | ||
129 | } | ||
130 | |||
131 | InsertQuery::InsertQuery( const OTodo& todo ) | ||
132 | : OSQLQuery(), m_todo( todo ) { | ||
133 | } | ||
134 | InsertQuery::~InsertQuery() { | ||
135 | } | ||
136 | /* | ||
137 | * converts from a OTodo to a query | ||
138 | * we leave out X-Ref + Alarms | ||
139 | */ | ||
140 | QString InsertQuery::query()const{ | ||
141 | int year, month, day; | ||
142 | year = month = day = 0; | ||
143 | if (m_todo.hasDueDate() ) { | ||
144 | QDate date = m_todo.dueDate(); | ||
145 | year = date.year(); | ||
146 | month = date.month(); | ||
147 | day = date.day(); | ||
148 | } | ||
149 | QString qu; | ||
150 | qu = "insert into todolist VALUES(" + QString::number( m_todo.uid() ) + ",'" + m_todo.idsToString( m_todo.categories() ) + "',"; | ||
151 | qu += QString::number( m_todo.isCompleted() ) + "," + QString::number( m_todo.progress() ) + ","; | ||
152 | qu += "'"+m_todo.summary()+"','"+QString::number(year)+"-"+QString::number(month)+"-"+QString::number(day)+"',"; | ||
153 | qu += QString::number(m_todo.priority() ) +",'" + m_todo.description() + "')"; | ||
154 | |||
155 | qWarning("add %s", qu.latin1() ); | ||
156 | return qu; | ||
157 | } | ||
158 | |||
159 | RemoveQuery::RemoveQuery(int uid ) | ||
160 | : OSQLQuery(), m_uid( uid ) {} | ||
161 | RemoveQuery::~RemoveQuery() {} | ||
162 | QString RemoveQuery::query()const { | ||
163 | QString qu = "DELETE from todolist where uid = " + QString::number(m_uid); | ||
164 | return qu; | ||
165 | } | ||
166 | |||
167 | |||
168 | ClearQuery::ClearQuery() | ||
169 | : OSQLQuery() {} | ||
170 | ClearQuery::~ClearQuery() {} | ||
171 | QString ClearQuery::query()const { | ||
172 | QString qu = "drop table todolist"; | ||
173 | return qu; | ||
174 | } | ||
175 | FindQuery::FindQuery(int uid) | ||
176 | : OSQLQuery(), m_uid(uid ) { | ||
177 | } | ||
178 | FindQuery::~FindQuery() { | ||
179 | } | ||
180 | QString FindQuery::query()const{ | ||
181 | QString qu = "select uid, categories, completed, progress, summary, "; | ||
182 | qu += "DueDate, priority, description from todolist where uid = " + QString::number(m_uid); | ||
183 | return qu; | ||
184 | } | ||
185 | |||
186 | OverDueQuery::OverDueQuery(): OSQLQuery() {} | ||
187 | OverDueQuery::~OverDueQuery() {} | ||
188 | QString OverDueQuery::query()const { | ||
189 | QDate date = QDate::currentDate(); | ||
190 | QString str; | ||
191 | str = QString("select uid from todolist where DueDate ='%1-%2-%3'").arg(date.year() ).arg(date.month() ).arg(date.day() ); | ||
192 | |||
193 | return str; | ||
194 | } | ||
195 | |||
196 | |||
197 | EffQuery::EffQuery( const QDate& start, const QDate& end, bool inc ) | ||
198 | : OSQLQuery(), m_start( start ), m_end( end ),m_inc(inc) {} | ||
199 | EffQuery::~EffQuery() {} | ||
200 | QString EffQuery::query()const { | ||
201 | return m_inc ? with() : out(); | ||
202 | } | ||
203 | QString EffQuery::with()const { | ||
204 | QString str; | ||
205 | str = QString("select uid from todolist where ( DueDate >= '%1-%2-%3' AND DueDate <= '%4-%5-%6' ) OR DueDate = '0-0-0' ") | ||
206 | .arg( m_start.year() ).arg( m_start.month() ).arg( m_start.day() ) | ||
207 | .arg( m_end .year() ).arg( m_end .month() ).arg( m_end .day() ); | ||
208 | return str; | ||
209 | } | ||
210 | QString EffQuery::out()const { | ||
211 | QString str; | ||
212 | str = QString("select uid from todolist where DueDate >= '%1-%2-%3' AND DueDate <= '%4-%5-%6'") | ||
213 | .arg(m_start.year() ).arg(m_start.month() ).arg( m_start.day() ) | ||
214 | .arg(m_end. year() ).arg(m_end. month() ).arg(m_end.day() ); | ||
215 | |||
216 | return str; | ||
217 | } | ||
218 | }; | ||
219 | |||
220 | OTodoAccessBackendSQL::OTodoAccessBackendSQL( const QString& file ) | ||
221 | : OTodoAccessBackend(), m_dict(15) | ||
222 | { | ||
223 | QString fi = file; | ||
224 | if ( fi.isEmpty() ) | ||
225 | fi = Global::applicationFileName( "todolist", "todolist.db" ); | ||
226 | OSQLManager man; | ||
227 | m_driver = man.standard(); | ||
228 | m_driver->setUrl(fi); | ||
229 | fillDict(); | ||
230 | } | ||
231 | |||
232 | OTodoAccessBackendSQL::~OTodoAccessBackendSQL(){ | ||
233 | } | ||
234 | bool OTodoAccessBackendSQL::load(){ | ||
235 | if (!m_driver->open() ) | ||
236 | return false; | ||
237 | |||
238 | CreateQuery creat; | ||
239 | OSQLResult res = m_driver->query(&creat ); | ||
240 | |||
241 | update(); | ||
242 | qWarning("loaded %d", m_uids.count() ); | ||
243 | return true; | ||
244 | } | ||
245 | bool OTodoAccessBackendSQL::reload(){ | ||
246 | return load(); | ||
247 | } | ||
248 | |||
249 | bool OTodoAccessBackendSQL::save(){ | ||
250 | return m_driver->close(); | ||
251 | } | ||
252 | QArray<int> OTodoAccessBackendSQL::allRecords()const { | ||
253 | return m_uids; | ||
254 | } | ||
255 | QArray<int> OTodoAccessBackendSQL::queryByExample( const OTodo& , int ){ | ||
256 | QArray<int> ints(0); | ||
257 | return ints; | ||
258 | } | ||
259 | OTodo OTodoAccessBackendSQL::find(int uid ) const{ | ||
260 | FindQuery query( uid ); | ||
261 | return todo( m_driver->query(&query) ); | ||
262 | |||
263 | } | ||
264 | void OTodoAccessBackendSQL::clear() { | ||
265 | ClearQuery cle; | ||
266 | OSQLResult res = m_driver->query( &cle ); | ||
267 | CreateQuery qu; | ||
268 | res = m_driver->query(&qu); | ||
269 | } | ||
270 | bool OTodoAccessBackendSQL::add( const OTodo& t) { | ||
271 | InsertQuery ins( t ); | ||
272 | OSQLResult res = m_driver->query( &ins ); | ||
273 | |||
274 | if ( res.state() == OSQLResult::Failure ) | ||
275 | return false; | ||
276 | int c = m_uids.count(); | ||
277 | m_uids.resize( c+1 ); | ||
278 | m_uids[c] = t.uid(); | ||
279 | |||
280 | return true; | ||
281 | } | ||
282 | bool OTodoAccessBackendSQL::remove( int uid ) { | ||
283 | RemoveQuery rem( uid ); | ||
284 | OSQLResult res = m_driver->query(&rem ); | ||
285 | |||
286 | if ( res.state() == OSQLResult::Failure ) | ||
287 | return false; | ||
288 | |||
289 | update(); | ||
290 | return true; | ||
291 | } | ||
292 | /* | ||
293 | * FIXME better set query | ||
294 | * but we need the cache for that | ||
295 | * now we remove | ||
296 | */ | ||
297 | bool OTodoAccessBackendSQL::replace( const OTodo& t) { | ||
298 | remove( t.uid() ); | ||
299 | return add(t); | ||
300 | } | ||
301 | QArray<int> OTodoAccessBackendSQL::overDue() { | ||
302 | OverDueQuery qu; | ||
303 | return uids( m_driver->query(&qu ) ); | ||
304 | } | ||
305 | QArray<int> OTodoAccessBackendSQL::effectiveToDos( const QDate& s, | ||
306 | const QDate& t, | ||
307 | bool u) { | ||
308 | EffQuery ef(s, t, u ); | ||
309 | return uids (m_driver->query(&ef) ); | ||
310 | } | ||
311 | QArray<int> OTodoAccessBackendSQL::sorted( bool asc, int sortOrder, | ||
312 | int sortFilter, int cat ) { | ||
313 | QArray<int> ints(0); | ||
314 | return ints; | ||
315 | } | ||
316 | bool OTodoAccessBackendSQL::date( QDate& da, const QString& str ) const{ | ||
317 | if ( str == "0-0-0" ) | ||
318 | return false; | ||
319 | else{ | ||
320 | int day, year, month; | ||
321 | QStringList list = QStringList::split("-", str ); | ||
322 | year = list[0].toInt(); | ||
323 | month = list[1].toInt(); | ||
324 | day = list[2].toInt(); | ||
325 | da.setYMD( year, month, day ); | ||
326 | return true; | ||
327 | } | ||
328 | } | ||
329 | OTodo OTodoAccessBackendSQL::todo( const OSQLResult& res) const{ | ||
330 | if ( res.state() == OSQLResult::Failure ) { | ||
331 | OTodo to; | ||
332 | return to; | ||
333 | } | ||
334 | |||
335 | OSQLResultItem::ValueList list = res.results(); | ||
336 | OSQLResultItem::ValueList::Iterator it = list.begin(); | ||
337 | |||
338 | bool has = false; QDate da = QDate::currentDate(); | ||
339 | has = date( da, (*it).data("DueDate") ); | ||
340 | QStringList cats = QStringList::split(";", (*it).data("categories") ); | ||
341 | |||
342 | OTodo to( (bool)(*it).data("completed").toInt(), (*it).data("priority").toInt(), | ||
343 | cats, (*it).data("summary"), (*it).data("description"), | ||
344 | (*it).data("progress").toUShort(), has, da, (*it).data("uid").toInt() ); | ||
345 | return to; | ||
346 | } | ||
347 | OTodo OTodoAccessBackendSQL::todo( int uid )const { | ||
348 | FindQuery find( uid ); | ||
349 | return todo( m_driver->query(&find) ); | ||
350 | } | ||
351 | /* | ||
352 | * update the dict | ||
353 | */ | ||
354 | void OTodoAccessBackendSQL::fillDict() { | ||
355 | /* initialize dict */ | ||
356 | /* | ||
357 | * UPDATE dict if you change anything!!! | ||
358 | */ | ||
359 | m_dict.setAutoDelete( TRUE ); | ||
360 | m_dict.insert("Categories" , new int(OTodo::Category) ); | ||
361 | m_dict.insert("Uid" , new int(OTodo::Uid) ); | ||
362 | m_dict.insert("HasDate" , new int(OTodo::HasDate) ); | ||
363 | m_dict.insert("Completed" , new int(OTodo::Completed) ); | ||
364 | m_dict.insert("Description" , new int(OTodo::Description) ); | ||
365 | m_dict.insert("Summary" , new int(OTodo::Summary) ); | ||
366 | m_dict.insert("Priority" , new int(OTodo::Priority) ); | ||
367 | m_dict.insert("DateDay" , new int(OTodo::DateDay) ); | ||
368 | m_dict.insert("DateMonth" , new int(OTodo::DateMonth) ); | ||
369 | m_dict.insert("DateYear" , new int(OTodo::DateYear) ); | ||
370 | m_dict.insert("Progress" , new int(OTodo::Progress) ); | ||
371 | m_dict.insert("Completed", new int(OTodo::Completed) ); | ||
372 | m_dict.insert("CrossReference", new int(OTodo::CrossReference) ); | ||
373 | m_dict.insert("HasAlarmDateTime",new int(OTodo::HasAlarmDateTime) ); | ||
374 | m_dict.insert("AlarmDateTime", new int(OTodo::AlarmDateTime) ); | ||
375 | } | ||
376 | void OTodoAccessBackendSQL::update() { | ||
377 | LoadQuery lo; | ||
378 | OSQLResult res = m_driver->query(&lo); | ||
379 | if ( res.state() != OSQLResult::Success ) | ||
380 | return; | ||
381 | |||
382 | m_uids = uids( res ); | ||
383 | } | ||
384 | QArray<int> OTodoAccessBackendSQL::uids( const OSQLResult& res) const{ | ||
385 | |||
386 | OSQLResultItem::ValueList list = res.results(); | ||
387 | OSQLResultItem::ValueList::Iterator it; | ||
388 | QArray<int> ints(list.count() ); | ||
389 | |||
390 | int i = 0; | ||
391 | for (it = list.begin(); it != list.end(); ++it ) { | ||
392 | ints[i] = (*it).data("uid").toInt(); | ||
393 | i++; | ||
394 | } | ||
395 | return ints; | ||
396 | } | ||
397 | |||
diff --git a/libopie/pim/otodoaccesssql.h b/libopie/pim/otodoaccesssql.h new file mode 100644 index 0000000..966628d --- a/dev/null +++ b/libopie/pim/otodoaccesssql.h | |||
@@ -0,0 +1,46 @@ | |||
1 | #ifndef OPIE_PIM_ACCESS_SQL_H | ||
2 | #define OPIE_PIM_ACCESS_SQL_H | ||
3 | |||
4 | #include <qasciidict.h> | ||
5 | |||
6 | #include "otodoaccessbackend.h" | ||
7 | |||
8 | class OSQLDriver; | ||
9 | class OSQLResult; | ||
10 | class OTodoAccessBackendSQL : public OTodoAccessBackend { | ||
11 | public: | ||
12 | OTodoAccessBackendSQL( const QString& file ); | ||
13 | ~OTodoAccessBackendSQL(); | ||
14 | |||
15 | bool load(); | ||
16 | bool reload(); | ||
17 | bool save(); | ||
18 | QArray<int> allRecords()const; | ||
19 | |||
20 | QArray<int> queryByExample( const OTodo& t, int sort ); | ||
21 | OTodo find(int uid)const; | ||
22 | void clear(); | ||
23 | bool add( const OTodo& t ); | ||
24 | bool remove( int uid ); | ||
25 | bool replace( const OTodo& t ); | ||
26 | |||
27 | QArray<int> overDue(); | ||
28 | QArray<int> effectiveToDos( const QDate& start, | ||
29 | const QDate& end, bool includeNoDates ); | ||
30 | QArray<int> sorted(bool asc, int sortOrder, int sortFilter, int cat ); | ||
31 | |||
32 | private: | ||
33 | void update(); | ||
34 | void fillDict(); | ||
35 | bool date( QDate& date, const QString& )const; | ||
36 | OTodo todo( const OSQLResult& )const; | ||
37 | QArray<int> uids( const OSQLResult& )const; | ||
38 | OTodo todo( int uid )const; | ||
39 | |||
40 | QAsciiDict<int> m_dict; | ||
41 | OSQLDriver* m_driver; | ||
42 | QArray<int> m_uids; | ||
43 | }; | ||
44 | |||
45 | |||
46 | #endif | ||
diff --git a/libopie/pim/otodoaccessxml.cpp b/libopie/pim/otodoaccessxml.cpp index 31822d4..80b8599 100644 --- a/libopie/pim/otodoaccessxml.cpp +++ b/libopie/pim/otodoaccessxml.cpp | |||
@@ -58,128 +58,129 @@ bool OTodoAccessXML::load() { | |||
58 | int len = ba.size(); | 58 | int len = ba.size(); |
59 | int i = 0; | 59 | int i = 0; |
60 | char *point; | 60 | char *point; |
61 | const char* collectionString = "<Task "; | 61 | const char* collectionString = "<Task "; |
62 | while ( dt+i != 0 && ( point = strstr( dt+i, collectionString ) ) != 0l ) { | 62 | while ( dt+i != 0 && ( point = strstr( dt+i, collectionString ) ) != 0l ) { |
63 | i = point -dt; | 63 | i = point -dt; |
64 | i+= strlen(collectionString); | 64 | i+= strlen(collectionString); |
65 | OTodo ev; | 65 | OTodo ev; |
66 | m_year = m_month = m_day = 0; | 66 | m_year = m_month = m_day = 0; |
67 | 67 | ||
68 | while ( TRUE ) { | 68 | while ( TRUE ) { |
69 | while ( i < len && (dt[i] == ' ' || dt[i] == '\n' || dt[i] == '\r') ) | 69 | while ( i < len && (dt[i] == ' ' || dt[i] == '\n' || dt[i] == '\r') ) |
70 | ++i; | 70 | ++i; |
71 | if ( i >= len-2 || (dt[i] == '/' && dt[i+1] == '>') ) | 71 | if ( i >= len-2 || (dt[i] == '/' && dt[i+1] == '>') ) |
72 | break; | 72 | break; |
73 | 73 | ||
74 | // we have another attribute, read it. | 74 | // we have another attribute, read it. |
75 | int j = i; | 75 | int j = i; |
76 | while ( j < len && dt[j] != '=' ) | 76 | while ( j < len && dt[j] != '=' ) |
77 | ++j; | 77 | ++j; |
78 | QCString attr( dt+i, j-i+1); | 78 | QCString attr( dt+i, j-i+1); |
79 | 79 | ||
80 | i = ++j; // skip = | 80 | i = ++j; // skip = |
81 | 81 | ||
82 | // find the start of quotes | 82 | // find the start of quotes |
83 | while ( i < len && dt[i] != '"' ) | 83 | while ( i < len && dt[i] != '"' ) |
84 | ++i; | 84 | ++i; |
85 | j = ++i; | 85 | j = ++i; |
86 | 86 | ||
87 | bool haveUtf = FALSE; | 87 | bool haveUtf = FALSE; |
88 | bool haveEnt = FALSE; | 88 | bool haveEnt = FALSE; |
89 | while ( j < len && dt[j] != '"' ) { | 89 | while ( j < len && dt[j] != '"' ) { |
90 | if ( ((unsigned char)dt[j]) > 0x7f ) | 90 | if ( ((unsigned char)dt[j]) > 0x7f ) |
91 | haveUtf = TRUE; | 91 | haveUtf = TRUE; |
92 | if ( dt[j] == '&' ) | 92 | if ( dt[j] == '&' ) |
93 | haveEnt = TRUE; | 93 | haveEnt = TRUE; |
94 | ++j; | 94 | ++j; |
95 | } | 95 | } |
96 | if ( i == j ) { | 96 | if ( i == j ) { |
97 | // empty value | 97 | // empty value |
98 | i = j + 1; | 98 | i = j + 1; |
99 | continue; | 99 | continue; |
100 | } | 100 | } |
101 | 101 | ||
102 | QCString value( dt+i, j-i+1 ); | 102 | QCString value( dt+i, j-i+1 ); |
103 | i = j + 1; | 103 | i = j + 1; |
104 | 104 | ||
105 | QString str = (haveUtf ? QString::fromUtf8( value ) | 105 | QString str = (haveUtf ? QString::fromUtf8( value ) |
106 | : QString::fromLatin1( value ) ); | 106 | : QString::fromLatin1( value ) ); |
107 | if ( haveEnt ) | 107 | if ( haveEnt ) |
108 | str = Qtopia::plainString( str ); | 108 | str = Qtopia::plainString( str ); |
109 | 109 | ||
110 | /* | 110 | /* |
111 | * add key + value | 111 | * add key + value |
112 | */ | 112 | */ |
113 | todo( &dict, ev, attr, str ); | 113 | todo( &dict, ev, attr, str ); |
114 | 114 | ||
115 | } | 115 | } |
116 | /* | 116 | /* |
117 | * now add it | 117 | * now add it |
118 | */ | 118 | */ |
119 | m_events.insert(ev.uid(), ev ); | 119 | m_events.insert(ev.uid(), ev ); |
120 | } | 120 | } |
121 | 121 | ||
122 | qWarning("counts %d", m_events.count() ); | ||
122 | return true; | 123 | return true; |
123 | } | 124 | } |
124 | bool OTodoAccessXML::reload() { | 125 | bool OTodoAccessXML::reload() { |
125 | return load(); | 126 | return load(); |
126 | } | 127 | } |
127 | bool OTodoAccessXML::save() { | 128 | bool OTodoAccessXML::save() { |
128 | // qWarning("saving"); | 129 | // qWarning("saving"); |
129 | if (!m_opened || !m_changed ) { | 130 | if (!m_opened || !m_changed ) { |
130 | // qWarning("not saving"); | 131 | // qWarning("not saving"); |
131 | return true; | 132 | return true; |
132 | } | 133 | } |
133 | QString strNewFile = m_file + ".new"; | 134 | QString strNewFile = m_file + ".new"; |
134 | QFile f( strNewFile ); | 135 | QFile f( strNewFile ); |
135 | if (!f.open( IO_WriteOnly|IO_Raw ) ) | 136 | if (!f.open( IO_WriteOnly|IO_Raw ) ) |
136 | return false; | 137 | return false; |
137 | 138 | ||
138 | int written; | 139 | int written; |
139 | QString out; | 140 | QString out; |
140 | out = "<!DOCTYPE Tasks>\n<Tasks>\n"; | 141 | out = "<!DOCTYPE Tasks>\n<Tasks>\n"; |
141 | 142 | ||
142 | // for all todos | 143 | // for all todos |
143 | QMap<int, OTodo>::Iterator it; | 144 | QMap<int, OTodo>::Iterator it; |
144 | for (it = m_events.begin(); it != m_events.end(); ++it ) { | 145 | for (it = m_events.begin(); it != m_events.end(); ++it ) { |
145 | out+= "<Task " + toString( (*it) ) + " />\n"; | 146 | out+= "<Task " + toString( (*it) ) + " />\n"; |
146 | QCString cstr = out.utf8(); | 147 | QCString cstr = out.utf8(); |
147 | written = f.writeBlock( cstr.data(), cstr.length() ); | 148 | written = f.writeBlock( cstr.data(), cstr.length() ); |
148 | 149 | ||
149 | /* less written then we wanted */ | 150 | /* less written then we wanted */ |
150 | if ( written != (int)cstr.length() ) { | 151 | if ( written != (int)cstr.length() ) { |
151 | f.close(); | 152 | f.close(); |
152 | QFile::remove( strNewFile ); | 153 | QFile::remove( strNewFile ); |
153 | return false; | 154 | return false; |
154 | } | 155 | } |
155 | out = QString::null; | 156 | out = QString::null; |
156 | } | 157 | } |
157 | 158 | ||
158 | out += "</Tasks>"; | 159 | out += "</Tasks>"; |
159 | QCString cstr = out.utf8(); | 160 | QCString cstr = out.utf8(); |
160 | written = f.writeBlock( cstr.data(), cstr.length() ); | 161 | written = f.writeBlock( cstr.data(), cstr.length() ); |
161 | 162 | ||
162 | if ( written != (int)cstr.length() ) { | 163 | if ( written != (int)cstr.length() ) { |
163 | f.close(); | 164 | f.close(); |
164 | QFile::remove( strNewFile ); | 165 | QFile::remove( strNewFile ); |
165 | return false; | 166 | return false; |
166 | } | 167 | } |
167 | /* flush before renaming */ | 168 | /* flush before renaming */ |
168 | f.close(); | 169 | f.close(); |
169 | 170 | ||
170 | if( ::rename( strNewFile.latin1(), m_file.latin1() ) < 0 ) { | 171 | if( ::rename( strNewFile.latin1(), m_file.latin1() ) < 0 ) { |
171 | // qWarning("error renaming"); | 172 | // qWarning("error renaming"); |
172 | QFile::remove( strNewFile ); | 173 | QFile::remove( strNewFile ); |
173 | } | 174 | } |
174 | 175 | ||
175 | m_changed = false; | 176 | m_changed = false; |
176 | return true; | 177 | return true; |
177 | } | 178 | } |
178 | QArray<int> OTodoAccessXML::allRecords()const { | 179 | QArray<int> OTodoAccessXML::allRecords()const { |
179 | QArray<int> ids( m_events.count() ); | 180 | QArray<int> ids( m_events.count() ); |
180 | QMap<int, OTodo>::ConstIterator it; | 181 | QMap<int, OTodo>::ConstIterator it; |
181 | int i = 0; | 182 | int i = 0; |
182 | 183 | ||
183 | for ( it = m_events.begin(); it != m_events.end(); ++it ) { | 184 | for ( it = m_events.begin(); it != m_events.end(); ++it ) { |
184 | ids[i] = it.key(); | 185 | ids[i] = it.key(); |
185 | i++; | 186 | i++; |
diff --git a/libopie2/opiepim/backend/otodoaccesssql.cpp b/libopie2/opiepim/backend/otodoaccesssql.cpp new file mode 100644 index 0000000..209e714 --- a/dev/null +++ b/libopie2/opiepim/backend/otodoaccesssql.cpp | |||
@@ -0,0 +1,397 @@ | |||
1 | |||
2 | #include <qdatetime.h> | ||
3 | |||
4 | #include <qpe/global.h> | ||
5 | |||
6 | #include <opie/osqldriver.h> | ||
7 | #include <opie/osqlresult.h> | ||
8 | #include <opie/osqlmanager.h> | ||
9 | #include <opie/osqlquery.h> | ||
10 | |||
11 | #include "otodoaccesssql.h" | ||
12 | |||
13 | /* | ||
14 | * first some query | ||
15 | * CREATE query | ||
16 | * LOAD query | ||
17 | * INSERT | ||
18 | * REMOVE | ||
19 | * CLEAR | ||
20 | */ | ||
21 | namespace { | ||
22 | /** | ||
23 | * CreateQuery for the Todolist Table | ||
24 | */ | ||
25 | class CreateQuery : public OSQLQuery { | ||
26 | public: | ||
27 | CreateQuery(); | ||
28 | ~CreateQuery(); | ||
29 | QString query()const; | ||
30 | }; | ||
31 | |||
32 | /** | ||
33 | * LoadQuery | ||
34 | * this one queries for all uids | ||
35 | */ | ||
36 | class LoadQuery : public OSQLQuery { | ||
37 | public: | ||
38 | LoadQuery(); | ||
39 | ~LoadQuery(); | ||
40 | QString query()const; | ||
41 | }; | ||
42 | |||
43 | /** | ||
44 | * inserts/adds a OTodo to the table | ||
45 | */ | ||
46 | class InsertQuery : public OSQLQuery { | ||
47 | public: | ||
48 | InsertQuery(const OTodo& ); | ||
49 | ~InsertQuery(); | ||
50 | QString query()const; | ||
51 | private: | ||
52 | OTodo m_todo; | ||
53 | }; | ||
54 | |||
55 | /** | ||
56 | * removes one from the table | ||
57 | */ | ||
58 | class RemoveQuery : public OSQLQuery { | ||
59 | public: | ||
60 | RemoveQuery(int uid ); | ||
61 | ~RemoveQuery(); | ||
62 | QString query()const; | ||
63 | private: | ||
64 | int m_uid; | ||
65 | }; | ||
66 | |||
67 | /** | ||
68 | * Clears (delete) a Table | ||
69 | */ | ||
70 | class ClearQuery : public OSQLQuery { | ||
71 | public: | ||
72 | ClearQuery(); | ||
73 | ~ClearQuery(); | ||
74 | QString query()const; | ||
75 | |||
76 | }; | ||
77 | |||
78 | /** | ||
79 | * a find query | ||
80 | */ | ||
81 | class FindQuery : public OSQLQuery { | ||
82 | public: | ||
83 | FindQuery(int uid); | ||
84 | ~FindQuery(); | ||
85 | QString query()const; | ||
86 | private: | ||
87 | int m_uid; | ||
88 | }; | ||
89 | |||
90 | /** | ||
91 | * overdue query | ||
92 | */ | ||
93 | class OverDueQuery : public OSQLQuery { | ||
94 | public: | ||
95 | OverDueQuery(); | ||
96 | ~OverDueQuery(); | ||
97 | QString query()const; | ||
98 | }; | ||
99 | class EffQuery : public OSQLQuery { | ||
100 | public: | ||
101 | EffQuery( const QDate&, const QDate&, bool inc ); | ||
102 | ~EffQuery(); | ||
103 | QString query()const; | ||
104 | private: | ||
105 | QString with()const; | ||
106 | QString out()const; | ||
107 | QDate m_start; | ||
108 | QDate m_end; | ||
109 | bool m_inc :1; | ||
110 | }; | ||
111 | |||
112 | |||
113 | CreateQuery::CreateQuery() : OSQLQuery() {} | ||
114 | CreateQuery::~CreateQuery() {} | ||
115 | QString CreateQuery::query()const { | ||
116 | QString qu; | ||
117 | qu += "create table todolist( uid, categories, completed, progress, "; | ||
118 | qu += "summary, DueDate, priority, description )"; | ||
119 | return qu; | ||
120 | } | ||
121 | |||
122 | LoadQuery::LoadQuery() : OSQLQuery() {} | ||
123 | LoadQuery::~LoadQuery() {} | ||
124 | QString LoadQuery::query()const { | ||
125 | QString qu; | ||
126 | qu += "select distinct uid from todolist"; | ||
127 | |||
128 | return qu; | ||
129 | } | ||
130 | |||
131 | InsertQuery::InsertQuery( const OTodo& todo ) | ||
132 | : OSQLQuery(), m_todo( todo ) { | ||
133 | } | ||
134 | InsertQuery::~InsertQuery() { | ||
135 | } | ||
136 | /* | ||
137 | * converts from a OTodo to a query | ||
138 | * we leave out X-Ref + Alarms | ||
139 | */ | ||
140 | QString InsertQuery::query()const{ | ||
141 | int year, month, day; | ||
142 | year = month = day = 0; | ||
143 | if (m_todo.hasDueDate() ) { | ||
144 | QDate date = m_todo.dueDate(); | ||
145 | year = date.year(); | ||
146 | month = date.month(); | ||
147 | day = date.day(); | ||
148 | } | ||
149 | QString qu; | ||
150 | qu = "insert into todolist VALUES(" + QString::number( m_todo.uid() ) + ",'" + m_todo.idsToString( m_todo.categories() ) + "',"; | ||
151 | qu += QString::number( m_todo.isCompleted() ) + "," + QString::number( m_todo.progress() ) + ","; | ||
152 | qu += "'"+m_todo.summary()+"','"+QString::number(year)+"-"+QString::number(month)+"-"+QString::number(day)+"',"; | ||
153 | qu += QString::number(m_todo.priority() ) +",'" + m_todo.description() + "')"; | ||
154 | |||
155 | qWarning("add %s", qu.latin1() ); | ||
156 | return qu; | ||
157 | } | ||
158 | |||
159 | RemoveQuery::RemoveQuery(int uid ) | ||
160 | : OSQLQuery(), m_uid( uid ) {} | ||
161 | RemoveQuery::~RemoveQuery() {} | ||
162 | QString RemoveQuery::query()const { | ||
163 | QString qu = "DELETE from todolist where uid = " + QString::number(m_uid); | ||
164 | return qu; | ||
165 | } | ||
166 | |||
167 | |||
168 | ClearQuery::ClearQuery() | ||
169 | : OSQLQuery() {} | ||
170 | ClearQuery::~ClearQuery() {} | ||
171 | QString ClearQuery::query()const { | ||
172 | QString qu = "drop table todolist"; | ||
173 | return qu; | ||
174 | } | ||
175 | FindQuery::FindQuery(int uid) | ||
176 | : OSQLQuery(), m_uid(uid ) { | ||
177 | } | ||
178 | FindQuery::~FindQuery() { | ||
179 | } | ||
180 | QString FindQuery::query()const{ | ||
181 | QString qu = "select uid, categories, completed, progress, summary, "; | ||
182 | qu += "DueDate, priority, description from todolist where uid = " + QString::number(m_uid); | ||
183 | return qu; | ||
184 | } | ||
185 | |||
186 | OverDueQuery::OverDueQuery(): OSQLQuery() {} | ||
187 | OverDueQuery::~OverDueQuery() {} | ||
188 | QString OverDueQuery::query()const { | ||
189 | QDate date = QDate::currentDate(); | ||
190 | QString str; | ||
191 | str = QString("select uid from todolist where DueDate ='%1-%2-%3'").arg(date.year() ).arg(date.month() ).arg(date.day() ); | ||
192 | |||
193 | return str; | ||
194 | } | ||
195 | |||
196 | |||
197 | EffQuery::EffQuery( const QDate& start, const QDate& end, bool inc ) | ||
198 | : OSQLQuery(), m_start( start ), m_end( end ),m_inc(inc) {} | ||
199 | EffQuery::~EffQuery() {} | ||
200 | QString EffQuery::query()const { | ||
201 | return m_inc ? with() : out(); | ||
202 | } | ||
203 | QString EffQuery::with()const { | ||
204 | QString str; | ||
205 | str = QString("select uid from todolist where ( DueDate >= '%1-%2-%3' AND DueDate <= '%4-%5-%6' ) OR DueDate = '0-0-0' ") | ||
206 | .arg( m_start.year() ).arg( m_start.month() ).arg( m_start.day() ) | ||
207 | .arg( m_end .year() ).arg( m_end .month() ).arg( m_end .day() ); | ||
208 | return str; | ||
209 | } | ||
210 | QString EffQuery::out()const { | ||
211 | QString str; | ||
212 | str = QString("select uid from todolist where DueDate >= '%1-%2-%3' AND DueDate <= '%4-%5-%6'") | ||
213 | .arg(m_start.year() ).arg(m_start.month() ).arg( m_start.day() ) | ||
214 | .arg(m_end. year() ).arg(m_end. month() ).arg(m_end.day() ); | ||
215 | |||
216 | return str; | ||
217 | } | ||
218 | }; | ||
219 | |||
220 | OTodoAccessBackendSQL::OTodoAccessBackendSQL( const QString& file ) | ||
221 | : OTodoAccessBackend(), m_dict(15) | ||
222 | { | ||
223 | QString fi = file; | ||
224 | if ( fi.isEmpty() ) | ||
225 | fi = Global::applicationFileName( "todolist", "todolist.db" ); | ||
226 | OSQLManager man; | ||
227 | m_driver = man.standard(); | ||
228 | m_driver->setUrl(fi); | ||
229 | fillDict(); | ||
230 | } | ||
231 | |||
232 | OTodoAccessBackendSQL::~OTodoAccessBackendSQL(){ | ||
233 | } | ||
234 | bool OTodoAccessBackendSQL::load(){ | ||
235 | if (!m_driver->open() ) | ||
236 | return false; | ||
237 | |||
238 | CreateQuery creat; | ||
239 | OSQLResult res = m_driver->query(&creat ); | ||
240 | |||
241 | update(); | ||
242 | qWarning("loaded %d", m_uids.count() ); | ||
243 | return true; | ||
244 | } | ||
245 | bool OTodoAccessBackendSQL::reload(){ | ||
246 | return load(); | ||
247 | } | ||
248 | |||
249 | bool OTodoAccessBackendSQL::save(){ | ||
250 | return m_driver->close(); | ||
251 | } | ||
252 | QArray<int> OTodoAccessBackendSQL::allRecords()const { | ||
253 | return m_uids; | ||
254 | } | ||
255 | QArray<int> OTodoAccessBackendSQL::queryByExample( const OTodo& , int ){ | ||
256 | QArray<int> ints(0); | ||
257 | return ints; | ||
258 | } | ||
259 | OTodo OTodoAccessBackendSQL::find(int uid ) const{ | ||
260 | FindQuery query( uid ); | ||
261 | return todo( m_driver->query(&query) ); | ||
262 | |||
263 | } | ||
264 | void OTodoAccessBackendSQL::clear() { | ||
265 | ClearQuery cle; | ||
266 | OSQLResult res = m_driver->query( &cle ); | ||
267 | CreateQuery qu; | ||
268 | res = m_driver->query(&qu); | ||
269 | } | ||
270 | bool OTodoAccessBackendSQL::add( const OTodo& t) { | ||
271 | InsertQuery ins( t ); | ||
272 | OSQLResult res = m_driver->query( &ins ); | ||
273 | |||
274 | if ( res.state() == OSQLResult::Failure ) | ||
275 | return false; | ||
276 | int c = m_uids.count(); | ||
277 | m_uids.resize( c+1 ); | ||
278 | m_uids[c] = t.uid(); | ||
279 | |||
280 | return true; | ||
281 | } | ||
282 | bool OTodoAccessBackendSQL::remove( int uid ) { | ||
283 | RemoveQuery rem( uid ); | ||
284 | OSQLResult res = m_driver->query(&rem ); | ||
285 | |||
286 | if ( res.state() == OSQLResult::Failure ) | ||
287 | return false; | ||
288 | |||
289 | update(); | ||
290 | return true; | ||
291 | } | ||
292 | /* | ||
293 | * FIXME better set query | ||
294 | * but we need the cache for that | ||
295 | * now we remove | ||
296 | */ | ||
297 | bool OTodoAccessBackendSQL::replace( const OTodo& t) { | ||
298 | remove( t.uid() ); | ||
299 | return add(t); | ||
300 | } | ||
301 | QArray<int> OTodoAccessBackendSQL::overDue() { | ||
302 | OverDueQuery qu; | ||
303 | return uids( m_driver->query(&qu ) ); | ||
304 | } | ||
305 | QArray<int> OTodoAccessBackendSQL::effectiveToDos( const QDate& s, | ||
306 | const QDate& t, | ||
307 | bool u) { | ||
308 | EffQuery ef(s, t, u ); | ||
309 | return uids (m_driver->query(&ef) ); | ||
310 | } | ||
311 | QArray<int> OTodoAccessBackendSQL::sorted( bool asc, int sortOrder, | ||
312 | int sortFilter, int cat ) { | ||
313 | QArray<int> ints(0); | ||
314 | return ints; | ||
315 | } | ||
316 | bool OTodoAccessBackendSQL::date( QDate& da, const QString& str ) const{ | ||
317 | if ( str == "0-0-0" ) | ||
318 | return false; | ||
319 | else{ | ||
320 | int day, year, month; | ||
321 | QStringList list = QStringList::split("-", str ); | ||
322 | year = list[0].toInt(); | ||
323 | month = list[1].toInt(); | ||
324 | day = list[2].toInt(); | ||
325 | da.setYMD( year, month, day ); | ||
326 | return true; | ||
327 | } | ||
328 | } | ||
329 | OTodo OTodoAccessBackendSQL::todo( const OSQLResult& res) const{ | ||
330 | if ( res.state() == OSQLResult::Failure ) { | ||
331 | OTodo to; | ||
332 | return to; | ||
333 | } | ||
334 | |||
335 | OSQLResultItem::ValueList list = res.results(); | ||
336 | OSQLResultItem::ValueList::Iterator it = list.begin(); | ||
337 | |||
338 | bool has = false; QDate da = QDate::currentDate(); | ||
339 | has = date( da, (*it).data("DueDate") ); | ||
340 | QStringList cats = QStringList::split(";", (*it).data("categories") ); | ||
341 | |||
342 | OTodo to( (bool)(*it).data("completed").toInt(), (*it).data("priority").toInt(), | ||
343 | cats, (*it).data("summary"), (*it).data("description"), | ||
344 | (*it).data("progress").toUShort(), has, da, (*it).data("uid").toInt() ); | ||
345 | return to; | ||
346 | } | ||
347 | OTodo OTodoAccessBackendSQL::todo( int uid )const { | ||
348 | FindQuery find( uid ); | ||
349 | return todo( m_driver->query(&find) ); | ||
350 | } | ||
351 | /* | ||
352 | * update the dict | ||
353 | */ | ||
354 | void OTodoAccessBackendSQL::fillDict() { | ||
355 | /* initialize dict */ | ||
356 | /* | ||
357 | * UPDATE dict if you change anything!!! | ||
358 | */ | ||
359 | m_dict.setAutoDelete( TRUE ); | ||
360 | m_dict.insert("Categories" , new int(OTodo::Category) ); | ||
361 | m_dict.insert("Uid" , new int(OTodo::Uid) ); | ||
362 | m_dict.insert("HasDate" , new int(OTodo::HasDate) ); | ||
363 | m_dict.insert("Completed" , new int(OTodo::Completed) ); | ||
364 | m_dict.insert("Description" , new int(OTodo::Description) ); | ||
365 | m_dict.insert("Summary" , new int(OTodo::Summary) ); | ||
366 | m_dict.insert("Priority" , new int(OTodo::Priority) ); | ||
367 | m_dict.insert("DateDay" , new int(OTodo::DateDay) ); | ||
368 | m_dict.insert("DateMonth" , new int(OTodo::DateMonth) ); | ||
369 | m_dict.insert("DateYear" , new int(OTodo::DateYear) ); | ||
370 | m_dict.insert("Progress" , new int(OTodo::Progress) ); | ||
371 | m_dict.insert("Completed", new int(OTodo::Completed) ); | ||
372 | m_dict.insert("CrossReference", new int(OTodo::CrossReference) ); | ||
373 | m_dict.insert("HasAlarmDateTime",new int(OTodo::HasAlarmDateTime) ); | ||
374 | m_dict.insert("AlarmDateTime", new int(OTodo::AlarmDateTime) ); | ||
375 | } | ||
376 | void OTodoAccessBackendSQL::update() { | ||
377 | LoadQuery lo; | ||
378 | OSQLResult res = m_driver->query(&lo); | ||
379 | if ( res.state() != OSQLResult::Success ) | ||
380 | return; | ||
381 | |||
382 | m_uids = uids( res ); | ||
383 | } | ||
384 | QArray<int> OTodoAccessBackendSQL::uids( const OSQLResult& res) const{ | ||
385 | |||
386 | OSQLResultItem::ValueList list = res.results(); | ||
387 | OSQLResultItem::ValueList::Iterator it; | ||
388 | QArray<int> ints(list.count() ); | ||
389 | |||
390 | int i = 0; | ||
391 | for (it = list.begin(); it != list.end(); ++it ) { | ||
392 | ints[i] = (*it).data("uid").toInt(); | ||
393 | i++; | ||
394 | } | ||
395 | return ints; | ||
396 | } | ||
397 | |||
diff --git a/libopie2/opiepim/backend/otodoaccesssql.h b/libopie2/opiepim/backend/otodoaccesssql.h new file mode 100644 index 0000000..966628d --- a/dev/null +++ b/libopie2/opiepim/backend/otodoaccesssql.h | |||
@@ -0,0 +1,46 @@ | |||
1 | #ifndef OPIE_PIM_ACCESS_SQL_H | ||
2 | #define OPIE_PIM_ACCESS_SQL_H | ||
3 | |||
4 | #include <qasciidict.h> | ||
5 | |||
6 | #include "otodoaccessbackend.h" | ||
7 | |||
8 | class OSQLDriver; | ||
9 | class OSQLResult; | ||
10 | class OTodoAccessBackendSQL : public OTodoAccessBackend { | ||
11 | public: | ||
12 | OTodoAccessBackendSQL( const QString& file ); | ||
13 | ~OTodoAccessBackendSQL(); | ||
14 | |||
15 | bool load(); | ||
16 | bool reload(); | ||
17 | bool save(); | ||
18 | QArray<int> allRecords()const; | ||
19 | |||
20 | QArray<int> queryByExample( const OTodo& t, int sort ); | ||
21 | OTodo find(int uid)const; | ||
22 | void clear(); | ||
23 | bool add( const OTodo& t ); | ||
24 | bool remove( int uid ); | ||
25 | bool replace( const OTodo& t ); | ||
26 | |||
27 | QArray<int> overDue(); | ||
28 | QArray<int> effectiveToDos( const QDate& start, | ||
29 | const QDate& end, bool includeNoDates ); | ||
30 | QArray<int> sorted(bool asc, int sortOrder, int sortFilter, int cat ); | ||
31 | |||
32 | private: | ||
33 | void update(); | ||
34 | void fillDict(); | ||
35 | bool date( QDate& date, const QString& )const; | ||
36 | OTodo todo( const OSQLResult& )const; | ||
37 | QArray<int> uids( const OSQLResult& )const; | ||
38 | OTodo todo( int uid )const; | ||
39 | |||
40 | QAsciiDict<int> m_dict; | ||
41 | OSQLDriver* m_driver; | ||
42 | QArray<int> m_uids; | ||
43 | }; | ||
44 | |||
45 | |||
46 | #endif | ||
diff --git a/libopie2/opiepim/backend/otodoaccessxml.cpp b/libopie2/opiepim/backend/otodoaccessxml.cpp index 31822d4..80b8599 100644 --- a/libopie2/opiepim/backend/otodoaccessxml.cpp +++ b/libopie2/opiepim/backend/otodoaccessxml.cpp | |||
@@ -58,128 +58,129 @@ bool OTodoAccessXML::load() { | |||
58 | int len = ba.size(); | 58 | int len = ba.size(); |
59 | int i = 0; | 59 | int i = 0; |
60 | char *point; | 60 | char *point; |
61 | const char* collectionString = "<Task "; | 61 | const char* collectionString = "<Task "; |
62 | while ( dt+i != 0 && ( point = strstr( dt+i, collectionString ) ) != 0l ) { | 62 | while ( dt+i != 0 && ( point = strstr( dt+i, collectionString ) ) != 0l ) { |
63 | i = point -dt; | 63 | i = point -dt; |
64 | i+= strlen(collectionString); | 64 | i+= strlen(collectionString); |
65 | OTodo ev; | 65 | OTodo ev; |
66 | m_year = m_month = m_day = 0; | 66 | m_year = m_month = m_day = 0; |
67 | 67 | ||
68 | while ( TRUE ) { | 68 | while ( TRUE ) { |
69 | while ( i < len && (dt[i] == ' ' || dt[i] == '\n' || dt[i] == '\r') ) | 69 | while ( i < len && (dt[i] == ' ' || dt[i] == '\n' || dt[i] == '\r') ) |
70 | ++i; | 70 | ++i; |
71 | if ( i >= len-2 || (dt[i] == '/' && dt[i+1] == '>') ) | 71 | if ( i >= len-2 || (dt[i] == '/' && dt[i+1] == '>') ) |
72 | break; | 72 | break; |
73 | 73 | ||
74 | // we have another attribute, read it. | 74 | // we have another attribute, read it. |
75 | int j = i; | 75 | int j = i; |
76 | while ( j < len && dt[j] != '=' ) | 76 | while ( j < len && dt[j] != '=' ) |
77 | ++j; | 77 | ++j; |
78 | QCString attr( dt+i, j-i+1); | 78 | QCString attr( dt+i, j-i+1); |
79 | 79 | ||
80 | i = ++j; // skip = | 80 | i = ++j; // skip = |
81 | 81 | ||
82 | // find the start of quotes | 82 | // find the start of quotes |
83 | while ( i < len && dt[i] != '"' ) | 83 | while ( i < len && dt[i] != '"' ) |
84 | ++i; | 84 | ++i; |
85 | j = ++i; | 85 | j = ++i; |
86 | 86 | ||
87 | bool haveUtf = FALSE; | 87 | bool haveUtf = FALSE; |
88 | bool haveEnt = FALSE; | 88 | bool haveEnt = FALSE; |
89 | while ( j < len && dt[j] != '"' ) { | 89 | while ( j < len && dt[j] != '"' ) { |
90 | if ( ((unsigned char)dt[j]) > 0x7f ) | 90 | if ( ((unsigned char)dt[j]) > 0x7f ) |
91 | haveUtf = TRUE; | 91 | haveUtf = TRUE; |
92 | if ( dt[j] == '&' ) | 92 | if ( dt[j] == '&' ) |
93 | haveEnt = TRUE; | 93 | haveEnt = TRUE; |
94 | ++j; | 94 | ++j; |
95 | } | 95 | } |
96 | if ( i == j ) { | 96 | if ( i == j ) { |
97 | // empty value | 97 | // empty value |
98 | i = j + 1; | 98 | i = j + 1; |
99 | continue; | 99 | continue; |
100 | } | 100 | } |
101 | 101 | ||
102 | QCString value( dt+i, j-i+1 ); | 102 | QCString value( dt+i, j-i+1 ); |
103 | i = j + 1; | 103 | i = j + 1; |
104 | 104 | ||
105 | QString str = (haveUtf ? QString::fromUtf8( value ) | 105 | QString str = (haveUtf ? QString::fromUtf8( value ) |
106 | : QString::fromLatin1( value ) ); | 106 | : QString::fromLatin1( value ) ); |
107 | if ( haveEnt ) | 107 | if ( haveEnt ) |
108 | str = Qtopia::plainString( str ); | 108 | str = Qtopia::plainString( str ); |
109 | 109 | ||
110 | /* | 110 | /* |
111 | * add key + value | 111 | * add key + value |
112 | */ | 112 | */ |
113 | todo( &dict, ev, attr, str ); | 113 | todo( &dict, ev, attr, str ); |
114 | 114 | ||
115 | } | 115 | } |
116 | /* | 116 | /* |
117 | * now add it | 117 | * now add it |
118 | */ | 118 | */ |
119 | m_events.insert(ev.uid(), ev ); | 119 | m_events.insert(ev.uid(), ev ); |
120 | } | 120 | } |
121 | 121 | ||
122 | qWarning("counts %d", m_events.count() ); | ||
122 | return true; | 123 | return true; |
123 | } | 124 | } |
124 | bool OTodoAccessXML::reload() { | 125 | bool OTodoAccessXML::reload() { |
125 | return load(); | 126 | return load(); |
126 | } | 127 | } |
127 | bool OTodoAccessXML::save() { | 128 | bool OTodoAccessXML::save() { |
128 | // qWarning("saving"); | 129 | // qWarning("saving"); |
129 | if (!m_opened || !m_changed ) { | 130 | if (!m_opened || !m_changed ) { |
130 | // qWarning("not saving"); | 131 | // qWarning("not saving"); |
131 | return true; | 132 | return true; |
132 | } | 133 | } |
133 | QString strNewFile = m_file + ".new"; | 134 | QString strNewFile = m_file + ".new"; |
134 | QFile f( strNewFile ); | 135 | QFile f( strNewFile ); |
135 | if (!f.open( IO_WriteOnly|IO_Raw ) ) | 136 | if (!f.open( IO_WriteOnly|IO_Raw ) ) |
136 | return false; | 137 | return false; |
137 | 138 | ||
138 | int written; | 139 | int written; |
139 | QString out; | 140 | QString out; |
140 | out = "<!DOCTYPE Tasks>\n<Tasks>\n"; | 141 | out = "<!DOCTYPE Tasks>\n<Tasks>\n"; |
141 | 142 | ||
142 | // for all todos | 143 | // for all todos |
143 | QMap<int, OTodo>::Iterator it; | 144 | QMap<int, OTodo>::Iterator it; |
144 | for (it = m_events.begin(); it != m_events.end(); ++it ) { | 145 | for (it = m_events.begin(); it != m_events.end(); ++it ) { |
145 | out+= "<Task " + toString( (*it) ) + " />\n"; | 146 | out+= "<Task " + toString( (*it) ) + " />\n"; |
146 | QCString cstr = out.utf8(); | 147 | QCString cstr = out.utf8(); |
147 | written = f.writeBlock( cstr.data(), cstr.length() ); | 148 | written = f.writeBlock( cstr.data(), cstr.length() ); |
148 | 149 | ||
149 | /* less written then we wanted */ | 150 | /* less written then we wanted */ |
150 | if ( written != (int)cstr.length() ) { | 151 | if ( written != (int)cstr.length() ) { |
151 | f.close(); | 152 | f.close(); |
152 | QFile::remove( strNewFile ); | 153 | QFile::remove( strNewFile ); |
153 | return false; | 154 | return false; |
154 | } | 155 | } |
155 | out = QString::null; | 156 | out = QString::null; |
156 | } | 157 | } |
157 | 158 | ||
158 | out += "</Tasks>"; | 159 | out += "</Tasks>"; |
159 | QCString cstr = out.utf8(); | 160 | QCString cstr = out.utf8(); |
160 | written = f.writeBlock( cstr.data(), cstr.length() ); | 161 | written = f.writeBlock( cstr.data(), cstr.length() ); |
161 | 162 | ||
162 | if ( written != (int)cstr.length() ) { | 163 | if ( written != (int)cstr.length() ) { |
163 | f.close(); | 164 | f.close(); |
164 | QFile::remove( strNewFile ); | 165 | QFile::remove( strNewFile ); |
165 | return false; | 166 | return false; |
166 | } | 167 | } |
167 | /* flush before renaming */ | 168 | /* flush before renaming */ |
168 | f.close(); | 169 | f.close(); |
169 | 170 | ||
170 | if( ::rename( strNewFile.latin1(), m_file.latin1() ) < 0 ) { | 171 | if( ::rename( strNewFile.latin1(), m_file.latin1() ) < 0 ) { |
171 | // qWarning("error renaming"); | 172 | // qWarning("error renaming"); |
172 | QFile::remove( strNewFile ); | 173 | QFile::remove( strNewFile ); |
173 | } | 174 | } |
174 | 175 | ||
175 | m_changed = false; | 176 | m_changed = false; |
176 | return true; | 177 | return true; |
177 | } | 178 | } |
178 | QArray<int> OTodoAccessXML::allRecords()const { | 179 | QArray<int> OTodoAccessXML::allRecords()const { |
179 | QArray<int> ids( m_events.count() ); | 180 | QArray<int> ids( m_events.count() ); |
180 | QMap<int, OTodo>::ConstIterator it; | 181 | QMap<int, OTodo>::ConstIterator it; |
181 | int i = 0; | 182 | int i = 0; |
182 | 183 | ||
183 | for ( it = m_events.begin(); it != m_events.end(); ++it ) { | 184 | for ( it = m_events.begin(); it != m_events.end(); ++it ) { |
184 | ids[i] = it.key(); | 185 | ids[i] = it.key(); |
185 | i++; | 186 | i++; |
diff --git a/libopie2/opiepim/core/otodoaccess.cpp b/libopie2/opiepim/core/otodoaccess.cpp index f51da29..5990841 100644 --- a/libopie2/opiepim/core/otodoaccess.cpp +++ b/libopie2/opiepim/core/otodoaccess.cpp | |||
@@ -1,77 +1,77 @@ | |||
1 | #include <qdatetime.h> | 1 | #include <qdatetime.h> |
2 | 2 | ||
3 | #include <qpe/alarmserver.h> | 3 | #include <qpe/alarmserver.h> |
4 | 4 | ||
5 | #include "otodoaccessxml.h" | 5 | #include "otodoaccesssql.h" |
6 | #include "otodoaccess.h" | 6 | #include "otodoaccess.h" |
7 | 7 | ||
8 | 8 | ||
9 | OTodoAccess::OTodoAccess( OTodoAccessBackend* end ) | 9 | OTodoAccess::OTodoAccess( OTodoAccessBackend* end ) |
10 | : QObject(), OPimAccessTemplate<OTodo>( end ), m_todoBackEnd( end ) | 10 | : QObject(), OPimAccessTemplate<OTodo>( end ), m_todoBackEnd( end ) |
11 | { | 11 | { |
12 | if (end == 0l ) | 12 | if (end == 0l ) |
13 | m_todoBackEnd = new OTodoAccessXML( "Todolist" ); | 13 | m_todoBackEnd = new OTodoAccessBackendSQL( QString::null); |
14 | 14 | ||
15 | setBackEnd( m_todoBackEnd ); | 15 | setBackEnd( m_todoBackEnd ); |
16 | } | 16 | } |
17 | OTodoAccess::~OTodoAccess() { | 17 | OTodoAccess::~OTodoAccess() { |
18 | // qWarning("~OTodoAccess"); | 18 | // qWarning("~OTodoAccess"); |
19 | } | 19 | } |
20 | void OTodoAccess::mergeWith( const QValueList<OTodo>& list ) { | 20 | void OTodoAccess::mergeWith( const QValueList<OTodo>& list ) { |
21 | QValueList<OTodo>::ConstIterator it; | 21 | QValueList<OTodo>::ConstIterator it; |
22 | for ( it = list.begin(); it != list.end(); ++it ) { | 22 | for ( it = list.begin(); it != list.end(); ++it ) { |
23 | replace( (*it) ); | 23 | replace( (*it) ); |
24 | } | 24 | } |
25 | } | 25 | } |
26 | OTodoAccess::List OTodoAccess::effectiveToDos( const QDate& start, | 26 | OTodoAccess::List OTodoAccess::effectiveToDos( const QDate& start, |
27 | const QDate& end, | 27 | const QDate& end, |
28 | bool includeNoDates ) { | 28 | bool includeNoDates ) { |
29 | QArray<int> ints = m_todoBackEnd->effectiveToDos( start, end, includeNoDates ); | 29 | QArray<int> ints = m_todoBackEnd->effectiveToDos( start, end, includeNoDates ); |
30 | 30 | ||
31 | List lis( ints, this ); | 31 | List lis( ints, this ); |
32 | return lis; | 32 | return lis; |
33 | } | 33 | } |
34 | OTodoAccess::List OTodoAccess::effectiveToDos( const QDate& start, | 34 | OTodoAccess::List OTodoAccess::effectiveToDos( const QDate& start, |
35 | bool includeNoDates ) { | 35 | bool includeNoDates ) { |
36 | return effectiveToDos( start, QDate::currentDate(), | 36 | return effectiveToDos( start, QDate::currentDate(), |
37 | includeNoDates ); | 37 | includeNoDates ); |
38 | } | 38 | } |
39 | OTodoAccess::List OTodoAccess::overDue() { | 39 | OTodoAccess::List OTodoAccess::overDue() { |
40 | List lis( m_todoBackEnd->overDue(), this ); | 40 | List lis( m_todoBackEnd->overDue(), this ); |
41 | return lis; | 41 | return lis; |
42 | } | 42 | } |
43 | void OTodoAccess::addAlarm( const OTodo& event) { | 43 | void OTodoAccess::addAlarm( const OTodo& event) { |
44 | if (!event.hasAlarmDateTime() ) | 44 | if (!event.hasAlarmDateTime() ) |
45 | return; | 45 | return; |
46 | 46 | ||
47 | QDateTime now = QDateTime::currentDateTime(); | 47 | QDateTime now = QDateTime::currentDateTime(); |
48 | QDateTime schedule = event.alarmDateTime(); | 48 | QDateTime schedule = event.alarmDateTime(); |
49 | 49 | ||
50 | if ( schedule > now ){ | 50 | if ( schedule > now ){ |
51 | AlarmServer::addAlarm( schedule, | 51 | AlarmServer::addAlarm( schedule, |
52 | "QPE/Application/todolist", | 52 | "QPE/Application/todolist", |
53 | "alarm(QDateTime,int)", event.uid() ); | 53 | "alarm(QDateTime,int)", event.uid() ); |
54 | 54 | ||
55 | } | 55 | } |
56 | } | 56 | } |
57 | void OTodoAccess::delAlarm( int uid) { | 57 | void OTodoAccess::delAlarm( int uid) { |
58 | 58 | ||
59 | QDateTime schedule; // Create null DateTime | 59 | QDateTime schedule; // Create null DateTime |
60 | 60 | ||
61 | // I hope this will remove all scheduled alarms | 61 | // I hope this will remove all scheduled alarms |
62 | // with the given uid !? | 62 | // with the given uid !? |
63 | // If not: I have to rethink how to remove already | 63 | // If not: I have to rethink how to remove already |
64 | // scheduled events... (se) | 64 | // scheduled events... (se) |
65 | // it should be fine -zecke | 65 | // it should be fine -zecke |
66 | // qWarning("Removing alarm for event with uid %d", uid ); | 66 | // qWarning("Removing alarm for event with uid %d", uid ); |
67 | AlarmServer::deleteAlarm( schedule , | 67 | AlarmServer::deleteAlarm( schedule , |
68 | "QPE/Application/todolist", | 68 | "QPE/Application/todolist", |
69 | "alarm(QDateTime,int)", uid ); | 69 | "alarm(QDateTime,int)", uid ); |
70 | } | 70 | } |
71 | /* sort order */ | 71 | /* sort order */ |
72 | OTodoAccess::List OTodoAccess::sorted( bool ascending, int sort,int filter, int cat ) { | 72 | OTodoAccess::List OTodoAccess::sorted( bool ascending, int sort,int filter, int cat ) { |
73 | QArray<int> ints = m_todoBackEnd->sorted( ascending, sort, | 73 | QArray<int> ints = m_todoBackEnd->sorted( ascending, sort, |
74 | filter, cat ); | 74 | filter, cat ); |
75 | OTodoAccess::List list( ints, this ); | 75 | OTodoAccess::List list( ints, this ); |
76 | return list; | 76 | return list; |
77 | } | 77 | } |
diff --git a/libopie2/opiepim/orecordlist.h b/libopie2/opiepim/orecordlist.h index 1fd0741..b6fa7fa 100644 --- a/libopie2/opiepim/orecordlist.h +++ b/libopie2/opiepim/orecordlist.h | |||
@@ -93,136 +93,135 @@ public: | |||
93 | ~ORecordList(); | 93 | ~ORecordList(); |
94 | 94 | ||
95 | /** | 95 | /** |
96 | * the first iterator | 96 | * the first iterator |
97 | */ | 97 | */ |
98 | Iterator begin(); | 98 | Iterator begin(); |
99 | 99 | ||
100 | /** | 100 | /** |
101 | * the end | 101 | * the end |
102 | */ | 102 | */ |
103 | Iterator end(); | 103 | Iterator end(); |
104 | 104 | ||
105 | /** | 105 | /** |
106 | * the number of items in the list | 106 | * the number of items in the list |
107 | */ | 107 | */ |
108 | uint count()const; | 108 | uint count()const; |
109 | 109 | ||
110 | T operator[]( uint i ); | 110 | T operator[]( uint i ); |
111 | // FIXME implemenent remove | 111 | // FIXME implemenent remove |
112 | /* | 112 | /* |
113 | ConstIterator begin()const; | 113 | ConstIterator begin()const; |
114 | ConstIterator end()const; | 114 | ConstIterator end()const; |
115 | */ | 115 | */ |
116 | private: | 116 | private: |
117 | QArray<int> m_ids; | 117 | QArray<int> m_ids; |
118 | const Base* m_acc; | 118 | const Base* m_acc; |
119 | }; | 119 | }; |
120 | 120 | ||
121 | /* ok now implement it */ | 121 | /* ok now implement it */ |
122 | template <class T> | 122 | template <class T> |
123 | ORecordListIterator<T>::ORecordListIterator() { | 123 | ORecordListIterator<T>::ORecordListIterator() { |
124 | m_current = 0; | 124 | m_current = 0; |
125 | m_temp = 0l; | 125 | m_temp = 0l; |
126 | m_end = true; | 126 | m_end = true; |
127 | m_record = T(); | 127 | m_record = T(); |
128 | } | 128 | } |
129 | template <class T> | 129 | template <class T> |
130 | ORecordListIterator<T>::~ORecordListIterator() { | 130 | ORecordListIterator<T>::~ORecordListIterator() { |
131 | /* nothing to delete */ | 131 | /* nothing to delete */ |
132 | } | 132 | } |
133 | 133 | ||
134 | template <class T> | 134 | template <class T> |
135 | ORecordListIterator<T>::ORecordListIterator( const ORecordListIterator<T>& it) { | 135 | ORecordListIterator<T>::ORecordListIterator( const ORecordListIterator<T>& it) { |
136 | // qWarning("ORecordListIterator copy c'tor"); | 136 | // qWarning("ORecordListIterator copy c'tor"); |
137 | m_uids = it.m_uids; | 137 | m_uids = it.m_uids; |
138 | m_current = it.m_current; | 138 | m_current = it.m_current; |
139 | m_temp = it.m_temp; | 139 | m_temp = it.m_temp; |
140 | m_end = it.m_end; | 140 | m_end = it.m_end; |
141 | m_record = it.m_record; | 141 | m_record = it.m_record; |
142 | } | 142 | } |
143 | 143 | ||
144 | template <class T> | 144 | template <class T> |
145 | ORecordListIterator<T> &ORecordListIterator<T>::operator=( const ORecordListIterator<T>& it) { | 145 | ORecordListIterator<T> &ORecordListIterator<T>::operator=( const ORecordListIterator<T>& it) { |
146 | m_uids = it.m_uids; | 146 | m_uids = it.m_uids; |
147 | m_current = it.m_current; | 147 | m_current = it.m_current; |
148 | m_temp = it.m_temp; | 148 | m_temp = it.m_temp; |
149 | m_end = it.m_end; | 149 | m_end = it.m_end; |
150 | m_record = it.m_record; | 150 | m_record = it.m_record; |
151 | 151 | ||
152 | return *this; | 152 | return *this; |
153 | } | 153 | } |
154 | 154 | ||
155 | template <class T> | 155 | template <class T> |
156 | T ORecordListIterator<T>::operator*() { | 156 | T ORecordListIterator<T>::operator*() { |
157 | // qWarning("operator* %d %d", m_current, m_uids[m_current] ); | 157 | qWarning("operator* %d %d", m_current, m_uids[m_current] ); |
158 | if (!m_end ) | 158 | if (!m_end ) |
159 | /* FIXME | 159 | /* FIXME |
160 | * until the cache is in place | 160 | * until the cache is in place |
161 | * we do the uid match uid check | 161 | * we do the uid match uid check |
162 | */ | 162 | */ |
163 | if(m_record.uid() != m_uids[m_current] ) | 163 | m_record = m_temp->find( m_uids[m_current] ); |
164 | m_record = m_temp->find( m_uids[m_current] ); | ||
165 | else | 164 | else |
166 | m_record = T(); | 165 | m_record = T(); |
167 | 166 | ||
168 | return m_record; | 167 | return m_record; |
169 | } | 168 | } |
170 | 169 | ||
171 | template <class T> | 170 | template <class T> |
172 | ORecordListIterator<T> &ORecordListIterator<T>::operator++() { | 171 | ORecordListIterator<T> &ORecordListIterator<T>::operator++() { |
173 | if (m_current < m_uids.count() ) { | 172 | if (m_current < m_uids.count() ) { |
174 | m_end = false; | 173 | m_end = false; |
175 | ++m_current; | 174 | ++m_current; |
176 | }else | 175 | }else |
177 | m_end = true; | 176 | m_end = true; |
178 | 177 | ||
179 | return *this; | 178 | return *this; |
180 | } | 179 | } |
181 | template <class T> | 180 | template <class T> |
182 | ORecordListIterator<T> &ORecordListIterator<T>::operator--() { | 181 | ORecordListIterator<T> &ORecordListIterator<T>::operator--() { |
183 | if ( m_current > 0 ) { | 182 | if ( m_current > 0 ) { |
184 | --m_current; | 183 | --m_current; |
185 | m_end = false; | 184 | m_end = false; |
186 | } else | 185 | } else |
187 | m_end = true; | 186 | m_end = true; |
188 | 187 | ||
189 | return *this; | 188 | return *this; |
190 | } | 189 | } |
191 | 190 | ||
192 | template <class T> | 191 | template <class T> |
193 | bool ORecordListIterator<T>::operator==( const ORecordListIterator<T>& it ) { | 192 | bool ORecordListIterator<T>::operator==( const ORecordListIterator<T>& it ) { |
194 | 193 | ||
195 | /* if both are at we're the same.... */ | 194 | /* if both are at we're the same.... */ |
196 | if ( m_end == it.m_end ) return true; | 195 | if ( m_end == it.m_end ) return true; |
197 | 196 | ||
198 | if ( m_uids != it.m_uids ) return false; | 197 | if ( m_uids != it.m_uids ) return false; |
199 | if ( m_current != it.m_current ) return false; | 198 | if ( m_current != it.m_current ) return false; |
200 | if ( m_temp != it.m_temp ) return false; | 199 | if ( m_temp != it.m_temp ) return false; |
201 | 200 | ||
202 | return true; | 201 | return true; |
203 | } | 202 | } |
204 | template <class T> | 203 | template <class T> |
205 | bool ORecordListIterator<T>::operator!=( const ORecordListIterator<T>& it ) { | 204 | bool ORecordListIterator<T>::operator!=( const ORecordListIterator<T>& it ) { |
206 | return !(*this == it ); | 205 | return !(*this == it ); |
207 | } | 206 | } |
208 | template <class T> | 207 | template <class T> |
209 | ORecordListIterator<T>::ORecordListIterator( const QArray<int> uids, | 208 | ORecordListIterator<T>::ORecordListIterator( const QArray<int> uids, |
210 | const Base* t ) | 209 | const Base* t ) |
211 | : m_uids( uids ), m_current( 0 ), m_temp( t ), m_end( false ) | 210 | : m_uids( uids ), m_current( 0 ), m_temp( t ), m_end( false ) |
212 | { | 211 | { |
213 | } | 212 | } |
214 | template <class T> | 213 | template <class T> |
215 | uint ORecordListIterator<T>::current()const { | 214 | uint ORecordListIterator<T>::current()const { |
216 | return m_current; | 215 | return m_current; |
217 | } | 216 | } |
218 | template <class T> | 217 | template <class T> |
219 | void ORecordListIterator<T>::setCurrent( uint cur ) { | 218 | void ORecordListIterator<T>::setCurrent( uint cur ) { |
220 | if( cur < m_uids.count() ) { | 219 | if( cur < m_uids.count() ) { |
221 | m_end = false; | 220 | m_end = false; |
222 | m_current= cur; | 221 | m_current= cur; |
223 | } | 222 | } |
224 | } | 223 | } |
225 | template <class T> | 224 | template <class T> |
226 | uint ORecordListIterator<T>::count()const { | 225 | uint ORecordListIterator<T>::count()const { |
227 | return m_uids.count(); | 226 | return m_uids.count(); |
228 | } | 227 | } |