?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
oledb32: Support DBSTATUS_S_ISNULL when converting to VARIANT.
[wine/multimedia.git] / dlls / oledb32 / convert.c
blobfe7ba8cb6c2b623dd61d0cff14a6c4b6e585d6b6
1 /* OLE DB Conversion library
2 *
3 * Copyright 2009 Huw Davies
4 *
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2.1 of the License, or (at your option) any later version.
9 *
10 * This library is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Lesser General Public License for more details.
14 *
15 * You should have received a copy of the GNU Lesser General Public
16 * License along with this library; if not, write to the Free Software
17 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
18 */
19
20 #include <stdarg.h>
21
22 #define COBJMACROS
23 #define NONAMELESSUNION
24 #define NONAMELESSSTRUCT
25
26 #include "windef.h"
27 #include "winbase.h"
28 #include "winnls.h"
29 #include "ole2.h"
30 #include "msdadc.h"
31 #include "oledberr.h"
32
33 #include "oledb_private.h"
34
35 #include "wine/debug.h"
36
37 WINE_DEFAULT_DEBUG_CHANNEL(oledb);
38
39 typedef struct
40 {
41 IDataConvert IDataConvert_iface;
42 IDCInfo IDCInfo_iface;
43
44 LONG ref;
45
46 UINT version; /* Set by IDCInfo_SetInfo */
47 } convert;
48
49 static inline convert *impl_from_IDataConvert(IDataConvert *iface)
50 {
51 return CONTAINING_RECORD(iface, convert, IDataConvert_iface);
52 }
53
54 static inline convert *impl_from_IDCInfo(IDCInfo *iface)
55 {
56 return CONTAINING_RECORD(iface, convert, IDCInfo_iface);
57 }
58
59 static HRESULT WINAPI convert_QueryInterface(IDataConvert* iface,
60 REFIID riid,
61 void **obj)
62 {
63 convert *This = impl_from_IDataConvert(iface);
64 TRACE("(%p)->(%s, %p)\n", This, debugstr_guid(riid), obj);
65
66 *obj = NULL;
67
68 if(IsEqualIID(riid, &IID_IUnknown) ||
69 IsEqualIID(riid, &IID_IDataConvert))
70 {
71 *obj = iface;
72 }
73 else if(IsEqualIID(riid, &IID_IDCInfo))
74 {
75 *obj = &This->IDCInfo_iface;
76 }
77 else
78 {
79 FIXME("interface %s not implemented\n", debugstr_guid(riid));
80 return E_NOINTERFACE;
81 }
82
83 IDataConvert_AddRef(iface);
84 return S_OK;
85 }
86
87
88 static ULONG WINAPI convert_AddRef(IDataConvert* iface)
89 {
90 convert *This = impl_from_IDataConvert(iface);
91 TRACE("(%p)\n", This);
92
93 return InterlockedIncrement(&This->ref);
94 }
95
96
97 static ULONG WINAPI convert_Release(IDataConvert* iface)
98 {
99 convert *This = impl_from_IDataConvert(iface);
100 LONG ref;
101
102 TRACE("(%p)\n", This);
103
104 ref = InterlockedDecrement(&This->ref);
105 if(ref == 0)
106 {
107 HeapFree(GetProcessHeap(), 0, This);
108 }
109
110 return ref;
111 }
112
113 static int get_length(DBTYPE type)
114 {
115 switch(type)
116 {
117 case DBTYPE_I1:
118 case DBTYPE_UI1:
119 return 1;
120 case DBTYPE_I2:
121 case DBTYPE_UI2:
122 return 2;
123 case DBTYPE_BOOL:
124 return sizeof(VARIANT_BOOL);
125 case DBTYPE_I4:
126 case DBTYPE_UI4:
127 case DBTYPE_R4:
128 return 4;
129 case DBTYPE_I8:
130 case DBTYPE_UI8:
131 case DBTYPE_R8:
132 case DBTYPE_DATE:
133 return 8;
134 case DBTYPE_DBDATE:
135 return sizeof(DBDATE);
136 case DBTYPE_DBTIMESTAMP:
137 return sizeof(DBTIMESTAMP);
138 case DBTYPE_CY:
139 return sizeof(CY);
140 case DBTYPE_BSTR:
141 return sizeof(BSTR);
142 case DBTYPE_FILETIME:
143 return sizeof(FILETIME);
144 case DBTYPE_GUID:
145 return sizeof(GUID);
146 case DBTYPE_WSTR:
147 case DBTYPE_STR:
148 case DBTYPE_BYREF | DBTYPE_WSTR:
149 return 0;
150 case DBTYPE_VARIANT:
151 return sizeof(VARIANT);
152 default:
153 FIXME("Unhandled type %04x\n", type);
154 return 0;
155 }
156 }
157
158 static HRESULT WINAPI convert_DataConvert(IDataConvert* iface,
159 DBTYPE src_type, DBTYPE dst_type,
160 DBLENGTH src_len, DBLENGTH *dst_len,
161 void *src, void *dst,
162 DBLENGTH dst_max_len,
163 DBSTATUS src_status, DBSTATUS *dst_status,
164 BYTE precision, BYTE scale,
165 DBDATACONVERT flags)
166 {
167 convert *This = impl_from_IDataConvert(iface);
168 DBLENGTH dst_len_loc;
169 DBSTATUS dst_status_loc;
170 VARIANT tmp;
171 HRESULT hr;
172
173 TRACE("(%p)->(%d, %d, %ld, %p, %p, %p, %ld, %d, %p, %d, %d, %x)\n", This,
174 src_type, dst_type, src_len, dst_len, src, dst, dst_max_len,
175 src_status, dst_status, precision, scale, flags);
176
177 if (!dst_len) dst_len = &dst_len_loc;
178 if (!dst_status) dst_status = &dst_status_loc;
179
180 *dst_status = DBSTATUS_E_BADACCESSOR;
181
182 if(IDataConvert_CanConvert(iface, src_type, dst_type) != S_OK)
183 {
184 return DB_E_UNSUPPORTEDCONVERSION;
185 }
186
187 if(src_type == DBTYPE_STR)
188 {
189 BSTR b;
190 DWORD len;
191
192 if(flags & DBDATACONVERT_LENGTHFROMNTS)
193 len = MultiByteToWideChar(CP_ACP, 0, src, -1, NULL, 0) - 1;
194 else
195 len = MultiByteToWideChar(CP_ACP, 0, src, src_len, NULL, 0);
196 b = SysAllocStringLen(NULL, len);
197 if(!b) return E_OUTOFMEMORY;
198 if(flags & DBDATACONVERT_LENGTHFROMNTS)
199 MultiByteToWideChar(CP_ACP, 0, src, -1, b, len + 1);
200 else
201 MultiByteToWideChar(CP_ACP, 0, src, src_len, b, len);
202
203 hr = IDataConvert_DataConvert(iface, DBTYPE_BSTR, dst_type, 0, dst_len,
204 &b, dst, dst_max_len, src_status, dst_status,
205 precision, scale, flags);
206
207 SysFreeString(b);
208 return hr;
209 }
210
211 if(src_type == DBTYPE_WSTR)
212 {
213 BSTR b;
214
215 if(flags & DBDATACONVERT_LENGTHFROMNTS)
216 b = SysAllocString(src);
217 else
218 b = SysAllocStringLen(src, src_len / 2);
219 if(!b) return E_OUTOFMEMORY;
220 hr = IDataConvert_DataConvert(iface, DBTYPE_BSTR, dst_type, 0, dst_len,
221 &b, dst, dst_max_len, src_status, dst_status,
222 precision, scale, flags);
223 SysFreeString(b);
224 return hr;
225 }
226
227 switch(dst_type)
228 {
229 case DBTYPE_I2:
230 {
231 signed short *d = dst;
232 switch(src_type)
233 {
234 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
235 case DBTYPE_I2: *d = *(signed short*)src; hr = S_OK; break;
236 case DBTYPE_I4: hr = VarI2FromI4(*(signed int*)src, d); break;
237 case DBTYPE_R4: hr = VarI2FromR4(*(FLOAT*)src, d); break;
238 case DBTYPE_R8: hr = VarI2FromR8(*(double*)src, d); break;
239 case DBTYPE_CY: hr = VarI2FromCy(*(CY*)src, d); break;
240 case DBTYPE_DATE: hr = VarI2FromDate(*(DATE*)src, d); break;
241 case DBTYPE_BSTR: hr = VarI2FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
242 case DBTYPE_BOOL: hr = VarI2FromBool(*(VARIANT_BOOL*)src, d); break;
243 case DBTYPE_DECIMAL: hr = VarI2FromDec((DECIMAL*)src, d); break;
244 case DBTYPE_I1: hr = VarI2FromI1(*(signed char*)src, d); break;
245 case DBTYPE_UI1: hr = VarI2FromUI1(*(BYTE*)src, d); break;
246 case DBTYPE_UI2: hr = VarI2FromUI2(*(WORD*)src, d); break;
247 case DBTYPE_UI4: hr = VarI2FromUI4(*(DWORD*)src, d); break;
248 case DBTYPE_I8: hr = VarI2FromI8(*(LONGLONG*)src, d); break;
249 case DBTYPE_UI8: hr = VarI2FromUI8(*(ULONGLONG*)src, d); break;
250 case DBTYPE_VARIANT:
251 VariantInit(&tmp);
252 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_I2)) == S_OK)
253 *d = V_I2(&tmp);
254 break;
255 default: FIXME("Unimplemented conversion %04x -> I2\n", src_type); return E_NOTIMPL;
256 }
257 break;
258 }
259
260 case DBTYPE_I4:
261 {
262 signed int *d = dst;
263 switch(src_type)
264 {
265 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
266 case DBTYPE_I2: hr = VarI4FromI2(*(signed short*)src, d); break;
267 case DBTYPE_I4: *d = *(signed int*)src; hr = S_OK; break;
268 case DBTYPE_R4: hr = VarI4FromR4(*(FLOAT*)src, d); break;
269 case DBTYPE_R8: hr = VarI4FromR8(*(double*)src, d); break;
270 case DBTYPE_CY: hr = VarI4FromCy(*(CY*)src, d); break;
271 case DBTYPE_DATE: hr = VarI4FromDate(*(DATE*)src, d); break;
272 case DBTYPE_BSTR: hr = VarI4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
273 case DBTYPE_BOOL: hr = VarI4FromBool(*(VARIANT_BOOL*)src, d); break;
274 case DBTYPE_DECIMAL: hr = VarI4FromDec((DECIMAL*)src, d); break;
275 case DBTYPE_I1: hr = VarI4FromI1(*(signed char*)src, d); break;
276 case DBTYPE_UI1: hr = VarI4FromUI1(*(BYTE*)src, d); break;
277 case DBTYPE_UI2: hr = VarI4FromUI2(*(WORD*)src, d); break;
278 case DBTYPE_UI4: hr = VarI4FromUI4(*(DWORD*)src, d); break;
279 case DBTYPE_I8: hr = VarI4FromI8(*(LONGLONG*)src, d); break;
280 case DBTYPE_UI8: hr = VarI4FromUI8(*(ULONGLONG*)src, d); break;
281 case DBTYPE_VARIANT:
282 VariantInit(&tmp);
283 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_I4)) == S_OK)
284 *d = V_I4(&tmp);
285 break;
286 default: FIXME("Unimplemented conversion %04x -> I4\n", src_type); return E_NOTIMPL;
287 }
288 break;
289 }
290
291 case DBTYPE_I8:
292 {
293 LONGLONG *d = dst;
294 switch(src_type)
295 {
296 case DBTYPE_BSTR: hr = VarI8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
297 case DBTYPE_I8: *d = *(LONGLONG*)src; hr = S_OK; break;
298 default: FIXME("Unimplemented conversion %04x -> I8\n", src_type); return E_NOTIMPL;
299 }
300 break;
301 }
302
303 case DBTYPE_R4:
304 {
305 FLOAT *d = dst;
306 switch(src_type)
307 {
308 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
309 case DBTYPE_I2: hr = VarR4FromI2(*(signed short*)src, d); break;
310 case DBTYPE_I4: hr = VarR4FromI4(*(signed int*)src, d); break;
311 case DBTYPE_R4: *d = *(FLOAT*)src; hr = S_OK; break;
312 case DBTYPE_R8: hr = VarR4FromR8(*(double*)src, d); break;
313 case DBTYPE_CY: hr = VarR4FromCy(*(CY*)src, d); break;
314 case DBTYPE_DATE: hr = VarR4FromDate(*(DATE*)src, d); break;
315 case DBTYPE_BSTR: hr = VarR4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
316 case DBTYPE_BOOL: hr = VarR4FromBool(*(VARIANT_BOOL*)src, d); break;
317 case DBTYPE_DECIMAL: hr = VarR4FromDec((DECIMAL*)src, d); break;
318 case DBTYPE_I1: hr = VarR4FromI1(*(signed char*)src, d); break;
319 case DBTYPE_UI1: hr = VarR4FromUI1(*(BYTE*)src, d); break;
320 case DBTYPE_UI2: hr = VarR4FromUI2(*(WORD*)src, d); break;
321 case DBTYPE_UI4: hr = VarR4FromUI4(*(DWORD*)src, d); break;
322 case DBTYPE_I8: hr = VarR4FromI8(*(LONGLONG*)src, d); break;
323 case DBTYPE_UI8: hr = VarR4FromUI8(*(ULONGLONG*)src, d); break;
324 default: FIXME("Unimplemented conversion %04x -> R4\n", src_type); return E_NOTIMPL;
325 }
326 break;
327 }
328 case DBTYPE_R8:
329 {
330 DOUBLE *d=dst;
331 switch (src_type)
332 {
333 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
334 case DBTYPE_I1: hr = VarR8FromI1(*(signed char*)src, d); break;
335 case DBTYPE_I2: hr = VarR8FromI2(*(signed short*)src, d); break;
336 case DBTYPE_I4: hr = VarR8FromI4(*(signed int*)src, d); break;
337 case DBTYPE_I8: hr = VarR8FromI8(*(LONGLONG*)src, d); break;
338 case DBTYPE_UI1: hr = VarR8FromUI1(*(BYTE*)src, d); break;
339 case DBTYPE_UI2: hr = VarR8FromUI2(*(WORD*)src, d); break;
340 case DBTYPE_UI4: hr = VarR8FromUI4(*(DWORD*)src, d); break;
341 case DBTYPE_UI8: hr = VarR8FromUI8(*(ULONGLONG*)src, d); break;
342 case DBTYPE_R4: hr = VarR8FromR4(*(FLOAT*)src, d); break;
343 case DBTYPE_R8: *d = *(DOUBLE*)src; hr = S_OK; break;
344 case DBTYPE_CY: hr = VarR8FromCy(*(CY*)src, d); break;
345 case DBTYPE_DATE: hr = VarR8FromDate(*(DATE*)src, d); break;
346 case DBTYPE_BSTR: hr = VarR8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
347 case DBTYPE_BOOL: hr = VarR8FromBool(*(VARIANT_BOOL*)src, d); break;
348 case DBTYPE_DECIMAL: hr = VarR8FromDec((DECIMAL*)src, d); break;
349 default: FIXME("Unimplemented conversion %04x -> R8\n", src_type); return E_NOTIMPL;
350 }
351 break;
352 }
353 case DBTYPE_BOOL:
354 {
355 VARIANT_BOOL *d=dst;
356 switch (src_type)
357 {
358 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
359 case DBTYPE_I1: hr = VarBoolFromI1(*(signed char*)src, d); break;
360 case DBTYPE_I2: hr = VarBoolFromI2(*(signed short*)src, d); break;
361 case DBTYPE_I4: hr = VarBoolFromI4(*(signed int*)src, d); break;
362 case DBTYPE_I8: hr = VarBoolFromI8(*(LONGLONG*)src, d); break;
363 case DBTYPE_UI1: hr = VarBoolFromUI1(*(BYTE*)src, d); break;
364 case DBTYPE_UI2: hr = VarBoolFromUI2(*(WORD*)src, d); break;
365 case DBTYPE_UI4: hr = VarBoolFromUI4(*(DWORD*)src, d); break;
366 case DBTYPE_UI8: hr = VarBoolFromUI8(*(ULONGLONG*)src, d); break;
367 case DBTYPE_R4: hr = VarBoolFromR4(*(FLOAT*)src, d); break;
368 case DBTYPE_R8: hr = VarBoolFromR8(*(DOUBLE*)src, d); break;
369 case DBTYPE_CY: hr = VarBoolFromCy(*(CY*)src, d); break;
370 case DBTYPE_DATE: hr = VarBoolFromDate(*(DATE*)src, d); break;
371 case DBTYPE_BSTR: hr = VarBoolFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
372 case DBTYPE_BOOL: *d = *(VARIANT_BOOL*)src; hr = S_OK; break;
373 case DBTYPE_DECIMAL: hr = VarBoolFromDec((DECIMAL*)src, d); break;
374 default: FIXME("Unimplemented conversion %04x -> BOOL\n", src_type); return E_NOTIMPL;
375 }
376 break;
377 }
378 case DBTYPE_DATE:
379 {
380 DATE *d=dst;
381 switch (src_type)
382 {
383 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
384 case DBTYPE_I1: hr = VarDateFromI1(*(signed char*)src, d); break;
385 case DBTYPE_I2: hr = VarDateFromI2(*(signed short*)src, d); break;
386 case DBTYPE_I4: hr = VarDateFromI4(*(signed int*)src, d); break;
387 case DBTYPE_I8: hr = VarDateFromI8(*(LONGLONG*)src, d); break;
388 case DBTYPE_UI1: hr = VarDateFromUI1(*(BYTE*)src, d); break;
389 case DBTYPE_UI2: hr = VarDateFromUI2(*(WORD*)src, d); break;
390 case DBTYPE_UI4: hr = VarDateFromUI4(*(DWORD*)src, d); break;
391 case DBTYPE_UI8: hr = VarDateFromUI8(*(ULONGLONG*)src, d); break;
392 case DBTYPE_R4: hr = VarDateFromR4(*(FLOAT*)src, d); break;
393 case DBTYPE_R8: hr = VarDateFromR8(*(DOUBLE*)src, d); break;
394 case DBTYPE_CY: hr = VarDateFromCy(*(CY*)src, d); break;
395 case DBTYPE_DATE: *d = *(DATE*)src; hr = S_OK; break;
396 case DBTYPE_BSTR: hr = VarDateFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
397 case DBTYPE_BOOL: hr = VarDateFromBool(*(VARIANT_BOOL*)src, d); break;
398 case DBTYPE_DECIMAL: hr = VarDateFromDec((DECIMAL*)src, d); break;
399 case DBTYPE_DBTIMESTAMP:
400 {
401 SYSTEMTIME st;
402 DBTIMESTAMP *ts=(DBTIMESTAMP*)src;
403
404 st.wYear = ts->year;
405 st.wMonth = ts->month;
406 st.wDay = ts->day;
407 st.wHour = ts->hour;
408 st.wMinute = ts->minute;
409 st.wSecond = ts->second;
410 st.wMilliseconds = ts->fraction/1000000;
411 hr = (SystemTimeToVariantTime(&st, d) ? S_OK : E_FAIL);
412 break;
413 }
414 default: FIXME("Unimplemented conversion %04x -> DATE\n", src_type); return E_NOTIMPL;
415 }
416 break;
417 }
418 case DBTYPE_DBDATE:
419 {
420 DBDATE *d=dst;
421 switch (src_type)
422 {
423 case DBTYPE_DBDATE: memcpy(d, src, sizeof(DBDATE)); hr = S_OK; break;
424 default: FIXME("Unimplemented conversion %04x -> DBDATE\n", src_type); return E_NOTIMPL;
425 }
426 break;
427 }
428 case DBTYPE_DBTIMESTAMP:
429 {
430 DBTIMESTAMP *d=dst;
431 switch (src_type)
432 {
433 case DBTYPE_EMPTY: memset(d, 0, sizeof(DBTIMESTAMP)); hr = S_OK; break;
434 case DBTYPE_DBTIMESTAMP: memcpy(d, src, sizeof(DBTIMESTAMP)); hr = S_OK; break;
435 case DBTYPE_DATE:
436 {
437 SYSTEMTIME st;
438 hr = (VariantTimeToSystemTime(*(double*)src, &st) ? S_OK : E_FAIL);
439 d->year = st.wYear;
440 d->month = st.wMonth;
441 d->day = st.wDay;
442 d->hour = st.wHour;
443 d->minute = st.wMinute;
444 d->second = st.wSecond;
445 d->fraction = st.wMilliseconds * 1000000;
446 break;
447 }
448 case DBTYPE_VARIANT:
449 {
450 if( V_VT((VARIANT*)src) == VT_DATE)
451 {
452 SYSTEMTIME st;
453 hr = (VariantTimeToSystemTime( V_DATE((VARIANT*)src), &st) ? S_OK : E_FAIL);
454 d->year = st.wYear;
455 d->month = st.wMonth;
456 d->day = st.wDay;
457 d->hour = st.wHour;
458 d->minute = st.wMinute;
459 d->second = st.wSecond;
460 d->fraction = st.wMilliseconds * 1000000;
461 break;
462 }
463 else
464 FIXME("Unimplemented variant type %d -> DBTIMESTAMP\n", V_VT((VARIANT*)src));
465 }
466 default: FIXME("Unimplemented conversion %04x -> DBTIMESTAMP\n", src_type); return E_NOTIMPL;
467 }
468 break;
469 }
470
471 case DBTYPE_CY:
472 {
473 CY *d = dst;
474 switch(src_type)
475 {
476 case DBTYPE_EMPTY: d->int64 = 0; hr = S_OK; break;
477 case DBTYPE_I2: hr = VarCyFromI2(*(signed short*)src, d); break;
478 case DBTYPE_I4: hr = VarCyFromI4(*(signed int*)src, d); break;
479 case DBTYPE_R4: hr = VarCyFromR4(*(FLOAT*)src, d); break;
480 case DBTYPE_R8: hr = VarCyFromR8(*(double*)src, d); break;
481 case DBTYPE_CY: *d = *(CY*)src; hr = S_OK; break;
482 case DBTYPE_DATE: hr = VarCyFromDate(*(DATE*)src, d); break;
483 case DBTYPE_BSTR: hr = VarCyFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
484 case DBTYPE_BOOL: hr = VarCyFromBool(*(VARIANT_BOOL*)src, d); break;
485 case DBTYPE_DECIMAL: hr = VarCyFromDec((DECIMAL*)src, d); break;
486 case DBTYPE_I1: hr = VarCyFromI1(*(signed char*)src, d); break;
487 case DBTYPE_UI1: hr = VarCyFromUI1(*(BYTE*)src, d); break;
488 case DBTYPE_UI2: hr = VarCyFromUI2(*(WORD*)src, d); break;
489 case DBTYPE_UI4: hr = VarCyFromUI4(*(DWORD*)src, d); break;
490 case DBTYPE_I8: hr = VarCyFromI8(*(LONGLONG*)src, d); break;
491 case DBTYPE_UI8: hr = VarCyFromUI8(*(ULONGLONG*)src, d); break;
492 default: FIXME("Unimplemented conversion %04x -> CY\n", src_type); return E_NOTIMPL;
493 }
494 break;
495 }
496
497 case DBTYPE_BSTR:
498 {
499 BSTR *d = dst;
500 switch(src_type)
501 {
502 case DBTYPE_EMPTY: *d = SysAllocStringLen(NULL, 0); hr = *d ? S_OK : E_OUTOFMEMORY; break;
503 case DBTYPE_I2: hr = VarBstrFromI2(*(signed short*)src, LOCALE_USER_DEFAULT, 0, d); break;
504 case DBTYPE_I4: hr = VarBstrFromI4(*(signed int*)src, LOCALE_USER_DEFAULT, 0, d); break;
505 case DBTYPE_R4: hr = VarBstrFromR4(*(FLOAT*)src, LOCALE_USER_DEFAULT, 0, d); break;
506 case DBTYPE_R8: hr = VarBstrFromR8(*(double*)src, LOCALE_USER_DEFAULT, 0, d); break;
507 case DBTYPE_CY: hr = VarBstrFromCy(*(CY*)src, LOCALE_USER_DEFAULT, 0, d); break;
508 case DBTYPE_DATE: hr = VarBstrFromDate(*(DATE*)src, LOCALE_USER_DEFAULT, 0, d); break;
509 case DBTYPE_BSTR: *d = SysAllocStringLen(*(BSTR*)src, SysStringLen(*(BSTR*)src)); hr = *d ? S_OK : E_OUTOFMEMORY; break;
510 case DBTYPE_BOOL: hr = VarBstrFromBool(*(VARIANT_BOOL*)src, LOCALE_USER_DEFAULT, 0, d); break;
511 case DBTYPE_DECIMAL: hr = VarBstrFromDec((DECIMAL*)src, LOCALE_USER_DEFAULT, 0, d); break;
512 case DBTYPE_I1: hr = VarBstrFromI1(*(signed char*)src, LOCALE_USER_DEFAULT, 0, d); break;
513 case DBTYPE_UI1: hr = VarBstrFromUI1(*(BYTE*)src, LOCALE_USER_DEFAULT, 0, d); break;
514 case DBTYPE_UI2: hr = VarBstrFromUI2(*(WORD*)src, LOCALE_USER_DEFAULT, 0, d); break;
515 case DBTYPE_UI4: hr = VarBstrFromUI4(*(DWORD*)src, LOCALE_USER_DEFAULT, 0, d); break;
516 case DBTYPE_I8: hr = VarBstrFromI8(*(LONGLONG*)src, LOCALE_USER_DEFAULT, 0, d); break;
517 case DBTYPE_UI8: hr = VarBstrFromUI8(*(ULONGLONG*)src, LOCALE_USER_DEFAULT, 0, d); break;
518 case DBTYPE_GUID:
519 {
520 WCHAR szBuff[39];
521 const GUID *id = (const GUID *)src;
522 WCHAR format[] = {
523 '{','%','0','8','X','-','%','0','4','X','-','%','0','4','X','-',
524 '%','0','2','X','%','0','2','X','-',
525 '%','0','2','X','%','0','2','X','%','0','2','X','%','0','2','X','%','0','2','X','%','0','2','X','}',0};
526 wsprintfW(szBuff, format,
527 id->Data1, id->Data2, id->Data3,
528 id->Data4[0], id->Data4[1], id->Data4[2], id->Data4[3],
529 id->Data4[4], id->Data4[5], id->Data4[6], id->Data4[7] );
530 *d = SysAllocString(szBuff);
531 hr = *d ? S_OK : E_OUTOFMEMORY;
532 }
533 break;
534 case DBTYPE_BYTES:
535 {
536 *d = SysAllocStringLen(NULL, 2 * src_len);
537 if (*d == NULL)
538 hr = E_OUTOFMEMORY;
539 else
540 {
541 const char hexchars[] = "0123456789ABCDEF";
542 WCHAR *s = *d;
543 unsigned char *p = src;
544 while (src_len > 0)
545 {
546 *s++ = hexchars[(*p >> 4) & 0x0F];
547 *s++ = hexchars[(*p) & 0x0F];
548 src_len--; p++;
549 }
550 hr = S_OK;
551 }
552 }
553 break;
554 case DBTYPE_VARIANT:
555 if(V_VT((VARIANT*)src) == VT_NULL)
556 {
557 *dst_status = DBSTATUS_S_ISNULL;
558 *dst_len = get_length(DBTYPE_BSTR);
559 return S_OK;
560 }
561 else
562 {
563 VariantInit(&tmp);
564 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_BSTR)) == S_OK)
565 *d = V_BSTR(&tmp);
566 }
567 break;
568 default: FIXME("Unimplemented conversion %04x -> BSTR\n", src_type); return E_NOTIMPL;
569 }
570 break;
571 }
572
573 case DBTYPE_UI1:
574 {
575 BYTE *d = dst;
576 switch(src_type)
577 {
578 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
579 case DBTYPE_I2: hr = VarUI1FromI2(*(signed short*)src, d); break;
580 case DBTYPE_I4: hr = VarUI1FromI4(*(signed int*)src, d); break;
581 case DBTYPE_R4: hr = VarUI1FromR4(*(FLOAT*)src, d); break;
582 case DBTYPE_R8: hr = VarUI1FromR8(*(double*)src, d); break;
583 case DBTYPE_CY: hr = VarUI1FromCy(*(CY*)src, d); break;
584 case DBTYPE_DATE: hr = VarUI1FromDate(*(DATE*)src, d); break;
585 case DBTYPE_BSTR: hr = VarUI1FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
586 case DBTYPE_BOOL: hr = VarUI1FromBool(*(VARIANT_BOOL*)src, d); break;
587 case DBTYPE_DECIMAL: hr = VarUI1FromDec((DECIMAL*)src, d); break;
588 case DBTYPE_I1: hr = VarUI1FromI1(*(signed char*)src, d); break;
589 case DBTYPE_UI1: *d = *(BYTE*)src; hr = S_OK; break;
590 case DBTYPE_UI2: hr = VarUI1FromUI2(*(WORD*)src, d); break;
591 case DBTYPE_UI4: hr = VarUI1FromUI4(*(DWORD*)src, d); break;
592 case DBTYPE_I8: hr = VarUI1FromI8(*(LONGLONG*)src, d); break;
593 case DBTYPE_UI8: hr = VarUI1FromUI8(*(ULONGLONG*)src, d); break;
594 default: FIXME("Unimplemented conversion %04x -> UI1\n", src_type); return E_NOTIMPL;
595 }
596 break;
597 }
598 case DBTYPE_UI2:
599 {
600 WORD *d = dst;
601 switch(src_type)
602 {
603 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
604 case DBTYPE_I2: hr = VarUI2FromI2(*(signed short*)src, d); break;
605 case DBTYPE_I4: hr = VarUI2FromI4(*(signed int*)src, d); break;
606 case DBTYPE_R4: hr = VarUI2FromR4(*(FLOAT*)src, d); break;
607 case DBTYPE_R8: hr = VarUI2FromR8(*(double*)src, d); break;
608 case DBTYPE_CY: hr = VarUI2FromCy(*(CY*)src, d); break;
609 case DBTYPE_DATE: hr = VarUI2FromDate(*(DATE*)src, d); break;
610 case DBTYPE_BSTR: hr = VarUI2FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
611 case DBTYPE_BOOL: hr = VarUI2FromBool(*(VARIANT_BOOL*)src, d); break;
612 case DBTYPE_DECIMAL: hr = VarUI2FromDec((DECIMAL*)src, d); break;
613 case DBTYPE_I1: hr = VarUI2FromI1(*(signed char*)src, d); break;
614 case DBTYPE_UI1: hr = VarUI2FromUI1(*(BYTE*)src, d); break;
615 case DBTYPE_UI2: *d = *(WORD*)src; hr = S_OK; break;
616 case DBTYPE_UI4: hr = VarUI2FromUI4(*(DWORD*)src, d); break;
617 case DBTYPE_I8: hr = VarUI2FromI8(*(LONGLONG*)src, d); break;
618 case DBTYPE_UI8: hr = VarUI2FromUI8(*(ULONGLONG*)src, d); break;
619 default: FIXME("Unimplemented conversion %04x -> UI2\n", src_type); return E_NOTIMPL;
620 }
621 break;
622 }
623
624 case DBTYPE_UI4:
625 {
626 DWORD *d = dst;
627 switch(src_type)
628 {
629 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
630 case DBTYPE_I2: hr = VarUI4FromI2(*(signed short*)src, d); break;
631 case DBTYPE_I4: hr = VarUI4FromI4(*(signed int*)src, d); break;
632 case DBTYPE_R4: hr = VarUI4FromR4(*(FLOAT*)src, d); break;
633 case DBTYPE_R8: hr = VarUI4FromR8(*(double*)src, d); break;
634 case DBTYPE_CY: hr = VarUI4FromCy(*(CY*)src, d); break;
635 case DBTYPE_DATE: hr = VarUI4FromDate(*(DATE*)src, d); break;
636 case DBTYPE_BSTR: hr = VarUI4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
637 case DBTYPE_BOOL: hr = VarUI4FromBool(*(VARIANT_BOOL*)src, d); break;
638 case DBTYPE_DECIMAL: hr = VarUI4FromDec((DECIMAL*)src, d); break;
639 case DBTYPE_I1: hr = VarUI4FromI1(*(signed char*)src, d); break;
640 case DBTYPE_UI1: hr = VarUI4FromUI1(*(BYTE*)src, d); break;
641 case DBTYPE_UI2: hr = VarUI4FromUI2(*(WORD*)src, d); break;
642 case DBTYPE_UI4: *d = *(DWORD*)src; hr = S_OK; break;
643 case DBTYPE_I8: hr = VarUI4FromI8(*(LONGLONG*)src, d); break;
644 case DBTYPE_UI8: hr = VarUI4FromUI8(*(ULONGLONG*)src, d); break;
645 case DBTYPE_VARIANT:
646 VariantInit(&tmp);
647 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_UI4)) == S_OK)
648 *d = V_UI4(&tmp);
649 break;
650 default: FIXME("Unimplemented conversion %04x -> UI4\n", src_type); return E_NOTIMPL;
651 }
652 break;
653 }
654
655 case DBTYPE_UI8:
656 {
657 ULONGLONG *d = dst;
658 switch(src_type)
659 {
660 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
661 case DBTYPE_I2: hr = VarUI8FromI2(*(signed short*)src, d); break;
662 case DBTYPE_I4: {LONGLONG s = *(signed int*)src; hr = VarUI8FromI8(s, d); break;}
663 case DBTYPE_R4: hr = VarUI8FromR4(*(FLOAT*)src, d); break;
664 case DBTYPE_R8: hr = VarUI8FromR8(*(double*)src, d); break;
665 case DBTYPE_CY: hr = VarUI8FromCy(*(CY*)src, d); break;
666 case DBTYPE_DATE: hr = VarUI8FromDate(*(DATE*)src, d); break;
667 case DBTYPE_BSTR: hr = VarUI8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
668 case DBTYPE_BOOL: hr = VarUI8FromBool(*(VARIANT_BOOL*)src, d); break;
669 case DBTYPE_DECIMAL: hr = VarUI8FromDec((DECIMAL*)src, d); break;
670 case DBTYPE_I1: hr = VarUI8FromI1(*(signed char*)src, d); break;
671 case DBTYPE_UI1: hr = VarUI8FromUI1(*(BYTE*)src, d); break;
672 case DBTYPE_UI2: hr = VarUI8FromUI2(*(WORD*)src, d); break;
673 case DBTYPE_UI4: hr = VarUI8FromUI4(*(DWORD*)src, d); break;
674 case DBTYPE_I8: hr = VarUI8FromI8(*(LONGLONG*)src, d); break;
675 case DBTYPE_UI8: *d = *(ULONGLONG*)src; hr = S_OK; break;
676 default: FIXME("Unimplemented conversion %04x -> UI8\n", src_type); return E_NOTIMPL;
677 }
678 break;
679 }
680
681 case DBTYPE_FILETIME:
682 {
683 FILETIME *d = dst;
684 switch(src_type)
685 {
686 case DBTYPE_EMPTY: d->dwLowDateTime = d->dwHighDateTime = 0; hr = S_OK; break;
687 case DBTYPE_FILETIME: *d = *(FILETIME*)src; hr = S_OK; break;
688 default: FIXME("Unimplemented conversion %04x -> FILETIME\n", src_type); return E_NOTIMPL;
689 }
690 break;
691 }
692
693 case DBTYPE_GUID:
694 {
695 GUID *d = dst;
696 switch(src_type)
697 {
698 case DBTYPE_EMPTY: *d = GUID_NULL; hr = S_OK; break;
699 case DBTYPE_GUID: *d = *(GUID*)src; hr = S_OK; break;
700 default: FIXME("Unimplemented conversion %04x -> GUID\n", src_type); return E_NOTIMPL;
701 }
702 break;
703 }
704
705 case DBTYPE_WSTR:
706 {
707 BSTR b;
708 DBLENGTH bstr_len;
709 INT bytes_to_copy;
710 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &bstr_len,
711 src, &b, sizeof(BSTR), src_status, dst_status,
712 precision, scale, flags);
713 if(hr != S_OK) return hr;
714 bstr_len = SysStringLen(b);
715 *dst_len = bstr_len * sizeof(WCHAR); /* Doesn't include size for '\0' */
716 *dst_status = DBSTATUS_S_OK;
717 bytes_to_copy = min(*dst_len + sizeof(WCHAR), dst_max_len);
718 if(dst)
719 {
720 if(bytes_to_copy >= sizeof(WCHAR))
721 {
722 memcpy(dst, b, bytes_to_copy - sizeof(WCHAR));
723 *((WCHAR*)dst + bytes_to_copy / sizeof(WCHAR) - 1) = 0;
724 if(bytes_to_copy < *dst_len + sizeof(WCHAR))
725 *dst_status = DBSTATUS_S_TRUNCATED;
726 }
727 else
728 {
729 *dst_status = DBSTATUS_E_DATAOVERFLOW;
730 hr = DB_E_ERRORSOCCURRED;
731 }
732 }
733 SysFreeString(b);
734 return hr;
735 }
736 case DBTYPE_STR:
737 {
738 BSTR b;
739 DBLENGTH bstr_len;
740 INT bytes_to_copy;
741 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &bstr_len,
742 src, &b, sizeof(BSTR), src_status, dst_status,
743 precision, scale, flags);
744 if(hr != S_OK) return hr;
745 bstr_len = SysStringLen(b);
746 *dst_len = bstr_len * sizeof(char); /* Doesn't include size for '\0' */
747 *dst_status = DBSTATUS_S_OK;
748 bytes_to_copy = min(*dst_len + sizeof(char), dst_max_len);
749 if(dst)
750 {
751 if(bytes_to_copy >= sizeof(char))
752 {
753 WideCharToMultiByte(CP_ACP, 0, b, bytes_to_copy - sizeof(char), dst, dst_max_len, NULL, NULL);
754 *((char *)dst + bytes_to_copy / sizeof(char) - 1) = 0;
755 if(bytes_to_copy < *dst_len + sizeof(char))
756 *dst_status = DBSTATUS_S_TRUNCATED;
757 }
758 else
759 {
760 *dst_status = DBSTATUS_E_DATAOVERFLOW;
761 hr = DB_E_ERRORSOCCURRED;
762 }
763 }
764 SysFreeString(b);
765 return hr;
766 }
767
768 case DBTYPE_BYREF | DBTYPE_WSTR:
769 {
770 BSTR b;
771 WCHAR **d = dst;
772 DBLENGTH bstr_len;
773 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &bstr_len,
774 src, &b, sizeof(BSTR), src_status, dst_status,
775 precision, scale, flags);
776 if(hr != S_OK) return hr;
777
778 bstr_len = SysStringLen(b) * sizeof(WCHAR);
779 *dst_len = bstr_len; /* Doesn't include size for '\0' */
780
781 *d = CoTaskMemAlloc(bstr_len + sizeof(WCHAR));
782 if(*d) memcpy(*d, b, bstr_len + sizeof(WCHAR));
783 else hr = E_OUTOFMEMORY;
784 SysFreeString(b);
785 return hr;
786 }
787
788 case DBTYPE_VARIANT:
789 {
790 VARIANT *v = dst;
791
792 if(src_status == DBSTATUS_S_ISNULL)
793 {
794 *dst_status = DBSTATUS_S_ISNULL;
795 *dst_len = 0;
796 return S_OK;
797 }
798
799 switch(src_type)
800 {
801 case DBTYPE_BOOL:
802 V_VT(v) = VT_BOOL;
803 V_BOOL(v) = *(VARIANT_BOOL*)src;
804 hr = S_OK;
805 break;
806 case DBTYPE_I4:
807 V_VT(v) = VT_I4;
808 V_I4(v) = *(signed int*)src;
809 hr = S_OK;
810 break;
811 case DBTYPE_I8:
812 V_VT(v) = VT_DECIMAL;
813 hr = VarDecFromI8( *(LONGLONG*)src, &V_DECIMAL(v));
814 break;
815 case DBTYPE_R8:
816 V_VT(v) = VT_R8;
817 V_R8(v) = *(double*)src;
818 hr = S_OK;
819 break;
820 case DBTYPE_BSTR:
821 {
822 BSTR s = *(WCHAR**)src;
823 TRACE("%s\n", debugstr_w(s));
824 V_VT(v) = VT_BSTR;
825 V_BSTR(v) = SysAllocString(s);
826 hr = V_BSTR(v) ? S_OK : E_OUTOFMEMORY;
827 break;
828 }
829 case DBTYPE_DATE:
830 V_VT(v) = VT_DATE;
831 V_DATE(v) = *(DATE*)src;
832 hr = S_OK;
833 break;
834 case DBTYPE_DBDATE:
835 {
836 SYSTEMTIME st;
837 DBDATE *ts=(DBDATE*)src;
838
839 V_VT(v) = VT_DATE;
840
841 st.wYear = ts->year;
842 st.wMonth = ts->month;
843 st.wDay = ts->day;
844 st.wHour = 0;
845 st.wMinute = 0;
846 st.wSecond = 0;
847 st.wMilliseconds = 0;
848 hr = (SystemTimeToVariantTime(&st, &V_DATE(v)) ? S_OK : E_FAIL);
849 break;
850 }
851 case DBTYPE_DBTIMESTAMP:
852 {
853 SYSTEMTIME st;
854 DBTIMESTAMP *ts = (DBTIMESTAMP *)src;
855
856 V_VT(v) = VT_DATE;
857
858 st.wYear = ts->year;
859 st.wMonth = ts->month;
860 st.wDay = ts->day;
861 st.wHour = ts->hour;
862 st.wMinute = ts->minute;
863 st.wSecond = ts->second;
864 st.wMilliseconds = ts->fraction/1000000;
865 hr = SystemTimeToVariantTime(&st, &V_DATE(v)) ? S_OK : E_FAIL;
866 break;
867 }
868 case DBTYPE_CY:
869 V_VT(v) = VT_CY;
870 V_CY(v) = *(CY*)src;
871 hr = S_OK;
872 break;
873 case DBTYPE_BYTES:
874 {
875 LONG i;
876 LONG size;
877 SAFEARRAY *psa = NULL;
878 SAFEARRAYBOUND rgsabound[1];
879 unsigned char *p = src;
880
881 size = min(src_len, dst_max_len);
882
883 rgsabound[0].lLbound = 0;
884 rgsabound[0].cElements = size;
885
886 psa = SafeArrayCreate(VT_UI1,1,rgsabound);
887 for(i =0; i < size; i++,p++)
888 {
889 hr = SafeArrayPutElement(psa, &i, &p);
890 if(FAILED(hr))
891 return hr;
892 }
893
894 V_VT(v) = VT_ARRAY|VT_UI1;
895 V_ARRAY(v) = psa;
896 hr = S_OK;
897 break;
898 }
899 default: FIXME("Unimplemented conversion %04x -> VARIANT\n", src_type); return E_NOTIMPL;
900 }
901 break;
902 }
903 case DBTYPE_BYTES:
904 {
905 BYTE *d = dst;
906
907 switch(src_type)
908 {
909 case DBTYPE_BYTES:
910 if( src_len > dst_max_len)
911 *dst_status = DBSTATUS_S_TRUNCATED;
912 else
913 *dst_status = DBSTATUS_S_OK;
914
915 *dst_len = src_len;
916 memcpy(d, src, min(src_len, dst_max_len));
917
918 return S_OK;
919 default: FIXME("Unimplemented conversion %04x -> DBTYPE_BYTES\n", src_type); return E_NOTIMPL;
920 }
921 break;
922 }
923
924 default:
925 FIXME("Unimplemented conversion %04x -> %04x\n", src_type, dst_type);
926 return E_NOTIMPL;
927 }
928
929 if(hr == DISP_E_OVERFLOW)
930 {
931 *dst_status = DBSTATUS_E_DATAOVERFLOW;
932 *dst_len = get_length(dst_type);
933 hr = DB_E_ERRORSOCCURRED;
934 }
935 else if(hr == S_OK)
936 {
937 *dst_status = DBSTATUS_S_OK;
938 *dst_len = get_length(dst_type);
939 }
940
941 return hr;
942 }
943
944 static inline WORD get_dbtype_class(DBTYPE type)
945 {
946 switch(type)
947 {
948 case DBTYPE_I2:
949 case DBTYPE_R4:
950 case DBTYPE_R8:
951 case DBTYPE_I1:
952 case DBTYPE_UI1:
953 case DBTYPE_UI2:
954 return DBTYPE_I2;
955
956 case DBTYPE_I4:
957 case DBTYPE_UI4:
958 return DBTYPE_I4;
959
960 case DBTYPE_I8:
961 case DBTYPE_UI8:
962 return DBTYPE_I8;
963
964 case DBTYPE_BSTR:
965 case DBTYPE_STR:
966 case DBTYPE_WSTR:
967 return DBTYPE_BSTR;
968
969 case DBTYPE_DBDATE:
970 case DBTYPE_DBTIME:
971 case DBTYPE_DBTIMESTAMP:
972 return DBTYPE_DBDATE;
973 }
974 return type;
975 }
976
977 /* Many src types will convert to this group of dst types */
978 static inline BOOL common_class(WORD dst_class)
979 {
980 switch(dst_class)
981 {
982 case DBTYPE_EMPTY:
983 case DBTYPE_NULL:
984 case DBTYPE_I2:
985 case DBTYPE_I4:
986 case DBTYPE_BSTR:
987 case DBTYPE_BOOL:
988 case DBTYPE_VARIANT:
989 case DBTYPE_I8:
990 case DBTYPE_CY:
991 case DBTYPE_DECIMAL:
992 case DBTYPE_NUMERIC:
993 return TRUE;
994 }
995 return FALSE;
996 }
997
998 static inline BOOL array_type(DBTYPE type)
999 {
1000 return (type >= DBTYPE_I2 && type <= DBTYPE_UI4);
1001 }
1002
1003 static HRESULT WINAPI convert_CanConvert(IDataConvert* iface,
1004 DBTYPE src_type, DBTYPE dst_type)
1005 {
1006 convert *This = impl_from_IDataConvert(iface);
1007 DBTYPE src_base_type = src_type & 0x1ff;
1008 DBTYPE dst_base_type = dst_type & 0x1ff;
1009 WORD dst_class = get_dbtype_class(dst_base_type);
1010
1011 TRACE("(%p)->(%d, %d)\n", This, src_type, dst_type);
1012
1013 if(src_type & DBTYPE_VECTOR || dst_type & DBTYPE_VECTOR) return S_FALSE;
1014
1015 if(src_type & DBTYPE_ARRAY)
1016 {
1017 if(!array_type(src_base_type)) return S_FALSE;
1018 if(dst_type & DBTYPE_ARRAY)
1019 {
1020 if(src_type == dst_type) return S_OK;
1021 return S_FALSE;
1022 }
1023 if(dst_type == DBTYPE_VARIANT) return S_OK;
1024 return S_FALSE;
1025 }
1026
1027 if(dst_type & DBTYPE_ARRAY)
1028 {
1029 if(!array_type(dst_base_type)) return S_FALSE;
1030 if(src_type == DBTYPE_IDISPATCH || src_type == DBTYPE_VARIANT) return S_OK;
1031 return S_FALSE;
1032 }
1033
1034 if(dst_type & DBTYPE_BYREF)
1035 if(dst_base_type != DBTYPE_BYTES && dst_base_type != DBTYPE_STR && dst_base_type != DBTYPE_WSTR)
1036 return S_FALSE;
1037
1038 switch(get_dbtype_class(src_base_type))
1039 {
1040 case DBTYPE_EMPTY:
1041 if(common_class(dst_class)) return S_OK;
1042 switch(dst_class)
1043 {
1044 case DBTYPE_DATE:
1045 case DBTYPE_GUID:
1046 case DBTYPE_FILETIME:
1047 return S_OK;
1048 default:
1049 if(dst_base_type == DBTYPE_DBTIMESTAMP) return S_OK;
1050 return S_FALSE;
1051 }
1052
1053 case DBTYPE_NULL:
1054 switch(dst_base_type)
1055 {
1056 case DBTYPE_NULL:
1057 case DBTYPE_VARIANT:
1058 case DBTYPE_FILETIME: return S_OK;
1059 default: return S_FALSE;
1060 }
1061
1062 case DBTYPE_I4:
1063 if(dst_base_type == DBTYPE_BYTES) return S_OK;
1064 /* fall through */
1065 case DBTYPE_I2:
1066 if(dst_base_type == DBTYPE_DATE) return S_OK;
1067 /* fall through */
1068 case DBTYPE_DECIMAL:
1069 if(common_class(dst_class)) return S_OK;
1070 if(dst_class == DBTYPE_DBDATE) return S_OK;
1071 return S_FALSE;
1072
1073 case DBTYPE_BOOL:
1074 if(dst_base_type == DBTYPE_DATE) return S_OK;
1075 /* fall through */
1076 case DBTYPE_NUMERIC:
1077 case DBTYPE_CY:
1078 if(common_class(dst_class)) return S_OK;
1079 return S_FALSE;
1080
1081 case DBTYPE_I8:
1082 if(common_class(dst_class)) return S_OK;
1083 switch(dst_base_type)
1084 {
1085 case DBTYPE_BYTES:
1086 case DBTYPE_FILETIME: return S_OK;
1087 default: return S_FALSE;
1088 }
1089
1090 case DBTYPE_DATE:
1091 switch(dst_class)
1092 {
1093 case DBTYPE_EMPTY:
1094 case DBTYPE_NULL:
1095 case DBTYPE_I2:
1096 case DBTYPE_I4:
1097 case DBTYPE_BSTR:
1098 case DBTYPE_BOOL:
1099 case DBTYPE_VARIANT:
1100 case DBTYPE_I8:
1101 case DBTYPE_DATE:
1102 case DBTYPE_DBDATE:
1103 case DBTYPE_FILETIME:
1104 return S_OK;
1105 default: return S_FALSE;
1106 }
1107
1108 case DBTYPE_IDISPATCH:
1109 case DBTYPE_VARIANT:
1110 switch(dst_base_type)
1111 {
1112 case DBTYPE_IDISPATCH:
1113 case DBTYPE_ERROR:
1114 case DBTYPE_IUNKNOWN:
1115 return S_OK;
1116 }
1117 /* fall through */
1118 case DBTYPE_BSTR:
1119 if(common_class(dst_class)) return S_OK;
1120 switch(dst_class)
1121 {
1122 case DBTYPE_DATE:
1123 case DBTYPE_GUID:
1124 case DBTYPE_BYTES:
1125 case DBTYPE_DBDATE:
1126 case DBTYPE_FILETIME:
1127 return S_OK;
1128 default: return S_FALSE;
1129 }
1130
1131 case DBTYPE_ERROR:
1132 switch(dst_base_type)
1133 {
1134 case DBTYPE_BSTR:
1135 case DBTYPE_ERROR:
1136 case DBTYPE_VARIANT:
1137 case DBTYPE_WSTR:
1138 return S_OK;
1139 default: return S_FALSE;
1140 }
1141
1142 case DBTYPE_IUNKNOWN:
1143 switch(dst_base_type)
1144 {
1145 case DBTYPE_EMPTY:
1146 case DBTYPE_NULL:
1147 case DBTYPE_IDISPATCH:
1148 case DBTYPE_VARIANT:
1149 case DBTYPE_IUNKNOWN:
1150 return S_OK;
1151 default: return S_FALSE;
1152 }
1153
1154 case DBTYPE_BYTES:
1155 if(dst_class == DBTYPE_I4 || dst_class == DBTYPE_I8) return S_OK;
1156 /* fall through */
1157 case DBTYPE_GUID:
1158 switch(dst_class)
1159 {
1160 case DBTYPE_EMPTY:
1161 case DBTYPE_NULL:
1162 case DBTYPE_BSTR:
1163 case DBTYPE_VARIANT:
1164 case DBTYPE_GUID:
1165 case DBTYPE_BYTES:
1166 return S_OK;
1167 default: return S_FALSE;
1168 }
1169
1170 case DBTYPE_FILETIME:
1171 if(dst_class == DBTYPE_I8) return S_OK;
1172 /* fall through */
1173 case DBTYPE_DBDATE:
1174 switch(dst_class)
1175 {
1176 case DBTYPE_EMPTY:
1177 case DBTYPE_NULL:
1178 case DBTYPE_DATE:
1179 case DBTYPE_BSTR:
1180 case DBTYPE_VARIANT:
1181 case DBTYPE_DBDATE:
1182 case DBTYPE_FILETIME:
1183 return S_OK;
1184 default: return S_FALSE;
1185 }
1186
1187 }
1188 return S_FALSE;
1189 }
1190
1191 static HRESULT WINAPI convert_GetConversionSize(IDataConvert* iface,
1192 DBTYPE src_type, DBTYPE dst_type,
1193 DBLENGTH *src_len, DBLENGTH *dst_len,
1194 void *src)
1195 {
1196 convert *This = impl_from_IDataConvert(iface);
1197 HRESULT hr;
1198
1199 TRACE("(%p)->(%d, %d, %p, %p, %p)\n", This, src_type, dst_type, src_len, dst_len, src);
1200
1201 hr = IDataConvert_CanConvert(iface, src_type, dst_type);
1202 if (hr != S_OK)
1203 return DB_E_UNSUPPORTEDCONVERSION;
1204
1205 if (!dst_len)
1206 return E_INVALIDARG;
1207
1208 /* for some types we don't need to look into source data */
1209 if ((*dst_len = get_length(dst_type)))
1210 return S_OK;
1211
1212 switch (dst_type)
1213 {
1214 case DBTYPE_STR:
1215 {
1216 switch (src_type)
1217 {
1218 case DBTYPE_VARIANT:
1219 {
1220 VARIANT v;
1221
1222 VariantInit(&v);
1223 if ((hr = VariantChangeType(&v, (VARIANT*)src, 0, VT_BSTR)) == S_OK)
1224 {
1225 *dst_len = WideCharToMultiByte(CP_ACP, 0, V_BSTR(&v), -1, NULL, 0, NULL, NULL);
1226 VariantClear(&v);
1227 }
1228 else
1229 return hr;
1230 }
1231 break;
1232 default:
1233 FIXME("unimplemented for %04x -> DBTYPE_STR\n", src_type);
1234 return E_NOTIMPL;
1235 }
1236 }
1237 break;
1238 case DBTYPE_WSTR:
1239 {
1240 switch (src_type)
1241 {
1242 case DBTYPE_VARIANT:
1243 {
1244 VARIANT v;
1245
1246 VariantInit(&v);
1247 if ((hr = VariantChangeType(&v, (VARIANT*)src, 0, VT_BSTR)) == S_OK)
1248 {
1249 *dst_len = (SysStringLen(V_BSTR(&v)) + 1) * sizeof(WCHAR);
1250 VariantClear(&v);
1251 }
1252 else
1253 return hr;
1254 }
1255 break;
1256 case DBTYPE_STR:
1257 if(src_len)
1258 *dst_len = (*src_len + 1) * sizeof(WCHAR);
1259 else
1260 *dst_len = (strlen(src) + 1) * sizeof(WCHAR);
1261 break;
1262 case DBTYPE_WSTR:
1263 if(src_len)
1264 *dst_len = (*src_len) + sizeof(WCHAR);
1265 else
1266 *dst_len = (lstrlenW(src) + 1) * sizeof(WCHAR);
1267 break;
1268 default:
1269 FIXME("unimplemented for %04x -> DBTYPE_WSTR\n", src_type);
1270 return E_NOTIMPL;
1271 }
1272 }
1273 break;
1274 default:
1275 FIXME("unimplemented for conversion %d->%d\n", src_type, dst_type);
1276 return E_NOTIMPL;
1277 }
1278
1279 return S_OK;
1280 }
1281
1282 static const struct IDataConvertVtbl convert_vtbl =
1283 {
1284 convert_QueryInterface,
1285 convert_AddRef,
1286 convert_Release,
1287 convert_DataConvert,
1288 convert_CanConvert,
1289 convert_GetConversionSize
1290 };
1291
1292 static HRESULT WINAPI dcinfo_QueryInterface(IDCInfo* iface, REFIID riid, void **obj)
1293 {
1294 convert *This = impl_from_IDCInfo(iface);
1295
1296 return IDataConvert_QueryInterface(&This->IDataConvert_iface, riid, obj);
1297 }
1298
1299 static ULONG WINAPI dcinfo_AddRef(IDCInfo* iface)
1300 {
1301 convert *This = impl_from_IDCInfo(iface);
1302
1303 return IDataConvert_AddRef(&This->IDataConvert_iface);
1304 }
1305
1306 static ULONG WINAPI dcinfo_Release(IDCInfo* iface)
1307 {
1308 convert *This = impl_from_IDCInfo(iface);
1309
1310 return IDataConvert_Release(&This->IDataConvert_iface);
1311 }
1312
1313 static HRESULT WINAPI dcinfo_GetInfo(IDCInfo *iface, ULONG num, DCINFOTYPE types[], DCINFO **info_ptr)
1314 {
1315 convert *This = impl_from_IDCInfo(iface);
1316 ULONG i;
1317 DCINFO *infos;
1318
1319 TRACE("(%p)->(%d, %p, %p)\n", This, num, types, info_ptr);
1320
1321 *info_ptr = infos = CoTaskMemAlloc(num * sizeof(*infos));
1322 if(!infos) return E_OUTOFMEMORY;
1323
1324 for(i = 0; i < num; i++)
1325 {
1326 infos[i].eInfoType = types[i];
1327 VariantInit(&infos[i].vData);
1328
1329 switch(types[i])
1330 {
1331 case DCINFOTYPE_VERSION:
1332 V_VT(&infos[i].vData) = VT_UI4;
1333 V_UI4(&infos[i].vData) = This->version;
1334 break;
1335 }
1336 }
1337
1338 return S_OK;
1339 }
1340
1341 static HRESULT WINAPI dcinfo_SetInfo(IDCInfo* iface, ULONG num, DCINFO info[])
1342 {
1343 convert *This = impl_from_IDCInfo(iface);
1344 ULONG i;
1345 HRESULT hr = S_OK;
1346
1347 TRACE("(%p)->(%d, %p)\n", This, num, info);
1348
1349 for(i = 0; i < num; i++)
1350 {
1351 switch(info[i].eInfoType)
1352 {
1353 case DCINFOTYPE_VERSION:
1354 if(V_VT(&info[i].vData) != VT_UI4)
1355 {
1356 FIXME("VERSION with vt %x\n", V_VT(&info[i].vData));
1357 hr = DB_S_ERRORSOCCURRED;
1358 break;
1359 }
1360 This->version = V_UI4(&info[i].vData);
1361 break;
1362
1363 default:
1364 FIXME("Unhandled info type %d (vt %x)\n", info[i].eInfoType, V_VT(&info[i].vData));
1365 }
1366 }
1367 return hr;
1368 }
1369
1370 static const struct IDCInfoVtbl dcinfo_vtbl =
1371 {
1372 dcinfo_QueryInterface,
1373 dcinfo_AddRef,
1374 dcinfo_Release,
1375 dcinfo_GetInfo,
1376 dcinfo_SetInfo
1377 };
1378
1379 HRESULT create_oledb_convert(IUnknown *outer, void **obj)
1380 {
1381 convert *This;
1382
1383 TRACE("(%p, %p)\n", outer, obj);
1384
1385 *obj = NULL;
1386
1387 if(outer) return CLASS_E_NOAGGREGATION;
1388
1389 This = HeapAlloc(GetProcessHeap(), 0, sizeof(*This));
1390 if(!This) return E_OUTOFMEMORY;
1391
1392 This->IDataConvert_iface.lpVtbl = &convert_vtbl;
1393 This->IDCInfo_iface.lpVtbl = &dcinfo_vtbl;
1394 This->ref = 1;
1395 This->version = 0x110;
1396
1397 *obj = &This->IDataConvert_iface;
1398
1399 return S_OK;
1400 }
Maarten's multimedia branch