oledb32: Implement conversion from DBTYPE_BYTES to DBTYPE_WSTR/DBTYPE_STR.
[wine] / dlls / oledb32 / convert.c
1 /* OLE DB Conversion library
2  *
3  * Copyright 2009 Huw Davies
4  *
5  * This library is free software; you can redistribute it and/or
6  * modify it under the terms of the GNU Lesser General Public
7  * License as published by the Free Software Foundation; either
8  * version 2.1 of the License, or (at your option) any later version.
9  *
10  * This library is distributed in the hope that it will be useful,
11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
13  * Lesser General Public License for more details.
14  *
15  * You should have received a copy of the GNU Lesser General Public
16  * License along with this library; if not, write to the Free Software
17  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
18  */
19
20 #include <stdarg.h>
21
22 #define COBJMACROS
23 #define NONAMELESSUNION
24 #define NONAMELESSSTRUCT
25
26 #include "windef.h"
27 #include "winbase.h"
28 #include "winnls.h"
29 #include "ole2.h"
30 #include "msdadc.h"
31 #include "oledberr.h"
32
33 #include "oledb_private.h"
34
35 #include "wine/debug.h"
36
37 WINE_DEFAULT_DEBUG_CHANNEL(oledb);
38
39 typedef struct
40 {
41     const struct IDataConvertVtbl *lpVtbl;
42     const struct IDCInfoVtbl *lpDCInfoVtbl;
43
44     LONG ref;
45
46     UINT version; /* Set by IDCInfo_SetInfo */
47 } convert;
48
49 static inline convert *impl_from_IDataConvert(IDataConvert *iface)
50 {
51     return (convert *)((char*)iface - FIELD_OFFSET(convert, lpVtbl));
52 }
53
54 static inline convert *impl_from_IDCInfo(IDCInfo *iface)
55 {
56     return (convert *)((char*)iface - FIELD_OFFSET(convert, lpDCInfoVtbl));
57 }
58
59 static HRESULT WINAPI convert_QueryInterface(IDataConvert* iface,
60                                              REFIID riid,
61                                              void **obj)
62 {
63     convert *This = impl_from_IDataConvert(iface);
64     TRACE("(%p)->(%s, %p)\n", This, debugstr_guid(riid), obj);
65
66     *obj = NULL;
67
68     if(IsEqualIID(riid, &IID_IUnknown) ||
69        IsEqualIID(riid, &IID_IDataConvert))
70     {
71         *obj = iface;
72     }
73     else if(IsEqualIID(riid, &IID_IDCInfo))
74     {
75         *obj = &This->lpDCInfoVtbl;
76     }
77     else
78     {
79         FIXME("interface %s not implemented\n", debugstr_guid(riid));
80         return E_NOINTERFACE;
81     }
82
83     IDataConvert_AddRef(iface);
84     return S_OK;
85 }
86
87
88 static ULONG WINAPI convert_AddRef(IDataConvert* iface)
89 {
90     convert *This = impl_from_IDataConvert(iface);
91     TRACE("(%p)\n", This);
92
93     return InterlockedIncrement(&This->ref);
94 }
95
96
97 static ULONG WINAPI convert_Release(IDataConvert* iface)
98 {
99     convert *This = impl_from_IDataConvert(iface);
100     LONG ref;
101
102     TRACE("(%p)\n", This);
103
104     ref = InterlockedDecrement(&This->ref);
105     if(ref == 0)
106     {
107         HeapFree(GetProcessHeap(), 0, This);
108     }
109
110     return ref;
111 }
112
113 static int get_length(DBTYPE type)
114 {
115     switch(type)
116     {
117     case DBTYPE_I1:
118     case DBTYPE_UI1:
119         return 1;
120     case DBTYPE_I2:
121     case DBTYPE_UI2:
122         return 2;
123     case DBTYPE_I4:
124     case DBTYPE_UI4:
125     case DBTYPE_R4:
126         return 4;
127     case DBTYPE_I8:
128     case DBTYPE_UI8:
129         return 8;
130     case DBTYPE_CY:
131         return sizeof(CY);
132     case DBTYPE_BSTR:
133         return sizeof(BSTR);
134     case DBTYPE_FILETIME:
135         return sizeof(FILETIME);
136     case DBTYPE_GUID:
137         return sizeof(GUID);
138     case DBTYPE_WSTR:
139     case DBTYPE_STR:
140     case DBTYPE_BYREF | DBTYPE_WSTR:
141         return 0;
142     default:
143         FIXME("Unhandled type %04x\n", type);
144         return 0;
145     }
146 }
147
148 static HRESULT WINAPI convert_DataConvert(IDataConvert* iface,
149                                           DBTYPE src_type, DBTYPE dst_type,
150                                           DBLENGTH src_len, DBLENGTH *dst_len,
151                                           void *src, void *dst,
152                                           DBLENGTH dst_max_len,
153                                           DBSTATUS src_status, DBSTATUS *dst_status,
154                                           BYTE precision, BYTE scale,
155                                           DBDATACONVERT flags)
156 {
157     convert *This = impl_from_IDataConvert(iface);
158     HRESULT hr;
159
160     TRACE("(%p)->(%d, %d, %d, %p, %p, %p, %d, %d, %p, %d, %d, %x)\n", This,
161           src_type, dst_type, src_len, dst_len, src, dst, dst_max_len,
162           src_status, dst_status, precision, scale, flags);
163
164     *dst_len = get_length(dst_type);
165     *dst_status = DBSTATUS_E_BADACCESSOR;
166
167     if(IDataConvert_CanConvert(iface, src_type, dst_type) != S_OK)
168     {
169         return DB_E_UNSUPPORTEDCONVERSION;
170     }
171
172     if(src_type == DBTYPE_STR)
173     {
174         BSTR b;
175         DWORD len;
176
177         if(flags & DBDATACONVERT_LENGTHFROMNTS)
178             len = MultiByteToWideChar(CP_ACP, 0, src, -1, NULL, 0) - 1;
179         else
180             len = MultiByteToWideChar(CP_ACP, 0, src, src_len, NULL, 0);
181         b = SysAllocStringLen(NULL, len);
182         if(!b) return E_OUTOFMEMORY;
183         if(flags & DBDATACONVERT_LENGTHFROMNTS)
184             MultiByteToWideChar(CP_ACP, 0, src, -1, b, len + 1);
185         else
186             MultiByteToWideChar(CP_ACP, 0, src, src_len, b, len);
187
188         hr = IDataConvert_DataConvert(iface, DBTYPE_BSTR, dst_type, 0, dst_len,
189                                       &b, dst, dst_max_len, src_status, dst_status,
190                                       precision, scale, flags);
191
192         SysFreeString(b);
193         return hr;
194     }
195
196     if(src_type == DBTYPE_WSTR)
197     {
198         BSTR b;
199
200         if(flags & DBDATACONVERT_LENGTHFROMNTS)
201             b = SysAllocString(src);
202         else
203             b = SysAllocStringLen(src, src_len / 2);
204         if(!b) return E_OUTOFMEMORY;
205         hr = IDataConvert_DataConvert(iface, DBTYPE_BSTR, dst_type, 0, dst_len,
206                                       &b, dst, dst_max_len, src_status, dst_status,
207                                       precision, scale, flags);
208         SysFreeString(b);
209         return hr;
210     }
211
212     switch(dst_type)
213     {
214     case DBTYPE_I2:
215     {
216         signed short *d = dst;
217         switch(src_type)
218         {
219         case DBTYPE_EMPTY:       *d = 0; hr = S_OK;                              break;
220         case DBTYPE_I2:          *d = *(signed short*)src; hr = S_OK;            break;
221         case DBTYPE_I4:          hr = VarI2FromI4(*(signed int*)src, d);         break;
222         case DBTYPE_R4:          hr = VarI2FromR4(*(FLOAT*)src, d);              break;
223         case DBTYPE_R8:          hr = VarI2FromR8(*(double*)src, d);             break;
224         case DBTYPE_CY:          hr = VarI2FromCy(*(CY*)src, d);                 break;
225         case DBTYPE_DATE:        hr = VarI2FromDate(*(DATE*)src, d);             break;
226         case DBTYPE_BSTR:        hr = VarI2FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
227         case DBTYPE_BOOL:        hr = VarI2FromBool(*(VARIANT_BOOL*)src, d);     break;
228         case DBTYPE_DECIMAL:     hr = VarI2FromDec((DECIMAL*)src, d);            break;
229         case DBTYPE_I1:          hr = VarI2FromI1(*(signed char*)src, d);        break;
230         case DBTYPE_UI1:         hr = VarI2FromUI1(*(BYTE*)src, d);              break;
231         case DBTYPE_UI2:         hr = VarI2FromUI2(*(WORD*)src, d);              break;
232         case DBTYPE_UI4:         hr = VarI2FromUI4(*(DWORD*)src, d);             break;
233         case DBTYPE_I8:          hr = VarI2FromI8(*(LONGLONG*)src, d);           break;
234         case DBTYPE_UI8:         hr = VarI2FromUI8(*(ULONGLONG*)src, d);         break;
235         default: FIXME("Unimplemented conversion %04x -> I2\n", src_type); return E_NOTIMPL;
236         }
237         break;
238     }
239
240     case DBTYPE_I4:
241     {
242         signed int *d = dst;
243         switch(src_type)
244         {
245         case DBTYPE_EMPTY:       *d = 0; hr = S_OK;                              break;
246         case DBTYPE_I2:          hr = VarI4FromI2(*(signed short*)src, d);       break;
247         case DBTYPE_I4:          *d = *(signed int*)src; hr = S_OK;              break;
248         case DBTYPE_R4:          hr = VarI4FromR4(*(FLOAT*)src, d);              break;
249         case DBTYPE_R8:          hr = VarI4FromR8(*(double*)src, d);             break;
250         case DBTYPE_CY:          hr = VarI4FromCy(*(CY*)src, d);                 break;
251         case DBTYPE_DATE:        hr = VarI4FromDate(*(DATE*)src, d);             break;
252         case DBTYPE_BSTR:        hr = VarI4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
253         case DBTYPE_BOOL:        hr = VarI4FromBool(*(VARIANT_BOOL*)src, d);     break;
254         case DBTYPE_DECIMAL:     hr = VarI4FromDec((DECIMAL*)src, d);            break;
255         case DBTYPE_I1:          hr = VarI4FromI1(*(signed char*)src, d);        break;
256         case DBTYPE_UI1:         hr = VarI4FromUI1(*(BYTE*)src, d);              break;
257         case DBTYPE_UI2:         hr = VarI4FromUI2(*(WORD*)src, d);              break;
258         case DBTYPE_UI4:         hr = VarI4FromUI4(*(DWORD*)src, d);             break;
259         case DBTYPE_I8:          hr = VarI4FromI8(*(LONGLONG*)src, d);           break;
260         case DBTYPE_UI8:         hr = VarI4FromUI8(*(ULONGLONG*)src, d);         break;
261         default: FIXME("Unimplemented conversion %04x -> I4\n", src_type); return E_NOTIMPL;
262         }
263         break;
264     }
265
266     case DBTYPE_R4:
267     {
268         FLOAT *d = dst;
269         switch(src_type)
270         {
271         case DBTYPE_EMPTY:       *d = 0; hr = S_OK;                              break;
272         case DBTYPE_I2:          hr = VarR4FromI2(*(signed short*)src, d);       break;
273         case DBTYPE_I4:          hr = VarR4FromI4(*(signed int*)src, d);         break;
274         case DBTYPE_R4:          *d = *(FLOAT*)src; hr = S_OK;                   break;
275         case DBTYPE_R8:          hr = VarR4FromR8(*(double*)src, d);             break;
276         case DBTYPE_CY:          hr = VarR4FromCy(*(CY*)src, d);                 break;
277         case DBTYPE_DATE:        hr = VarR4FromDate(*(DATE*)src, d);             break;
278         case DBTYPE_BSTR:        hr = VarR4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
279         case DBTYPE_BOOL:        hr = VarR4FromBool(*(VARIANT_BOOL*)src, d);     break;
280         case DBTYPE_DECIMAL:     hr = VarR4FromDec((DECIMAL*)src, d);            break;
281         case DBTYPE_I1:          hr = VarR4FromI1(*(signed char*)src, d);        break;
282         case DBTYPE_UI1:         hr = VarR4FromUI1(*(BYTE*)src, d);              break;
283         case DBTYPE_UI2:         hr = VarR4FromUI2(*(WORD*)src, d);              break;
284         case DBTYPE_UI4:         hr = VarR4FromUI4(*(DWORD*)src, d);             break;
285         case DBTYPE_I8:          hr = VarR4FromI8(*(LONGLONG*)src, d);           break;
286         case DBTYPE_UI8:         hr = VarR4FromUI8(*(ULONGLONG*)src, d);         break;
287         default: FIXME("Unimplemented conversion %04x -> R4\n", src_type); return E_NOTIMPL;
288         }
289         break;
290     }
291
292     case DBTYPE_CY:
293     {
294         CY *d = dst;
295         switch(src_type)
296         {
297         case DBTYPE_EMPTY:       d->int64 = 0; hr = S_OK;                              break;
298         case DBTYPE_I2:          hr = VarCyFromI2(*(signed short*)src, d);       break;
299         case DBTYPE_I4:          hr = VarCyFromI4(*(signed int*)src, d);         break;
300         case DBTYPE_R4:          hr = VarCyFromR4(*(FLOAT*)src, d);              break;
301         case DBTYPE_R8:          hr = VarCyFromR8(*(double*)src, d);             break;
302         case DBTYPE_CY:          *d = *(CY*)src; hr = S_OK;                      break;
303         case DBTYPE_DATE:        hr = VarCyFromDate(*(DATE*)src, d);             break;
304         case DBTYPE_BSTR:        hr = VarCyFromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
305         case DBTYPE_BOOL:        hr = VarCyFromBool(*(VARIANT_BOOL*)src, d);     break;
306         case DBTYPE_DECIMAL:     hr = VarCyFromDec((DECIMAL*)src, d);            break;
307         case DBTYPE_I1:          hr = VarCyFromI1(*(signed char*)src, d);        break;
308         case DBTYPE_UI1:         hr = VarCyFromUI1(*(BYTE*)src, d);              break;
309         case DBTYPE_UI2:         hr = VarCyFromUI2(*(WORD*)src, d);              break;
310         case DBTYPE_UI4:         hr = VarCyFromUI4(*(DWORD*)src, d);             break;
311         case DBTYPE_I8:          hr = VarCyFromI8(*(LONGLONG*)src, d);           break;
312         case DBTYPE_UI8:         hr = VarCyFromUI8(*(ULONGLONG*)src, d);         break;
313         default: FIXME("Unimplemented conversion %04x -> CY\n", src_type); return E_NOTIMPL;
314         }
315         break;
316     }
317
318     case DBTYPE_BSTR:
319     {
320         BSTR *d = dst;
321         switch(src_type)
322         {
323         case DBTYPE_EMPTY:       *d = SysAllocStringLen(NULL, 0); hr = *d ? S_OK : E_OUTOFMEMORY;      break;
324         case DBTYPE_I2:          hr = VarBstrFromI2(*(signed short*)src, LOCALE_USER_DEFAULT, 0, d);   break;
325         case DBTYPE_I4:          hr = VarBstrFromI4(*(signed int*)src, LOCALE_USER_DEFAULT, 0, d);     break;
326         case DBTYPE_R4:          hr = VarBstrFromR4(*(FLOAT*)src, LOCALE_USER_DEFAULT, 0, d);          break;
327         case DBTYPE_R8:          hr = VarBstrFromR8(*(double*)src, LOCALE_USER_DEFAULT, 0, d);         break;
328         case DBTYPE_CY:          hr = VarBstrFromCy(*(CY*)src, LOCALE_USER_DEFAULT, 0, d);             break;
329         case DBTYPE_DATE:        hr = VarBstrFromDate(*(DATE*)src, LOCALE_USER_DEFAULT, 0, d);         break;
330         case DBTYPE_BSTR:        *d = SysAllocStringLen(*(BSTR*)src, SysStringLen(*(BSTR*)src)); hr = *d ? S_OK : E_OUTOFMEMORY;     break;
331         case DBTYPE_BOOL:        hr = VarBstrFromBool(*(VARIANT_BOOL*)src, LOCALE_USER_DEFAULT, 0, d); break;
332         case DBTYPE_DECIMAL:     hr = VarBstrFromDec((DECIMAL*)src, LOCALE_USER_DEFAULT, 0, d);        break;
333         case DBTYPE_I1:          hr = VarBstrFromI1(*(signed char*)src, LOCALE_USER_DEFAULT, 0, d);    break;
334         case DBTYPE_UI1:         hr = VarBstrFromUI1(*(BYTE*)src, LOCALE_USER_DEFAULT, 0, d);          break;
335         case DBTYPE_UI2:         hr = VarBstrFromUI2(*(WORD*)src, LOCALE_USER_DEFAULT, 0, d);          break;
336         case DBTYPE_UI4:         hr = VarBstrFromUI4(*(DWORD*)src, LOCALE_USER_DEFAULT, 0, d);         break;
337         case DBTYPE_I8:          hr = VarBstrFromI8(*(LONGLONG*)src, LOCALE_USER_DEFAULT, 0, d);       break;
338         case DBTYPE_UI8:         hr = VarBstrFromUI8(*(ULONGLONG*)src, LOCALE_USER_DEFAULT, 0, d);     break;
339         case DBTYPE_GUID:
340         {
341             WCHAR szBuff[39];
342             const GUID *id = (const GUID *)src;
343             WCHAR format[] = {
344                 '{','%','0','8','X','-','%','0','4','X','-','%','0','4','X','-',
345                 '%','0','2','X','%','0','2','X','-',
346                 '%','0','2','X','%','0','2','X','%','0','2','X','%','0','2','X','%','0','2','X','%','0','2','X','}',0};
347             wsprintfW(szBuff, format,
348                 id->Data1, id->Data2, id->Data3,
349                 id->Data4[0], id->Data4[1], id->Data4[2], id->Data4[3],
350                 id->Data4[4], id->Data4[5], id->Data4[6], id->Data4[7] );
351             *d = SysAllocString(szBuff);
352             hr = *d ? S_OK : E_OUTOFMEMORY;
353         }
354         break;
355         case DBTYPE_BYTES:
356         {
357             *d = SysAllocStringLen(NULL, 2 * src_len);
358             if (*d == NULL)
359                 hr = E_OUTOFMEMORY;
360             else
361             {
362                 const char hexchars[] = "0123456789ABCDEF";
363                 WCHAR *s = *d;
364                 unsigned char *p = src;
365                 while (src_len > 0)
366                 {
367                     *s++ = hexchars[(*p >> 4) & 0x0F];
368                     *s++ = hexchars[(*p)      & 0x0F];
369                     src_len--; p++;
370                 }
371                 hr = S_OK;
372             }
373         }
374         break;
375         default: FIXME("Unimplemented conversion %04x -> BSTR\n", src_type); return E_NOTIMPL;
376         }
377         break;
378     }
379
380     case DBTYPE_UI1:
381     {
382         BYTE *d = dst;
383         switch(src_type)
384         {
385         case DBTYPE_EMPTY:       *d = 0; hr = S_OK;                              break;
386         case DBTYPE_I2:          hr = VarUI1FromI2(*(signed short*)src, d);      break;
387         case DBTYPE_I4:          hr = VarUI1FromI4(*(signed int*)src, d);        break;
388         case DBTYPE_R4:          hr = VarUI1FromR4(*(FLOAT*)src, d);             break;
389         case DBTYPE_R8:          hr = VarUI1FromR8(*(double*)src, d);            break;
390         case DBTYPE_CY:          hr = VarUI1FromCy(*(CY*)src, d);                break;
391         case DBTYPE_DATE:        hr = VarUI1FromDate(*(DATE*)src, d);            break;
392         case DBTYPE_BSTR:        hr = VarUI1FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
393         case DBTYPE_BOOL:        hr = VarUI1FromBool(*(VARIANT_BOOL*)src, d);    break;
394         case DBTYPE_DECIMAL:     hr = VarUI1FromDec((DECIMAL*)src, d);           break;
395         case DBTYPE_I1:          hr = VarUI1FromI1(*(signed char*)src, d);       break;
396         case DBTYPE_UI1:         *d = *(BYTE*)src; hr = S_OK;                    break;
397         case DBTYPE_UI2:         hr = VarUI1FromUI2(*(WORD*)src, d);             break;
398         case DBTYPE_UI4:         hr = VarUI1FromUI4(*(DWORD*)src, d);            break;
399         case DBTYPE_I8:          hr = VarUI1FromI8(*(LONGLONG*)src, d);          break;
400         case DBTYPE_UI8:         hr = VarUI1FromUI8(*(ULONGLONG*)src, d);        break;
401         default: FIXME("Unimplemented conversion %04x -> UI1\n", src_type); return E_NOTIMPL;
402         }
403         break;
404     }
405
406     case DBTYPE_UI4:
407     {
408         DWORD *d = dst;
409         switch(src_type)
410         {
411         case DBTYPE_EMPTY:       *d = 0; hr = S_OK;                              break;
412         case DBTYPE_I2:          hr = VarUI4FromI2(*(signed short*)src, d);      break;
413         case DBTYPE_I4:          hr = VarUI4FromI4(*(signed int*)src, d);        break;
414         case DBTYPE_R4:          hr = VarUI4FromR4(*(FLOAT*)src, d);             break;
415         case DBTYPE_R8:          hr = VarUI4FromR8(*(double*)src, d);            break;
416         case DBTYPE_CY:          hr = VarUI4FromCy(*(CY*)src, d);                break;
417         case DBTYPE_DATE:        hr = VarUI4FromDate(*(DATE*)src, d);            break;
418         case DBTYPE_BSTR:        hr = VarUI4FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
419         case DBTYPE_BOOL:        hr = VarUI4FromBool(*(VARIANT_BOOL*)src, d);    break;
420         case DBTYPE_DECIMAL:     hr = VarUI4FromDec((DECIMAL*)src, d);           break;
421         case DBTYPE_I1:          hr = VarUI4FromI1(*(signed char*)src, d);       break;
422         case DBTYPE_UI1:         hr = VarUI4FromUI1(*(BYTE*)src, d);             break;
423         case DBTYPE_UI2:         hr = VarUI4FromUI2(*(WORD*)src, d);             break;
424         case DBTYPE_UI4:         *d = *(DWORD*)src; hr = S_OK;                   break;
425         case DBTYPE_I8:          hr = VarUI4FromI8(*(LONGLONG*)src, d);          break;
426         case DBTYPE_UI8:         hr = VarUI4FromUI8(*(ULONGLONG*)src, d);        break;
427         default: FIXME("Unimplemented conversion %04x -> UI4\n", src_type); return E_NOTIMPL;
428         }
429         break;
430     }
431
432     case DBTYPE_UI8:
433     {
434         ULONGLONG *d = dst;
435         switch(src_type)
436         {
437         case DBTYPE_EMPTY:       *d = 0; hr = S_OK;                              break;
438         case DBTYPE_I2:          hr = VarUI8FromI2(*(signed short*)src, d);      break;
439         case DBTYPE_I4:          {LONGLONG s = *(signed int*)src; hr = VarUI8FromI8(s, d);        break;}
440         case DBTYPE_R4:          hr = VarUI8FromR4(*(FLOAT*)src, d);             break;
441         case DBTYPE_R8:          hr = VarUI8FromR8(*(double*)src, d);            break;
442         case DBTYPE_CY:          hr = VarUI8FromCy(*(CY*)src, d);                break;
443         case DBTYPE_DATE:        hr = VarUI8FromDate(*(DATE*)src, d);            break;
444         case DBTYPE_BSTR:        hr = VarUI8FromStr(*(WCHAR**)src, LOCALE_USER_DEFAULT, 0, d); break;
445         case DBTYPE_BOOL:        hr = VarUI8FromBool(*(VARIANT_BOOL*)src, d);    break;
446         case DBTYPE_DECIMAL:     hr = VarUI8FromDec((DECIMAL*)src, d);           break;
447         case DBTYPE_I1:          hr = VarUI8FromI1(*(signed char*)src, d);       break;
448         case DBTYPE_UI1:         hr = VarUI8FromUI1(*(BYTE*)src, d);             break;
449         case DBTYPE_UI2:         hr = VarUI8FromUI2(*(WORD*)src, d);             break;
450         case DBTYPE_UI4:         hr = VarUI8FromUI4(*(DWORD*)src, d);            break;
451         case DBTYPE_I8:          hr = VarUI8FromI8(*(LONGLONG*)src, d);          break;
452         case DBTYPE_UI8:         *d = *(ULONGLONG*)src; hr = S_OK;               break;
453         default: FIXME("Unimplemented conversion %04x -> UI8\n", src_type); return E_NOTIMPL;
454         }
455         break;
456     }
457
458     case DBTYPE_FILETIME:
459     {
460         FILETIME *d = dst;
461         switch(src_type)
462         {
463         case DBTYPE_EMPTY:       d->dwLowDateTime = d->dwHighDateTime = 0; hr = S_OK;    break;
464         case DBTYPE_FILETIME:    *d = *(FILETIME*)src; hr = S_OK;                        break;
465         default: FIXME("Unimplemented conversion %04x -> FILETIME\n", src_type); return E_NOTIMPL;
466         }
467         break;
468     }
469
470     case DBTYPE_GUID:
471     {
472         GUID *d = dst;
473         switch(src_type)
474         {
475         case DBTYPE_EMPTY:       *d = GUID_NULL; hr = S_OK; break;
476         case DBTYPE_GUID:        *d = *(GUID*)src; hr = S_OK; break;
477         default: FIXME("Unimplemented conversion %04x -> GUID\n", src_type); return E_NOTIMPL;
478         }
479         break;
480     }
481
482     case DBTYPE_WSTR:
483     {
484         BSTR b;
485         DBLENGTH bstr_len;
486         INT bytes_to_copy;
487         hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &bstr_len,
488                                       src, &b, sizeof(BSTR), src_status, dst_status,
489                                       precision, scale, flags);
490         if(hr != S_OK) return hr;
491         bstr_len = SysStringLen(b);
492         *dst_len = bstr_len * sizeof(WCHAR); /* Doesn't include size for '\0' */
493         *dst_status = DBSTATUS_S_OK;
494         bytes_to_copy = min(*dst_len + sizeof(WCHAR), dst_max_len);
495         if(dst)
496         {
497             if(bytes_to_copy >= sizeof(WCHAR))
498             {
499                 memcpy(dst, b, bytes_to_copy - sizeof(WCHAR));
500                 *((WCHAR*)dst + bytes_to_copy / sizeof(WCHAR) - 1) = 0;
501                 if(bytes_to_copy < *dst_len + sizeof(WCHAR))
502                     *dst_status = DBSTATUS_S_TRUNCATED;
503             }
504             else
505             {
506                 *dst_status = DBSTATUS_E_DATAOVERFLOW;
507                 hr = DB_E_ERRORSOCCURRED;
508             }
509         }
510         SysFreeString(b);
511         return hr;
512     }
513     case DBTYPE_STR:
514     {
515         BSTR b;
516         DBLENGTH bstr_len;
517         INT bytes_to_copy;
518         hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &bstr_len,
519                                       src, &b, sizeof(BSTR), src_status, dst_status,
520                                       precision, scale, flags);
521         if(hr != S_OK) return hr;
522         bstr_len = SysStringLen(b);
523         *dst_len = bstr_len * sizeof(char); /* Doesn't include size for '\0' */
524         *dst_status = DBSTATUS_S_OK;
525         bytes_to_copy = min(*dst_len + sizeof(char), dst_max_len);
526         if(dst)
527         {
528             if(bytes_to_copy >= sizeof(char))
529             {
530                 WideCharToMultiByte(CP_ACP, 0, b, bytes_to_copy - sizeof(char), dst, dst_max_len, NULL, NULL);
531                 *((char *)dst + bytes_to_copy / sizeof(char) - 1) = 0;
532                 if(bytes_to_copy < *dst_len + sizeof(char))
533                     *dst_status = DBSTATUS_S_TRUNCATED;
534             }
535             else
536             {
537                 *dst_status = DBSTATUS_E_DATAOVERFLOW;
538                 hr = DB_E_ERRORSOCCURRED;
539             }
540         }
541         SysFreeString(b);
542         return hr;
543     }
544
545     case DBTYPE_BYREF | DBTYPE_WSTR:
546     {
547         BSTR b;
548         WCHAR **d = dst;
549         DBLENGTH bstr_len;
550         hr = IDataConvert_DataConvert(iface, src_type, DBTYPE_BSTR, src_len, &bstr_len,
551                                       src, &b, sizeof(BSTR), src_status, dst_status,
552                                       precision, scale, flags);
553         if(hr != S_OK) return hr;
554
555         bstr_len = SysStringLen(b) * sizeof(WCHAR);
556         *dst_len = bstr_len; /* Doesn't include size for '\0' */
557
558         *d = CoTaskMemAlloc(bstr_len + sizeof(WCHAR));
559         if(*d) memcpy(*d, b, bstr_len + sizeof(WCHAR));
560         else hr = E_OUTOFMEMORY;
561         SysFreeString(b);
562         return hr;
563     }
564
565     default:
566         FIXME("Unimplemented conversion %04x -> %04x\n", src_type, dst_type);
567         return E_NOTIMPL;
568
569     }
570
571     if(hr == DISP_E_OVERFLOW)
572     {
573         *dst_status = DBSTATUS_E_DATAOVERFLOW;
574         hr = DB_E_ERRORSOCCURRED;
575     }
576     else if(hr == S_OK)
577         *dst_status = DBSTATUS_S_OK;
578
579     return hr;
580 }
581
582 static inline WORD get_dbtype_class(DBTYPE type)
583 {
584     switch(type)
585     {
586     case DBTYPE_I2:
587     case DBTYPE_R4:
588     case DBTYPE_R8:
589     case DBTYPE_I1:
590     case DBTYPE_UI1:
591     case DBTYPE_UI2:
592         return DBTYPE_I2;
593
594     case DBTYPE_I4:
595     case DBTYPE_UI4:
596         return DBTYPE_I4;
597
598     case DBTYPE_I8:
599     case DBTYPE_UI8:
600         return DBTYPE_I8;
601
602     case DBTYPE_BSTR:
603     case DBTYPE_STR:
604     case DBTYPE_WSTR:
605         return DBTYPE_BSTR;
606
607     case DBTYPE_DBDATE:
608     case DBTYPE_DBTIME:
609     case DBTYPE_DBTIMESTAMP:
610         return DBTYPE_DBDATE;
611     }
612     return type;
613 }
614
615 /* Many src types will convert to this group of dst types */
616 static inline BOOL common_class(WORD dst_class)
617 {
618     switch(dst_class)
619     {
620     case DBTYPE_EMPTY:
621     case DBTYPE_NULL:
622     case DBTYPE_I2:
623     case DBTYPE_I4:
624     case DBTYPE_BSTR:
625     case DBTYPE_BOOL:
626     case DBTYPE_VARIANT:
627     case DBTYPE_I8:
628     case DBTYPE_CY:
629     case DBTYPE_DECIMAL:
630     case DBTYPE_NUMERIC:
631         return TRUE;
632     }
633     return FALSE;
634 }
635
636 static inline BOOL array_type(DBTYPE type)
637 {
638     return (type >= DBTYPE_I2 && type <= DBTYPE_UI4);
639 }
640
641 static HRESULT WINAPI convert_CanConvert(IDataConvert* iface,
642                                          DBTYPE src_type, DBTYPE dst_type)
643 {
644     convert *This = impl_from_IDataConvert(iface);
645     DBTYPE src_base_type = src_type & 0x1ff;
646     DBTYPE dst_base_type = dst_type & 0x1ff;
647     WORD dst_class = get_dbtype_class(dst_base_type);
648
649     TRACE("(%p)->(%d, %d)\n", This, src_type, dst_type);
650
651     if(src_type & DBTYPE_VECTOR || dst_type & DBTYPE_VECTOR) return S_FALSE;
652
653     if(src_type & DBTYPE_ARRAY)
654     {
655         if(!array_type(src_base_type)) return S_FALSE;
656         if(dst_type & DBTYPE_ARRAY)
657         {
658             if(src_type == dst_type) return S_OK;
659             return S_FALSE;
660         }
661         if(dst_type == DBTYPE_VARIANT) return S_OK;
662         return S_FALSE;
663     }
664
665     if(dst_type & DBTYPE_ARRAY)
666     {
667         if(!array_type(dst_base_type)) return S_FALSE;
668         if(src_type == DBTYPE_IDISPATCH || src_type == DBTYPE_VARIANT) return S_OK;
669         return S_FALSE;
670     }
671
672     if(dst_type & DBTYPE_BYREF)
673         if(dst_base_type != DBTYPE_BYTES && dst_base_type != DBTYPE_STR && dst_base_type != DBTYPE_WSTR)
674             return S_FALSE;
675
676     switch(get_dbtype_class(src_base_type))
677     {
678     case DBTYPE_EMPTY:
679         if(common_class(dst_class)) return S_OK;
680         switch(dst_class)
681         {
682         case DBTYPE_DATE:
683         case DBTYPE_GUID:
684         case DBTYPE_FILETIME:
685             return S_OK;
686         default:
687             if(dst_base_type == DBTYPE_DBTIMESTAMP) return S_OK;
688             return S_FALSE;
689         }
690
691     case DBTYPE_NULL:
692         switch(dst_base_type)
693         {
694         case DBTYPE_NULL:
695         case DBTYPE_VARIANT:
696         case DBTYPE_FILETIME: return S_OK;
697         default: return S_FALSE;
698         }
699
700     case DBTYPE_I4:
701         if(dst_base_type == DBTYPE_BYTES) return S_OK;
702         /* fall through */
703     case DBTYPE_I2:
704         if(dst_base_type == DBTYPE_DATE) return S_OK;
705         /* fall through */
706     case DBTYPE_DECIMAL:
707         if(common_class(dst_class)) return S_OK;
708         if(dst_class == DBTYPE_DBDATE) return S_OK;
709         return S_FALSE;
710
711     case DBTYPE_BOOL:
712         if(dst_base_type == DBTYPE_DATE) return S_OK;
713     case DBTYPE_NUMERIC:
714     case DBTYPE_CY:
715         if(common_class(dst_class)) return S_OK;
716         return S_FALSE;
717
718     case DBTYPE_I8:
719         if(common_class(dst_class)) return S_OK;
720         switch(dst_base_type)
721         {
722         case DBTYPE_BYTES:
723         case DBTYPE_FILETIME: return S_OK;
724         default: return S_FALSE;
725         }
726
727     case DBTYPE_DATE:
728         switch(dst_class)
729         {
730         case DBTYPE_EMPTY:
731         case DBTYPE_NULL:
732         case DBTYPE_I2:
733         case DBTYPE_I4:
734         case DBTYPE_BSTR:
735         case DBTYPE_BOOL:
736         case DBTYPE_VARIANT:
737         case DBTYPE_I8:
738         case DBTYPE_DATE:
739         case DBTYPE_DBDATE:
740         case DBTYPE_FILETIME:
741             return S_OK;
742         default: return S_FALSE;
743         }
744
745     case DBTYPE_IDISPATCH:
746     case DBTYPE_VARIANT:
747         switch(dst_base_type)
748         {
749         case DBTYPE_IDISPATCH:
750         case DBTYPE_ERROR:
751         case DBTYPE_IUNKNOWN:
752             return S_OK;
753         }
754         /* fall through */
755     case DBTYPE_BSTR:
756         if(common_class(dst_class)) return S_OK;
757         switch(dst_class)
758         {
759         case DBTYPE_DATE:
760         case DBTYPE_GUID:
761         case DBTYPE_BYTES:
762         case DBTYPE_DBDATE:
763         case DBTYPE_FILETIME:
764             return S_OK;
765         default: return S_FALSE;
766         }
767
768     case DBTYPE_ERROR:
769         switch(dst_base_type)
770         {
771         case DBTYPE_BSTR:
772         case DBTYPE_ERROR:
773         case DBTYPE_VARIANT:
774         case DBTYPE_WSTR:
775             return S_OK;
776         default: return S_FALSE;
777         }
778
779     case DBTYPE_IUNKNOWN:
780         switch(dst_base_type)
781         {
782         case DBTYPE_EMPTY:
783         case DBTYPE_NULL:
784         case DBTYPE_IDISPATCH:
785         case DBTYPE_VARIANT:
786         case DBTYPE_IUNKNOWN:
787             return S_OK;
788         default: return S_FALSE;
789         }
790
791     case DBTYPE_BYTES:
792         if(dst_class == DBTYPE_I4 || dst_class == DBTYPE_I8) return S_OK;
793         /* fall through */
794     case DBTYPE_GUID:
795         switch(dst_class)
796         {
797         case DBTYPE_EMPTY:
798         case DBTYPE_NULL:
799         case DBTYPE_BSTR:
800         case DBTYPE_VARIANT:
801         case DBTYPE_GUID:
802         case DBTYPE_BYTES:
803             return S_OK;
804         default: return S_FALSE;
805         }
806
807     case DBTYPE_FILETIME:
808         if(dst_class == DBTYPE_I8) return S_OK;
809         /* fall through */
810     case DBTYPE_DBDATE:
811         switch(dst_class)
812         {
813         case DBTYPE_EMPTY:
814         case DBTYPE_NULL:
815         case DBTYPE_DATE:
816         case DBTYPE_BSTR:
817         case DBTYPE_VARIANT:
818         case DBTYPE_DBDATE:
819         case DBTYPE_FILETIME:
820             return S_OK;
821         default: return S_FALSE;
822         }
823
824     }
825     return S_FALSE;
826 }
827
828 static HRESULT WINAPI convert_GetConversionSize(IDataConvert* iface,
829                                                 DBTYPE wSrcType, DBTYPE wDstType,
830                                                 DBLENGTH *pcbSrcLength, DBLENGTH *pcbDstLength,
831                                                 void *pSrc)
832 {
833     convert *This = impl_from_IDataConvert(iface);
834     FIXME("(%p)->(%d, %d, %p, %p, %p): stub\n", This, wSrcType, wDstType, pcbSrcLength, pcbDstLength, pSrc);
835
836     return E_NOTIMPL;
837 }
838
839 static const struct IDataConvertVtbl convert_vtbl =
840 {
841     convert_QueryInterface,
842     convert_AddRef,
843     convert_Release,
844     convert_DataConvert,
845     convert_CanConvert,
846     convert_GetConversionSize
847 };
848
849 static HRESULT WINAPI dcinfo_QueryInterface(IDCInfo* iface, REFIID riid, void **obj)
850 {
851     convert *This = impl_from_IDCInfo(iface);
852
853     return IDataConvert_QueryInterface((IDataConvert *)This, riid, obj);
854 }
855
856 static ULONG WINAPI dcinfo_AddRef(IDCInfo* iface)
857 {
858     convert *This = impl_from_IDCInfo(iface);
859
860     return IDataConvert_AddRef((IDataConvert *)This);
861 }
862
863 static ULONG WINAPI dcinfo_Release(IDCInfo* iface)
864 {
865     convert *This = impl_from_IDCInfo(iface);
866
867     return IDataConvert_Release((IDataConvert *)This);
868 }
869
870 static HRESULT WINAPI dcinfo_GetInfo(IDCInfo *iface, ULONG num, DCINFOTYPE types[], DCINFO **info_ptr)
871 {
872     convert *This = impl_from_IDCInfo(iface);
873     ULONG i;
874     DCINFO *infos;
875
876     TRACE("(%p)->(%d, %p, %p)\n", This, num, types, info_ptr);
877
878     *info_ptr = infos = CoTaskMemAlloc(num * sizeof(*infos));
879     if(!infos) return E_OUTOFMEMORY;
880
881     for(i = 0; i < num; i++)
882     {
883         infos[i].eInfoType = types[i];
884         VariantInit(&infos[i].vData);
885
886         switch(types[i])
887         {
888         case DCINFOTYPE_VERSION:
889             V_VT(&infos[i].vData) = VT_UI4;
890             V_UI4(&infos[i].vData) = This->version;
891             break;
892         }
893     }
894
895     return S_OK;
896 }
897
898 static HRESULT WINAPI dcinfo_SetInfo(IDCInfo* iface, ULONG num, DCINFO info[])
899 {
900     convert *This = impl_from_IDCInfo(iface);
901     ULONG i;
902     HRESULT hr = S_OK;
903
904     TRACE("(%p)->(%d, %p)\n", This, num, info);
905
906     for(i = 0; i < num; i++)
907     {
908         switch(info[i].eInfoType)
909         {
910         case DCINFOTYPE_VERSION:
911             if(V_VT(&info[i].vData) != VT_UI4)
912             {
913                 FIXME("VERSION with vt %x\n", V_VT(&info[i].vData));
914                 hr = DB_S_ERRORSOCCURRED;
915                 break;
916             }
917             This->version = V_UI4(&info[i].vData);
918             break;
919
920         default:
921             FIXME("Unhandled info type %d (vt %x)\n", info[i].eInfoType, V_VT(&info[i].vData));
922         }
923     }
924     return hr;
925 }
926
927 static const struct IDCInfoVtbl dcinfo_vtbl =
928 {
929     dcinfo_QueryInterface,
930     dcinfo_AddRef,
931     dcinfo_Release,
932     dcinfo_GetInfo,
933     dcinfo_SetInfo
934 };
935
936 HRESULT create_oledb_convert(IUnknown *outer, void **obj)
937 {
938     convert *This;
939
940     TRACE("(%p, %p)\n", outer, obj);
941
942     *obj = NULL;
943
944     if(outer) return CLASS_E_NOAGGREGATION;
945
946     This = HeapAlloc(GetProcessHeap(), 0, sizeof(*This));
947     if(!This) return E_OUTOFMEMORY;
948
949     This->lpVtbl = &convert_vtbl;
950     This->lpDCInfoVtbl = &dcinfo_vtbl;
951     This->ref = 1;
952     This->version = 0x110;
953
954     *obj = &This->lpVtbl;
955
956     return S_OK;
957 }