oledb32: Coerce Variant to VT_DATE when converting data.
[wine.git] / dlls / oledb32 / convert.c
blob22609aed8808177caff4addc883999b4a183c01c
1 /* OLE DB Conversion library
3 * Copyright 2009 Huw Davies
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.
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.
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
20 #include <stdarg.h>
22 #define COBJMACROS
24 #include "windef.h"
25 #include "winbase.h"
26 #include "winnls.h"
27 #include "ole2.h"
28 #include "msdadc.h"
29 #include "oledberr.h"
31 #include "oledb_private.h"
33 #include "wine/debug.h"
35 WINE_DEFAULT_DEBUG_CHANNEL(oledb);
37 typedef struct
39 IDataConvert IDataConvert_iface;
40 IDCInfo IDCInfo_iface;
42 LONG ref;
44 UINT version; /* Set by IDCInfo_SetInfo */
45 } convert;
47 static inline convert *impl_from_IDataConvert(IDataConvert *iface)
49 return CONTAINING_RECORD(iface, convert, IDataConvert_iface);
52 static inline convert *impl_from_IDCInfo(IDCInfo *iface)
54 return CONTAINING_RECORD(iface, convert, IDCInfo_iface);
57 static HRESULT WINAPI convert_QueryInterface(IDataConvert* iface,
58 REFIID riid,
59 void **obj)
61 convert *This = impl_from_IDataConvert(iface);
62 TRACE("(%p)->(%s, %p)\n", This, debugstr_guid(riid), obj);
64 *obj = NULL;
66 if(IsEqualIID(riid, &IID_IUnknown) ||
67 IsEqualIID(riid, &IID_IDataConvert))
69 *obj = iface;
71 else if(IsEqualIID(riid, &IID_IDCInfo))
73 *obj = &This->IDCInfo_iface;
75 else
77 FIXME("interface %s not implemented\n", debugstr_guid(riid));
78 return E_NOINTERFACE;
81 IDataConvert_AddRef(iface);
82 return S_OK;
86 static ULONG WINAPI convert_AddRef(IDataConvert* iface)
88 convert *This = impl_from_IDataConvert(iface);
89 TRACE("(%p)\n", This);
91 return InterlockedIncrement(&This->ref);
95 static ULONG WINAPI convert_Release(IDataConvert* iface)
97 convert *This = impl_from_IDataConvert(iface);
98 LONG ref;
100 TRACE("(%p)\n", This);
102 ref = InterlockedDecrement(&This->ref);
103 if(ref == 0)
104 heap_free(This);
106 return ref;
109 static int get_length(DBTYPE type)
111 switch(type)
113 case DBTYPE_I1:
114 case DBTYPE_UI1:
115 return 1;
116 case DBTYPE_I2:
117 case DBTYPE_UI2:
118 return 2;
119 case DBTYPE_BOOL:
120 return sizeof(VARIANT_BOOL);
121 case DBTYPE_I4:
122 case DBTYPE_UI4:
123 case DBTYPE_R4:
124 return 4;
125 case DBTYPE_I8:
126 case DBTYPE_UI8:
127 case DBTYPE_R8:
128 case DBTYPE_DATE:
129 return 8;
130 case DBTYPE_DBDATE:
131 return sizeof(DBDATE);
132 case DBTYPE_DBTIMESTAMP:
133 return sizeof(DBTIMESTAMP);
134 case DBTYPE_CY:
135 return sizeof(CY);
136 case DBTYPE_BSTR:
137 return sizeof(BSTR);
138 case DBTYPE_FILETIME:
139 return sizeof(FILETIME);
140 case DBTYPE_GUID:
141 return sizeof(GUID);
142 case DBTYPE_NUMERIC:
143 return sizeof(DB_NUMERIC);
144 case DBTYPE_BYTES:
145 case DBTYPE_WSTR:
146 case DBTYPE_STR:
147 case DBTYPE_BYREF | DBTYPE_WSTR:
148 return 0;
149 case DBTYPE_VARIANT:
150 return sizeof(VARIANT);
151 default:
152 FIXME("Unhandled type %04x\n", type);
153 return 0;
157 static HRESULT WINAPI convert_DataConvert(IDataConvert* iface,
158 DBTYPE src_type, DBTYPE dst_type,
159 DBLENGTH src_len, DBLENGTH *dst_len,
160 void *src, void *dst,
161 DBLENGTH dst_max_len,
162 DBSTATUS src_status, DBSTATUS *dst_status,
163 BYTE precision, BYTE scale,
164 DBDATACONVERT flags)
166 convert *This = impl_from_IDataConvert(iface);
167 DBLENGTH dst_len_loc;
168 DBSTATUS dst_status_loc;
169 VARIANT tmp;
170 HRESULT hr;
172 TRACE("(%p)->(%d, %d, %ld, %p, %p, %p, %ld, %d, %p, %d, %d, %x)\n", This,
173 src_type, dst_type, src_len, dst_len, src, dst, dst_max_len,
174 src_status, dst_status, precision, scale, flags);
176 if (!dst_len) dst_len = &dst_len_loc;
177 if (!dst_status) dst_status = &dst_status_loc;
179 *dst_status = DBSTATUS_E_BADACCESSOR;
181 if(src_status == DBSTATUS_S_ISNULL)
183 *dst_status = DBSTATUS_S_ISNULL;
184 *dst_len = 0;
185 return S_OK;
188 if(src_type == DBTYPE_VARIANT && V_VT((VARIANT*)src) == VT_NULL)
190 if(dst_type == DBTYPE_VARIANT)
191 *dst_len = sizeof(VARIANT);
193 *dst_status = DBSTATUS_S_ISNULL;
194 return S_OK;
197 if(IDataConvert_CanConvert(iface, src_type, dst_type) != S_OK)
199 return DB_E_UNSUPPORTEDCONVERSION;
202 if(dst == NULL && get_length(dst_type) != 0)
204 *dst_len = get_length(src_type);
205 *dst_status = DBSTATUS_S_OK;
206 return S_OK;
209 if(src_type == DBTYPE_STR)
211 BSTR b;
212 DWORD len;
214 if(flags & DBDATACONVERT_LENGTHFROMNTS)
215 len = MultiByteToWideChar(CP_ACP, 0, src, -1, NULL, 0) - 1;
216 else
217 len = MultiByteToWideChar(CP_ACP, 0, src, src_len, NULL, 0);
218 b = SysAllocStringLen(NULL, len);
219 if(!b) return E_OUTOFMEMORY;
220 if(flags & DBDATACONVERT_LENGTHFROMNTS)
221 MultiByteToWideChar(CP_ACP, 0, src, -1, b, len + 1);
222 else
223 MultiByteToWideChar(CP_ACP, 0, src, src_len, b, len);
225 hr = IDataConvert_DataConvert(iface, DBTYPE_BSTR, dst_type, 0, dst_len,
226 &b, dst, dst_max_len, src_status, dst_status,
227 precision, scale, flags);
229 SysFreeString(b);
230 return hr;
233 if(src_type == DBTYPE_WSTR)
235 BSTR b;
237 if(flags & DBDATACONVERT_LENGTHFROMNTS)
238 b = SysAllocString(src);
239 else
240 b = SysAllocStringLen(src, src_len / 2);
241 if(!b) return E_OUTOFMEMORY;
242 hr = IDataConvert_DataConvert(iface, DBTYPE_BSTR, dst_type, 0, dst_len,
243 &b, dst, dst_max_len, src_status, dst_status,
244 precision, scale, flags);
245 SysFreeString(b);
246 return hr;
249 switch(dst_type)
251 case DBTYPE_I2:
253 signed short *d = dst;
254 switch(src_type)
256 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
257 case DBTYPE_I2: *d = *(signed short*)src; hr = S_OK; break;
258 case DBTYPE_I4: hr = VarI2FromI4(*(signed int*)src, d); break;
259 case DBTYPE_R4: hr = VarI2FromR4(*(FLOAT*)src, d); break;
260 case DBTYPE_R8: hr = VarI2FromR8(*(double*)src, d); break;
261 case DBTYPE_CY: hr = VarI2FromCy(*(CY*)src, d); break;
262 case DBTYPE_DATE: hr = VarI2FromDate(*(DATE*)src, d); break;
263 case DBTYPE_BSTR: hr = VarI2FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
264 case DBTYPE_BOOL: hr = VarI2FromBool(*(VARIANT_BOOL*)src, d); break;
265 case DBTYPE_DECIMAL: hr = VarI2FromDec((DECIMAL*)src, d); break;
266 case DBTYPE_I1: hr = VarI2FromI1(*(signed char*)src, d); break;
267 case DBTYPE_UI1: hr = VarI2FromUI1(*(BYTE*)src, d); break;
268 case DBTYPE_UI2: hr = VarI2FromUI2(*(WORD*)src, d); break;
269 case DBTYPE_UI4: hr = VarI2FromUI4(*(DWORD*)src, d); break;
270 case DBTYPE_I8: hr = VarI2FromI8(*(LONGLONG*)src, d); break;
271 case DBTYPE_UI8: hr = VarI2FromUI8(*(ULONGLONG*)src, d); break;
272 case DBTYPE_VARIANT:
273 VariantInit(&tmp);
274 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_I2)) == S_OK)
275 *d = V_I2(&tmp);
276 break;
277 default: FIXME("Unimplemented conversion %04x -> I2\n", src_type); return E_NOTIMPL;
279 break;
282 case DBTYPE_I4:
284 signed int *d = dst;
285 switch(src_type)
287 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
288 case DBTYPE_I2: hr = VarI4FromI2(*(signed short*)src, d); break;
289 case DBTYPE_I4: *d = *(signed int*)src; hr = S_OK; break;
290 case DBTYPE_R4: hr = VarI4FromR4(*(FLOAT*)src, d); break;
291 case DBTYPE_R8: hr = VarI4FromR8(*(double*)src, d); break;
292 case DBTYPE_CY: hr = VarI4FromCy(*(CY*)src, d); break;
293 case DBTYPE_DATE: hr = VarI4FromDate(*(DATE*)src, d); break;
294 case DBTYPE_BSTR: hr = VarI4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
295 case DBTYPE_BOOL: hr = VarI4FromBool(*(VARIANT_BOOL*)src, d); break;
296 case DBTYPE_DECIMAL: hr = VarI4FromDec((DECIMAL*)src, d); break;
297 case DBTYPE_I1: hr = VarI4FromI1(*(signed char*)src, d); break;
298 case DBTYPE_UI1: hr = VarI4FromUI1(*(BYTE*)src, d); break;
299 case DBTYPE_UI2: hr = VarI4FromUI2(*(WORD*)src, d); break;
300 case DBTYPE_UI4: hr = VarI4FromUI4(*(DWORD*)src, d); break;
301 case DBTYPE_I8: hr = VarI4FromI8(*(LONGLONG*)src, d); break;
302 case DBTYPE_UI8: hr = VarI4FromUI8(*(ULONGLONG*)src, d); break;
303 case DBTYPE_VARIANT:
304 VariantInit(&tmp);
305 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_I4)) == S_OK)
306 *d = V_I4(&tmp);
307 break;
308 default: FIXME("Unimplemented conversion %04x -> I4\n", src_type); return E_NOTIMPL;
310 break;
313 case DBTYPE_I8:
315 LONGLONG *d = dst;
316 switch(src_type)
318 case DBTYPE_BSTR: hr = VarI8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
319 case DBTYPE_I8: *d = *(LONGLONG*)src; hr = S_OK; break;
320 default: FIXME("Unimplemented conversion %04x -> I8\n", src_type); return E_NOTIMPL;
322 break;
325 case DBTYPE_R4:
327 FLOAT *d = dst;
328 switch(src_type)
330 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
331 case DBTYPE_I2: hr = VarR4FromI2(*(signed short*)src, d); break;
332 case DBTYPE_I4: hr = VarR4FromI4(*(signed int*)src, d); break;
333 case DBTYPE_R4: *d = *(FLOAT*)src; hr = S_OK; break;
334 case DBTYPE_R8: hr = VarR4FromR8(*(double*)src, d); break;
335 case DBTYPE_CY: hr = VarR4FromCy(*(CY*)src, d); break;
336 case DBTYPE_DATE: hr = VarR4FromDate(*(DATE*)src, d); break;
337 case DBTYPE_BSTR: hr = VarR4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
338 case DBTYPE_BOOL: hr = VarR4FromBool(*(VARIANT_BOOL*)src, d); break;
339 case DBTYPE_DECIMAL: hr = VarR4FromDec((DECIMAL*)src, d); break;
340 case DBTYPE_I1: hr = VarR4FromI1(*(signed char*)src, d); break;
341 case DBTYPE_UI1: hr = VarR4FromUI1(*(BYTE*)src, d); break;
342 case DBTYPE_UI2: hr = VarR4FromUI2(*(WORD*)src, d); break;
343 case DBTYPE_UI4: hr = VarR4FromUI4(*(DWORD*)src, d); break;
344 case DBTYPE_I8: hr = VarR4FromI8(*(LONGLONG*)src, d); break;
345 case DBTYPE_UI8: hr = VarR4FromUI8(*(ULONGLONG*)src, d); break;
346 case DBTYPE_VARIANT:
347 VariantInit(&tmp);
348 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_R4)) == S_OK)
349 *d = V_R4(&tmp);
350 break;
351 default: FIXME("Unimplemented conversion %04x -> R4\n", src_type); return E_NOTIMPL;
353 break;
355 case DBTYPE_R8:
357 DOUBLE *d=dst;
358 switch (src_type)
360 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
361 case DBTYPE_I1: hr = VarR8FromI1(*(signed char*)src, d); break;
362 case DBTYPE_I2: hr = VarR8FromI2(*(signed short*)src, d); break;
363 case DBTYPE_I4: hr = VarR8FromI4(*(signed int*)src, d); break;
364 case DBTYPE_I8: hr = VarR8FromI8(*(LONGLONG*)src, d); break;
365 case DBTYPE_UI1: hr = VarR8FromUI1(*(BYTE*)src, d); break;
366 case DBTYPE_UI2: hr = VarR8FromUI2(*(WORD*)src, d); break;
367 case DBTYPE_UI4: hr = VarR8FromUI4(*(DWORD*)src, d); break;
368 case DBTYPE_UI8: hr = VarR8FromUI8(*(ULONGLONG*)src, d); break;
369 case DBTYPE_R4: hr = VarR8FromR4(*(FLOAT*)src, d); break;
370 case DBTYPE_R8: *d = *(DOUBLE*)src; hr = S_OK; break;
371 case DBTYPE_CY: hr = VarR8FromCy(*(CY*)src, d); break;
372 case DBTYPE_DATE: hr = VarR8FromDate(*(DATE*)src, d); break;
373 case DBTYPE_BSTR: hr = VarR8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
374 case DBTYPE_BOOL: hr = VarR8FromBool(*(VARIANT_BOOL*)src, d); break;
375 case DBTYPE_DECIMAL: hr = VarR8FromDec((DECIMAL*)src, d); break;
376 case DBTYPE_VARIANT:
377 VariantInit(&tmp);
378 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_R8)) == S_OK)
379 *d = V_R8(&tmp);
380 break;
381 default: FIXME("Unimplemented conversion %04x -> R8\n", src_type); return E_NOTIMPL;
383 break;
385 case DBTYPE_BOOL:
387 VARIANT_BOOL *d=dst;
388 switch (src_type)
390 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
391 case DBTYPE_I1: hr = VarBoolFromI1(*(signed char*)src, d); break;
392 case DBTYPE_I2: hr = VarBoolFromI2(*(signed short*)src, d); break;
393 case DBTYPE_I4: hr = VarBoolFromI4(*(signed int*)src, d); break;
394 case DBTYPE_I8: hr = VarBoolFromI8(*(LONGLONG*)src, d); break;
395 case DBTYPE_UI1: hr = VarBoolFromUI1(*(BYTE*)src, d); break;
396 case DBTYPE_UI2: hr = VarBoolFromUI2(*(WORD*)src, d); break;
397 case DBTYPE_UI4: hr = VarBoolFromUI4(*(DWORD*)src, d); break;
398 case DBTYPE_UI8: hr = VarBoolFromUI8(*(ULONGLONG*)src, d); break;
399 case DBTYPE_R4: hr = VarBoolFromR4(*(FLOAT*)src, d); break;
400 case DBTYPE_R8: hr = VarBoolFromR8(*(DOUBLE*)src, d); break;
401 case DBTYPE_CY: hr = VarBoolFromCy(*(CY*)src, d); break;
402 case DBTYPE_DATE: hr = VarBoolFromDate(*(DATE*)src, d); break;
403 case DBTYPE_BSTR: hr = VarBoolFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
404 case DBTYPE_BOOL: *d = *(VARIANT_BOOL*)src; hr = S_OK; break;
405 case DBTYPE_DECIMAL: hr = VarBoolFromDec((DECIMAL*)src, d); break;
406 default: FIXME("Unimplemented conversion %04x -> BOOL\n", src_type); return E_NOTIMPL;
408 break;
410 case DBTYPE_DATE:
412 DATE *d=dst;
413 switch (src_type)
415 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
416 case DBTYPE_I1: hr = VarDateFromI1(*(signed char*)src, d); break;
417 case DBTYPE_I2: hr = VarDateFromI2(*(signed short*)src, d); break;
418 case DBTYPE_I4: hr = VarDateFromI4(*(signed int*)src, d); break;
419 case DBTYPE_I8: hr = VarDateFromI8(*(LONGLONG*)src, d); break;
420 case DBTYPE_UI1: hr = VarDateFromUI1(*(BYTE*)src, d); break;
421 case DBTYPE_UI2: hr = VarDateFromUI2(*(WORD*)src, d); break;
422 case DBTYPE_UI4: hr = VarDateFromUI4(*(DWORD*)src, d); break;
423 case DBTYPE_UI8: hr = VarDateFromUI8(*(ULONGLONG*)src, d); break;
424 case DBTYPE_R4: hr = VarDateFromR4(*(FLOAT*)src, d); break;
425 case DBTYPE_R8: hr = VarDateFromR8(*(DOUBLE*)src, d); break;
426 case DBTYPE_CY: hr = VarDateFromCy(*(CY*)src, d); break;
427 case DBTYPE_DATE: *d = *(DATE*)src; hr = S_OK; break;
428 case DBTYPE_BSTR: hr = VarDateFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
429 case DBTYPE_BOOL: hr = VarDateFromBool(*(VARIANT_BOOL*)src, d); break;
430 case DBTYPE_DECIMAL: hr = VarDateFromDec((DECIMAL*)src, d); break;
431 case DBTYPE_DBTIMESTAMP:
433 SYSTEMTIME st;
434 DBTIMESTAMP *ts=(DBTIMESTAMP*)src;
436 st.wYear = ts->year;
437 st.wMonth = ts->month;
438 st.wDay = ts->day;
439 st.wHour = ts->hour;
440 st.wMinute = ts->minute;
441 st.wSecond = ts->second;
442 st.wMilliseconds = ts->fraction/1000000;
443 hr = (SystemTimeToVariantTime(&st, d) ? S_OK : E_FAIL);
444 break;
446 default: FIXME("Unimplemented conversion %04x -> DATE\n", src_type); return E_NOTIMPL;
448 break;
450 case DBTYPE_DBDATE:
452 DBDATE *d=dst;
453 switch (src_type)
455 case DBTYPE_DBDATE: memcpy(d, src, sizeof(DBDATE)); hr = S_OK; break;
456 case DBTYPE_BSTR:
458 VARIANT var;
459 BSTR s = *(WCHAR**)src;
461 VariantInit(&var);
462 V_VT(&var) = VT_BSTR;
463 V_BSTR(&var) = SysAllocString(s);
465 if ((hr = VariantChangeType(&var, &var, 0, VT_DATE)) == S_OK)
467 SYSTEMTIME st;
468 hr = (VariantTimeToSystemTime( V_DATE(&var), &st) ? S_OK : E_FAIL);
469 d->year = st.wYear;
470 d->month = st.wMonth;
471 d->day = st.wDay;
474 VariantClear(&var);
476 break;
477 case DBTYPE_VARIANT:
479 VariantInit(&tmp);
481 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_DATE)) == S_OK)
483 SYSTEMTIME st;
484 hr = (VariantTimeToSystemTime( V_DATE(&tmp), &st) ? S_OK : E_FAIL);
485 d->year = st.wYear;
486 d->month = st.wMonth;
487 d->day = st.wDay;
489 else
491 FIXME("Unimplemented variant type %d -> DBDATE\n", V_VT((VARIANT*)src));
492 return E_NOTIMPL;
494 break;
496 default: FIXME("Unimplemented conversion %04x -> DBDATE\n", src_type); return E_NOTIMPL;
498 break;
500 case DBTYPE_DBTIMESTAMP:
502 DBTIMESTAMP *d=dst;
503 switch (src_type)
505 case DBTYPE_EMPTY: memset(d, 0, sizeof(DBTIMESTAMP)); hr = S_OK; break;
506 case DBTYPE_DBTIMESTAMP: memcpy(d, src, sizeof(DBTIMESTAMP)); hr = S_OK; break;
507 case DBTYPE_BSTR:
509 VARIANT var;
510 BSTR s = *(WCHAR**)src;
512 VariantInit(&var);
513 V_VT(&var) = VT_BSTR;
514 V_BSTR(&var) = SysAllocString(s);
516 if ((hr = VariantChangeType(&var, &var, 0, VT_DATE)) == S_OK)
518 SYSTEMTIME st;
520 hr = (VariantTimeToSystemTime( V_DATE(&var), &st) ? S_OK : E_FAIL);
521 d->year = st.wYear;
522 d->month = st.wMonth;
523 d->day = st.wDay;
524 d->hour = st.wHour;
525 d->minute = st.wMinute;
526 d->second = st.wSecond;
527 d->fraction = st.wMilliseconds * 1000000;
530 VariantClear(&var);
532 break;
533 case DBTYPE_DATE:
535 SYSTEMTIME st;
536 hr = (VariantTimeToSystemTime(*(double*)src, &st) ? S_OK : E_FAIL);
537 d->year = st.wYear;
538 d->month = st.wMonth;
539 d->day = st.wDay;
540 d->hour = st.wHour;
541 d->minute = st.wMinute;
542 d->second = st.wSecond;
543 d->fraction = st.wMilliseconds * 1000000;
544 break;
546 case DBTYPE_VARIANT:
547 if( V_VT((VARIANT*)src) == VT_DATE)
549 SYSTEMTIME st;
550 hr = (VariantTimeToSystemTime( V_DATE((VARIANT*)src), &st) ? S_OK : E_FAIL);
551 d->year = st.wYear;
552 d->month = st.wMonth;
553 d->day = st.wDay;
554 d->hour = st.wHour;
555 d->minute = st.wMinute;
556 d->second = st.wSecond;
557 d->fraction = st.wMilliseconds * 1000000;
559 else
561 FIXME("Unimplemented variant type %d -> DBTIMESTAMP\n", V_VT((VARIANT*)src));
562 return E_NOTIMPL;
564 break;
565 default: FIXME("Unimplemented conversion %04x -> DBTIMESTAMP\n", src_type); return E_NOTIMPL;
567 break;
570 case DBTYPE_CY:
572 CY *d = dst;
573 switch(src_type)
575 case DBTYPE_EMPTY: d->int64 = 0; hr = S_OK; break;
576 case DBTYPE_I2: hr = VarCyFromI2(*(signed short*)src, d); break;
577 case DBTYPE_I4: hr = VarCyFromI4(*(signed int*)src, d); break;
578 case DBTYPE_R4: hr = VarCyFromR4(*(FLOAT*)src, d); break;
579 case DBTYPE_R8: hr = VarCyFromR8(*(double*)src, d); break;
580 case DBTYPE_CY: *d = *(CY*)src; hr = S_OK; break;
581 case DBTYPE_DATE: hr = VarCyFromDate(*(DATE*)src, d); break;
582 case DBTYPE_BSTR: hr = VarCyFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
583 case DBTYPE_BOOL: hr = VarCyFromBool(*(VARIANT_BOOL*)src, d); break;
584 case DBTYPE_DECIMAL: hr = VarCyFromDec((DECIMAL*)src, d); break;
585 case DBTYPE_I1: hr = VarCyFromI1(*(signed char*)src, d); break;
586 case DBTYPE_UI1: hr = VarCyFromUI1(*(BYTE*)src, d); break;
587 case DBTYPE_UI2: hr = VarCyFromUI2(*(WORD*)src, d); break;
588 case DBTYPE_UI4: hr = VarCyFromUI4(*(DWORD*)src, d); break;
589 case DBTYPE_I8: hr = VarCyFromI8(*(LONGLONG*)src, d); break;
590 case DBTYPE_UI8: hr = VarCyFromUI8(*(ULONGLONG*)src, d); break;
591 default: FIXME("Unimplemented conversion %04x -> CY\n", src_type); return E_NOTIMPL;
593 break;
596 case DBTYPE_BSTR:
598 BSTR *d = dst;
599 switch(src_type)
601 case DBTYPE_EMPTY: *d = SysAllocStringLen(NULL, 0); hr = *d ? S_OK : E_OUTOFMEMORY; break;
602 case DBTYPE_I2: hr = VarBstrFromI2(*(signed short*)src, LOCALE_USER_DEFAULT, 0, d); break;
603 case DBTYPE_I4: hr = VarBstrFromI4(*(signed int*)src, LOCALE_USER_DEFAULT, 0, d); break;
604 case DBTYPE_R4: hr = VarBstrFromR4(*(FLOAT*)src, LOCALE_USER_DEFAULT, 0, d); break;
605 case DBTYPE_R8: hr = VarBstrFromR8(*(double*)src, LOCALE_USER_DEFAULT, 0, d); break;
606 case DBTYPE_CY: hr = VarBstrFromCy(*(CY*)src, LOCALE_USER_DEFAULT, 0, d); break;
607 case DBTYPE_DATE: hr = VarBstrFromDate(*(DATE*)src, LOCALE_USER_DEFAULT, 0, d); break;
608 case DBTYPE_BSTR: *d = SysAllocStringLen(*(BSTR*)src, SysStringLen(*(BSTR*)src)); hr = *d ? S_OK : E_OUTOFMEMORY; break;
609 case DBTYPE_BOOL: hr = VarBstrFromBool(*(VARIANT_BOOL*)src, LOCALE_USER_DEFAULT, 0, d); break;
610 case DBTYPE_DECIMAL: hr = VarBstrFromDec((DECIMAL*)src, LOCALE_USER_DEFAULT, 0, d); break;
611 case DBTYPE_I1: hr = VarBstrFromI1(*(signed char*)src, LOCALE_USER_DEFAULT, 0, d); break;
612 case DBTYPE_UI1: hr = VarBstrFromUI1(*(BYTE*)src, LOCALE_USER_DEFAULT, 0, d); break;
613 case DBTYPE_UI2: hr = VarBstrFromUI2(*(WORD*)src, LOCALE_USER_DEFAULT, 0, d); break;
614 case DBTYPE_UI4: hr = VarBstrFromUI4(*(DWORD*)src, LOCALE_USER_DEFAULT, 0, d); break;
615 case DBTYPE_I8: hr = VarBstrFromI8(*(LONGLONG*)src, LOCALE_USER_DEFAULT, 0, d); break;
616 case DBTYPE_UI8: hr = VarBstrFromUI8(*(ULONGLONG*)src, LOCALE_USER_DEFAULT, 0, d); break;
617 case DBTYPE_GUID:
619 WCHAR szBuff[39];
620 const GUID *id = (const GUID *)src;
621 WCHAR format[] = {
622 '{','%','0','8','X','-','%','0','4','X','-','%','0','4','X','-',
623 '%','0','2','X','%','0','2','X','-',
624 '%','0','2','X','%','0','2','X','%','0','2','X','%','0','2','X','%','0','2','X','%','0','2','X','}',0};
625 wsprintfW(szBuff, format,
626 id->Data1, id->Data2, id->Data3,
627 id->Data4[0], id->Data4[1], id->Data4[2], id->Data4[3],
628 id->Data4[4], id->Data4[5], id->Data4[6], id->Data4[7] );
629 *d = SysAllocString(szBuff);
630 hr = *d ? S_OK : E_OUTOFMEMORY;
632 break;
633 case DBTYPE_BYTES:
635 *d = SysAllocStringLen(NULL, 2 * src_len);
636 if (*d == NULL)
637 hr = E_OUTOFMEMORY;
638 else
640 const char hexchars[] = "0123456789ABCDEF";
641 WCHAR *s = *d;
642 unsigned char *p = src;
643 while (src_len > 0)
645 *s++ = hexchars[(*p >> 4) & 0x0F];
646 *s++ = hexchars[(*p) & 0x0F];
647 src_len--; p++;
649 hr = S_OK;
652 break;
653 case DBTYPE_DBTIMESTAMP:
655 WCHAR szBuff[64];
656 static const WCHAR format1[] = {
657 '%','0','4','d','-','%','0','2','d','-','%','0','2','d',' ','%','0','2','d',':','%','0','2','d',
658 ':','%','0','2','d', 0};
659 static const WCHAR format2[] = {
660 '%','0','4','d','-','%','0','2','d','-','%','0','2','d',' ','%','0','2','d',':','%','0','2','d',
661 ':','%','0','2','d','.','%','0','9','d', 0};
662 DBTIMESTAMP *ts = (DBTIMESTAMP *)src;
664 if(ts->fraction == 0)
665 wsprintfW(szBuff, format1, ts->year, ts->month, ts->day, ts->hour, ts->minute, ts->second);
666 else
667 wsprintfW(szBuff, format2, ts->year, ts->month, ts->day, ts->hour, ts->minute, ts->second, ts->fraction );
668 *d = SysAllocString(szBuff);
669 hr = *d ? S_OK : E_OUTOFMEMORY;
670 break;
672 case DBTYPE_VARIANT:
673 VariantInit(&tmp);
674 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_BSTR)) == S_OK)
675 *d = V_BSTR(&tmp);
676 break;
677 default: FIXME("Unimplemented conversion %04x -> BSTR\n", src_type); return E_NOTIMPL;
679 break;
682 case DBTYPE_UI1:
684 BYTE *d = dst;
685 switch(src_type)
687 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
688 case DBTYPE_I2: hr = VarUI1FromI2(*(signed short*)src, d); break;
689 case DBTYPE_I4: hr = VarUI1FromI4(*(signed int*)src, d); break;
690 case DBTYPE_R4: hr = VarUI1FromR4(*(FLOAT*)src, d); break;
691 case DBTYPE_R8: hr = VarUI1FromR8(*(double*)src, d); break;
692 case DBTYPE_CY: hr = VarUI1FromCy(*(CY*)src, d); break;
693 case DBTYPE_DATE: hr = VarUI1FromDate(*(DATE*)src, d); break;
694 case DBTYPE_BSTR: hr = VarUI1FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
695 case DBTYPE_BOOL: hr = VarUI1FromBool(*(VARIANT_BOOL*)src, d); break;
696 case DBTYPE_DECIMAL: hr = VarUI1FromDec((DECIMAL*)src, d); break;
697 case DBTYPE_I1: hr = VarUI1FromI1(*(signed char*)src, d); break;
698 case DBTYPE_UI1: *d = *(BYTE*)src; hr = S_OK; break;
699 case DBTYPE_UI2: hr = VarUI1FromUI2(*(WORD*)src, d); break;
700 case DBTYPE_UI4: hr = VarUI1FromUI4(*(DWORD*)src, d); break;
701 case DBTYPE_I8: hr = VarUI1FromI8(*(LONGLONG*)src, d); break;
702 case DBTYPE_UI8: hr = VarUI1FromUI8(*(ULONGLONG*)src, d); break;
703 default: FIXME("Unimplemented conversion %04x -> UI1\n", src_type); return E_NOTIMPL;
705 break;
707 case DBTYPE_UI2:
709 WORD *d = dst;
710 switch(src_type)
712 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
713 case DBTYPE_I2: hr = VarUI2FromI2(*(signed short*)src, d); break;
714 case DBTYPE_I4: hr = VarUI2FromI4(*(signed int*)src, d); break;
715 case DBTYPE_R4: hr = VarUI2FromR4(*(FLOAT*)src, d); break;
716 case DBTYPE_R8: hr = VarUI2FromR8(*(double*)src, d); break;
717 case DBTYPE_CY: hr = VarUI2FromCy(*(CY*)src, d); break;
718 case DBTYPE_DATE: hr = VarUI2FromDate(*(DATE*)src, d); break;
719 case DBTYPE_BSTR: hr = VarUI2FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
720 case DBTYPE_BOOL: hr = VarUI2FromBool(*(VARIANT_BOOL*)src, d); break;
721 case DBTYPE_DECIMAL: hr = VarUI2FromDec((DECIMAL*)src, d); break;
722 case DBTYPE_I1: hr = VarUI2FromI1(*(signed char*)src, d); break;
723 case DBTYPE_UI1: hr = VarUI2FromUI1(*(BYTE*)src, d); break;
724 case DBTYPE_UI2: *d = *(WORD*)src; hr = S_OK; break;
725 case DBTYPE_UI4: hr = VarUI2FromUI4(*(DWORD*)src, d); break;
726 case DBTYPE_I8: hr = VarUI2FromI8(*(LONGLONG*)src, d); break;
727 case DBTYPE_UI8: hr = VarUI2FromUI8(*(ULONGLONG*)src, d); break;
728 default: FIXME("Unimplemented conversion %04x -> UI2\n", src_type); return E_NOTIMPL;
730 break;
733 case DBTYPE_UI4:
735 DWORD *d = dst;
736 switch(src_type)
738 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
739 case DBTYPE_I2: hr = VarUI4FromI2(*(signed short*)src, d); break;
740 case DBTYPE_I4: hr = VarUI4FromI4(*(signed int*)src, d); break;
741 case DBTYPE_R4: hr = VarUI4FromR4(*(FLOAT*)src, d); break;
742 case DBTYPE_R8: hr = VarUI4FromR8(*(double*)src, d); break;
743 case DBTYPE_CY: hr = VarUI4FromCy(*(CY*)src, d); break;
744 case DBTYPE_DATE: hr = VarUI4FromDate(*(DATE*)src, d); break;
745 case DBTYPE_BSTR: hr = VarUI4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
746 case DBTYPE_BOOL: hr = VarUI4FromBool(*(VARIANT_BOOL*)src, d); break;
747 case DBTYPE_DECIMAL: hr = VarUI4FromDec((DECIMAL*)src, d); break;
748 case DBTYPE_I1: hr = VarUI4FromI1(*(signed char*)src, d); break;
749 case DBTYPE_UI1: hr = VarUI4FromUI1(*(BYTE*)src, d); break;
750 case DBTYPE_UI2: hr = VarUI4FromUI2(*(WORD*)src, d); break;
751 case DBTYPE_UI4: *d = *(DWORD*)src; hr = S_OK; break;
752 case DBTYPE_I8: hr = VarUI4FromI8(*(LONGLONG*)src, d); break;
753 case DBTYPE_UI8: hr = VarUI4FromUI8(*(ULONGLONG*)src, d); break;
754 case DBTYPE_VARIANT:
755 VariantInit(&tmp);
756 if ((hr = VariantChangeType(&tmp, (VARIANT*)src, 0, VT_UI4)) == S_OK)
757 *d = V_UI4(&tmp);
758 break;
759 default: FIXME("Unimplemented conversion %04x -> UI4\n", src_type); return E_NOTIMPL;
761 break;
764 case DBTYPE_UI8:
766 ULONGLONG *d = dst;
767 switch(src_type)
769 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
770 case DBTYPE_I2: hr = VarUI8FromI2(*(signed short*)src, d); break;
771 case DBTYPE_I4: {LONGLONG s = *(signed int*)src; hr = VarUI8FromI8(s, d); break;}
772 case DBTYPE_R4: hr = VarUI8FromR4(*(FLOAT*)src, d); break;
773 case DBTYPE_R8: hr = VarUI8FromR8(*(double*)src, d); break;
774 case DBTYPE_CY: hr = VarUI8FromCy(*(CY*)src, d); break;
775 case DBTYPE_DATE: hr = VarUI8FromDate(*(DATE*)src, d); break;
776 case DBTYPE_BSTR: hr = VarUI8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
777 case DBTYPE_BOOL: hr = VarUI8FromBool(*(VARIANT_BOOL*)src, d); break;
778 case DBTYPE_DECIMAL: hr = VarUI8FromDec((DECIMAL*)src, d); break;
779 case DBTYPE_I1: hr = VarUI8FromI1(*(signed char*)src, d); break;
780 case DBTYPE_UI1: hr = VarUI8FromUI1(*(BYTE*)src, d); break;
781 case DBTYPE_UI2: hr = VarUI8FromUI2(*(WORD*)src, d); break;
782 case DBTYPE_UI4: hr = VarUI8FromUI4(*(DWORD*)src, d); break;
783 case DBTYPE_I8: hr = VarUI8FromI8(*(LONGLONG*)src, d); break;
784 case DBTYPE_UI8: *d = *(ULONGLONG*)src; hr = S_OK; break;
785 default: FIXME("Unimplemented conversion %04x -> UI8\n", src_type); return E_NOTIMPL;
787 break;
790 case DBTYPE_FILETIME:
792 FILETIME *d = dst;
793 switch(src_type)
795 case DBTYPE_EMPTY: d->dwLowDateTime = d->dwHighDateTime = 0; hr = S_OK; break;
796 case DBTYPE_FILETIME: *d = *(FILETIME*)src; hr = S_OK; break;
797 default: FIXME("Unimplemented conversion %04x -> FILETIME\n", src_type); return E_NOTIMPL;
799 break;
802 case DBTYPE_GUID:
804 GUID *d = dst;
805 switch(src_type)
807 case DBTYPE_EMPTY: *d = GUID_NULL; hr = S_OK; break;
808 case DBTYPE_GUID: *d = *(GUID*)src; hr = S_OK; break;
809 default: FIXME("Unimplemented conversion %04x -> GUID\n", src_type); return E_NOTIMPL;
811 break;
814 case DBTYPE_WSTR:
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 || *dst_status == DBSTATUS_S_ISNULL)
823 return hr;
824 bstr_len = SysStringLen(b);
825 *dst_len = bstr_len * sizeof(WCHAR); /* Doesn't include size for '\0' */
826 *dst_status = DBSTATUS_S_OK;
827 bytes_to_copy = min(*dst_len + sizeof(WCHAR), dst_max_len);
828 if(dst)
830 if(bytes_to_copy >= sizeof(WCHAR))
832 memcpy(dst, b, bytes_to_copy - sizeof(WCHAR));
833 *((WCHAR*)dst + bytes_to_copy / sizeof(WCHAR) - 1) = 0;
834 if(bytes_to_copy < *dst_len + sizeof(WCHAR))
835 *dst_status = DBSTATUS_S_TRUNCATED;
837 else
839 *dst_status = DBSTATUS_E_DATAOVERFLOW;
840 hr = DB_E_ERRORSOCCURRED;
843 SysFreeString(b);
844 return hr;
847 case DBTYPE_STR:
849 BSTR b;
850 DBLENGTH length;
851 INT bytes_to_copy;
852 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &length,
853 src, &b, sizeof(BSTR), src_status, dst_status,
854 precision, scale, flags);
855 if(hr != S_OK) return hr;
856 length = WideCharToMultiByte(CP_ACP, 0, b, SysStringLen(b), NULL, 0, NULL, NULL);
857 *dst_len = length; /* Doesn't include size for '\0' */
858 *dst_status = DBSTATUS_S_OK;
859 bytes_to_copy = min(length + 1, dst_max_len);
860 if(dst)
862 if(bytes_to_copy >= sizeof(char))
864 WideCharToMultiByte(CP_ACP, 0, b, SysStringLen(b), dst, bytes_to_copy - 1, NULL, NULL);
865 *((char *)dst + bytes_to_copy - 1) = 0;
866 if(bytes_to_copy < length + 1)
867 *dst_status = DBSTATUS_S_TRUNCATED;
869 else
871 *dst_status = DBSTATUS_E_DATAOVERFLOW;
872 hr = DB_E_ERRORSOCCURRED;
875 SysFreeString(b);
876 return hr;
879 case DBTYPE_BYREF | DBTYPE_WSTR:
881 BSTR b;
882 WCHAR **d = dst;
883 DBLENGTH bstr_len;
884 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &bstr_len,
885 src, &b, sizeof(BSTR), src_status, dst_status,
886 precision, scale, flags);
887 if(hr != S_OK) return hr;
889 bstr_len = SysStringLen(b) * sizeof(WCHAR);
890 *dst_len = bstr_len; /* Doesn't include size for '\0' */
892 *d = CoTaskMemAlloc(bstr_len + sizeof(WCHAR));
893 if(*d) memcpy(*d, b, bstr_len + sizeof(WCHAR));
894 else hr = E_OUTOFMEMORY;
895 SysFreeString(b);
896 return hr;
899 case DBTYPE_BYREF | DBTYPE_STR:
901 BSTR b;
902 char **d = dst;
903 DBLENGTH length;
904 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &length,
905 src, &b, sizeof(BSTR), src_status, dst_status,
906 precision, scale, flags);
907 if(hr != S_OK) return hr;
909 length = WideCharToMultiByte(CP_ACP, 0, b, SysStringLen(b) + 1, NULL, 0, NULL, NULL);
910 *dst_len = length - 1; /* Doesn't include size for '\0' */
911 *dst_status = DBSTATUS_S_OK;
912 *d = CoTaskMemAlloc(length);
914 if(*d)
915 WideCharToMultiByte(CP_ACP, 0, b, SysStringLen(b) + 1, *d, length, NULL, NULL);
916 else
917 hr = E_OUTOFMEMORY;
918 SysFreeString(b);
920 return hr;
923 case DBTYPE_VARIANT:
925 VARIANT *v = dst;
927 switch(src_type)
929 case DBTYPE_BOOL:
930 V_VT(v) = VT_BOOL;
931 V_BOOL(v) = *(VARIANT_BOOL*)src;
932 hr = S_OK;
933 break;
934 case DBTYPE_I2:
935 V_VT(v) = VT_I2;
936 V_I2(v) = *(signed short*)src;
937 hr = S_OK;
938 break;
939 case DBTYPE_I4:
940 V_VT(v) = VT_I4;
941 V_I4(v) = *(signed int*)src;
942 hr = S_OK;
943 break;
944 case DBTYPE_I8:
945 V_VT(v) = VT_DECIMAL;
946 hr = VarDecFromI8( *(LONGLONG*)src, &V_DECIMAL(v));
947 break;
948 case DBTYPE_R4:
949 V_VT(v) = VT_R4;
950 V_R4(v) = *(FLOAT*)src;
951 hr = S_OK;
952 break;
953 case DBTYPE_R8:
954 V_VT(v) = VT_R8;
955 V_R8(v) = *(double*)src;
956 hr = S_OK;
957 break;
958 case DBTYPE_BSTR:
960 BSTR s = *(WCHAR**)src;
961 TRACE("%s\n", debugstr_w(s));
962 V_VT(v) = VT_BSTR;
963 V_BSTR(v) = SysAllocString(s);
964 hr = V_BSTR(v) ? S_OK : E_OUTOFMEMORY;
965 break;
967 case DBTYPE_DATE:
968 V_VT(v) = VT_DATE;
969 V_DATE(v) = *(DATE*)src;
970 hr = S_OK;
971 break;
972 case DBTYPE_DBDATE:
974 SYSTEMTIME st;
975 DBDATE *ts=(DBDATE*)src;
977 V_VT(v) = VT_DATE;
979 st.wYear = ts->year;
980 st.wMonth = ts->month;
981 st.wDay = ts->day;
982 st.wHour = 0;
983 st.wMinute = 0;
984 st.wSecond = 0;
985 st.wMilliseconds = 0;
986 hr = (SystemTimeToVariantTime(&st, &V_DATE(v)) ? S_OK : E_FAIL);
987 break;
989 case DBTYPE_DBTIMESTAMP:
991 SYSTEMTIME st;
992 DBTIMESTAMP *ts = (DBTIMESTAMP *)src;
994 V_VT(v) = VT_DATE;
996 st.wYear = ts->year;
997 st.wMonth = ts->month;
998 st.wDay = ts->day;
999 st.wHour = ts->hour;
1000 st.wMinute = ts->minute;
1001 st.wSecond = ts->second;
1002 st.wMilliseconds = ts->fraction/1000000;
1003 hr = SystemTimeToVariantTime(&st, &V_DATE(v)) ? S_OK : E_FAIL;
1004 break;
1006 case DBTYPE_CY:
1007 V_VT(v) = VT_CY;
1008 V_CY(v) = *(CY*)src;
1009 hr = S_OK;
1010 break;
1011 case DBTYPE_BYTES:
1013 LONG i;
1014 SAFEARRAY *psa = NULL;
1015 SAFEARRAYBOUND rgsabound[1];
1016 unsigned char *p = src;
1018 rgsabound[0].lLbound = 0;
1019 rgsabound[0].cElements = src_len;
1021 psa = SafeArrayCreate(VT_UI1,1,rgsabound);
1022 for(i =0; i < src_len; i++,p++)
1024 hr = SafeArrayPutElement(psa, &i, p);
1025 if(FAILED(hr)) {
1026 SafeArrayDestroy (psa);
1027 return hr;
1031 V_VT(v) = VT_ARRAY|VT_UI1;
1032 V_ARRAY(v) = psa;
1033 hr = S_OK;
1034 break;
1036 default: FIXME("Unimplemented conversion %04x -> VARIANT\n", src_type); return E_NOTIMPL;
1038 break;
1040 case DBTYPE_BYTES:
1042 BYTE *d = dst;
1044 switch(src_type)
1046 case DBTYPE_BYTES:
1047 if( src_len > dst_max_len)
1048 *dst_status = DBSTATUS_S_TRUNCATED;
1049 else
1050 *dst_status = DBSTATUS_S_OK;
1052 *dst_len = src_len;
1053 memcpy(d, src, min(src_len, dst_max_len));
1055 return S_OK;
1056 case DBTYPE_VARIANT:
1058 switch(V_VT((VARIANT*)src))
1060 case VT_UI1 | VT_ARRAY:
1062 LONG l;
1063 BYTE *data = NULL;
1065 hr = SafeArrayGetUBound(V_ARRAY((VARIANT*)src), 1, &l);
1066 if(FAILED(hr))
1067 return hr;
1069 hr = SafeArrayAccessData(V_ARRAY((VARIANT*)src), (VOID**)&data);
1070 if(FAILED(hr))
1072 ERR("SafeArrayAccessData Failed = 0x%08x\n", hr);
1073 return hr;
1076 *dst_len = l+1;
1077 *dst_status = DBSTATUS_S_OK;
1078 memcpy(d, data, *dst_len);
1080 SafeArrayUnaccessData(V_ARRAY((VARIANT*)src));
1081 return S_OK;
1083 break;
1084 default:
1085 FIXME("Unimplemented variant type %d -> BYTES\n", V_VT((VARIANT*)src));
1086 return E_NOTIMPL;
1089 break;
1090 default: FIXME("Unimplemented conversion %04x -> DBTYPE_BYTES\n", src_type); return E_NOTIMPL;
1092 break;
1094 case DBTYPE_BYTES | DBTYPE_BYREF:
1096 BYTE **d = dst;
1098 switch(src_type)
1100 case DBTYPE_BYTES:
1101 *d = CoTaskMemAlloc(src_len);
1102 if(*d) memcpy(*d, src, src_len);
1103 else hr = E_OUTOFMEMORY;
1105 *dst_len = src_len;
1106 *dst_status = DBSTATUS_S_OK;
1107 return S_OK;
1108 default: FIXME("Unimplemented conversion %04x -> DBTYPE_BYTES | DBTYPE_BYREF\n", src_type); return E_NOTIMPL;
1110 break;
1113 case DBTYPE_NUMERIC:
1114 FIXME("Unimplemented conversion %04x -> DBTYPE_NUMERIC\n", src_type);
1115 return E_NOTIMPL;
1117 default:
1118 FIXME("Unimplemented conversion %04x -> %04x\n", src_type, dst_type);
1119 return E_NOTIMPL;
1122 if(hr == DISP_E_OVERFLOW)
1124 *dst_status = DBSTATUS_E_DATAOVERFLOW;
1125 *dst_len = get_length(dst_type);
1126 hr = DB_E_ERRORSOCCURRED;
1128 else if(hr == S_OK)
1130 *dst_status = DBSTATUS_S_OK;
1131 *dst_len = get_length(dst_type);
1134 return hr;
1137 static inline WORD get_dbtype_class(DBTYPE type)
1139 switch(type)
1141 case DBTYPE_I2:
1142 case DBTYPE_R4:
1143 case DBTYPE_R8:
1144 case DBTYPE_I1:
1145 case DBTYPE_UI1:
1146 case DBTYPE_UI2:
1147 return DBTYPE_I2;
1149 case DBTYPE_I4:
1150 case DBTYPE_UI4:
1151 return DBTYPE_I4;
1153 case DBTYPE_I8:
1154 case DBTYPE_UI8:
1155 return DBTYPE_I8;
1157 case DBTYPE_BSTR:
1158 case DBTYPE_STR:
1159 case DBTYPE_WSTR:
1160 return DBTYPE_BSTR;
1162 case DBTYPE_DBDATE:
1163 case DBTYPE_DBTIME:
1164 case DBTYPE_DBTIMESTAMP:
1165 return DBTYPE_DBDATE;
1167 return type;
1170 /* Many src types will convert to this group of dst types */
1171 static inline BOOL common_class(WORD dst_class)
1173 switch(dst_class)
1175 case DBTYPE_EMPTY:
1176 case DBTYPE_NULL:
1177 case DBTYPE_I2:
1178 case DBTYPE_I4:
1179 case DBTYPE_BSTR:
1180 case DBTYPE_BOOL:
1181 case DBTYPE_VARIANT:
1182 case DBTYPE_I8:
1183 case DBTYPE_CY:
1184 case DBTYPE_DECIMAL:
1185 case DBTYPE_NUMERIC:
1186 return TRUE;
1188 return FALSE;
1191 static inline BOOL array_type(DBTYPE type)
1193 return (type >= DBTYPE_I2 && type <= DBTYPE_UI4);
1196 static HRESULT WINAPI convert_CanConvert(IDataConvert* iface,
1197 DBTYPE src_type, DBTYPE dst_type)
1199 convert *This = impl_from_IDataConvert(iface);
1200 DBTYPE src_base_type = src_type & 0x1ff;
1201 DBTYPE dst_base_type = dst_type & 0x1ff;
1202 WORD dst_class = get_dbtype_class(dst_base_type);
1204 TRACE("(%p)->(%d, %d)\n", This, src_type, dst_type);
1206 if(src_type & DBTYPE_VECTOR || dst_type & DBTYPE_VECTOR) return S_FALSE;
1208 if(src_type & DBTYPE_ARRAY)
1210 if(!array_type(src_base_type)) return S_FALSE;
1211 if(dst_type & DBTYPE_ARRAY)
1213 if(src_type == dst_type) return S_OK;
1214 return S_FALSE;
1216 if(dst_type == DBTYPE_VARIANT) return S_OK;
1217 return S_FALSE;
1220 if(dst_type & DBTYPE_ARRAY)
1222 if(!array_type(dst_base_type)) return S_FALSE;
1223 if(src_type == DBTYPE_IDISPATCH || src_type == DBTYPE_VARIANT) return S_OK;
1224 return S_FALSE;
1227 if(dst_type & DBTYPE_BYREF)
1228 if(dst_base_type != DBTYPE_BYTES && dst_base_type != DBTYPE_STR && dst_base_type != DBTYPE_WSTR)
1229 return S_FALSE;
1231 switch(get_dbtype_class(src_base_type))
1233 case DBTYPE_EMPTY:
1234 if(common_class(dst_class)) return S_OK;
1235 switch(dst_class)
1237 case DBTYPE_DATE:
1238 case DBTYPE_GUID:
1239 case DBTYPE_FILETIME:
1240 return S_OK;
1241 default:
1242 if(dst_base_type == DBTYPE_DBTIMESTAMP) return S_OK;
1243 return S_FALSE;
1246 case DBTYPE_NULL:
1247 switch(dst_base_type)
1249 case DBTYPE_NULL:
1250 case DBTYPE_VARIANT:
1251 case DBTYPE_FILETIME: return S_OK;
1252 default: return S_FALSE;
1255 case DBTYPE_I4:
1256 if(dst_base_type == DBTYPE_BYTES) return S_OK;
1257 /* fall through */
1258 case DBTYPE_I2:
1259 if(dst_base_type == DBTYPE_DATE) return S_OK;
1260 /* fall through */
1261 case DBTYPE_DECIMAL:
1262 if(common_class(dst_class)) return S_OK;
1263 if(dst_class == DBTYPE_DBDATE) return S_OK;
1264 return S_FALSE;
1266 case DBTYPE_BOOL:
1267 if(dst_base_type == DBTYPE_DATE) return S_OK;
1268 /* fall through */
1269 case DBTYPE_NUMERIC:
1270 case DBTYPE_CY:
1271 if(common_class(dst_class)) return S_OK;
1272 return S_FALSE;
1274 case DBTYPE_I8:
1275 if(common_class(dst_class)) return S_OK;
1276 switch(dst_base_type)
1278 case DBTYPE_BYTES:
1279 case DBTYPE_FILETIME: return S_OK;
1280 default: return S_FALSE;
1283 case DBTYPE_DATE:
1284 switch(dst_class)
1286 case DBTYPE_EMPTY:
1287 case DBTYPE_NULL:
1288 case DBTYPE_I2:
1289 case DBTYPE_I4:
1290 case DBTYPE_BSTR:
1291 case DBTYPE_BOOL:
1292 case DBTYPE_VARIANT:
1293 case DBTYPE_I8:
1294 case DBTYPE_DATE:
1295 case DBTYPE_DBDATE:
1296 case DBTYPE_FILETIME:
1297 return S_OK;
1298 default: return S_FALSE;
1301 case DBTYPE_IDISPATCH:
1302 case DBTYPE_VARIANT:
1303 switch(dst_base_type)
1305 case DBTYPE_IDISPATCH:
1306 case DBTYPE_ERROR:
1307 case DBTYPE_IUNKNOWN:
1308 return S_OK;
1310 /* fall through */
1311 case DBTYPE_BSTR:
1312 if(common_class(dst_class)) return S_OK;
1313 switch(dst_class)
1315 case DBTYPE_DATE:
1316 case DBTYPE_GUID:
1317 case DBTYPE_BYTES:
1318 case DBTYPE_DBDATE:
1319 case DBTYPE_FILETIME:
1320 return S_OK;
1321 default: return S_FALSE;
1324 case DBTYPE_ERROR:
1325 switch(dst_base_type)
1327 case DBTYPE_BSTR:
1328 case DBTYPE_ERROR:
1329 case DBTYPE_VARIANT:
1330 case DBTYPE_WSTR:
1331 return S_OK;
1332 default: return S_FALSE;
1335 case DBTYPE_IUNKNOWN:
1336 switch(dst_base_type)
1338 case DBTYPE_EMPTY:
1339 case DBTYPE_NULL:
1340 case DBTYPE_IDISPATCH:
1341 case DBTYPE_VARIANT:
1342 case DBTYPE_IUNKNOWN:
1343 return S_OK;
1344 default: return S_FALSE;
1347 case DBTYPE_BYTES:
1348 if(dst_class == DBTYPE_I4 || dst_class == DBTYPE_I8) return S_OK;
1349 /* fall through */
1350 case DBTYPE_GUID:
1351 switch(dst_class)
1353 case DBTYPE_EMPTY:
1354 case DBTYPE_NULL:
1355 case DBTYPE_BSTR:
1356 case DBTYPE_VARIANT:
1357 case DBTYPE_GUID:
1358 case DBTYPE_BYTES:
1359 return S_OK;
1360 default: return S_FALSE;
1363 case DBTYPE_FILETIME:
1364 if(dst_class == DBTYPE_I8) return S_OK;
1365 /* fall through */
1366 case DBTYPE_DBDATE:
1367 switch(dst_class)
1369 case DBTYPE_EMPTY:
1370 case DBTYPE_NULL:
1371 case DBTYPE_DATE:
1372 case DBTYPE_BSTR:
1373 case DBTYPE_VARIANT:
1374 case DBTYPE_DBDATE:
1375 case DBTYPE_FILETIME:
1376 return S_OK;
1377 default: return S_FALSE;
1381 return S_FALSE;
1384 static HRESULT WINAPI convert_GetConversionSize(IDataConvert* iface,
1385 DBTYPE src_type, DBTYPE dst_type,
1386 DBLENGTH *src_len, DBLENGTH *dst_len,
1387 void *src)
1389 convert *This = impl_from_IDataConvert(iface);
1390 HRESULT hr;
1392 TRACE("(%p)->(%d, %d, %p, %p, %p)\n", This, src_type, dst_type, src_len, dst_len, src);
1394 hr = IDataConvert_CanConvert(iface, src_type, dst_type);
1395 if (hr != S_OK)
1396 return DB_E_UNSUPPORTEDCONVERSION;
1398 if (!dst_len)
1399 return E_INVALIDARG;
1401 /* for some types we don't need to look into source data */
1402 if ((*dst_len = get_length(dst_type)))
1403 return S_OK;
1405 *dst_len = 110;
1407 if(src_type == DBTYPE_VARIANT && V_VT((VARIANT*)src) == VT_NULL)
1408 return S_OK;
1410 switch (dst_type)
1412 case DBTYPE_STR:
1413 switch (src_type)
1415 case DBTYPE_VARIANT:
1417 VARIANT v;
1419 VariantInit(&v);
1420 if ((hr = VariantChangeType(&v, (VARIANT*)src, 0, VT_BSTR)) == S_OK)
1422 *dst_len = WideCharToMultiByte(CP_ACP, 0, V_BSTR(&v), -1, NULL, 0, NULL, NULL);
1423 VariantClear(&v);
1425 else
1426 return hr;
1428 break;
1429 case DBTYPE_DATE:
1430 case DBTYPE_DECIMAL:
1431 case DBTYPE_EMPTY:
1432 case DBTYPE_I1:
1433 case DBTYPE_I2:
1434 case DBTYPE_UI2:
1435 case DBTYPE_I4:
1436 case DBTYPE_UI4:
1437 case DBTYPE_I8:
1438 case DBTYPE_UI8:
1439 case DBTYPE_R4:
1440 case DBTYPE_DBDATE:
1441 case DBTYPE_DBTIMESTAMP:
1442 case DBTYPE_DBTIME:
1443 break;
1444 default:
1445 FIXME("unimplemented for %04x -> DBTYPE_STR\n", src_type);
1446 return E_NOTIMPL;
1448 break;
1449 case DBTYPE_WSTR:
1450 switch (src_type)
1452 case DBTYPE_VARIANT:
1454 VARIANT v;
1456 VariantInit(&v);
1457 if ((hr = VariantChangeType(&v, (VARIANT*)src, 0, VT_BSTR)) == S_OK)
1459 *dst_len = (SysStringLen(V_BSTR(&v))+1) * sizeof(WCHAR);
1460 VariantClear(&v);
1463 break;
1464 case DBTYPE_STR:
1465 if(src_len)
1466 *dst_len = (*src_len + 1) * sizeof(WCHAR);
1467 else
1468 *dst_len = (strlen(src) + 1) * sizeof(WCHAR);
1469 break;
1470 case DBTYPE_WSTR:
1471 if(src_len)
1472 *dst_len = (*src_len) + sizeof(WCHAR);
1473 else
1474 *dst_len = (lstrlenW(src) + 1) * sizeof(WCHAR);
1475 break;
1476 case DBTYPE_DATE:
1477 case DBTYPE_DECIMAL:
1478 case DBTYPE_EMPTY:
1479 case DBTYPE_I1:
1480 case DBTYPE_I2:
1481 case DBTYPE_UI2:
1482 case DBTYPE_I4:
1483 case DBTYPE_UI4:
1484 case DBTYPE_I8:
1485 case DBTYPE_UI8:
1486 case DBTYPE_R4:
1487 case DBTYPE_DBDATE:
1488 case DBTYPE_DBTIMESTAMP:
1489 case DBTYPE_DBTIME:
1490 break;
1491 default:
1492 FIXME("unimplemented for %04x -> DBTYPE_WSTR\n", src_type);
1493 return E_NOTIMPL;
1495 break;
1496 case DBTYPE_BYTES:
1497 switch (src_type)
1499 case DBTYPE_VARIANT:
1500 if(V_VT((VARIANT*)src) == VT_BSTR)
1501 *dst_len = (SysStringLen(V_BSTR((VARIANT*)src))) / sizeof(WCHAR);
1502 else
1504 switch(V_VT((VARIANT*)src))
1506 case VT_UI1 | VT_ARRAY:
1508 LONG l;
1510 hr = SafeArrayGetUBound(V_ARRAY((VARIANT*)src), 1, &l);
1511 if(FAILED(hr))
1512 return hr;
1513 *dst_len = l+1;
1515 break;
1517 default:
1518 WARN("DBTYPE_VARIANT(%d)->DBTYPE_BYTES unimplemented\n", V_VT((VARIANT*)src));
1521 break;
1522 default:
1523 FIXME("unimplemented for %04x -> DBTYPE_BYTES\n", src_type);
1524 return E_NOTIMPL;
1526 break;
1527 default:
1528 FIXME("unimplemented for conversion %d->%d\n", src_type, dst_type);
1529 return E_NOTIMPL;
1532 return S_OK;
1535 static const struct IDataConvertVtbl convert_vtbl =
1537 convert_QueryInterface,
1538 convert_AddRef,
1539 convert_Release,
1540 convert_DataConvert,
1541 convert_CanConvert,
1542 convert_GetConversionSize
1545 static HRESULT WINAPI dcinfo_QueryInterface(IDCInfo* iface, REFIID riid, void **obj)
1547 convert *This = impl_from_IDCInfo(iface);
1549 return IDataConvert_QueryInterface(&This->IDataConvert_iface, riid, obj);
1552 static ULONG WINAPI dcinfo_AddRef(IDCInfo* iface)
1554 convert *This = impl_from_IDCInfo(iface);
1556 return IDataConvert_AddRef(&This->IDataConvert_iface);
1559 static ULONG WINAPI dcinfo_Release(IDCInfo* iface)
1561 convert *This = impl_from_IDCInfo(iface);
1563 return IDataConvert_Release(&This->IDataConvert_iface);
1566 static HRESULT WINAPI dcinfo_GetInfo(IDCInfo *iface, ULONG num, DCINFOTYPE types[], DCINFO **info_ptr)
1568 convert *This = impl_from_IDCInfo(iface);
1569 ULONG i;
1570 DCINFO *infos;
1572 TRACE("(%p)->(%d, %p, %p)\n", This, num, types, info_ptr);
1574 *info_ptr = infos = CoTaskMemAlloc(num * sizeof(*infos));
1575 if(!infos) return E_OUTOFMEMORY;
1577 for(i = 0; i < num; i++)
1579 infos[i].eInfoType = types[i];
1580 VariantInit(&infos[i].vData);
1582 switch(types[i])
1584 case DCINFOTYPE_VERSION:
1585 V_VT(&infos[i].vData) = VT_UI4;
1586 V_UI4(&infos[i].vData) = This->version;
1587 break;
1591 return S_OK;
1594 static HRESULT WINAPI dcinfo_SetInfo(IDCInfo* iface, ULONG num, DCINFO info[])
1596 convert *This = impl_from_IDCInfo(iface);
1597 ULONG i;
1598 HRESULT hr = S_OK;
1600 TRACE("(%p)->(%d, %p)\n", This, num, info);
1602 for(i = 0; i < num; i++)
1604 switch(info[i].eInfoType)
1606 case DCINFOTYPE_VERSION:
1607 if(V_VT(&info[i].vData) != VT_UI4)
1609 FIXME("VERSION with vt %x\n", V_VT(&info[i].vData));
1610 hr = DB_S_ERRORSOCCURRED;
1611 break;
1613 This->version = V_UI4(&info[i].vData);
1614 break;
1616 default:
1617 FIXME("Unhandled info type %d (vt %x)\n", info[i].eInfoType, V_VT(&info[i].vData));
1620 return hr;
1623 static const struct IDCInfoVtbl dcinfo_vtbl =
1625 dcinfo_QueryInterface,
1626 dcinfo_AddRef,
1627 dcinfo_Release,
1628 dcinfo_GetInfo,
1629 dcinfo_SetInfo
1632 HRESULT create_oledb_convert(IUnknown *outer, void **obj)
1634 convert *This;
1636 TRACE("(%p, %p)\n", outer, obj);
1638 *obj = NULL;
1640 if(outer) return CLASS_E_NOAGGREGATION;
1642 This = heap_alloc(sizeof(*This));
1643 if(!This) return E_OUTOFMEMORY;
1645 This->IDataConvert_iface.lpVtbl = &convert_vtbl;
1646 This->IDCInfo_iface.lpVtbl = &dcinfo_vtbl;
1647 This->ref = 1;
1648 This->version = 0x110;
1650 *obj = &This->IDataConvert_iface;
1652 return S_OK;