2 * Copyright 2019 Alistair Leslie-Hughes
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Lesser General Public
6 * License as published by the Free Software Foundation; either
7 * version 2.1 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Lesser General Public License for more details.
14 * You should have received a copy of the GNU Lesser General Public
15 * License along with this library; if not, write to the Free Software
16 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
28 #include "wine/debug.h"
34 #include "msdasql_private.h"
36 WINE_DEFAULT_DEBUG_CHANNEL(msdasql
);
38 DEFINE_GUID(DBPROPSET_DATASOURCEINFO
, 0xc8b522bb, 0x5cf3, 0x11ce, 0xad, 0xe5, 0x00, 0xaa, 0x00, 0x44, 0x77, 0x3d);
39 DEFINE_GUID(DBPROPSET_DBINIT
, 0xc8b522bc, 0x5cf3, 0x11ce, 0xad, 0xe5, 0x00, 0xaa, 0x00, 0x44, 0x77, 0x3d);
41 DEFINE_GUID(DBGUID_DEFAULT
, 0xc8b521fb, 0x5cf3, 0x11ce, 0xad, 0xe5, 0x00, 0xaa, 0x00, 0x44, 0x77, 0x3d);
43 static HRESULT WINAPI
ClassFactory_QueryInterface(IClassFactory
*iface
, REFIID riid
, void **ppv
)
47 if(IsEqualGUID(&IID_IUnknown
, riid
)) {
48 TRACE("(%p)->(IID_IUnknown %p)\n", iface
, ppv
);
50 }else if(IsEqualGUID(&IID_IClassFactory
, riid
)) {
51 TRACE("(%p)->(IID_IClassFactory %p)\n", iface
, ppv
);
56 IUnknown_AddRef((IUnknown
*)*ppv
);
60 WARN("(%p)->(%s %p)\n", iface
, debugstr_guid(riid
), ppv
);
64 static ULONG WINAPI
ClassFactory_AddRef(IClassFactory
*iface
)
66 TRACE("(%p)\n", iface
);
70 static ULONG WINAPI
ClassFactory_Release(IClassFactory
*iface
)
72 TRACE("(%p)\n", iface
);
76 static HRESULT
create_msdasql_provider(REFIID riid
, void **ppv
);
77 static HRESULT
create_msdasql_enumerator(REFIID riid
, void **ppv
);
79 HRESULT WINAPI
msdasql_CreateInstance(IClassFactory
*iface
, IUnknown
*outer
, REFIID riid
, void **ppv
)
81 TRACE("(%p %s %p)\n", outer
, debugstr_guid(riid
), ppv
);
83 return create_msdasql_provider(riid
, ppv
);
86 static HRESULT WINAPI
ClassFactory_LockServer(IClassFactory
*iface
, BOOL fLock
)
88 TRACE("(%p)->(%x)\n", iface
, fLock
);
92 static const IClassFactoryVtbl cfmsdasqlVtbl
= {
93 ClassFactory_QueryInterface
,
96 msdasql_CreateInstance
,
97 ClassFactory_LockServer
100 HRESULT WINAPI
enumerationcf_CreateInstance(IClassFactory
*iface
, IUnknown
*outer
, REFIID riid
, void **ppv
)
102 TRACE("(%p %s %p)\n", outer
, debugstr_guid(riid
), ppv
);
104 return create_msdasql_enumerator(riid
, ppv
);
107 static const IClassFactoryVtbl enumfactoryVtbl
=
109 ClassFactory_QueryInterface
,
111 ClassFactory_Release
,
112 enumerationcf_CreateInstance
,
113 ClassFactory_LockServer
116 static IClassFactory cfmsdasql
= { &cfmsdasqlVtbl
};
117 static IClassFactory enumfactory
= { &enumfactoryVtbl
};
119 HRESULT WINAPI
DllGetClassObject( REFCLSID rclsid
, REFIID riid
, void **ppv
)
121 TRACE("%s %s %p\n", debugstr_guid(rclsid
), debugstr_guid(riid
), ppv
);
123 if (IsEqualGUID(&CLSID_MSDASQL
, rclsid
))
124 return IClassFactory_QueryInterface(&cfmsdasql
, riid
, ppv
);
125 else if (IsEqualGUID(&CLSID_MSDASQL_ENUMERATOR
, rclsid
))
126 return IClassFactory_QueryInterface(&enumfactory
, riid
, ppv
);
128 return CLASS_E_CLASSNOTAVAILABLE
;
135 DBPROPOPTIONS options
;
137 HRESULT (*convert_dbproperty
)(const WCHAR
*src
, VARIANT
*dest
);
146 static int __cdecl
dbmodeprop_compare(const void *a
, const void *b
)
148 const WCHAR
*src
= a
;
149 const struct mode_propval
*propval
= b
;
150 return wcsicmp(src
, propval
->name
);
153 static HRESULT
convert_dbproperty_mode(const WCHAR
*src
, VARIANT
*dest
)
155 struct mode_propval mode_propvals
[] =
157 { L
"Read", DB_MODE_READ
},
158 { L
"ReadWrite", DB_MODE_READWRITE
},
159 { L
"Share Deny None", DB_MODE_SHARE_DENY_NONE
},
160 { L
"Share Deny Read", DB_MODE_SHARE_DENY_READ
},
161 { L
"Share Deny Write", DB_MODE_SHARE_DENY_WRITE
},
162 { L
"Share Exclusive", DB_MODE_SHARE_EXCLUSIVE
},
163 { L
"Write", DB_MODE_WRITE
},
165 struct mode_propval
*prop
;
167 if ((prop
= bsearch(src
, mode_propvals
, ARRAY_SIZE(mode_propvals
),
168 sizeof(struct mode_propval
), dbmodeprop_compare
)))
171 V_I4(dest
) = prop
->value
;
172 TRACE("%s = %#x\n", debugstr_w(src
), prop
->value
);
179 static const struct dbproperty dbproperties
[] =
181 { L
"Password", DBPROP_AUTH_PASSWORD
, DBPROPOPTIONS_OPTIONAL
, VT_BSTR
},
182 { L
"Persist Security Info", DBPROP_AUTH_PERSIST_SENSITIVE_AUTHINFO
, DBPROPOPTIONS_OPTIONAL
, VT_BOOL
},
183 { L
"User ID", DBPROP_AUTH_USERID
, DBPROPOPTIONS_OPTIONAL
, VT_BSTR
},
184 { L
"Data Source", DBPROP_INIT_DATASOURCE
, DBPROPOPTIONS_REQUIRED
, VT_BSTR
},
185 { L
"Window Handle", DBPROP_INIT_HWND
, DBPROPOPTIONS_OPTIONAL
, sizeof(void *) == 8 ? VT_I8
: VT_I4
},
186 { L
"Location", DBPROP_INIT_LOCATION
, DBPROPOPTIONS_OPTIONAL
, VT_BSTR
},
187 { L
"Mode", DBPROP_INIT_MODE
, DBPROPOPTIONS_OPTIONAL
, VT_I4
, convert_dbproperty_mode
},
188 { L
"Prompt", DBPROP_INIT_PROMPT
, DBPROPOPTIONS_OPTIONAL
, VT_I2
},
189 { L
"Connect Timeout", DBPROP_INIT_TIMEOUT
, DBPROPOPTIONS_OPTIONAL
, VT_I4
},
190 { L
"Extended Properties", DBPROP_INIT_PROVIDERSTRING
, DBPROPOPTIONS_REQUIRED
, VT_BSTR
},
191 { L
"Locale Identifier", DBPROP_INIT_LCID
, DBPROPOPTIONS_OPTIONAL
, VT_I4
},
192 { L
"Initial Catalog", DBPROP_INIT_CATALOG
, DBPROPOPTIONS_OPTIONAL
, VT_BSTR
},
193 { L
"OLE DB Services", DBPROP_INIT_OLEDBSERVICES
, DBPROPOPTIONS_OPTIONAL
, VT_I4
},
194 { L
"General Timeout", DBPROP_INIT_GENERALTIMEOUT
, DBPROPOPTIONS_OPTIONAL
, VT_I4
},
205 IUnknown MSDASQL_iface
;
206 IDBProperties IDBProperties_iface
;
207 IDBInitialize IDBInitialize_iface
;
208 IDBCreateSession IDBCreateSession_iface
;
209 IPersist IPersist_iface
;
212 struct msdasql_prop properties
[14];
215 static inline struct msdasql
*impl_from_IUnknown(IUnknown
*iface
)
217 return CONTAINING_RECORD(iface
, struct msdasql
, MSDASQL_iface
);
220 static inline struct msdasql
*impl_from_IDBProperties(IDBProperties
*iface
)
222 return CONTAINING_RECORD(iface
, struct msdasql
, IDBProperties_iface
);
225 static inline struct msdasql
*impl_from_IDBInitialize(IDBInitialize
*iface
)
227 return CONTAINING_RECORD(iface
, struct msdasql
, IDBInitialize_iface
);
230 static inline struct msdasql
*impl_from_IDBCreateSession(IDBCreateSession
*iface
)
232 return CONTAINING_RECORD(iface
, struct msdasql
, IDBCreateSession_iface
);
235 static inline struct msdasql
*impl_from_IPersist( IPersist
*iface
)
237 return CONTAINING_RECORD( iface
, struct msdasql
, IPersist_iface
);
240 static HRESULT WINAPI
msdsql_QueryInterface(IUnknown
*iface
, REFIID riid
, void **out
)
242 struct msdasql
*provider
= impl_from_IUnknown(iface
);
244 TRACE("(%p)->(%s %p)\n", provider
, debugstr_guid(riid
), out
);
246 if(IsEqualGUID(riid
, &IID_IUnknown
) ||
247 IsEqualGUID(riid
, &CLSID_MSDASQL
))
249 *out
= &provider
->MSDASQL_iface
;
251 else if(IsEqualGUID(riid
, &IID_IDBProperties
))
253 *out
= &provider
->IDBProperties_iface
;
255 else if ( IsEqualGUID(riid
, &IID_IDBInitialize
))
257 *out
= &provider
->IDBInitialize_iface
;
259 else if (IsEqualGUID(riid
, &IID_IDBCreateSession
))
261 *out
= &provider
->IDBCreateSession_iface
;
263 else if(IsEqualGUID(&IID_IPersist
, riid
))
265 *out
= &provider
->IPersist_iface
;
269 FIXME("(%s, %p)\n", debugstr_guid(riid
), out
);
271 return E_NOINTERFACE
;
274 IUnknown_AddRef((IUnknown
*)*out
);
278 static ULONG WINAPI
msdsql_AddRef(IUnknown
*iface
)
280 struct msdasql
*provider
= impl_from_IUnknown(iface
);
281 ULONG ref
= InterlockedIncrement(&provider
->ref
);
283 TRACE("(%p) ref=%u\n", provider
, ref
);
288 static ULONG WINAPI
msdsql_Release(IUnknown
*iface
)
290 struct msdasql
*provider
= impl_from_IUnknown(iface
);
291 ULONG ref
= InterlockedDecrement(&provider
->ref
);
293 TRACE("(%p) ref=%u\n", provider
, ref
);
303 static const IUnknownVtbl msdsql_vtbl
=
305 msdsql_QueryInterface
,
310 static HRESULT WINAPI
dbprops_QueryInterface(IDBProperties
*iface
, REFIID riid
, void **ppvObject
)
312 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
314 return IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppvObject
);
317 static ULONG WINAPI
dbprops_AddRef(IDBProperties
*iface
)
319 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
321 return IUnknown_AddRef(&provider
->MSDASQL_iface
);
324 static ULONG WINAPI
dbprops_Release(IDBProperties
*iface
)
326 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
328 return IUnknown_Release(&provider
->MSDASQL_iface
);
331 static HRESULT WINAPI
dbprops_GetProperties(IDBProperties
*iface
, ULONG cPropertyIDSets
,
332 const DBPROPIDSET rgPropertyIDSets
[], ULONG
*pcPropertySets
, DBPROPSET
**prgPropertySets
)
334 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
338 TRACE("(%p)->(%d %p %p %p)\n", provider
, cPropertyIDSets
, rgPropertyIDSets
, pcPropertySets
, prgPropertySets
);
342 if (cPropertyIDSets
!= 1)
344 FIXME("Currently only 1 property set supported.\n");
348 propset
= CoTaskMemAlloc(cPropertyIDSets
* sizeof(DBPROPSET
));
350 if (IsEqualGUID(&rgPropertyIDSets
[0].guidPropertySet
, &DBPROPSET_DATASOURCEINFO
))
352 TRACE("Propertyset DBPROPSET_DATASOURCEINFO not supported\n");
353 propset
->guidPropertySet
= rgPropertyIDSets
[0].guidPropertySet
;
354 propset
->cProperties
= rgPropertyIDSets
[0].cPropertyIDs
;
356 propset
->rgProperties
= CoTaskMemAlloc(propset
->cProperties
* sizeof(DBPROP
));
358 for (j
=0; j
< propset
->cProperties
; j
++)
360 propset
->rgProperties
[j
].dwPropertyID
= rgPropertyIDSets
[0].rgPropertyIDs
[j
];
361 propset
->rgProperties
[j
].dwStatus
= DBPROPSTATUS_NOTSUPPORTED
;
364 *prgPropertySets
= propset
;
366 return DB_E_ERRORSOCCURRED
;
369 propset
->guidPropertySet
= DBPROPSET_DBINIT
;
371 for (i
=0; i
< cPropertyIDSets
; i
++)
373 TRACE("Property id %d (count %d, set %s)\n", i
, rgPropertyIDSets
[i
].cPropertyIDs
,
374 debugstr_guid(&rgPropertyIDSets
[i
].guidPropertySet
));
376 propset
->cProperties
= rgPropertyIDSets
[i
].cPropertyIDs
;
377 propset
->rgProperties
= CoTaskMemAlloc(propset
->cProperties
* sizeof(DBPROP
));
379 for (j
=0; j
< propset
->cProperties
; j
++)
381 propset
->rgProperties
[j
].dwPropertyID
= rgPropertyIDSets
[i
].rgPropertyIDs
[j
];
383 for(k
= 0; k
< ARRAY_SIZE(provider
->properties
); k
++)
385 if (provider
->properties
[k
].id
== rgPropertyIDSets
[i
].rgPropertyIDs
[j
])
387 V_VT(&propset
->rgProperties
[j
].vValue
) = VT_EMPTY
;
388 VariantCopy(&propset
->rgProperties
[j
].vValue
, &provider
->properties
[k
].value
);
395 *prgPropertySets
= propset
;
400 static HRESULT WINAPI
dbprops_GetPropertyInfo(IDBProperties
*iface
, ULONG cPropertyIDSets
,
401 const DBPROPIDSET rgPropertyIDSets
[], ULONG
*pcPropertyInfoSets
,
402 DBPROPINFOSET
**prgPropertyInfoSets
, OLECHAR
**ppDescBuffer
)
404 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
406 DBPROPINFOSET
*infoset
;
410 TRACE("(%p)->(%d %p %p %p %p)\n", provider
, cPropertyIDSets
, rgPropertyIDSets
, pcPropertyInfoSets
,
411 prgPropertyInfoSets
, ppDescBuffer
);
413 infoset
= CoTaskMemAlloc(sizeof(DBPROPINFOSET
));
414 memcpy(&infoset
->guidPropertySet
, &DBPROPSET_DBINIT
, sizeof(GUID
));
415 infoset
->cPropertyInfos
= ARRAY_SIZE(dbproperties
);
416 infoset
->rgPropertyInfos
= CoTaskMemAlloc(sizeof(DBPROPINFO
) * ARRAY_SIZE(dbproperties
));
418 for(i
=0; i
< ARRAY_SIZE(dbproperties
); i
++)
420 size
+= lstrlenW(dbproperties
[i
].name
) + 1;
423 ptr
= *ppDescBuffer
= CoTaskMemAlloc(size
* sizeof(WCHAR
));
424 memset(*ppDescBuffer
, 0, size
* sizeof(WCHAR
));
426 for(i
=0; i
< ARRAY_SIZE(dbproperties
); i
++)
428 lstrcpyW(ptr
, dbproperties
[i
].name
);
429 infoset
->rgPropertyInfos
[i
].pwszDescription
= ptr
;
430 infoset
->rgPropertyInfos
[i
].dwPropertyID
= dbproperties
[i
].id
;
431 infoset
->rgPropertyInfos
[i
].dwFlags
= DBPROPFLAGS_DBINIT
| DBPROPFLAGS_READ
| DBPROPFLAGS_WRITE
;
432 infoset
->rgPropertyInfos
[i
].vtType
= dbproperties
[i
].type
;
433 V_VT(&infoset
->rgPropertyInfos
[i
].vValues
) = VT_EMPTY
;
435 ptr
+= lstrlenW(dbproperties
[i
].name
) + 1;
438 *pcPropertyInfoSets
= 1;
439 *prgPropertyInfoSets
= infoset
;
444 static HRESULT WINAPI
dbprops_SetProperties(IDBProperties
*iface
, ULONG cPropertySets
,
445 DBPROPSET rgPropertySets
[])
447 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
450 TRACE("(%p)->(%d %p)\n", provider
, cPropertySets
, rgPropertySets
);
452 for (i
=0; i
< cPropertySets
; i
++)
454 for (j
=0; j
< rgPropertySets
[i
].cProperties
; j
++)
456 for(k
=0; k
< ARRAY_SIZE(provider
->properties
); k
++)
458 if (provider
->properties
[k
].id
== rgPropertySets
[i
].rgProperties
[j
].dwPropertyID
)
460 TRACE("Found property %d\n", provider
->properties
[k
].id
);
461 VariantCopy(&provider
->properties
[k
].value
, &rgPropertySets
[i
].rgProperties
[j
].vValue
);
471 static const struct IDBPropertiesVtbl dbprops_vtbl
=
473 dbprops_QueryInterface
,
476 dbprops_GetProperties
,
477 dbprops_GetPropertyInfo
,
478 dbprops_SetProperties
481 static HRESULT WINAPI
dbinit_QueryInterface(IDBInitialize
*iface
, REFIID riid
, void **ppvObject
)
483 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
485 return IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppvObject
);
488 static ULONG WINAPI
dbinit_AddRef(IDBInitialize
*iface
)
490 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
492 return IUnknown_AddRef(&provider
->MSDASQL_iface
);
495 static ULONG WINAPI
dbinit_Release(IDBInitialize
*iface
)
497 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
499 return IUnknown_Release(&provider
->MSDASQL_iface
);
502 static HRESULT WINAPI
dbinit_Initialize(IDBInitialize
*iface
)
504 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
506 FIXME("%p stub\n", provider
);
511 static HRESULT WINAPI
dbinit_Uninitialize(IDBInitialize
*iface
)
513 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
515 FIXME("%p stub\n", provider
);
521 static const struct IDBInitializeVtbl dbinit_vtbl
=
523 dbinit_QueryInterface
,
530 static HRESULT WINAPI
dbsess_QueryInterface(IDBCreateSession
*iface
, REFIID riid
, void **ppvObject
)
532 struct msdasql
*provider
= impl_from_IDBCreateSession(iface
);
534 return IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppvObject
);
537 static ULONG WINAPI
dbsess_AddRef(IDBCreateSession
*iface
)
539 struct msdasql
*provider
= impl_from_IDBCreateSession(iface
);
541 return IUnknown_AddRef(&provider
->MSDASQL_iface
);
544 static ULONG WINAPI
dbsess_Release(IDBCreateSession
*iface
)
546 struct msdasql
*provider
= impl_from_IDBCreateSession(iface
);
548 return IUnknown_Release(&provider
->MSDASQL_iface
);
551 static HRESULT WINAPI
dbsess_CreateSession(IDBCreateSession
*iface
, IUnknown
*outer
, REFIID riid
,
554 struct msdasql
*provider
= impl_from_IDBCreateSession(iface
);
557 TRACE("%p, outer %p, riid %s, session %p stub\n", provider
, outer
, debugstr_guid(riid
), session
);
560 FIXME("outer currently not supported.\n");
562 hr
= create_db_session(riid
, &provider
->MSDASQL_iface
, (void**)session
);
567 static const struct IDBCreateSessionVtbl dbsess_vtbl
=
569 dbsess_QueryInterface
,
575 static HRESULT WINAPI
persist_QueryInterface(IPersist
*iface
, REFIID riid
, void **ppv
)
577 struct msdasql
*provider
= impl_from_IPersist( iface
);
578 return IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppv
);
581 static ULONG WINAPI
persist_AddRef(IPersist
*iface
)
583 struct msdasql
*provider
= impl_from_IPersist( iface
);
584 return IUnknown_AddRef(&provider
->MSDASQL_iface
);
587 static ULONG WINAPI
persist_Release(IPersist
*iface
)
589 struct msdasql
*provider
= impl_from_IPersist( iface
);
590 return IUnknown_Release(&provider
->MSDASQL_iface
);
593 static HRESULT WINAPI
persist_GetClassID(IPersist
*iface
, CLSID
*classid
)
595 struct msdasql
*provider
= impl_from_IPersist( iface
);
597 TRACE("(%p)->(%p)\n", provider
, classid
);
602 *classid
= CLSID_MSDASQL
;
607 static const IPersistVtbl persistVtbl
= {
608 persist_QueryInterface
,
614 static HRESULT
create_msdasql_provider(REFIID riid
, void **ppv
)
616 struct msdasql
*provider
;
620 provider
= malloc(sizeof(struct msdasql
));
622 return E_OUTOFMEMORY
;
624 provider
->MSDASQL_iface
.lpVtbl
= &msdsql_vtbl
;
625 provider
->IDBProperties_iface
.lpVtbl
= &dbprops_vtbl
;
626 provider
->IDBInitialize_iface
.lpVtbl
= &dbinit_vtbl
;
627 provider
->IDBCreateSession_iface
.lpVtbl
= &dbsess_vtbl
;
628 provider
->IPersist_iface
.lpVtbl
= &persistVtbl
;
631 for(i
=0; i
< ARRAY_SIZE(dbproperties
); i
++)
633 provider
->properties
[i
].id
= dbproperties
[i
].id
;
634 VariantInit(&provider
->properties
[i
].value
);
636 /* Only the follow are initialized to a value */
637 switch(dbproperties
[i
].id
)
639 case DBPROP_INIT_PROMPT
:
640 V_VT(&provider
->properties
[i
].value
) = dbproperties
[i
].type
;
641 V_I2(&provider
->properties
[i
].value
) = 4;
643 case DBPROP_INIT_LCID
:
644 V_VT(&provider
->properties
[i
].value
) = dbproperties
[i
].type
;
645 V_I4(&provider
->properties
[i
].value
) = GetUserDefaultLCID();
647 case DBPROP_INIT_OLEDBSERVICES
:
648 V_VT(&provider
->properties
[i
].value
) = dbproperties
[i
].type
;
649 V_I4(&provider
->properties
[i
].value
) = -1;
652 V_VT(&provider
->properties
[i
].value
) = VT_EMPTY
;
656 hr
= IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppv
);
657 IUnknown_Release(&provider
->MSDASQL_iface
);
663 ISourcesRowset ISourcesRowset_iface
;
667 static inline struct msdasql_enum
*msdasql_enum_from_ISourcesRowset(ISourcesRowset
*iface
)
669 return CONTAINING_RECORD(iface
, struct msdasql_enum
, ISourcesRowset_iface
);
672 static HRESULT WINAPI
msdasql_enum_QueryInterface(ISourcesRowset
*iface
, REFIID riid
, void **out
)
674 struct msdasql_enum
*enumerator
= msdasql_enum_from_ISourcesRowset(iface
);
676 TRACE("(%p)->(%s %p)\n", enumerator
, debugstr_guid(riid
), out
);
678 if(IsEqualGUID(riid
, &IID_IUnknown
) ||
679 IsEqualGUID(riid
, &IID_ISourcesRowset
) )
681 *out
= &enumerator
->ISourcesRowset_iface
;
685 FIXME("(%s, %p)\n", debugstr_guid(riid
), out
);
687 return E_NOINTERFACE
;
690 IUnknown_AddRef((IUnknown
*)*out
);
694 static ULONG WINAPI
msdasql_enum_AddRef(ISourcesRowset
*iface
)
696 struct msdasql_enum
*enumerator
= msdasql_enum_from_ISourcesRowset(iface
);
697 ULONG ref
= InterlockedIncrement(&enumerator
->ref
);
699 TRACE("(%p) ref=%u\n", enumerator
, ref
);
704 static ULONG WINAPI
msdasql_enum_Release(ISourcesRowset
*iface
)
706 struct msdasql_enum
*enumerator
= msdasql_enum_from_ISourcesRowset(iface
);
707 ULONG ref
= InterlockedDecrement(&enumerator
->ref
);
709 TRACE("(%p) ref=%u\n", enumerator
, ref
);
719 struct msdasql_enum_rowset
721 IRowset IRowset_iface
;
722 IAccessor IAccessor_iface
;
726 static inline struct msdasql_enum_rowset
*msdasql_rs_from_IRowset(IRowset
*iface
)
728 return CONTAINING_RECORD(iface
, struct msdasql_enum_rowset
, IRowset_iface
);
731 static inline struct msdasql_enum_rowset
*msdasql_enum_from_IAccessor ( IAccessor
*iface
)
733 return CONTAINING_RECORD( iface
, struct msdasql_enum_rowset
, IAccessor_iface
);
736 static HRESULT WINAPI
enum_rowset_QueryInterface(IRowset
*iface
, REFIID riid
, void **ppv
)
738 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
740 TRACE( "%p, %s, %p\n", rowset
, debugstr_guid(riid
), ppv
);
743 if(IsEqualGUID(&IID_IUnknown
, riid
) ||
744 IsEqualGUID(&IID_IRowset
, riid
))
746 *ppv
= &rowset
->IRowset_iface
;
748 else if(IsEqualGUID(&IID_IAccessor
, riid
))
750 *ppv
= &rowset
->IAccessor_iface
;
755 IUnknown_AddRef((IUnknown
*)*ppv
);
759 FIXME("(%p)->(%s %p)\n", iface
, debugstr_guid(riid
), ppv
);
760 return E_NOINTERFACE
;
763 static ULONG WINAPI
enum_rowset_AddRef(IRowset
*iface
)
765 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
766 LONG refs
= InterlockedIncrement( &rowset
->ref
);
767 TRACE( "%p new refcount %d\n", rowset
, refs
);
771 static ULONG WINAPI
enum_rowset_Release(IRowset
*iface
)
773 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
774 LONG refs
= InterlockedDecrement( &rowset
->ref
);
775 TRACE( "%p new refcount %d\n", rowset
, refs
);
778 TRACE( "destroying %p\n", rowset
);
784 static HRESULT WINAPI
enum_rowset_AddRefRows(IRowset
*iface
, DBCOUNTITEM count
,
785 const HROW rows
[], DBREFCOUNT ref_counts
[], DBROWSTATUS status
[])
787 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
789 FIXME("%p, %ld, %p, %p, %p\n", rowset
, count
, rows
, ref_counts
, status
);
794 static HRESULT WINAPI
enum_rowset_GetData(IRowset
*iface
, HROW row
, HACCESSOR accessor
, void *data
)
796 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
798 FIXME("%p, %ld, %ld, %p\n", rowset
, row
, accessor
, data
);
803 static HRESULT WINAPI
enum_rowset_GetNextRows(IRowset
*iface
, HCHAPTER reserved
, DBROWOFFSET offset
,
804 DBROWCOUNT count
, DBCOUNTITEM
*obtained
, HROW
**rows
)
806 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
808 FIXME("%p, %ld, %ld, %ld, %p, %p\n", rowset
, reserved
, offset
, count
, obtained
, rows
);
810 if (!obtained
|| !rows
)
818 return DB_S_ENDOFROWSET
;
821 static HRESULT WINAPI
enum_rowset_ReleaseRows(IRowset
*iface
, DBCOUNTITEM count
,
822 const HROW rows
[], DBROWOPTIONS options
[], DBREFCOUNT ref_counts
[], DBROWSTATUS status
[])
824 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
826 FIXME("%p, %ld, %p, %p, %p, %p\n", rowset
, count
, rows
, options
, ref_counts
, status
);
831 static HRESULT WINAPI
enum_rowset_RestartPosition(IRowset
*iface
, HCHAPTER reserved
)
833 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
835 FIXME("%p, %ld\n", rowset
, reserved
);
840 static const struct IRowsetVtbl enum_rowset_vtbl
=
842 enum_rowset_QueryInterface
,
845 enum_rowset_AddRefRows
,
847 enum_rowset_GetNextRows
,
848 enum_rowset_ReleaseRows
,
849 enum_rowset_RestartPosition
852 static HRESULT WINAPI
enum_rs_accessor_QueryInterface(IAccessor
*iface
, REFIID riid
, void **out
)
854 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
855 return IRowset_QueryInterface(&rowset
->IRowset_iface
, riid
, out
);
858 static ULONG WINAPI
enum_rs_accessor_AddRef(IAccessor
*iface
)
860 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
861 return IRowset_AddRef(&rowset
->IRowset_iface
);
864 static ULONG WINAPI
enum_rs_accessor_Release(IAccessor
*iface
)
866 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
867 return IRowset_Release(&rowset
->IRowset_iface
);
870 static HRESULT WINAPI
enum_rs_accessor_AddRefAccessor(IAccessor
*iface
, HACCESSOR accessor
, DBREFCOUNT
*count
)
872 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
873 FIXME("%p, %lu, %p\n", rowset
, accessor
, count
);
877 static HRESULT WINAPI
enum_rs_accessor_CreateAccessor(IAccessor
*iface
, DBACCESSORFLAGS flags
,
878 DBCOUNTITEM count
, const DBBINDING bindings
[], DBLENGTH row_size
, HACCESSOR
*accessor
,
879 DBBINDSTATUS status
[])
881 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
883 FIXME("%p 0x%08x, %lu, %p, %lu, %p, %p\n", rowset
, flags
, count
, bindings
, row_size
, accessor
, status
);
886 *accessor
= 0xdeadbeef;
891 static HRESULT WINAPI
enum_rs_accessor_GetBindings(IAccessor
*iface
, HACCESSOR accessor
,
892 DBACCESSORFLAGS
*flags
, DBCOUNTITEM
*count
, DBBINDING
**bindings
)
894 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
895 FIXME("%p %lu, %p, %p, %p\n", rowset
, accessor
, flags
, count
, bindings
);
899 static HRESULT WINAPI
enum_rs_accessor_ReleaseAccessor(IAccessor
*iface
, HACCESSOR accessor
, DBREFCOUNT
*count
)
901 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
903 FIXME("%p, %lu, %p\n", rowset
, accessor
, count
);
911 struct IAccessorVtbl enum_accessor_vtbl
=
913 enum_rs_accessor_QueryInterface
,
914 enum_rs_accessor_AddRef
,
915 enum_rs_accessor_Release
,
916 enum_rs_accessor_AddRefAccessor
,
917 enum_rs_accessor_CreateAccessor
,
918 enum_rs_accessor_GetBindings
,
919 enum_rs_accessor_ReleaseAccessor
922 static HRESULT WINAPI
msdasql_enum_GetSourcesRowset(ISourcesRowset
*iface
, IUnknown
*outer
, REFIID riid
, ULONG sets
,
923 DBPROPSET properties
[], IUnknown
**rowset
)
925 struct msdasql_enum
*enumerator
= msdasql_enum_from_ISourcesRowset(iface
);
926 struct msdasql_enum_rowset
*enum_rs
;
929 TRACE("(%p) %p, %s, %d, %p, %p\n", enumerator
, outer
, debugstr_guid(riid
), sets
, properties
, rowset
);
931 enum_rs
= malloc(sizeof(*enum_rs
));
932 enum_rs
->IRowset_iface
.lpVtbl
= &enum_rowset_vtbl
;
933 enum_rs
->IAccessor_iface
.lpVtbl
= &enum_accessor_vtbl
;
936 hr
= IRowset_QueryInterface(&enum_rs
->IRowset_iface
, riid
, (void**)rowset
);
937 IRowset_Release(&enum_rs
->IRowset_iface
);
941 static const ISourcesRowsetVtbl msdsqlenum_vtbl
=
943 msdasql_enum_QueryInterface
,
945 msdasql_enum_Release
,
946 msdasql_enum_GetSourcesRowset
949 static HRESULT
create_msdasql_enumerator(REFIID riid
, void **ppv
)
951 struct msdasql_enum
*enumerator
;
954 enumerator
= malloc(sizeof(*enumerator
));
956 return E_OUTOFMEMORY
;
958 enumerator
->ISourcesRowset_iface
.lpVtbl
= &msdsqlenum_vtbl
;
961 hr
= IUnknown_QueryInterface(&enumerator
->ISourcesRowset_iface
, riid
, ppv
);
962 IUnknown_Release(&enumerator
->ISourcesRowset_iface
);