Details | Last modification | View Log | RSS feed
Rev | Author | Line No. | Line |
---|---|---|---|
2498 | - | 1 | |
2 | namespace GMap.NET.CacheProviders |
||
3 | { |
||
4 | #if MySQL |
||
5 | using System; |
||
6 | using System.Data; |
||
7 | using System.Diagnostics; |
||
8 | using System.IO; |
||
9 | using GMap.NET; |
||
10 | using MySql.Data.MySqlClient; |
||
11 | using GMap.NET.MapProviders; |
||
12 | |||
13 | /// <summary> |
||
14 | /// image cache for mysql server |
||
15 | /// </summary> |
||
16 | public class MySQLPureImageCache : PureImageCache, IDisposable |
||
17 | { |
||
18 | string connectionString = string.Empty; |
||
19 | public string ConnectionString |
||
20 | { |
||
21 | get |
||
22 | { |
||
23 | return connectionString; |
||
24 | } |
||
25 | set |
||
26 | { |
||
27 | if(connectionString != value) |
||
28 | { |
||
29 | connectionString = value; |
||
30 | |||
31 | if(Initialized) |
||
32 | { |
||
33 | Dispose(); |
||
34 | Initialize(); |
||
35 | } |
||
36 | } |
||
37 | } |
||
38 | } |
||
39 | |||
40 | MySqlCommand cmdInsert; |
||
41 | MySqlCommand cmdFetch; |
||
42 | MySqlConnection cnGet; |
||
43 | MySqlConnection cnSet; |
||
44 | |||
45 | bool initialized = false; |
||
46 | |||
47 | /// <summary> |
||
48 | /// is cache initialized |
||
49 | /// </summary> |
||
50 | public bool Initialized |
||
51 | { |
||
52 | get |
||
53 | { |
||
54 | lock(this) |
||
55 | { |
||
56 | return initialized; |
||
57 | } |
||
58 | } |
||
59 | private set |
||
60 | { |
||
61 | lock(this) |
||
62 | { |
||
63 | initialized = value; |
||
64 | } |
||
65 | } |
||
66 | } |
||
67 | |||
68 | /// <summary> |
||
69 | /// inits connection to server |
||
70 | /// </summary> |
||
71 | /// <returns></returns> |
||
72 | public bool Initialize() |
||
73 | { |
||
74 | lock(this) |
||
75 | { |
||
76 | if(!initialized) |
||
77 | { |
||
78 | #region prepare mssql & cache table |
||
79 | try |
||
80 | { |
||
81 | // different connections so the multi-thread inserts and selects don't collide on open readers. |
||
82 | this.cnGet = new MySqlConnection(connectionString); |
||
83 | this.cnGet.Open(); |
||
84 | this.cnSet = new MySqlConnection(connectionString); |
||
85 | this.cnSet.Open(); |
||
86 | |||
87 | { |
||
88 | using(MySqlCommand cmd = new MySqlCommand( |
||
89 | @" CREATE TABLE IF NOT EXISTS `gmapnetcache` ( |
||
90 | `Type` int(10) NOT NULL, |
||
91 | `Zoom` int(10) NOT NULL, |
||
92 | `X` int(10) NOT NULL, |
||
93 | `Y` int(10) NOT NULL, |
||
94 | `Tile` longblob NOT NULL, |
||
95 | PRIMARY KEY (`Type`,`Zoom`,`X`,`Y`) |
||
96 | ) ENGINE=InnoDB DEFAULT CHARSET=utf8;", cnGet)) |
||
97 | { |
||
98 | cmd.ExecuteNonQuery(); |
||
99 | } |
||
100 | } |
||
101 | |||
102 | this.cmdFetch = new MySqlCommand("SELECT Tile FROM `gmapnetcache` WHERE Type=@type AND Zoom=@zoom AND X=@x AND Y=@y", cnGet); |
||
103 | this.cmdFetch.Parameters.Add("@type", MySqlDbType.Int32); |
||
104 | this.cmdFetch.Parameters.Add("@zoom", MySqlDbType.Int32); |
||
105 | this.cmdFetch.Parameters.Add("@x", MySqlDbType.Int32); |
||
106 | this.cmdFetch.Parameters.Add("@y", MySqlDbType.Int32); |
||
107 | this.cmdFetch.Prepare(); |
||
108 | |||
109 | this.cmdInsert = new MySqlCommand("INSERT INTO `gmapnetcache` ( Type, Zoom, X, Y, Tile ) VALUES ( @type, @zoom, @x, @y, @tile )", cnSet); |
||
110 | this.cmdInsert.Parameters.Add("@type", MySqlDbType.Int32); |
||
111 | this.cmdInsert.Parameters.Add("@zoom", MySqlDbType.Int32); |
||
112 | this.cmdInsert.Parameters.Add("@x", MySqlDbType.Int32); |
||
113 | this.cmdInsert.Parameters.Add("@y", MySqlDbType.Int32); |
||
114 | this.cmdInsert.Parameters.Add("@tile", MySqlDbType.Blob); //, calcmaximgsize); |
||
115 | //can't prepare insert because of the IMAGE field having a variable size. Could set it to some 'maximum' size? |
||
116 | |||
117 | Initialized = true; |
||
118 | } |
||
119 | catch(Exception ex) |
||
120 | { |
||
121 | this.initialized = false; |
||
122 | Debug.WriteLine(ex.Message); |
||
123 | } |
||
124 | #endregion |
||
125 | } |
||
126 | return initialized; |
||
127 | } |
||
128 | } |
||
129 | |||
130 | #region IDisposable Members |
||
131 | |||
132 | public void Dispose() |
||
133 | { |
||
134 | lock(cmdInsert) |
||
135 | { |
||
136 | if(cmdInsert != null) |
||
137 | { |
||
138 | cmdInsert.Dispose(); |
||
139 | cmdInsert = null; |
||
140 | } |
||
141 | |||
142 | if(cnSet != null) |
||
143 | { |
||
144 | cnSet.Dispose(); |
||
145 | cnSet = null; |
||
146 | } |
||
147 | } |
||
148 | |||
149 | lock(cmdFetch) |
||
150 | { |
||
151 | if(cmdFetch != null) |
||
152 | { |
||
153 | cmdFetch.Dispose(); |
||
154 | cmdFetch = null; |
||
155 | } |
||
156 | |||
157 | if(cnGet != null) |
||
158 | { |
||
159 | cnGet.Dispose(); |
||
160 | cnGet = null; |
||
161 | } |
||
162 | } |
||
163 | Initialized = false; |
||
164 | } |
||
165 | #endregion |
||
166 | |||
167 | #region PureImageCache Members |
||
168 | public bool PutImageToCache(byte[] tile, int type, GPoint pos, int zoom) |
||
169 | { |
||
170 | bool ret = true; |
||
171 | { |
||
172 | if(Initialize()) |
||
173 | { |
||
174 | try |
||
175 | { |
||
176 | lock(cmdInsert) |
||
177 | { |
||
178 | cnSet.Ping(); |
||
179 | |||
180 | if(cnSet.State != ConnectionState.Open) |
||
181 | { |
||
182 | cnSet.Open(); |
||
183 | } |
||
184 | |||
185 | cmdInsert.Parameters["@type"].Value = type; |
||
186 | cmdInsert.Parameters["@zoom"].Value = zoom; |
||
187 | cmdInsert.Parameters["@x"].Value = pos.X; |
||
188 | cmdInsert.Parameters["@y"].Value = pos.Y; |
||
189 | cmdInsert.Parameters["@tile"].Value = tile; |
||
190 | cmdInsert.ExecuteNonQuery(); |
||
191 | } |
||
192 | } |
||
193 | catch(Exception ex) |
||
194 | { |
||
195 | Debug.WriteLine(ex.ToString()); |
||
196 | ret = false; |
||
197 | Dispose(); |
||
198 | } |
||
199 | } |
||
200 | } |
||
201 | return ret; |
||
202 | } |
||
203 | |||
204 | public PureImage GetImageFromCache(int type, GPoint pos, int zoom) |
||
205 | { |
||
206 | PureImage ret = null; |
||
207 | { |
||
208 | if(Initialize()) |
||
209 | { |
||
210 | try |
||
211 | { |
||
212 | object odata = null; |
||
213 | lock(cmdFetch) |
||
214 | { |
||
215 | cnGet.Ping(); |
||
216 | |||
217 | if(cnGet.State != ConnectionState.Open) |
||
218 | { |
||
219 | cnGet.Open(); |
||
220 | } |
||
221 | |||
222 | cmdFetch.Parameters["@type"].Value = type; |
||
223 | cmdFetch.Parameters["@zoom"].Value = zoom; |
||
224 | cmdFetch.Parameters["@x"].Value = pos.X; |
||
225 | cmdFetch.Parameters["@y"].Value = pos.Y; |
||
226 | odata = cmdFetch.ExecuteScalar(); |
||
227 | } |
||
228 | |||
229 | if(odata != null && odata != DBNull.Value) |
||
230 | { |
||
231 | byte[] tile = (byte[])odata; |
||
232 | if(tile != null && tile.Length > 0) |
||
233 | { |
||
234 | if(GMapProvider.TileImageProxy != null) |
||
235 | { |
||
236 | ret = GMapProvider.TileImageProxy.FromArray(tile); |
||
237 | } |
||
238 | } |
||
239 | tile = null; |
||
240 | } |
||
241 | } |
||
242 | catch(Exception ex) |
||
243 | { |
||
244 | Debug.WriteLine(ex.ToString()); |
||
245 | ret = null; |
||
246 | Dispose(); |
||
247 | } |
||
248 | } |
||
249 | } |
||
250 | return ret; |
||
251 | } |
||
252 | |||
253 | int PureImageCache.DeleteOlderThan(DateTime date, int ? type) |
||
254 | { |
||
255 | throw new NotImplementedException(); |
||
256 | } |
||
257 | #endregion |
||
258 | } |
||
259 | #endif |
||
260 | } |