include/mscvpdb.h: Use flexible array members for the rest of structures.
[wine.git] / dlls / oledb32 / convert.c
blob540ceac1d2da5e0a25fbdb707bca2255deec5846
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 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, %Id, %p, %p, %p, %Id, %ld, %p, %d, %d, %lx)\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_I1:
253 signed char *d = dst;
254 switch(src_type)
256 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
257 case DBTYPE_I1: *d = *(signed char*)src; hr = S_OK; break;
258 case DBTYPE_I2: hr = VarI1FromI2(*(signed short*)src, d); break;
259 case DBTYPE_I4: hr = VarI1FromI4(*(signed int*)src, d); break;
260 case DBTYPE_R4: hr = VarI1FromR4(*(FLOAT*)src, d); break;
261 case DBTYPE_R8: hr = VarI1FromR8(*(double*)src, d); break;
262 case DBTYPE_CY: hr = VarI1FromCy(*(CY*)src, d); break;
263 case DBTYPE_DATE: hr = VarI1FromDate(*(DATE*)src, d); break;
264 case DBTYPE_BSTR: hr = VarI1FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
265 case DBTYPE_BOOL: hr = VarI1FromBool(*(VARIANT_BOOL*)src, d); break;
266 case DBTYPE_DECIMAL: hr = VarI1FromDec(src, d); break;
267 case DBTYPE_UI1: hr = VarI1FromUI1(*(BYTE*)src, d); break;
268 case DBTYPE_UI2: hr = VarI1FromUI2(*(WORD*)src, d); break;
269 case DBTYPE_UI4: hr = VarI1FromUI4(*(DWORD*)src, d); break;
270 case DBTYPE_I8: hr = VarI1FromI8(*(LONGLONG*)src, d); break;
271 case DBTYPE_UI8: hr = VarI1FromUI8(*(ULONGLONG*)src, d); break;
272 case DBTYPE_VARIANT:
273 VariantInit(&tmp);
274 if ((hr = VariantChangeType(&tmp, src, 0, VT_I1)) == S_OK)
275 *d = V_I1(&tmp);
276 break;
277 default: FIXME("Unimplemented conversion %04x -> I1\n", src_type); return E_NOTIMPL;
279 break;
282 case DBTYPE_I2:
284 signed short *d = dst;
285 switch(src_type)
287 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
288 case DBTYPE_I2: *d = *(signed short*)src; hr = S_OK; break;
289 case DBTYPE_I4: hr = VarI2FromI4(*(signed int*)src, d); break;
290 case DBTYPE_R4: hr = VarI2FromR4(*(FLOAT*)src, d); break;
291 case DBTYPE_R8: hr = VarI2FromR8(*(double*)src, d); break;
292 case DBTYPE_CY: hr = VarI2FromCy(*(CY*)src, d); break;
293 case DBTYPE_DATE: hr = VarI2FromDate(*(DATE*)src, d); break;
294 case DBTYPE_BSTR: hr = VarI2FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
295 case DBTYPE_BOOL: hr = VarI2FromBool(*(VARIANT_BOOL*)src, d); break;
296 case DBTYPE_DECIMAL: hr = VarI2FromDec(src, d); break;
297 case DBTYPE_I1: hr = VarI2FromI1(*(signed char*)src, d); break;
298 case DBTYPE_UI1: hr = VarI2FromUI1(*(BYTE*)src, d); break;
299 case DBTYPE_UI2: hr = VarI2FromUI2(*(WORD*)src, d); break;
300 case DBTYPE_UI4: hr = VarI2FromUI4(*(DWORD*)src, d); break;
301 case DBTYPE_I8: hr = VarI2FromI8(*(LONGLONG*)src, d); break;
302 case DBTYPE_UI8: hr = VarI2FromUI8(*(ULONGLONG*)src, d); break;
303 case DBTYPE_VARIANT:
304 VariantInit(&tmp);
305 if ((hr = VariantChangeType(&tmp, src, 0, VT_I2)) == S_OK)
306 *d = V_I2(&tmp);
307 break;
308 default: FIXME("Unimplemented conversion %04x -> I2\n", src_type); return E_NOTIMPL;
310 break;
313 case DBTYPE_I4:
315 LONG *d = dst;
316 switch(src_type)
318 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
319 case DBTYPE_I2: hr = VarI4FromI2(*(signed short*)src, d); break;
320 case DBTYPE_I4: *d = *(signed int*)src; hr = S_OK; break;
321 case DBTYPE_R4: hr = VarI4FromR4(*(FLOAT*)src, d); break;
322 case DBTYPE_R8: hr = VarI4FromR8(*(double*)src, d); break;
323 case DBTYPE_CY: hr = VarI4FromCy(*(CY*)src, d); break;
324 case DBTYPE_DATE: hr = VarI4FromDate(*(DATE*)src, d); break;
325 case DBTYPE_BSTR: hr = VarI4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
326 case DBTYPE_BOOL: hr = VarI4FromBool(*(VARIANT_BOOL*)src, d); break;
327 case DBTYPE_DECIMAL: hr = VarI4FromDec(src, d); break;
328 case DBTYPE_I1: hr = VarI4FromI1(*(signed char*)src, d); break;
329 case DBTYPE_UI1: hr = VarI4FromUI1(*(BYTE*)src, d); break;
330 case DBTYPE_UI2: hr = VarI4FromUI2(*(WORD*)src, d); break;
331 case DBTYPE_UI4: hr = VarI4FromUI4(*(DWORD*)src, d); break;
332 case DBTYPE_I8: hr = VarI4FromI8(*(LONGLONG*)src, d); break;
333 case DBTYPE_UI8: hr = VarI4FromUI8(*(ULONGLONG*)src, d); break;
334 case DBTYPE_VARIANT:
335 VariantInit(&tmp);
336 if ((hr = VariantChangeType(&tmp, src, 0, VT_I4)) == S_OK)
337 *d = V_I4(&tmp);
338 break;
339 default: FIXME("Unimplemented conversion %04x -> I4\n", src_type); return E_NOTIMPL;
341 break;
344 case DBTYPE_I8:
346 LONGLONG *d = dst;
347 switch(src_type)
349 case DBTYPE_BSTR: hr = VarI8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
350 case DBTYPE_I8: *d = *(LONGLONG*)src; hr = S_OK; break;
351 default: FIXME("Unimplemented conversion %04x -> I8\n", src_type); return E_NOTIMPL;
353 break;
356 case DBTYPE_R4:
358 FLOAT *d = dst;
359 switch(src_type)
361 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
362 case DBTYPE_I2: hr = VarR4FromI2(*(signed short*)src, d); break;
363 case DBTYPE_I4: hr = VarR4FromI4(*(signed int*)src, d); break;
364 case DBTYPE_R4: *d = *(FLOAT*)src; hr = S_OK; break;
365 case DBTYPE_R8: hr = VarR4FromR8(*(double*)src, d); break;
366 case DBTYPE_CY: hr = VarR4FromCy(*(CY*)src, d); break;
367 case DBTYPE_DATE: hr = VarR4FromDate(*(DATE*)src, d); break;
368 case DBTYPE_BSTR: hr = VarR4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
369 case DBTYPE_BOOL: hr = VarR4FromBool(*(VARIANT_BOOL*)src, d); break;
370 case DBTYPE_DECIMAL: hr = VarR4FromDec(src, d); break;
371 case DBTYPE_I1: hr = VarR4FromI1(*(signed char*)src, d); break;
372 case DBTYPE_UI1: hr = VarR4FromUI1(*(BYTE*)src, d); break;
373 case DBTYPE_UI2: hr = VarR4FromUI2(*(WORD*)src, d); break;
374 case DBTYPE_UI4: hr = VarR4FromUI4(*(DWORD*)src, d); break;
375 case DBTYPE_I8: hr = VarR4FromI8(*(LONGLONG*)src, d); break;
376 case DBTYPE_UI8: hr = VarR4FromUI8(*(ULONGLONG*)src, d); break;
377 case DBTYPE_VARIANT:
378 VariantInit(&tmp);
379 if ((hr = VariantChangeType(&tmp, src, 0, VT_R4)) == S_OK)
380 *d = V_R4(&tmp);
381 break;
382 default: FIXME("Unimplemented conversion %04x -> R4\n", src_type); return E_NOTIMPL;
384 break;
386 case DBTYPE_R8:
388 DOUBLE *d=dst;
389 switch (src_type)
391 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
392 case DBTYPE_I1: hr = VarR8FromI1(*(signed char*)src, d); break;
393 case DBTYPE_I2: hr = VarR8FromI2(*(signed short*)src, d); break;
394 case DBTYPE_I4: hr = VarR8FromI4(*(signed int*)src, d); break;
395 case DBTYPE_I8: hr = VarR8FromI8(*(LONGLONG*)src, d); break;
396 case DBTYPE_UI1: hr = VarR8FromUI1(*(BYTE*)src, d); break;
397 case DBTYPE_UI2: hr = VarR8FromUI2(*(WORD*)src, d); break;
398 case DBTYPE_UI4: hr = VarR8FromUI4(*(DWORD*)src, d); break;
399 case DBTYPE_UI8: hr = VarR8FromUI8(*(ULONGLONG*)src, d); break;
400 case DBTYPE_R4: hr = VarR8FromR4(*(FLOAT*)src, d); break;
401 case DBTYPE_R8: *d = *(DOUBLE*)src; hr = S_OK; break;
402 case DBTYPE_CY: hr = VarR8FromCy(*(CY*)src, d); break;
403 case DBTYPE_DATE: hr = VarR8FromDate(*(DATE*)src, d); break;
404 case DBTYPE_BSTR: hr = VarR8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
405 case DBTYPE_BOOL: hr = VarR8FromBool(*(VARIANT_BOOL*)src, d); break;
406 case DBTYPE_DECIMAL: hr = VarR8FromDec(src, d); break;
407 case DBTYPE_VARIANT:
408 VariantInit(&tmp);
409 if ((hr = VariantChangeType(&tmp, src, 0, VT_R8)) == S_OK)
410 *d = V_R8(&tmp);
411 break;
412 default: FIXME("Unimplemented conversion %04x -> R8\n", src_type); return E_NOTIMPL;
414 break;
416 case DBTYPE_BOOL:
418 VARIANT_BOOL *d=dst;
419 switch (src_type)
421 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
422 case DBTYPE_I1: hr = VarBoolFromI1(*(signed char*)src, d); break;
423 case DBTYPE_I2: hr = VarBoolFromI2(*(signed short*)src, d); break;
424 case DBTYPE_I4: hr = VarBoolFromI4(*(signed int*)src, d); break;
425 case DBTYPE_I8: hr = VarBoolFromI8(*(LONGLONG*)src, d); break;
426 case DBTYPE_UI1: hr = VarBoolFromUI1(*(BYTE*)src, d); break;
427 case DBTYPE_UI2: hr = VarBoolFromUI2(*(WORD*)src, d); break;
428 case DBTYPE_UI4: hr = VarBoolFromUI4(*(DWORD*)src, d); break;
429 case DBTYPE_UI8: hr = VarBoolFromUI8(*(ULONGLONG*)src, d); break;
430 case DBTYPE_R4: hr = VarBoolFromR4(*(FLOAT*)src, d); break;
431 case DBTYPE_R8: hr = VarBoolFromR8(*(DOUBLE*)src, d); break;
432 case DBTYPE_CY: hr = VarBoolFromCy(*(CY*)src, d); break;
433 case DBTYPE_DATE: hr = VarBoolFromDate(*(DATE*)src, d); break;
434 case DBTYPE_BSTR: hr = VarBoolFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
435 case DBTYPE_BOOL: *d = *(VARIANT_BOOL*)src; hr = S_OK; break;
436 case DBTYPE_DECIMAL: hr = VarBoolFromDec(src, d); break;
437 default: FIXME("Unimplemented conversion %04x -> BOOL\n", src_type); return E_NOTIMPL;
439 break;
441 case DBTYPE_DATE:
443 DATE *d=dst;
444 switch (src_type)
446 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
447 case DBTYPE_I1: hr = VarDateFromI1(*(signed char*)src, d); break;
448 case DBTYPE_I2: hr = VarDateFromI2(*(signed short*)src, d); break;
449 case DBTYPE_I4: hr = VarDateFromI4(*(signed int*)src, d); break;
450 case DBTYPE_I8: hr = VarDateFromI8(*(LONGLONG*)src, d); break;
451 case DBTYPE_UI1: hr = VarDateFromUI1(*(BYTE*)src, d); break;
452 case DBTYPE_UI2: hr = VarDateFromUI2(*(WORD*)src, d); break;
453 case DBTYPE_UI4: hr = VarDateFromUI4(*(DWORD*)src, d); break;
454 case DBTYPE_UI8: hr = VarDateFromUI8(*(ULONGLONG*)src, d); break;
455 case DBTYPE_R4: hr = VarDateFromR4(*(FLOAT*)src, d); break;
456 case DBTYPE_R8: hr = VarDateFromR8(*(DOUBLE*)src, d); break;
457 case DBTYPE_CY: hr = VarDateFromCy(*(CY*)src, d); break;
458 case DBTYPE_DATE: *d = *(DATE*)src; hr = S_OK; break;
459 case DBTYPE_BSTR: hr = VarDateFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
460 case DBTYPE_BOOL: hr = VarDateFromBool(*(VARIANT_BOOL*)src, d); break;
461 case DBTYPE_DECIMAL: hr = VarDateFromDec(src, d); break;
462 case DBTYPE_DBTIMESTAMP:
464 SYSTEMTIME st;
465 DBTIMESTAMP *ts = src;
467 st.wYear = ts->year;
468 st.wMonth = ts->month;
469 st.wDay = ts->day;
470 st.wHour = ts->hour;
471 st.wMinute = ts->minute;
472 st.wSecond = ts->second;
473 st.wMilliseconds = ts->fraction/1000000;
474 hr = (SystemTimeToVariantTime(&st, d) ? S_OK : E_FAIL);
475 break;
477 case DBTYPE_VARIANT:
479 VARIANT tmp;
480 VariantInit(&tmp);
481 if ((hr = VariantChangeType(&tmp, src, 0, VT_DATE)) == S_OK)
482 *d = V_DATE(&tmp);
483 break;
485 default: FIXME("Unimplemented conversion %04x -> DATE\n", src_type); return E_NOTIMPL;
487 break;
489 case DBTYPE_DBDATE:
491 DBDATE *d=dst;
492 switch (src_type)
494 case DBTYPE_DBDATE: memcpy(d, src, sizeof(DBDATE)); hr = S_OK; break;
495 case DBTYPE_BSTR:
497 VARIANT var;
498 BSTR s = *(WCHAR**)src;
500 VariantInit(&var);
501 V_VT(&var) = VT_BSTR;
502 V_BSTR(&var) = SysAllocString(s);
504 if ((hr = VariantChangeType(&var, &var, 0, VT_DATE)) == S_OK)
506 SYSTEMTIME st;
507 hr = (VariantTimeToSystemTime( V_DATE(&var), &st) ? S_OK : E_FAIL);
508 d->year = st.wYear;
509 d->month = st.wMonth;
510 d->day = st.wDay;
513 VariantClear(&var);
515 break;
516 case DBTYPE_VARIANT:
518 VariantInit(&tmp);
520 if ((hr = VariantChangeType(&tmp, src, 0, VT_DATE)) == S_OK)
522 SYSTEMTIME st;
523 hr = (VariantTimeToSystemTime( V_DATE(&tmp), &st) ? S_OK : E_FAIL);
524 d->year = st.wYear;
525 d->month = st.wMonth;
526 d->day = st.wDay;
528 else
530 FIXME("Unimplemented variant type %d -> DBDATE\n", V_VT((VARIANT*)src));
531 return E_NOTIMPL;
533 break;
535 default: FIXME("Unimplemented conversion %04x -> DBDATE\n", src_type); return E_NOTIMPL;
537 break;
539 case DBTYPE_DBTIMESTAMP:
541 DBTIMESTAMP *d=dst;
542 switch (src_type)
544 case DBTYPE_EMPTY: memset(d, 0, sizeof(DBTIMESTAMP)); hr = S_OK; break;
545 case DBTYPE_DBTIMESTAMP: memcpy(d, src, sizeof(DBTIMESTAMP)); hr = S_OK; break;
546 case DBTYPE_BSTR:
548 VARIANT var;
549 BSTR s = *(WCHAR**)src;
551 VariantInit(&var);
552 V_VT(&var) = VT_BSTR;
553 V_BSTR(&var) = SysAllocString(s);
555 if ((hr = VariantChangeType(&var, &var, 0, VT_DATE)) == S_OK)
557 SYSTEMTIME st;
559 hr = (VariantTimeToSystemTime( V_DATE(&var), &st) ? S_OK : E_FAIL);
560 d->year = st.wYear;
561 d->month = st.wMonth;
562 d->day = st.wDay;
563 d->hour = st.wHour;
564 d->minute = st.wMinute;
565 d->second = st.wSecond;
566 d->fraction = st.wMilliseconds * 1000000;
568 else
570 if(swscanf( s, L"%d-%d-%d %d:%d:%d.%d", &d->year, &d->month, &d->day, &d->hour, &d->minute,
571 &d->second, &d->fraction) != 7)
573 hr = DISP_E_TYPEMISMATCH;
574 *dst_status = DBSTATUS_E_CANTCONVERTVALUE;
575 *dst_len = get_length(dst_type);
577 else
578 hr = S_OK;
581 VariantClear(&var);
583 break;
584 case DBTYPE_DATE:
586 SYSTEMTIME st;
587 hr = (VariantTimeToSystemTime(*(double*)src, &st) ? S_OK : E_FAIL);
588 d->year = st.wYear;
589 d->month = st.wMonth;
590 d->day = st.wDay;
591 d->hour = st.wHour;
592 d->minute = st.wMinute;
593 d->second = st.wSecond;
594 d->fraction = st.wMilliseconds * 1000000;
595 break;
597 case DBTYPE_VARIANT:
598 if( V_VT((VARIANT*)src) == VT_DATE)
600 SYSTEMTIME st;
601 hr = (VariantTimeToSystemTime( V_DATE((VARIANT*)src), &st) ? S_OK : E_FAIL);
602 d->year = st.wYear;
603 d->month = st.wMonth;
604 d->day = st.wDay;
605 d->hour = st.wHour;
606 d->minute = st.wMinute;
607 d->second = st.wSecond;
608 d->fraction = st.wMilliseconds * 1000000;
610 else
612 FIXME("Unimplemented variant type %d -> DBTIMESTAMP\n", V_VT((VARIANT*)src));
613 return E_NOTIMPL;
615 break;
616 default: FIXME("Unimplemented conversion %04x -> DBTIMESTAMP\n", src_type); return E_NOTIMPL;
618 break;
621 case DBTYPE_CY:
623 CY *d = dst;
624 switch(src_type)
626 case DBTYPE_EMPTY: d->int64 = 0; hr = S_OK; break;
627 case DBTYPE_I2: hr = VarCyFromI2(*(signed short*)src, d); break;
628 case DBTYPE_I4: hr = VarCyFromI4(*(signed int*)src, d); break;
629 case DBTYPE_R4: hr = VarCyFromR4(*(FLOAT*)src, d); break;
630 case DBTYPE_R8: hr = VarCyFromR8(*(double*)src, d); break;
631 case DBTYPE_CY: *d = *(CY*)src; hr = S_OK; break;
632 case DBTYPE_DATE: hr = VarCyFromDate(*(DATE*)src, d); break;
633 case DBTYPE_BSTR: hr = VarCyFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
634 case DBTYPE_BOOL: hr = VarCyFromBool(*(VARIANT_BOOL*)src, d); break;
635 case DBTYPE_DECIMAL: hr = VarCyFromDec(src, d); break;
636 case DBTYPE_I1: hr = VarCyFromI1(*(signed char*)src, d); break;
637 case DBTYPE_UI1: hr = VarCyFromUI1(*(BYTE*)src, d); break;
638 case DBTYPE_UI2: hr = VarCyFromUI2(*(WORD*)src, d); break;
639 case DBTYPE_UI4: hr = VarCyFromUI4(*(DWORD*)src, d); break;
640 case DBTYPE_I8: hr = VarCyFromI8(*(LONGLONG*)src, d); break;
641 case DBTYPE_UI8: hr = VarCyFromUI8(*(ULONGLONG*)src, d); break;
642 default: FIXME("Unimplemented conversion %04x -> CY\n", src_type); return E_NOTIMPL;
644 break;
647 case DBTYPE_BSTR:
649 BSTR *d = dst;
650 switch(src_type)
652 case DBTYPE_EMPTY: *d = SysAllocStringLen(NULL, 0); hr = *d ? S_OK : E_OUTOFMEMORY; break;
653 case DBTYPE_I2: hr = VarBstrFromI2(*(signed short*)src, LOCALE_USER_DEFAULT, 0, d); break;
654 case DBTYPE_I4: hr = VarBstrFromI4(*(signed int*)src, LOCALE_USER_DEFAULT, 0, d); break;
655 case DBTYPE_R4: hr = VarBstrFromR4(*(FLOAT*)src, LOCALE_USER_DEFAULT, 0, d); break;
656 case DBTYPE_R8: hr = VarBstrFromR8(*(double*)src, LOCALE_USER_DEFAULT, 0, d); break;
657 case DBTYPE_CY: hr = VarBstrFromCy(*(CY*)src, LOCALE_USER_DEFAULT, 0, d); break;
658 case DBTYPE_DATE: hr = VarBstrFromDate(*(DATE*)src, LOCALE_USER_DEFAULT, 0, d); break;
659 case DBTYPE_BSTR: *d = SysAllocStringLen(*(BSTR*)src, SysStringLen(*(BSTR*)src)); hr = *d ? S_OK : E_OUTOFMEMORY; break;
660 case DBTYPE_BOOL: hr = VarBstrFromBool(*(VARIANT_BOOL*)src, LOCALE_USER_DEFAULT, 0, d); break;
661 case DBTYPE_DECIMAL: hr = VarBstrFromDec(src, LOCALE_USER_DEFAULT, 0, d); break;
662 case DBTYPE_I1: hr = VarBstrFromI1(*(signed char*)src, LOCALE_USER_DEFAULT, 0, d); break;
663 case DBTYPE_UI1: hr = VarBstrFromUI1(*(BYTE*)src, LOCALE_USER_DEFAULT, 0, d); break;
664 case DBTYPE_UI2: hr = VarBstrFromUI2(*(WORD*)src, LOCALE_USER_DEFAULT, 0, d); break;
665 case DBTYPE_UI4: hr = VarBstrFromUI4(*(DWORD*)src, LOCALE_USER_DEFAULT, 0, d); break;
666 case DBTYPE_I8: hr = VarBstrFromI8(*(LONGLONG*)src, LOCALE_USER_DEFAULT, 0, d); break;
667 case DBTYPE_UI8: hr = VarBstrFromUI8(*(ULONGLONG*)src, LOCALE_USER_DEFAULT, 0, d); break;
668 case DBTYPE_GUID:
670 WCHAR szBuff[39];
671 const GUID *id = src;
672 wsprintfW(szBuff, L"{%08X-%04X-%04X-%02X%02X-%02X%02X%02X%02X%02X%02X}",
673 id->Data1, id->Data2, id->Data3,
674 id->Data4[0], id->Data4[1], id->Data4[2], id->Data4[3],
675 id->Data4[4], id->Data4[5], id->Data4[6], id->Data4[7] );
676 *d = SysAllocString(szBuff);
677 hr = *d ? S_OK : E_OUTOFMEMORY;
679 break;
680 case DBTYPE_BYTES:
682 *d = SysAllocStringLen(NULL, 2 * src_len);
683 if (*d == NULL)
684 hr = E_OUTOFMEMORY;
685 else
687 static const char hexchars[] = "0123456789ABCDEF";
688 WCHAR *s = *d;
689 unsigned char *p = src;
690 while (src_len > 0)
692 *s++ = hexchars[(*p >> 4) & 0x0F];
693 *s++ = hexchars[(*p) & 0x0F];
694 src_len--; p++;
696 hr = S_OK;
699 break;
700 case DBTYPE_DBTIMESTAMP:
702 WCHAR szBuff[64];
703 DBTIMESTAMP *ts = src;
705 if(ts->fraction == 0)
706 wsprintfW(szBuff, L"%04d-%02d-%02d %02d:%02d:%02d", ts->year, ts->month, ts->day, ts->hour,
707 ts->minute, ts->second);
708 else
709 wsprintfW(szBuff, L"%04d-%02d-%02d %02d:%02d:%02d.%09d", ts->year, ts->month, ts->day, ts->hour,
710 ts->minute, ts->second, ts->fraction );
711 *d = SysAllocString(szBuff);
712 hr = *d ? S_OK : E_OUTOFMEMORY;
713 break;
715 case DBTYPE_VARIANT:
716 VariantInit(&tmp);
717 if ((hr = VariantChangeType(&tmp, src, 0, VT_BSTR)) == S_OK)
718 *d = V_BSTR(&tmp);
719 break;
720 default: FIXME("Unimplemented conversion %04x -> BSTR\n", src_type); return E_NOTIMPL;
722 break;
725 case DBTYPE_UI1:
727 BYTE *d = dst;
728 switch(src_type)
730 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
731 case DBTYPE_I2: hr = VarUI1FromI2(*(signed short*)src, d); break;
732 case DBTYPE_I4: hr = VarUI1FromI4(*(signed int*)src, d); break;
733 case DBTYPE_R4: hr = VarUI1FromR4(*(FLOAT*)src, d); break;
734 case DBTYPE_R8: hr = VarUI1FromR8(*(double*)src, d); break;
735 case DBTYPE_CY: hr = VarUI1FromCy(*(CY*)src, d); break;
736 case DBTYPE_DATE: hr = VarUI1FromDate(*(DATE*)src, d); break;
737 case DBTYPE_BSTR: hr = VarUI1FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
738 case DBTYPE_BOOL: hr = VarUI1FromBool(*(VARIANT_BOOL*)src, d); break;
739 case DBTYPE_DECIMAL: hr = VarUI1FromDec(src, d); break;
740 case DBTYPE_I1: hr = VarUI1FromI1(*(signed char*)src, d); break;
741 case DBTYPE_UI1: *d = *(BYTE*)src; hr = S_OK; break;
742 case DBTYPE_UI2: hr = VarUI1FromUI2(*(WORD*)src, d); break;
743 case DBTYPE_UI4: hr = VarUI1FromUI4(*(DWORD*)src, d); break;
744 case DBTYPE_I8: hr = VarUI1FromI8(*(LONGLONG*)src, d); break;
745 case DBTYPE_UI8: hr = VarUI1FromUI8(*(ULONGLONG*)src, d); break;
746 default: FIXME("Unimplemented conversion %04x -> UI1\n", src_type); return E_NOTIMPL;
748 break;
750 case DBTYPE_UI2:
752 WORD *d = dst;
753 switch(src_type)
755 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
756 case DBTYPE_I2: hr = VarUI2FromI2(*(signed short*)src, d); break;
757 case DBTYPE_I4: hr = VarUI2FromI4(*(signed int*)src, d); break;
758 case DBTYPE_R4: hr = VarUI2FromR4(*(FLOAT*)src, d); break;
759 case DBTYPE_R8: hr = VarUI2FromR8(*(double*)src, d); break;
760 case DBTYPE_CY: hr = VarUI2FromCy(*(CY*)src, d); break;
761 case DBTYPE_DATE: hr = VarUI2FromDate(*(DATE*)src, d); break;
762 case DBTYPE_BSTR: hr = VarUI2FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
763 case DBTYPE_BOOL: hr = VarUI2FromBool(*(VARIANT_BOOL*)src, d); break;
764 case DBTYPE_DECIMAL: hr = VarUI2FromDec(src, d); break;
765 case DBTYPE_I1: hr = VarUI2FromI1(*(signed char*)src, d); break;
766 case DBTYPE_UI1: hr = VarUI2FromUI1(*(BYTE*)src, d); break;
767 case DBTYPE_UI2: *d = *(WORD*)src; hr = S_OK; break;
768 case DBTYPE_UI4: hr = VarUI2FromUI4(*(DWORD*)src, d); break;
769 case DBTYPE_I8: hr = VarUI2FromI8(*(LONGLONG*)src, d); break;
770 case DBTYPE_UI8: hr = VarUI2FromUI8(*(ULONGLONG*)src, d); break;
771 default: FIXME("Unimplemented conversion %04x -> UI2\n", src_type); return E_NOTIMPL;
773 break;
776 case DBTYPE_UI4:
778 DWORD *d = dst;
779 switch(src_type)
781 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
782 case DBTYPE_I2: hr = VarUI4FromI2(*(signed short*)src, d); break;
783 case DBTYPE_I4: hr = VarUI4FromI4(*(signed int*)src, d); break;
784 case DBTYPE_R4: hr = VarUI4FromR4(*(FLOAT*)src, d); break;
785 case DBTYPE_R8: hr = VarUI4FromR8(*(double*)src, d); break;
786 case DBTYPE_CY: hr = VarUI4FromCy(*(CY*)src, d); break;
787 case DBTYPE_DATE: hr = VarUI4FromDate(*(DATE*)src, d); break;
788 case DBTYPE_BSTR: hr = VarUI4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
789 case DBTYPE_BOOL: hr = VarUI4FromBool(*(VARIANT_BOOL*)src, d); break;
790 case DBTYPE_DECIMAL: hr = VarUI4FromDec(src, d); break;
791 case DBTYPE_I1: hr = VarUI4FromI1(*(signed char*)src, d); break;
792 case DBTYPE_UI1: hr = VarUI4FromUI1(*(BYTE*)src, d); break;
793 case DBTYPE_UI2: hr = VarUI4FromUI2(*(WORD*)src, d); break;
794 case DBTYPE_UI4: *d = *(DWORD*)src; hr = S_OK; break;
795 case DBTYPE_I8: hr = VarUI4FromI8(*(LONGLONG*)src, d); break;
796 case DBTYPE_UI8: hr = VarUI4FromUI8(*(ULONGLONG*)src, d); break;
797 case DBTYPE_VARIANT:
798 VariantInit(&tmp);
799 if ((hr = VariantChangeType(&tmp, src, 0, VT_UI4)) == S_OK)
800 *d = V_UI4(&tmp);
801 break;
802 default: FIXME("Unimplemented conversion %04x -> UI4\n", src_type); return E_NOTIMPL;
804 break;
807 case DBTYPE_UI8:
809 ULONGLONG *d = dst;
810 switch(src_type)
812 case DBTYPE_EMPTY: *d = 0; hr = S_OK; break;
813 case DBTYPE_I2: hr = VarUI8FromI2(*(signed short*)src, d); break;
814 case DBTYPE_I4: {LONGLONG s = *(signed int*)src; hr = VarUI8FromI8(s, d); break;}
815 case DBTYPE_R4: hr = VarUI8FromR4(*(FLOAT*)src, d); break;
816 case DBTYPE_R8: hr = VarUI8FromR8(*(double*)src, d); break;
817 case DBTYPE_CY: hr = VarUI8FromCy(*(CY*)src, d); break;
818 case DBTYPE_DATE: hr = VarUI8FromDate(*(DATE*)src, d); break;
819 case DBTYPE_BSTR: hr = VarUI8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
820 case DBTYPE_BOOL: hr = VarUI8FromBool(*(VARIANT_BOOL*)src, d); break;
821 case DBTYPE_DECIMAL: hr = VarUI8FromDec(src, d); break;
822 case DBTYPE_I1: hr = VarUI8FromI1(*(signed char*)src, d); break;
823 case DBTYPE_UI1: hr = VarUI8FromUI1(*(BYTE*)src, d); break;
824 case DBTYPE_UI2: hr = VarUI8FromUI2(*(WORD*)src, d); break;
825 case DBTYPE_UI4: hr = VarUI8FromUI4(*(DWORD*)src, d); break;
826 case DBTYPE_I8: hr = VarUI8FromI8(*(LONGLONG*)src, d); break;
827 case DBTYPE_UI8: *d = *(ULONGLONG*)src; hr = S_OK; break;
828 case DBTYPE_VARIANT:
829 VariantInit(&tmp);
830 if ((hr = VariantChangeType(&tmp, src, 0, VT_UI8)) == S_OK)
831 *d = V_UI8(&tmp);
832 break;
833 default: FIXME("Unimplemented conversion %04x -> UI8\n", src_type); return E_NOTIMPL;
835 break;
838 case DBTYPE_FILETIME:
840 FILETIME *d = dst;
841 switch(src_type)
843 case DBTYPE_EMPTY: d->dwLowDateTime = d->dwHighDateTime = 0; hr = S_OK; break;
844 case DBTYPE_FILETIME: *d = *(FILETIME*)src; hr = S_OK; break;
845 default: FIXME("Unimplemented conversion %04x -> FILETIME\n", src_type); return E_NOTIMPL;
847 break;
850 case DBTYPE_GUID:
852 GUID *d = dst;
853 switch(src_type)
855 case DBTYPE_EMPTY: *d = GUID_NULL; hr = S_OK; break;
856 case DBTYPE_GUID: *d = *(GUID*)src; hr = S_OK; break;
857 case DBTYPE_VARIANT:
858 if (V_VT((VARIANT *)src) == VT_BSTR)
860 hr = CLSIDFromString(V_BSTR((VARIANT *)src), d);
861 if (FAILED(hr))
863 *dst_len = sizeof(GUID);
864 *dst_status = DBSTATUS_E_CANTCONVERTVALUE;
866 break;
868 default: FIXME("Unimplemented conversion %04x -> GUID\n", src_type); return E_NOTIMPL;
870 break;
873 case DBTYPE_WSTR:
875 BSTR b;
876 DBLENGTH bstr_len;
877 INT bytes_to_copy;
878 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &bstr_len,
879 src, &b, sizeof(BSTR), src_status, dst_status,
880 precision, scale, flags);
881 if(hr != S_OK || *dst_status == DBSTATUS_S_ISNULL)
882 return hr;
883 bstr_len = SysStringLen(b);
884 *dst_len = bstr_len * sizeof(WCHAR); /* Doesn't include size for '\0' */
885 *dst_status = DBSTATUS_S_OK;
886 bytes_to_copy = min(*dst_len + sizeof(WCHAR), dst_max_len);
887 if(dst)
889 if(bytes_to_copy >= sizeof(WCHAR))
891 memcpy(dst, b, bytes_to_copy - sizeof(WCHAR));
892 *((WCHAR*)dst + bytes_to_copy / sizeof(WCHAR) - 1) = 0;
893 if(bytes_to_copy < *dst_len + sizeof(WCHAR))
894 *dst_status = DBSTATUS_S_TRUNCATED;
896 else
898 *dst_status = DBSTATUS_E_DATAOVERFLOW;
899 hr = DB_E_ERRORSOCCURRED;
902 SysFreeString(b);
903 return hr;
906 case DBTYPE_STR:
908 BSTR b;
909 DBLENGTH length;
910 INT bytes_to_copy;
911 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &length,
912 src, &b, sizeof(BSTR), src_status, dst_status,
913 precision, scale, flags);
914 if(hr != S_OK) return hr;
915 length = WideCharToMultiByte(CP_ACP, 0, b, SysStringLen(b), NULL, 0, NULL, NULL);
916 *dst_len = length; /* Doesn't include size for '\0' */
917 *dst_status = DBSTATUS_S_OK;
918 bytes_to_copy = min(length + 1, dst_max_len);
919 if(dst)
921 if(bytes_to_copy >= sizeof(char))
923 WideCharToMultiByte(CP_ACP, 0, b, SysStringLen(b), dst, bytes_to_copy - 1, NULL, NULL);
924 *((char *)dst + bytes_to_copy - 1) = 0;
925 if(bytes_to_copy < length + 1)
926 *dst_status = DBSTATUS_S_TRUNCATED;
928 else
930 *dst_status = DBSTATUS_E_DATAOVERFLOW;
931 hr = DB_E_ERRORSOCCURRED;
934 SysFreeString(b);
935 return hr;
938 case DBTYPE_BYREF | DBTYPE_WSTR:
940 BSTR b;
941 WCHAR **d = dst;
942 DBLENGTH bstr_len;
943 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &bstr_len,
944 src, &b, sizeof(BSTR), src_status, dst_status,
945 precision, scale, flags);
946 if(hr != S_OK) return hr;
948 bstr_len = SysStringLen(b) * sizeof(WCHAR);
949 *dst_len = bstr_len; /* Doesn't include size for '\0' */
951 *d = CoTaskMemAlloc(bstr_len + sizeof(WCHAR));
952 if(*d) memcpy(*d, b, bstr_len + sizeof(WCHAR));
953 else hr = E_OUTOFMEMORY;
954 SysFreeString(b);
955 return hr;
958 case DBTYPE_BYREF | DBTYPE_STR:
960 BSTR b;
961 char **d = dst;
962 DBLENGTH length;
963 hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &length,
964 src, &b, sizeof(BSTR), src_status, dst_status,
965 precision, scale, flags);
966 if(hr != S_OK) return hr;
968 length = WideCharToMultiByte(CP_ACP, 0, b, SysStringLen(b) + 1, NULL, 0, NULL, NULL);
969 *dst_len = length - 1; /* Doesn't include size for '\0' */
970 *dst_status = DBSTATUS_S_OK;
971 *d = CoTaskMemAlloc(length);
973 if(*d)
974 WideCharToMultiByte(CP_ACP, 0, b, SysStringLen(b) + 1, *d, length, NULL, NULL);
975 else
976 hr = E_OUTOFMEMORY;
977 SysFreeString(b);
979 return hr;
982 case DBTYPE_VARIANT:
984 VARIANT *v = dst;
986 switch(src_type)
988 case DBTYPE_BOOL:
989 V_VT(v) = VT_BOOL;
990 V_BOOL(v) = *(VARIANT_BOOL*)src;
991 hr = S_OK;
992 break;
993 case DBTYPE_I2:
994 V_VT(v) = VT_I2;
995 V_I2(v) = *(signed short*)src;
996 hr = S_OK;
997 break;
998 case DBTYPE_I4:
999 V_VT(v) = VT_I4;
1000 V_I4(v) = *(signed int*)src;
1001 hr = S_OK;
1002 break;
1003 case DBTYPE_I8:
1004 V_VT(v) = VT_DECIMAL;
1005 hr = VarDecFromI8( *(LONGLONG*)src, &V_DECIMAL(v));
1006 break;
1007 case DBTYPE_R4:
1008 V_VT(v) = VT_R4;
1009 V_R4(v) = *(FLOAT*)src;
1010 hr = S_OK;
1011 break;
1012 case DBTYPE_R8:
1013 V_VT(v) = VT_R8;
1014 V_R8(v) = *(double*)src;
1015 hr = S_OK;
1016 break;
1017 case DBTYPE_BSTR:
1019 BSTR s = *(WCHAR**)src;
1020 TRACE("%s\n", debugstr_w(s));
1021 V_VT(v) = VT_BSTR;
1022 V_BSTR(v) = SysAllocString(s);
1023 hr = V_BSTR(v) ? S_OK : E_OUTOFMEMORY;
1024 break;
1026 case DBTYPE_DATE:
1027 V_VT(v) = VT_DATE;
1028 V_DATE(v) = *(DATE*)src;
1029 hr = S_OK;
1030 break;
1031 case DBTYPE_DBDATE:
1033 SYSTEMTIME st;
1034 DBDATE *ts = src;
1036 V_VT(v) = VT_DATE;
1038 st.wYear = ts->year;
1039 st.wMonth = ts->month;
1040 st.wDay = ts->day;
1041 st.wHour = 0;
1042 st.wMinute = 0;
1043 st.wSecond = 0;
1044 st.wMilliseconds = 0;
1045 hr = (SystemTimeToVariantTime(&st, &V_DATE(v)) ? S_OK : E_FAIL);
1046 break;
1048 case DBTYPE_DBTIMESTAMP:
1050 SYSTEMTIME st;
1051 DBTIMESTAMP *ts = src;
1053 V_VT(v) = VT_DATE;
1055 st.wYear = ts->year;
1056 st.wMonth = ts->month;
1057 st.wDay = ts->day;
1058 st.wHour = ts->hour;
1059 st.wMinute = ts->minute;
1060 st.wSecond = ts->second;
1061 st.wMilliseconds = ts->fraction/1000000;
1062 hr = SystemTimeToVariantTime(&st, &V_DATE(v)) ? S_OK : E_FAIL;
1063 break;
1065 case DBTYPE_CY:
1066 V_VT(v) = VT_CY;
1067 V_CY(v) = *(CY*)src;
1068 hr = S_OK;
1069 break;
1070 case DBTYPE_BYTES:
1072 LONG i;
1073 SAFEARRAY *psa = NULL;
1074 SAFEARRAYBOUND rgsabound[1];
1075 unsigned char *p = src;
1077 rgsabound[0].lLbound = 0;
1078 rgsabound[0].cElements = src_len;
1080 psa = SafeArrayCreate(VT_UI1,1,rgsabound);
1081 for(i =0; i < src_len; i++,p++)
1083 hr = SafeArrayPutElement(psa, &i, p);
1084 if(FAILED(hr)) {
1085 SafeArrayDestroy (psa);
1086 return hr;
1090 V_VT(v) = VT_ARRAY|VT_UI1;
1091 V_ARRAY(v) = psa;
1092 hr = S_OK;
1093 break;
1095 case DBTYPE_VARIANT:
1097 VariantInit(v);
1098 hr = VariantCopy(v, (VARIANT *)src);
1099 break;
1101 default: FIXME("Unimplemented conversion %04x -> VARIANT\n", src_type); return E_NOTIMPL;
1103 break;
1105 case DBTYPE_BYTES:
1107 BYTE *d = dst;
1109 switch(src_type)
1111 case DBTYPE_BYTES:
1112 if( src_len > dst_max_len)
1113 *dst_status = DBSTATUS_S_TRUNCATED;
1114 else
1115 *dst_status = DBSTATUS_S_OK;
1117 *dst_len = src_len;
1118 memcpy(d, src, min(src_len, dst_max_len));
1120 return S_OK;
1121 case DBTYPE_VARIANT:
1123 switch(V_VT((VARIANT*)src))
1125 case VT_UI1 | VT_ARRAY:
1127 LONG l;
1128 BYTE *data = NULL;
1130 hr = SafeArrayGetUBound(V_ARRAY((VARIANT*)src), 1, &l);
1131 if(FAILED(hr))
1132 return hr;
1134 hr = SafeArrayAccessData(V_ARRAY((VARIANT*)src), (VOID**)&data);
1135 if(FAILED(hr))
1137 ERR("SafeArrayAccessData Failed = 0x%08lx\n", hr);
1138 return hr;
1141 *dst_len = l+1;
1142 *dst_status = DBSTATUS_S_OK;
1143 memcpy(d, data, *dst_len);
1145 SafeArrayUnaccessData(V_ARRAY((VARIANT*)src));
1146 return S_OK;
1148 break;
1149 default:
1150 FIXME("Unimplemented variant type %d -> BYTES\n", V_VT((VARIANT*)src));
1151 return E_NOTIMPL;
1154 break;
1155 default: FIXME("Unimplemented conversion %04x -> DBTYPE_BYTES\n", src_type); return E_NOTIMPL;
1157 break;
1159 case DBTYPE_BYTES | DBTYPE_BYREF:
1161 BYTE **d = dst;
1163 switch(src_type)
1165 case DBTYPE_BYTES:
1166 *d = CoTaskMemAlloc(src_len);
1167 if(*d) memcpy(*d, src, src_len);
1168 else hr = E_OUTOFMEMORY;
1170 *dst_len = src_len;
1171 *dst_status = DBSTATUS_S_OK;
1172 return S_OK;
1173 default: FIXME("Unimplemented conversion %04x -> DBTYPE_BYTES | DBTYPE_BYREF\n", src_type); return E_NOTIMPL;
1175 break;
1178 case DBTYPE_NUMERIC:
1179 FIXME("Unimplemented conversion %04x -> DBTYPE_NUMERIC\n", src_type);
1180 return E_NOTIMPL;
1182 default:
1183 FIXME("Unimplemented conversion %04x -> %04x\n", src_type, dst_type);
1184 return E_NOTIMPL;
1187 if(hr == DISP_E_OVERFLOW)
1189 *dst_status = DBSTATUS_E_DATAOVERFLOW;
1190 *dst_len = get_length(dst_type);
1191 hr = DB_E_ERRORSOCCURRED;
1193 else if(hr == S_OK)
1195 *dst_status = DBSTATUS_S_OK;
1196 *dst_len = get_length(dst_type);
1199 return hr;
1202 static inline WORD get_dbtype_class(DBTYPE type)
1204 switch(type)
1206 case DBTYPE_I2:
1207 case DBTYPE_R4:
1208 case DBTYPE_R8:
1209 case DBTYPE_I1:
1210 case DBTYPE_UI1:
1211 case DBTYPE_UI2:
1212 return DBTYPE_I2;
1214 case DBTYPE_I4:
1215 case DBTYPE_UI4:
1216 return DBTYPE_I4;
1218 case DBTYPE_I8:
1219 case DBTYPE_UI8:
1220 return DBTYPE_I8;
1222 case DBTYPE_BSTR:
1223 case DBTYPE_STR:
1224 case DBTYPE_WSTR:
1225 return DBTYPE_BSTR;
1227 case DBTYPE_DBDATE:
1228 case DBTYPE_DBTIME:
1229 case DBTYPE_DBTIMESTAMP:
1230 return DBTYPE_DBDATE;
1232 return type;
1235 /* Many src types will convert to this group of dst types */
1236 static inline BOOL common_class(WORD dst_class)
1238 switch(dst_class)
1240 case DBTYPE_EMPTY:
1241 case DBTYPE_NULL:
1242 case DBTYPE_I2:
1243 case DBTYPE_I4:
1244 case DBTYPE_BSTR:
1245 case DBTYPE_BOOL:
1246 case DBTYPE_VARIANT:
1247 case DBTYPE_I8:
1248 case DBTYPE_CY:
1249 case DBTYPE_DECIMAL:
1250 case DBTYPE_NUMERIC:
1251 return TRUE;
1253 return FALSE;
1256 static inline BOOL array_type(DBTYPE type)
1258 return (type >= DBTYPE_I2 && type <= DBTYPE_UI4);
1261 static HRESULT WINAPI convert_CanConvert(IDataConvert* iface,
1262 DBTYPE src_type, DBTYPE dst_type)
1264 convert *This = impl_from_IDataConvert(iface);
1265 DBTYPE src_base_type = src_type & 0x1ff;
1266 DBTYPE dst_base_type = dst_type & 0x1ff;
1267 WORD dst_class = get_dbtype_class(dst_base_type);
1269 TRACE("(%p)->(%d, %d)\n", This, src_type, dst_type);
1271 if(src_type & DBTYPE_VECTOR || dst_type & DBTYPE_VECTOR) return S_FALSE;
1273 if(src_type & DBTYPE_ARRAY)
1275 if(!array_type(src_base_type)) return S_FALSE;
1276 if(dst_type & DBTYPE_ARRAY)
1278 if(src_type == dst_type) return S_OK;
1279 return S_FALSE;
1281 if(dst_type == DBTYPE_VARIANT) return S_OK;
1282 return S_FALSE;
1285 if(dst_type & DBTYPE_ARRAY)
1287 if(!array_type(dst_base_type)) return S_FALSE;
1288 if(src_type == DBTYPE_IDISPATCH || src_type == DBTYPE_VARIANT) return S_OK;
1289 return S_FALSE;
1292 if(dst_type & DBTYPE_BYREF)
1293 if(dst_base_type != DBTYPE_BYTES && dst_base_type != DBTYPE_STR && dst_base_type != DBTYPE_WSTR)
1294 return S_FALSE;
1296 switch(get_dbtype_class(src_base_type))
1298 case DBTYPE_EMPTY:
1299 if(common_class(dst_class)) return S_OK;
1300 switch(dst_class)
1302 case DBTYPE_DATE:
1303 case DBTYPE_GUID:
1304 case DBTYPE_FILETIME:
1305 return S_OK;
1306 default:
1307 if(dst_base_type == DBTYPE_DBTIMESTAMP) return S_OK;
1308 return S_FALSE;
1311 case DBTYPE_NULL:
1312 switch(dst_base_type)
1314 case DBTYPE_NULL:
1315 case DBTYPE_VARIANT:
1316 case DBTYPE_FILETIME: return S_OK;
1317 default: return S_FALSE;
1320 case DBTYPE_I4:
1321 if(dst_base_type == DBTYPE_BYTES) return S_OK;
1322 /* fall through */
1323 case DBTYPE_I2:
1324 if(dst_base_type == DBTYPE_DATE) return S_OK;
1325 /* fall through */
1326 case DBTYPE_DECIMAL:
1327 if(common_class(dst_class)) return S_OK;
1328 if(dst_class == DBTYPE_DBDATE) return S_OK;
1329 return S_FALSE;
1331 case DBTYPE_BOOL:
1332 if(dst_base_type == DBTYPE_DATE) return S_OK;
1333 /* fall through */
1334 case DBTYPE_NUMERIC:
1335 case DBTYPE_CY:
1336 if(common_class(dst_class)) return S_OK;
1337 return S_FALSE;
1339 case DBTYPE_I8:
1340 if(common_class(dst_class)) return S_OK;
1341 switch(dst_base_type)
1343 case DBTYPE_BYTES:
1344 case DBTYPE_FILETIME: return S_OK;
1345 default: return S_FALSE;
1348 case DBTYPE_DATE:
1349 switch(dst_class)
1351 case DBTYPE_EMPTY:
1352 case DBTYPE_NULL:
1353 case DBTYPE_I2:
1354 case DBTYPE_I4:
1355 case DBTYPE_BSTR:
1356 case DBTYPE_BOOL:
1357 case DBTYPE_VARIANT:
1358 case DBTYPE_I8:
1359 case DBTYPE_DATE:
1360 case DBTYPE_DBDATE:
1361 case DBTYPE_FILETIME:
1362 return S_OK;
1363 default: return S_FALSE;
1366 case DBTYPE_IDISPATCH:
1367 case DBTYPE_VARIANT:
1368 switch(dst_base_type)
1370 case DBTYPE_IDISPATCH:
1371 case DBTYPE_ERROR:
1372 case DBTYPE_IUNKNOWN:
1373 return S_OK;
1375 /* fall through */
1376 case DBTYPE_BSTR:
1377 if(common_class(dst_class)) return S_OK;
1378 switch(dst_class)
1380 case DBTYPE_DATE:
1381 case DBTYPE_GUID:
1382 case DBTYPE_BYTES:
1383 case DBTYPE_DBDATE:
1384 case DBTYPE_FILETIME:
1385 return S_OK;
1386 default: return S_FALSE;
1389 case DBTYPE_ERROR:
1390 switch(dst_base_type)
1392 case DBTYPE_BSTR:
1393 case DBTYPE_ERROR:
1394 case DBTYPE_VARIANT:
1395 case DBTYPE_WSTR:
1396 return S_OK;
1397 default: return S_FALSE;
1400 case DBTYPE_IUNKNOWN:
1401 switch(dst_base_type)
1403 case DBTYPE_EMPTY:
1404 case DBTYPE_NULL:
1405 case DBTYPE_IDISPATCH:
1406 case DBTYPE_VARIANT:
1407 case DBTYPE_IUNKNOWN:
1408 return S_OK;
1409 default: return S_FALSE;
1412 case DBTYPE_BYTES:
1413 if(dst_class == DBTYPE_I4 || dst_class == DBTYPE_I8) return S_OK;
1414 /* fall through */
1415 case DBTYPE_GUID:
1416 switch(dst_class)
1418 case DBTYPE_EMPTY:
1419 case DBTYPE_NULL:
1420 case DBTYPE_BSTR:
1421 case DBTYPE_VARIANT:
1422 case DBTYPE_GUID:
1423 case DBTYPE_BYTES:
1424 return S_OK;
1425 default: return S_FALSE;
1428 case DBTYPE_FILETIME:
1429 if(dst_class == DBTYPE_I8) return S_OK;
1430 /* fall through */
1431 case DBTYPE_DBDATE:
1432 switch(dst_class)
1434 case DBTYPE_EMPTY:
1435 case DBTYPE_NULL:
1436 case DBTYPE_DATE:
1437 case DBTYPE_BSTR:
1438 case DBTYPE_VARIANT:
1439 case DBTYPE_DBDATE:
1440 case DBTYPE_FILETIME:
1441 return S_OK;
1442 default: return S_FALSE;
1446 return S_FALSE;
1449 static HRESULT WINAPI convert_GetConversionSize(IDataConvert* iface,
1450 DBTYPE src_type, DBTYPE dst_type,
1451 DBLENGTH *src_len, DBLENGTH *dst_len,
1452 void *src)
1454 convert *This = impl_from_IDataConvert(iface);
1455 HRESULT hr;
1457 TRACE("(%p)->(%d, %d, %p, %p, %p)\n", This, src_type, dst_type, src_len, dst_len, src);
1459 hr = IDataConvert_CanConvert(iface, src_type, dst_type);
1460 if (hr != S_OK)
1461 return DB_E_UNSUPPORTEDCONVERSION;
1463 if (!dst_len)
1464 return E_INVALIDARG;
1466 /* for some types we don't need to look into source data */
1467 if ((*dst_len = get_length(dst_type)))
1468 return S_OK;
1470 *dst_len = 110;
1472 if(src_type == DBTYPE_VARIANT && V_VT((VARIANT*)src) == VT_NULL)
1473 return S_OK;
1475 switch (dst_type)
1477 case DBTYPE_STR:
1478 switch (src_type)
1480 case DBTYPE_VARIANT:
1482 VARIANT v;
1484 VariantInit(&v);
1485 if ((hr = VariantChangeType(&v, src, 0, VT_BSTR)) == S_OK)
1487 *dst_len = WideCharToMultiByte(CP_ACP, 0, V_BSTR(&v), -1, NULL, 0, NULL, NULL);
1488 VariantClear(&v);
1490 else
1491 return hr;
1493 break;
1494 case DBTYPE_DATE:
1495 case DBTYPE_DECIMAL:
1496 case DBTYPE_EMPTY:
1497 case DBTYPE_I1:
1498 case DBTYPE_I2:
1499 case DBTYPE_UI2:
1500 case DBTYPE_I4:
1501 case DBTYPE_UI4:
1502 case DBTYPE_I8:
1503 case DBTYPE_UI8:
1504 case DBTYPE_R4:
1505 case DBTYPE_DBDATE:
1506 case DBTYPE_DBTIMESTAMP:
1507 case DBTYPE_DBTIME:
1508 break;
1509 default:
1510 FIXME("unimplemented for %04x -> DBTYPE_STR\n", src_type);
1511 return E_NOTIMPL;
1513 break;
1514 case DBTYPE_WSTR:
1515 switch (src_type)
1517 case DBTYPE_VARIANT:
1519 VARIANT v;
1521 VariantInit(&v);
1522 if ((hr = VariantChangeType(&v, src, 0, VT_BSTR)) == S_OK)
1524 *dst_len = (SysStringLen(V_BSTR(&v))+1) * sizeof(WCHAR);
1525 VariantClear(&v);
1528 break;
1529 case DBTYPE_STR:
1530 if(src_len)
1531 *dst_len = (*src_len + 1) * sizeof(WCHAR);
1532 else
1533 *dst_len = (strlen(src) + 1) * sizeof(WCHAR);
1534 break;
1535 case DBTYPE_WSTR:
1536 if(src_len)
1537 *dst_len = (*src_len) + sizeof(WCHAR);
1538 else
1539 *dst_len = (lstrlenW(src) + 1) * sizeof(WCHAR);
1540 break;
1541 case DBTYPE_DATE:
1542 case DBTYPE_DECIMAL:
1543 case DBTYPE_EMPTY:
1544 case DBTYPE_I1:
1545 case DBTYPE_I2:
1546 case DBTYPE_UI2:
1547 case DBTYPE_I4:
1548 case DBTYPE_UI4:
1549 case DBTYPE_I8:
1550 case DBTYPE_UI8:
1551 case DBTYPE_R4:
1552 case DBTYPE_DBDATE:
1553 case DBTYPE_DBTIMESTAMP:
1554 case DBTYPE_DBTIME:
1555 break;
1556 default:
1557 FIXME("unimplemented for %04x -> DBTYPE_WSTR\n", src_type);
1558 return E_NOTIMPL;
1560 break;
1561 case DBTYPE_BYTES:
1562 switch (src_type)
1564 case DBTYPE_VARIANT:
1565 if(V_VT((VARIANT*)src) == VT_BSTR)
1566 *dst_len = (SysStringLen(V_BSTR((VARIANT*)src))) / sizeof(WCHAR);
1567 else
1569 switch(V_VT((VARIANT*)src))
1571 case VT_UI1 | VT_ARRAY:
1573 LONG l;
1575 hr = SafeArrayGetUBound(V_ARRAY((VARIANT*)src), 1, &l);
1576 if(FAILED(hr))
1577 return hr;
1578 *dst_len = l+1;
1580 break;
1582 default:
1583 WARN("DBTYPE_VARIANT(%d)->DBTYPE_BYTES unimplemented\n", V_VT((VARIANT*)src));
1586 break;
1587 default:
1588 FIXME("unimplemented for %04x -> DBTYPE_BYTES\n", src_type);
1589 return E_NOTIMPL;
1591 break;
1592 default:
1593 FIXME("unimplemented for conversion %d->%d\n", src_type, dst_type);
1594 return E_NOTIMPL;
1597 return S_OK;
1600 static const struct IDataConvertVtbl convert_vtbl =
1602 convert_QueryInterface,
1603 convert_AddRef,
1604 convert_Release,
1605 convert_DataConvert,
1606 convert_CanConvert,
1607 convert_GetConversionSize
1610 static HRESULT WINAPI dcinfo_QueryInterface(IDCInfo* iface, REFIID riid, void **obj)
1612 convert *This = impl_from_IDCInfo(iface);
1614 return IDataConvert_QueryInterface(&This->IDataConvert_iface, riid, obj);
1617 static ULONG WINAPI dcinfo_AddRef(IDCInfo* iface)
1619 convert *This = impl_from_IDCInfo(iface);
1621 return IDataConvert_AddRef(&This->IDataConvert_iface);
1624 static ULONG WINAPI dcinfo_Release(IDCInfo* iface)
1626 convert *This = impl_from_IDCInfo(iface);
1628 return IDataConvert_Release(&This->IDataConvert_iface);
1631 static HRESULT WINAPI dcinfo_GetInfo(IDCInfo *iface, ULONG num, DCINFOTYPE types[], DCINFO **info_ptr)
1633 convert *This = impl_from_IDCInfo(iface);
1634 ULONG i;
1635 DCINFO *infos;
1637 TRACE("(%p)->(%ld, %p, %p)\n", This, num, types, info_ptr);
1639 *info_ptr = infos = CoTaskMemAlloc(num * sizeof(*infos));
1640 if(!infos) return E_OUTOFMEMORY;
1642 for(i = 0; i < num; i++)
1644 infos[i].eInfoType = types[i];
1645 VariantInit(&infos[i].vData);
1647 switch(types[i])
1649 case DCINFOTYPE_VERSION:
1650 V_VT(&infos[i].vData) = VT_UI4;
1651 V_UI4(&infos[i].vData) = This->version;
1652 break;
1656 return S_OK;
1659 static HRESULT WINAPI dcinfo_SetInfo(IDCInfo* iface, ULONG num, DCINFO info[])
1661 convert *This = impl_from_IDCInfo(iface);
1662 ULONG i;
1663 HRESULT hr = S_OK;
1665 TRACE("(%p)->(%ld, %p)\n", This, num, info);
1667 for(i = 0; i < num; i++)
1669 switch(info[i].eInfoType)
1671 case DCINFOTYPE_VERSION:
1672 if(V_VT(&info[i].vData) != VT_UI4)
1674 FIXME("VERSION with vt %x\n", V_VT(&info[i].vData));
1675 hr = DB_S_ERRORSOCCURRED;
1676 break;
1678 This->version = V_UI4(&info[i].vData);
1679 break;
1681 default:
1682 FIXME("Unhandled info type %ld (vt %x)\n", info[i].eInfoType, V_VT(&info[i].vData));
1685 return hr;
1688 static const struct IDCInfoVtbl dcinfo_vtbl =
1690 dcinfo_QueryInterface,
1691 dcinfo_AddRef,
1692 dcinfo_Release,
1693 dcinfo_GetInfo,
1694 dcinfo_SetInfo
1697 HRESULT create_oledb_convert(IUnknown *outer, void **obj)
1699 convert *This;
1701 TRACE("(%p, %p)\n", outer, obj);
1703 *obj = NULL;
1705 if(outer) return CLASS_E_NOAGGREGATION;
1707 This = malloc(sizeof(*This));
1708 if(!This) return E_OUTOFMEMORY;
1710 This->IDataConvert_iface.lpVtbl = &convert_vtbl;
1711 This->IDCInfo_iface.lpVtbl = &dcinfo_vtbl;
1712 This->ref = 1;
1713 This->version = 0x110;
1715 *obj = &This->IDataConvert_iface;
1717 return S_OK;