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