OSDN Git Service

21f90ea879ca70c5779a95cebf18b097a68e12fd
[neighbornote/NeighborNote.git] / src / cx / fbn / nevernote / sql / SyncTable.java
1 /*\r
2  * This file is part of NeverNote \r
3  * Copyright 2009 Randy Baumgarte\r
4  * \r
5  * This file may be licensed under the terms of of the\r
6  * GNU General Public License Version 2 (the ``GPL'').\r
7  *\r
8  * Software distributed under the License is distributed\r
9  * on an ``AS IS'' basis, WITHOUT WARRANTY OF ANY KIND, either\r
10  * express or implied. See the GPL for the specific language\r
11  * governing rights and limitations.\r
12  *\r
13  * You should have received a copy of the GPL along with this\r
14  * program. If not, go to http://www.gnu.org/licenses/gpl.html\r
15  * or write to the Free Software Foundation, Inc.,\r
16  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.\r
17  *\r
18 */\r
19 \r
20 \r
21 package cx.fbn.nevernote.sql;\r
22 \r
23 import java.util.ArrayList;\r
24 import java.util.List;\r
25 \r
26 import cx.fbn.nevernote.sql.driver.NSqlQuery;\r
27 import cx.fbn.nevernote.utilities.ApplicationLogger;\r
28 import cx.fbn.nevernote.utilities.ListManager;\r
29 \r
30 public class SyncTable {\r
31         ListManager parent;\r
32         private final ApplicationLogger                 logger;\r
33         private final DatabaseConnection                db;\r
34 \r
35         \r
36         // Constructor\r
37         public SyncTable(ApplicationLogger l, DatabaseConnection d) {\r
38                 logger = l;\r
39                 db = d;\r
40         }\r
41         // Create the table\r
42         public void createTable() {\r
43                 NSqlQuery query = new NSqlQuery(db.getConnection());\r
44                 logger.log(logger.HIGH, "Creating table Sync...");\r
45         if (!query.exec("Create table Sync (key varchar primary key, value varchar);"))\r
46                 logger.log(logger.HIGH, "Table Sync creation FAILED!!!"); \r
47         addRecord("LastSequenceDate","0");\r
48         addRecord("UpdateSequenceNumber", "0");\r
49         }\r
50         // Drop the table\r
51         public void dropTable() {\r
52                 NSqlQuery query = new NSqlQuery(db.getConnection());\r
53                 query.exec("Drop table Sync");\r
54         }\r
55         // Add an item to the table\r
56         public void addRecord(String key, String value) {\r
57         NSqlQuery query = new NSqlQuery(db.getConnection());\r
58                 query.prepare("Insert Into Sync (key,  value) values (:key, :value);");\r
59                 query.bindValue(":key", key);\r
60                 query.bindValue(":value", value);\r
61                 if (!query.exec()) {\r
62                         logger.log(logger.MEDIUM, "Add to into Sync failed.");\r
63                         logger.log(logger.MEDIUM, query.lastError());\r
64                 }\r
65         }\r
66         // Add an item to the table\r
67         public void deleteRecord(String key) {\r
68         NSqlQuery query = new NSqlQuery(db.getConnection());\r
69                 query.prepare("Delete From Sync where key=:key");\r
70                 query.bindValue(":key", key);\r
71                 if (!query.exec()) {\r
72                         logger.log(logger.MEDIUM, "Delete from Sync failed.");\r
73                         logger.log(logger.MEDIUM, query.lastError());\r
74                 }\r
75         }\r
76         // Get a key field\r
77         public String getRecord(String key) {\r
78         NSqlQuery query = new NSqlQuery(db.getConnection());\r
79         query.prepare("Select value from Sync where key=:key");\r
80         query.bindValue(":key", key);\r
81                 if (!query.exec()) {\r
82                         logger.log(logger.MEDIUM, "getRecord from sync failed.");\r
83                         logger.log(logger.MEDIUM, query.lastError());\r
84                         return null;\r
85                 }\r
86                 if (query.next()) {\r
87                         return (query.valueString(0));\r
88                 }\r
89                 return null;\r
90         }\r
91         // Set a key field\r
92         public void setRecord(String key, String value) {\r
93         NSqlQuery query = new NSqlQuery(db.getConnection());\r
94         query.prepare("Update Sync set value=:value where key=:key");\r
95         query.bindValue(":key", key);\r
96         query.bindValue(":value", value);\r
97                 if (!query.exec()) {\r
98                         logger.log(logger.MEDIUM, "setRecord from sync failed.");\r
99                         logger.log(logger.MEDIUM, query.lastError());\r
100                 }\r
101                 return;\r
102         }\r
103 \r
104         // Set the last sequence date\r
105         public void setLastSequenceDate(long date) {\r
106                 setRecord("LastSequenceDate", new Long(date).toString());\r
107         }\r
108         // Set the last sequence date\r
109         public void setUpdateSequenceNumber(int number) {\r
110                 setRecord("UpdateSequenceNumber", new Integer(number).toString());\r
111         }\r
112         // get last sequence date\r
113         public long getLastSequenceDate() {\r
114                 return new Long(getRecord("LastSequenceDate"));\r
115         }\r
116         // Get invalid attributes for a given element\r
117         public int getUpdateSequenceNumber() {\r
118                 return new Integer(getRecord("UpdateSequenceNumber"));\r
119         }\r
120         // Get notebooks/tags to ignore\r
121         public List<String> getIgnoreRecords(String type) {\r
122                 List<String> values = new ArrayList<String>();\r
123         NSqlQuery query = new NSqlQuery(db.getConnection());\r
124         if (!query.prepare("Select value from Sync where key like :type")) {\r
125                         logger.log(logger.MEDIUM, "getIgnoreRecords from sync failed.");\r
126                         logger.log(logger.MEDIUM, query.lastError());\r
127                         return null;\r
128                 }\r
129         query.bindValue(":type", "IGNORE" +type +"-%");\r
130         query.exec();\r
131                 while (query.next()) {\r
132                         values.add(query.valueString(0));\r
133                 }\r
134                 return values;\r
135         }\r
136         // Expunge ignore records\r
137         // Add an item to the table\r
138 \r
139 }\r