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