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"
37 #include "msdasql_private.h"
39 WINE_DEFAULT_DEBUG_CHANNEL(msdasql
);
41 DEFINE_GUID(DBPROPSET_DATASOURCEINFO
, 0xc8b522bb, 0x5cf3, 0x11ce, 0xad, 0xe5, 0x00, 0xaa, 0x00, 0x44, 0x77, 0x3d);
42 DEFINE_GUID(DBPROPSET_DBINIT
, 0xc8b522bc, 0x5cf3, 0x11ce, 0xad, 0xe5, 0x00, 0xaa, 0x00, 0x44, 0x77, 0x3d);
43 DEFINE_GUID(DBPROPSET_ROWSET
, 0xc8b522be, 0x5cf3, 0x11ce, 0xad, 0xe5, 0x00, 0xaa, 0x00, 0x44, 0x77, 0x3d);
45 DEFINE_GUID(DBGUID_DEFAULT
, 0xc8b521fb, 0x5cf3, 0x11ce, 0xad, 0xe5, 0x00, 0xaa, 0x00, 0x44, 0x77, 0x3d);
47 void dump_sql_diag_records(SQLSMALLINT type
, SQLHANDLE handle
)
49 SQLCHAR state
[6], msg
[SQL_MAX_MESSAGE_LENGTH
];
51 SQLSMALLINT i
= 1, len
;
53 if (!TRACE_ON(msdasql
))
56 while(SQLGetDiagRec(type
, handle
, i
, state
, &native
, msg
, sizeof(msg
), &len
) == SQL_SUCCESS
)
58 WARN("%d: %s: %s\n", i
, state
, msg
);
63 static HRESULT WINAPI
ClassFactory_QueryInterface(IClassFactory
*iface
, REFIID riid
, void **ppv
)
67 if(IsEqualGUID(&IID_IUnknown
, riid
)) {
68 TRACE("(%p)->(IID_IUnknown %p)\n", iface
, ppv
);
70 }else if(IsEqualGUID(&IID_IClassFactory
, riid
)) {
71 TRACE("(%p)->(IID_IClassFactory %p)\n", iface
, ppv
);
76 IUnknown_AddRef((IUnknown
*)*ppv
);
80 WARN("(%p)->(%s %p)\n", iface
, debugstr_guid(riid
), ppv
);
84 static ULONG WINAPI
ClassFactory_AddRef(IClassFactory
*iface
)
86 TRACE("(%p)\n", iface
);
90 static ULONG WINAPI
ClassFactory_Release(IClassFactory
*iface
)
92 TRACE("(%p)\n", iface
);
96 static HRESULT
create_msdasql_provider(REFIID riid
, void **ppv
);
97 static HRESULT
create_msdasql_enumerator(REFIID riid
, void **ppv
);
99 HRESULT WINAPI
msdasql_CreateInstance(IClassFactory
*iface
, IUnknown
*outer
, REFIID riid
, void **ppv
)
101 TRACE("(%p %s %p)\n", outer
, debugstr_guid(riid
), ppv
);
103 return create_msdasql_provider(riid
, ppv
);
106 static HRESULT WINAPI
ClassFactory_LockServer(IClassFactory
*iface
, BOOL fLock
)
108 TRACE("(%p)->(%x)\n", iface
, fLock
);
112 static const IClassFactoryVtbl cfmsdasqlVtbl
= {
113 ClassFactory_QueryInterface
,
115 ClassFactory_Release
,
116 msdasql_CreateInstance
,
117 ClassFactory_LockServer
120 HRESULT WINAPI
enumerationcf_CreateInstance(IClassFactory
*iface
, IUnknown
*outer
, REFIID riid
, void **ppv
)
122 TRACE("(%p %s %p)\n", outer
, debugstr_guid(riid
), ppv
);
124 return create_msdasql_enumerator(riid
, ppv
);
127 static const IClassFactoryVtbl enumfactoryVtbl
=
129 ClassFactory_QueryInterface
,
131 ClassFactory_Release
,
132 enumerationcf_CreateInstance
,
133 ClassFactory_LockServer
136 static IClassFactory cfmsdasql
= { &cfmsdasqlVtbl
};
137 static IClassFactory enumfactory
= { &enumfactoryVtbl
};
139 HRESULT WINAPI
DllGetClassObject( REFCLSID rclsid
, REFIID riid
, void **ppv
)
141 TRACE("%s %s %p\n", debugstr_guid(rclsid
), debugstr_guid(riid
), ppv
);
143 if (IsEqualGUID(&CLSID_MSDASQL
, rclsid
))
144 return IClassFactory_QueryInterface(&cfmsdasql
, riid
, ppv
);
145 else if (IsEqualGUID(&CLSID_MSDASQL_ENUMERATOR
, rclsid
))
146 return IClassFactory_QueryInterface(&enumfactory
, riid
, ppv
);
148 return CLASS_E_CLASSNOTAVAILABLE
;
155 DBPROPOPTIONS options
;
157 HRESULT (*convert_dbproperty
)(const WCHAR
*src
, VARIANT
*dest
);
166 static int __cdecl
dbmodeprop_compare(const void *a
, const void *b
)
168 const WCHAR
*src
= a
;
169 const struct mode_propval
*propval
= b
;
170 return wcsicmp(src
, propval
->name
);
173 static HRESULT
convert_dbproperty_mode(const WCHAR
*src
, VARIANT
*dest
)
175 struct mode_propval mode_propvals
[] =
177 { L
"Read", DB_MODE_READ
},
178 { L
"ReadWrite", DB_MODE_READWRITE
},
179 { L
"Share Deny None", DB_MODE_SHARE_DENY_NONE
},
180 { L
"Share Deny Read", DB_MODE_SHARE_DENY_READ
},
181 { L
"Share Deny Write", DB_MODE_SHARE_DENY_WRITE
},
182 { L
"Share Exclusive", DB_MODE_SHARE_EXCLUSIVE
},
183 { L
"Write", DB_MODE_WRITE
},
185 struct mode_propval
*prop
;
187 if ((prop
= bsearch(src
, mode_propvals
, ARRAY_SIZE(mode_propvals
),
188 sizeof(struct mode_propval
), dbmodeprop_compare
)))
191 V_I4(dest
) = prop
->value
;
192 TRACE("%s = %#lx\n", debugstr_w(src
), prop
->value
);
199 static const struct dbproperty dbproperties
[] =
201 { L
"Password", DBPROP_AUTH_PASSWORD
, DBPROPOPTIONS_OPTIONAL
, VT_BSTR
},
202 { L
"Persist Security Info", DBPROP_AUTH_PERSIST_SENSITIVE_AUTHINFO
, DBPROPOPTIONS_OPTIONAL
, VT_BOOL
},
203 { L
"User ID", DBPROP_AUTH_USERID
, DBPROPOPTIONS_OPTIONAL
, VT_BSTR
},
204 { L
"Data Source", DBPROP_INIT_DATASOURCE
, DBPROPOPTIONS_REQUIRED
, VT_BSTR
},
205 { L
"Window Handle", DBPROP_INIT_HWND
, DBPROPOPTIONS_OPTIONAL
, sizeof(void *) == 8 ? VT_I8
: VT_I4
},
206 { L
"Location", DBPROP_INIT_LOCATION
, DBPROPOPTIONS_OPTIONAL
, VT_BSTR
},
207 { L
"Mode", DBPROP_INIT_MODE
, DBPROPOPTIONS_OPTIONAL
, VT_I4
, convert_dbproperty_mode
},
208 { L
"Prompt", DBPROP_INIT_PROMPT
, DBPROPOPTIONS_OPTIONAL
, VT_I2
},
209 { L
"Connect Timeout", DBPROP_INIT_TIMEOUT
, DBPROPOPTIONS_OPTIONAL
, VT_I4
},
210 { L
"Extended Properties", DBPROP_INIT_PROVIDERSTRING
, DBPROPOPTIONS_REQUIRED
, VT_BSTR
},
211 { L
"Locale Identifier", DBPROP_INIT_LCID
, DBPROPOPTIONS_OPTIONAL
, VT_I4
},
212 { L
"Initial Catalog", DBPROP_INIT_CATALOG
, DBPROPOPTIONS_OPTIONAL
, VT_BSTR
},
213 { L
"OLE DB Services", DBPROP_INIT_OLEDBSERVICES
, DBPROPOPTIONS_OPTIONAL
, VT_I4
},
214 { L
"General Timeout", DBPROP_INIT_GENERALTIMEOUT
, DBPROPOPTIONS_OPTIONAL
, VT_I4
},
225 IUnknown MSDASQL_iface
;
226 IDBProperties IDBProperties_iface
;
227 IDBInitialize IDBInitialize_iface
;
228 IDBCreateSession IDBCreateSession_iface
;
229 IPersist IPersist_iface
;
232 struct msdasql_prop properties
[14];
239 static inline struct msdasql
*impl_from_IUnknown(IUnknown
*iface
)
241 return CONTAINING_RECORD(iface
, struct msdasql
, MSDASQL_iface
);
244 static inline struct msdasql
*impl_from_IDBProperties(IDBProperties
*iface
)
246 return CONTAINING_RECORD(iface
, struct msdasql
, IDBProperties_iface
);
249 static inline struct msdasql
*impl_from_IDBInitialize(IDBInitialize
*iface
)
251 return CONTAINING_RECORD(iface
, struct msdasql
, IDBInitialize_iface
);
254 static inline struct msdasql
*impl_from_IDBCreateSession(IDBCreateSession
*iface
)
256 return CONTAINING_RECORD(iface
, struct msdasql
, IDBCreateSession_iface
);
259 static inline struct msdasql
*impl_from_IPersist( IPersist
*iface
)
261 return CONTAINING_RECORD( iface
, struct msdasql
, IPersist_iface
);
264 static HRESULT WINAPI
msdsql_QueryInterface(IUnknown
*iface
, REFIID riid
, void **out
)
266 struct msdasql
*provider
= impl_from_IUnknown(iface
);
268 TRACE("(%p)->(%s %p)\n", provider
, debugstr_guid(riid
), out
);
270 if(IsEqualGUID(riid
, &IID_IUnknown
) ||
271 IsEqualGUID(riid
, &CLSID_MSDASQL
))
273 *out
= &provider
->MSDASQL_iface
;
275 else if(IsEqualGUID(riid
, &IID_IDBProperties
))
277 *out
= &provider
->IDBProperties_iface
;
279 else if ( IsEqualGUID(riid
, &IID_IDBInitialize
))
281 *out
= &provider
->IDBInitialize_iface
;
283 else if (IsEqualGUID(riid
, &IID_IDBCreateSession
))
285 *out
= &provider
->IDBCreateSession_iface
;
287 else if(IsEqualGUID(&IID_IPersist
, riid
))
289 *out
= &provider
->IPersist_iface
;
293 FIXME("(%s, %p)\n", debugstr_guid(riid
), out
);
295 return E_NOINTERFACE
;
298 IUnknown_AddRef((IUnknown
*)*out
);
302 static ULONG WINAPI
msdsql_AddRef(IUnknown
*iface
)
304 struct msdasql
*provider
= impl_from_IUnknown(iface
);
305 ULONG ref
= InterlockedIncrement(&provider
->ref
);
307 TRACE("(%p) ref=%lu\n", provider
, ref
);
312 static ULONG WINAPI
msdsql_Release(IUnknown
*iface
)
314 struct msdasql
*provider
= impl_from_IUnknown(iface
);
315 ULONG ref
= InterlockedDecrement(&provider
->ref
);
317 TRACE("(%p) ref=%lu\n", provider
, ref
);
321 SQLDisconnect(provider
->hdbc
);
323 SQLFreeHandle(SQL_HANDLE_DBC
, provider
->hdbc
);
324 SQLFreeHandle(SQL_HANDLE_ENV
, provider
->henv
);
331 static const IUnknownVtbl msdsql_vtbl
=
333 msdsql_QueryInterface
,
338 static HRESULT WINAPI
dbprops_QueryInterface(IDBProperties
*iface
, REFIID riid
, void **ppvObject
)
340 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
342 return IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppvObject
);
345 static ULONG WINAPI
dbprops_AddRef(IDBProperties
*iface
)
347 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
349 return IUnknown_AddRef(&provider
->MSDASQL_iface
);
352 static ULONG WINAPI
dbprops_Release(IDBProperties
*iface
)
354 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
356 return IUnknown_Release(&provider
->MSDASQL_iface
);
359 static HRESULT WINAPI
dbprops_GetProperties(IDBProperties
*iface
, ULONG cPropertyIDSets
,
360 const DBPROPIDSET rgPropertyIDSets
[], ULONG
*pcPropertySets
, DBPROPSET
**prgPropertySets
)
362 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
366 TRACE("(%p)->(%ld %p %p %p)\n", provider
, cPropertyIDSets
, rgPropertyIDSets
, pcPropertySets
, prgPropertySets
);
370 if (cPropertyIDSets
!= 1)
372 FIXME("Currently only 1 property set supported.\n");
376 propset
= CoTaskMemAlloc(cPropertyIDSets
* sizeof(DBPROPSET
));
378 if (IsEqualGUID(&rgPropertyIDSets
[0].guidPropertySet
, &DBPROPSET_DATASOURCEINFO
))
380 TRACE("Propertyset DBPROPSET_DATASOURCEINFO not supported\n");
381 propset
->guidPropertySet
= rgPropertyIDSets
[0].guidPropertySet
;
382 propset
->cProperties
= rgPropertyIDSets
[0].cPropertyIDs
;
384 propset
->rgProperties
= CoTaskMemAlloc(propset
->cProperties
* sizeof(DBPROP
));
386 for (j
=0; j
< propset
->cProperties
; j
++)
388 propset
->rgProperties
[j
].dwPropertyID
= rgPropertyIDSets
[0].rgPropertyIDs
[j
];
389 propset
->rgProperties
[j
].dwStatus
= DBPROPSTATUS_NOTSUPPORTED
;
392 *prgPropertySets
= propset
;
394 return DB_E_ERRORSOCCURRED
;
397 propset
->guidPropertySet
= DBPROPSET_DBINIT
;
399 for (i
=0; i
< cPropertyIDSets
; i
++)
401 TRACE("Property id %d (count %ld, set %s)\n", i
, rgPropertyIDSets
[i
].cPropertyIDs
,
402 debugstr_guid(&rgPropertyIDSets
[i
].guidPropertySet
));
404 propset
->cProperties
= rgPropertyIDSets
[i
].cPropertyIDs
;
405 propset
->rgProperties
= CoTaskMemAlloc(propset
->cProperties
* sizeof(DBPROP
));
407 for (j
=0; j
< propset
->cProperties
; j
++)
409 propset
->rgProperties
[j
].dwPropertyID
= rgPropertyIDSets
[i
].rgPropertyIDs
[j
];
411 for(k
= 0; k
< ARRAY_SIZE(provider
->properties
); k
++)
413 if (provider
->properties
[k
].id
== rgPropertyIDSets
[i
].rgPropertyIDs
[j
])
415 V_VT(&propset
->rgProperties
[j
].vValue
) = VT_EMPTY
;
416 VariantCopy(&propset
->rgProperties
[j
].vValue
, &provider
->properties
[k
].value
);
423 *prgPropertySets
= propset
;
428 static HRESULT WINAPI
dbprops_GetPropertyInfo(IDBProperties
*iface
, ULONG cPropertyIDSets
,
429 const DBPROPIDSET rgPropertyIDSets
[], ULONG
*pcPropertyInfoSets
,
430 DBPROPINFOSET
**prgPropertyInfoSets
, OLECHAR
**ppDescBuffer
)
432 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
434 DBPROPINFOSET
*infoset
;
438 TRACE("(%p)->(%ld %p %p %p %p)\n", provider
, cPropertyIDSets
, rgPropertyIDSets
, pcPropertyInfoSets
,
439 prgPropertyInfoSets
, ppDescBuffer
);
441 infoset
= CoTaskMemAlloc(sizeof(DBPROPINFOSET
));
442 memcpy(&infoset
->guidPropertySet
, &DBPROPSET_DBINIT
, sizeof(GUID
));
443 infoset
->cPropertyInfos
= ARRAY_SIZE(dbproperties
);
444 infoset
->rgPropertyInfos
= CoTaskMemAlloc(sizeof(DBPROPINFO
) * ARRAY_SIZE(dbproperties
));
446 for(i
=0; i
< ARRAY_SIZE(dbproperties
); i
++)
448 size
+= lstrlenW(dbproperties
[i
].name
) + 1;
451 ptr
= *ppDescBuffer
= CoTaskMemAlloc(size
* sizeof(WCHAR
));
452 memset(*ppDescBuffer
, 0, size
* sizeof(WCHAR
));
454 for(i
=0; i
< ARRAY_SIZE(dbproperties
); i
++)
456 lstrcpyW(ptr
, dbproperties
[i
].name
);
457 infoset
->rgPropertyInfos
[i
].pwszDescription
= ptr
;
458 infoset
->rgPropertyInfos
[i
].dwPropertyID
= dbproperties
[i
].id
;
459 infoset
->rgPropertyInfos
[i
].dwFlags
= DBPROPFLAGS_DBINIT
| DBPROPFLAGS_READ
| DBPROPFLAGS_WRITE
;
460 infoset
->rgPropertyInfos
[i
].vtType
= dbproperties
[i
].type
;
461 V_VT(&infoset
->rgPropertyInfos
[i
].vValues
) = VT_EMPTY
;
463 ptr
+= lstrlenW(dbproperties
[i
].name
) + 1;
466 *pcPropertyInfoSets
= 1;
467 *prgPropertyInfoSets
= infoset
;
472 static HRESULT WINAPI
dbprops_SetProperties(IDBProperties
*iface
, ULONG cPropertySets
,
473 DBPROPSET rgPropertySets
[])
475 struct msdasql
*provider
= impl_from_IDBProperties(iface
);
478 TRACE("(%p)->(%ld %p)\n", provider
, cPropertySets
, rgPropertySets
);
480 for (i
=0; i
< cPropertySets
; i
++)
482 for (j
=0; j
< rgPropertySets
[i
].cProperties
; j
++)
484 for(k
=0; k
< ARRAY_SIZE(provider
->properties
); k
++)
486 if (provider
->properties
[k
].id
== rgPropertySets
[i
].rgProperties
[j
].dwPropertyID
)
488 TRACE("Found property %d\n", provider
->properties
[k
].id
);
489 VariantCopy(&provider
->properties
[k
].value
, &rgPropertySets
[i
].rgProperties
[j
].vValue
);
499 static const struct IDBPropertiesVtbl dbprops_vtbl
=
501 dbprops_QueryInterface
,
504 dbprops_GetProperties
,
505 dbprops_GetPropertyInfo
,
506 dbprops_SetProperties
509 static HRESULT WINAPI
dbinit_QueryInterface(IDBInitialize
*iface
, REFIID riid
, void **ppvObject
)
511 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
513 return IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppvObject
);
516 static ULONG WINAPI
dbinit_AddRef(IDBInitialize
*iface
)
518 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
520 return IUnknown_AddRef(&provider
->MSDASQL_iface
);
523 static ULONG WINAPI
dbinit_Release(IDBInitialize
*iface
)
525 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
527 return IUnknown_Release(&provider
->MSDASQL_iface
);
530 static HRESULT WINAPI
dbinit_Initialize(IDBInitialize
*iface
)
532 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
536 FIXME("%p semi-stub\n", provider
);
538 for(i
=0; i
< sizeof(provider
->properties
); i
++)
540 if (provider
->properties
[i
].id
== DBPROP_INIT_DATASOURCE
)
544 if (i
>= sizeof(provider
->properties
))
546 ERR("Datasource not found\n");
550 ret
= SQLConnectW( provider
->hdbc
, (SQLWCHAR
*)V_BSTR(&provider
->properties
[i
].value
),
551 SQL_NTS
, NULL
, SQL_NTS
, NULL
, SQL_NTS
);
552 TRACE("SQLConnectW ret %d\n", ret
);
553 if (ret
!= SQL_SUCCESS
)
555 dump_sql_diag_records(SQL_HANDLE_DBC
, provider
->hdbc
);
557 if (ret
!= SQL_SUCCESS_WITH_INFO
)
564 static HRESULT WINAPI
dbinit_Uninitialize(IDBInitialize
*iface
)
566 struct msdasql
*provider
= impl_from_IDBInitialize(iface
);
568 FIXME("%p stub\n", provider
);
574 static const struct IDBInitializeVtbl dbinit_vtbl
=
576 dbinit_QueryInterface
,
583 static HRESULT WINAPI
dbsess_QueryInterface(IDBCreateSession
*iface
, REFIID riid
, void **ppvObject
)
585 struct msdasql
*provider
= impl_from_IDBCreateSession(iface
);
587 return IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppvObject
);
590 static ULONG WINAPI
dbsess_AddRef(IDBCreateSession
*iface
)
592 struct msdasql
*provider
= impl_from_IDBCreateSession(iface
);
594 return IUnknown_AddRef(&provider
->MSDASQL_iface
);
597 static ULONG WINAPI
dbsess_Release(IDBCreateSession
*iface
)
599 struct msdasql
*provider
= impl_from_IDBCreateSession(iface
);
601 return IUnknown_Release(&provider
->MSDASQL_iface
);
604 static HRESULT WINAPI
dbsess_CreateSession(IDBCreateSession
*iface
, IUnknown
*outer
, REFIID riid
,
607 struct msdasql
*provider
= impl_from_IDBCreateSession(iface
);
610 TRACE("%p, outer %p, riid %s, session %p stub\n", provider
, outer
, debugstr_guid(riid
), session
);
613 FIXME("outer currently not supported.\n");
615 hr
= create_db_session(riid
, &provider
->MSDASQL_iface
, provider
->hdbc
, (void**)session
);
620 static const struct IDBCreateSessionVtbl dbsess_vtbl
=
622 dbsess_QueryInterface
,
628 static HRESULT WINAPI
persist_QueryInterface(IPersist
*iface
, REFIID riid
, void **ppv
)
630 struct msdasql
*provider
= impl_from_IPersist( iface
);
631 return IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppv
);
634 static ULONG WINAPI
persist_AddRef(IPersist
*iface
)
636 struct msdasql
*provider
= impl_from_IPersist( iface
);
637 return IUnknown_AddRef(&provider
->MSDASQL_iface
);
640 static ULONG WINAPI
persist_Release(IPersist
*iface
)
642 struct msdasql
*provider
= impl_from_IPersist( iface
);
643 return IUnknown_Release(&provider
->MSDASQL_iface
);
646 static HRESULT WINAPI
persist_GetClassID(IPersist
*iface
, CLSID
*classid
)
648 struct msdasql
*provider
= impl_from_IPersist( iface
);
650 TRACE("(%p)->(%p)\n", provider
, classid
);
655 *classid
= CLSID_MSDASQL
;
660 static const IPersistVtbl persistVtbl
= {
661 persist_QueryInterface
,
667 static HRESULT
create_msdasql_provider(REFIID riid
, void **ppv
)
669 struct msdasql
*provider
;
673 provider
= malloc(sizeof(struct msdasql
));
675 return E_OUTOFMEMORY
;
677 provider
->MSDASQL_iface
.lpVtbl
= &msdsql_vtbl
;
678 provider
->IDBProperties_iface
.lpVtbl
= &dbprops_vtbl
;
679 provider
->IDBInitialize_iface
.lpVtbl
= &dbinit_vtbl
;
680 provider
->IDBCreateSession_iface
.lpVtbl
= &dbsess_vtbl
;
681 provider
->IPersist_iface
.lpVtbl
= &persistVtbl
;
684 for(i
=0; i
< ARRAY_SIZE(dbproperties
); i
++)
686 provider
->properties
[i
].id
= dbproperties
[i
].id
;
687 VariantInit(&provider
->properties
[i
].value
);
689 /* Only the follow are initialized to a value */
690 switch(dbproperties
[i
].id
)
692 case DBPROP_INIT_PROMPT
:
693 V_VT(&provider
->properties
[i
].value
) = dbproperties
[i
].type
;
694 V_I2(&provider
->properties
[i
].value
) = 4;
696 case DBPROP_INIT_LCID
:
697 V_VT(&provider
->properties
[i
].value
) = dbproperties
[i
].type
;
698 V_I4(&provider
->properties
[i
].value
) = GetUserDefaultLCID();
700 case DBPROP_INIT_OLEDBSERVICES
:
701 V_VT(&provider
->properties
[i
].value
) = dbproperties
[i
].type
;
702 V_I4(&provider
->properties
[i
].value
) = -1;
705 V_VT(&provider
->properties
[i
].value
) = VT_EMPTY
;
709 SQLAllocHandle(SQL_HANDLE_ENV
, NULL
, &provider
->henv
);
710 if (SQLSetEnvAttr(provider
->henv
, SQL_ATTR_ODBC_VERSION
, (void *)SQL_OV_ODBC3_80
, 0) == SQL_ERROR
)
712 WARN("Falling back to SQL_OV_ODBC3\n");
713 SQLSetEnvAttr(provider
->henv
, SQL_ATTR_ODBC_VERSION
, (void *)SQL_OV_ODBC3
, 0);
716 SQLAllocHandle(SQL_HANDLE_DBC
, provider
->henv
, &provider
->hdbc
);
718 hr
= IUnknown_QueryInterface(&provider
->MSDASQL_iface
, riid
, ppv
);
719 IUnknown_Release(&provider
->MSDASQL_iface
);
725 ISourcesRowset ISourcesRowset_iface
;
729 static inline struct msdasql_enum
*msdasql_enum_from_ISourcesRowset(ISourcesRowset
*iface
)
731 return CONTAINING_RECORD(iface
, struct msdasql_enum
, ISourcesRowset_iface
);
734 static HRESULT WINAPI
msdasql_enum_QueryInterface(ISourcesRowset
*iface
, REFIID riid
, void **out
)
736 struct msdasql_enum
*enumerator
= msdasql_enum_from_ISourcesRowset(iface
);
738 TRACE("(%p)->(%s %p)\n", enumerator
, debugstr_guid(riid
), out
);
740 if(IsEqualGUID(riid
, &IID_IUnknown
) ||
741 IsEqualGUID(riid
, &IID_ISourcesRowset
) )
743 *out
= &enumerator
->ISourcesRowset_iface
;
747 FIXME("(%s, %p)\n", debugstr_guid(riid
), out
);
749 return E_NOINTERFACE
;
752 IUnknown_AddRef((IUnknown
*)*out
);
756 static ULONG WINAPI
msdasql_enum_AddRef(ISourcesRowset
*iface
)
758 struct msdasql_enum
*enumerator
= msdasql_enum_from_ISourcesRowset(iface
);
759 ULONG ref
= InterlockedIncrement(&enumerator
->ref
);
761 TRACE("(%p) ref=%lu\n", enumerator
, ref
);
766 static ULONG WINAPI
msdasql_enum_Release(ISourcesRowset
*iface
)
768 struct msdasql_enum
*enumerator
= msdasql_enum_from_ISourcesRowset(iface
);
769 ULONG ref
= InterlockedDecrement(&enumerator
->ref
);
771 TRACE("(%p) ref=%lu\n", enumerator
, ref
);
781 struct msdasql_enum_rowset
783 IRowset IRowset_iface
;
784 IAccessor IAccessor_iface
;
788 static inline struct msdasql_enum_rowset
*msdasql_rs_from_IRowset(IRowset
*iface
)
790 return CONTAINING_RECORD(iface
, struct msdasql_enum_rowset
, IRowset_iface
);
793 static inline struct msdasql_enum_rowset
*msdasql_enum_from_IAccessor ( IAccessor
*iface
)
795 return CONTAINING_RECORD( iface
, struct msdasql_enum_rowset
, IAccessor_iface
);
798 static HRESULT WINAPI
enum_rowset_QueryInterface(IRowset
*iface
, REFIID riid
, void **ppv
)
800 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
802 TRACE( "%p, %s, %p\n", rowset
, debugstr_guid(riid
), ppv
);
805 if(IsEqualGUID(&IID_IUnknown
, riid
) ||
806 IsEqualGUID(&IID_IRowset
, riid
))
808 *ppv
= &rowset
->IRowset_iface
;
810 else if(IsEqualGUID(&IID_IAccessor
, riid
))
812 *ppv
= &rowset
->IAccessor_iface
;
817 IUnknown_AddRef((IUnknown
*)*ppv
);
821 FIXME("(%p)->(%s %p)\n", iface
, debugstr_guid(riid
), ppv
);
822 return E_NOINTERFACE
;
825 static ULONG WINAPI
enum_rowset_AddRef(IRowset
*iface
)
827 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
828 LONG refs
= InterlockedIncrement( &rowset
->ref
);
829 TRACE( "%p new refcount %ld\n", rowset
, refs
);
833 static ULONG WINAPI
enum_rowset_Release(IRowset
*iface
)
835 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
836 LONG refs
= InterlockedDecrement( &rowset
->ref
);
837 TRACE( "%p new refcount %ld\n", rowset
, refs
);
840 TRACE( "destroying %p\n", rowset
);
846 static HRESULT WINAPI
enum_rowset_AddRefRows(IRowset
*iface
, DBCOUNTITEM count
,
847 const HROW rows
[], DBREFCOUNT ref_counts
[], DBROWSTATUS status
[])
849 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
851 FIXME("%p, %Iu, %p, %p, %p\n", rowset
, count
, rows
, ref_counts
, status
);
856 static HRESULT WINAPI
enum_rowset_GetData(IRowset
*iface
, HROW row
, HACCESSOR accessor
, void *data
)
858 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
860 FIXME("%p, %Iu, %Iu, %p\n", rowset
, row
, accessor
, data
);
865 static HRESULT WINAPI
enum_rowset_GetNextRows(IRowset
*iface
, HCHAPTER reserved
, DBROWOFFSET offset
,
866 DBROWCOUNT count
, DBCOUNTITEM
*obtained
, HROW
**rows
)
868 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
870 FIXME("%p, %Iu, %Iu, %Iu, %p, %p\n", rowset
, reserved
, offset
, count
, obtained
, rows
);
872 if (!obtained
|| !rows
)
880 return DB_S_ENDOFROWSET
;
883 static HRESULT WINAPI
enum_rowset_ReleaseRows(IRowset
*iface
, DBCOUNTITEM count
,
884 const HROW rows
[], DBROWOPTIONS options
[], DBREFCOUNT ref_counts
[], DBROWSTATUS status
[])
886 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
888 FIXME("%p, %Iu, %p, %p, %p, %p\n", rowset
, count
, rows
, options
, ref_counts
, status
);
893 static HRESULT WINAPI
enum_rowset_RestartPosition(IRowset
*iface
, HCHAPTER reserved
)
895 struct msdasql_enum_rowset
*rowset
= msdasql_rs_from_IRowset( iface
);
897 FIXME("%p, %Iu\n", rowset
, reserved
);
902 static const struct IRowsetVtbl enum_rowset_vtbl
=
904 enum_rowset_QueryInterface
,
907 enum_rowset_AddRefRows
,
909 enum_rowset_GetNextRows
,
910 enum_rowset_ReleaseRows
,
911 enum_rowset_RestartPosition
914 static HRESULT WINAPI
enum_rs_accessor_QueryInterface(IAccessor
*iface
, REFIID riid
, void **out
)
916 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
917 return IRowset_QueryInterface(&rowset
->IRowset_iface
, riid
, out
);
920 static ULONG WINAPI
enum_rs_accessor_AddRef(IAccessor
*iface
)
922 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
923 return IRowset_AddRef(&rowset
->IRowset_iface
);
926 static ULONG WINAPI
enum_rs_accessor_Release(IAccessor
*iface
)
928 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
929 return IRowset_Release(&rowset
->IRowset_iface
);
932 static HRESULT WINAPI
enum_rs_accessor_AddRefAccessor(IAccessor
*iface
, HACCESSOR accessor
, DBREFCOUNT
*count
)
934 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
935 FIXME("%p, %Iu, %p\n", rowset
, accessor
, count
);
939 static HRESULT WINAPI
enum_rs_accessor_CreateAccessor(IAccessor
*iface
, DBACCESSORFLAGS flags
,
940 DBCOUNTITEM count
, const DBBINDING bindings
[], DBLENGTH row_size
, HACCESSOR
*accessor
,
941 DBBINDSTATUS status
[])
943 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
945 FIXME("%p 0x%08lx, %Iu, %p, %Iu, %p, %p\n", rowset
, flags
, count
, bindings
, row_size
, accessor
, status
);
948 *accessor
= 0xdeadbeef;
953 static HRESULT WINAPI
enum_rs_accessor_GetBindings(IAccessor
*iface
, HACCESSOR accessor
,
954 DBACCESSORFLAGS
*flags
, DBCOUNTITEM
*count
, DBBINDING
**bindings
)
956 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
957 FIXME("%p, %Iu, %p, %p, %p\n", rowset
, accessor
, flags
, count
, bindings
);
961 static HRESULT WINAPI
enum_rs_accessor_ReleaseAccessor(IAccessor
*iface
, HACCESSOR accessor
, DBREFCOUNT
*count
)
963 struct msdasql_enum_rowset
*rowset
= msdasql_enum_from_IAccessor( iface
);
965 FIXME("%p, %Iu, %p\n", rowset
, accessor
, count
);
973 struct IAccessorVtbl enum_accessor_vtbl
=
975 enum_rs_accessor_QueryInterface
,
976 enum_rs_accessor_AddRef
,
977 enum_rs_accessor_Release
,
978 enum_rs_accessor_AddRefAccessor
,
979 enum_rs_accessor_CreateAccessor
,
980 enum_rs_accessor_GetBindings
,
981 enum_rs_accessor_ReleaseAccessor
984 static HRESULT WINAPI
msdasql_enum_GetSourcesRowset(ISourcesRowset
*iface
, IUnknown
*outer
, REFIID riid
, ULONG sets
,
985 DBPROPSET properties
[], IUnknown
**rowset
)
987 struct msdasql_enum
*enumerator
= msdasql_enum_from_ISourcesRowset(iface
);
988 struct msdasql_enum_rowset
*enum_rs
;
991 TRACE("(%p) %p, %s, %lu, %p, %p\n", enumerator
, outer
, debugstr_guid(riid
), sets
, properties
, rowset
);
993 enum_rs
= malloc(sizeof(*enum_rs
));
994 enum_rs
->IRowset_iface
.lpVtbl
= &enum_rowset_vtbl
;
995 enum_rs
->IAccessor_iface
.lpVtbl
= &enum_accessor_vtbl
;
998 hr
= IRowset_QueryInterface(&enum_rs
->IRowset_iface
, riid
, (void**)rowset
);
999 IRowset_Release(&enum_rs
->IRowset_iface
);
1003 static const ISourcesRowsetVtbl msdsqlenum_vtbl
=
1005 msdasql_enum_QueryInterface
,
1006 msdasql_enum_AddRef
,
1007 msdasql_enum_Release
,
1008 msdasql_enum_GetSourcesRowset
1011 static HRESULT
create_msdasql_enumerator(REFIID riid
, void **ppv
)
1013 struct msdasql_enum
*enumerator
;
1016 enumerator
= malloc(sizeof(*enumerator
));
1018 return E_OUTOFMEMORY
;
1020 enumerator
->ISourcesRowset_iface
.lpVtbl
= &msdsqlenum_vtbl
;
1021 enumerator
->ref
= 1;
1023 hr
= IUnknown_QueryInterface(&enumerator
->ISourcesRowset_iface
, riid
, ppv
);
1024 IUnknown_Release(&enumerator
->ISourcesRowset_iface
);