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