dlls/msdasql/session.c

   1 /*
   2  * Copyright 2020 Alistair Leslie-Hughes
   3  *
   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.
   8  *
   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.
  13  *
  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
  17  */
  18
  19 #define COBJMACROS
  20
  21 #include <stdarg.h>
  22
  23 #include "windef.h"
  24 #include "winbase.h"
  25 #include "objbase.h"
  26 #include "rpcproxy.h"
  27 #include "msdasc.h"
  28 #include "wine/heap.h"
  29 #include "wine/debug.h"
  30
  31 #include "msdasql.h"
  32 #include "oledberr.h"
  33 #include "sqlucode.h"
  34
  35 #include "msdasql_private.h"
  36
  37 WINE_DEFAULT_DEBUG_CHANNEL(msdasql);
  38
  39 struct msdasql_session
  40 {
  41     IUnknown session_iface;
  42     IGetDataSource IGetDataSource_iface;
  43     IOpenRowset    IOpenRowset_iface;
  44     ISessionProperties ISessionProperties_iface;
  45     IDBCreateCommand IDBCreateCommand_iface;
  46     ITransactionJoin ITransactionJoin_iface;
  47     LONG refs;
  48
  49     IUnknown *datasource;
  50
  51     HDBC hdbc;
  52 };
  53
  54 static inline struct msdasql_session *impl_from_IUnknown( IUnknown *iface )
  55 {
  56     return CONTAINING_RECORD( iface, struct msdasql_session, session_iface );
  57 }
  58
  59 static inline struct msdasql_session *impl_from_IGetDataSource( IGetDataSource *iface )
  60 {
  61     return CONTAINING_RECORD( iface, struct msdasql_session, IGetDataSource_iface );
  62 }
  63
  64 static inline struct msdasql_session *impl_from_IOpenRowset( IOpenRowset *iface )
  65 {
  66     return CONTAINING_RECORD( iface, struct msdasql_session, IOpenRowset_iface );
  67 }
  68
  69 static inline struct msdasql_session *impl_from_ISessionProperties( ISessionProperties *iface )
  70 {
  71     return CONTAINING_RECORD( iface, struct msdasql_session, ISessionProperties_iface );
  72 }
  73
  74 static inline struct msdasql_session *impl_from_IDBCreateCommand( IDBCreateCommand *iface )
  75 {
  76     return CONTAINING_RECORD( iface, struct msdasql_session, IDBCreateCommand_iface );
  77 }
  78
  79 static inline struct msdasql_session *impl_from_ITransactionJoin( ITransactionJoin *iface )
  80 {
  81     return CONTAINING_RECORD( iface, struct msdasql_session, ITransactionJoin_iface );
  82 }
  83
  84 static HRESULT WINAPI session_QueryInterface(IUnknown *iface, REFIID riid, void **ppv)
  85 {
  86     struct msdasql_session *session = impl_from_IUnknown( iface );
  87
  88     TRACE( "%p, %s, %p\n", iface, debugstr_guid(riid), ppv );
  89     *ppv = NULL;
  90
  91     if(IsEqualGUID(&IID_IUnknown, riid))
  92     {
  93         TRACE("(%p)->(IID_IUnknown %p)\n", iface, ppv);
  94         *ppv = &session->session_iface;
  95     }
  96     else if(IsEqualGUID(&IID_IGetDataSource, riid))
  97     {
  98         TRACE("(%p)->(IID_IGetDataSource %p)\n", iface, ppv);
  99         *ppv = &session->IGetDataSource_iface;
 100     }
 101     else if(IsEqualGUID(&IID_IOpenRowset, riid))
 102     {
 103         TRACE("(%p)->(IID_IOpenRowset %p)\n", iface, ppv);
 104         *ppv = &session->IOpenRowset_iface;
 105     }
 106     else if(IsEqualGUID(&IID_ISessionProperties, riid))
 107     {
 108         TRACE("(%p)->(IID_ISessionProperties %p)\n", iface, ppv);
 109         *ppv = &session->ISessionProperties_iface;
 110     }
 111     else if(IsEqualGUID(&IID_IDBCreateCommand, riid))
 112     {
 113         TRACE("(%p)->(IDBCreateCommand_iface %p)\n", iface, ppv);
 114         *ppv = &session->IDBCreateCommand_iface;
 115     }
 116     else if(IsEqualGUID(&IID_ITransactionJoin, riid))
 117     {
 118         TRACE("(%p)->(ITransactionJoin %p)\n", iface, ppv);
 119         *ppv = &session->ITransactionJoin_iface;
 120     }
 121     else if(IsEqualGUID(&IID_IBindResource, riid))
 122     {
 123         TRACE("(%p)->(IID_IBindResource not support)\n", iface);
 124         return E_NOINTERFACE;
 125     }
 126     else if(IsEqualGUID(&IID_ICreateRow, riid))
 127     {
 128         TRACE("(%p)->(IID_ICreateRow not support)\n", iface);
 129         return E_NOINTERFACE;
 130     }
 131
 132     if(*ppv)
 133     {
 134         IUnknown_AddRef((IUnknown*)*ppv);
 135         return S_OK;
 136     }
 137
 138     FIXME("(%p)->(%s %p)\n", iface, debugstr_guid(riid), ppv);
 139     return E_NOINTERFACE;
 140 }
 141
 142 static ULONG WINAPI session_AddRef(IUnknown *iface)
 143 {
 144     struct msdasql_session *session = impl_from_IUnknown( iface );
 145     LONG refs = InterlockedIncrement( &session->refs );
 146     TRACE( "%p new refcount %ld\n", session, refs );
 147     return refs;
 148 }
 149
 150 static ULONG WINAPI session_Release(IUnknown *iface)
 151 {
 152     struct msdasql_session *session = impl_from_IUnknown( iface );
 153     LONG refs = InterlockedDecrement( &session->refs );
 154     TRACE( "%p new refcount %ld\n", session, refs );
 155     if (!refs)
 156     {
 157         TRACE( "destroying %p\n", session );
 158
 159         IUnknown_Release(session->datasource);
 160         heap_free( session );
 161     }
 162     return refs;
 163 }
 164
 165 static const IUnknownVtbl unkfactoryVtbl =
 166 {
 167     session_QueryInterface,
 168     session_AddRef,
 169     session_Release,
 170 };
 171
 172
 173 HRESULT WINAPI datasource_QueryInterface(IGetDataSource *iface, REFIID riid, void **out)
 174 {
 175     struct msdasql_session *session = impl_from_IGetDataSource( iface );
 176     return IUnknown_QueryInterface(&session->session_iface, riid, out);
 177 }
 178
 179 ULONG WINAPI datasource_AddRef(IGetDataSource *iface)
 180 {
 181     struct msdasql_session *session = impl_from_IGetDataSource( iface );
 182     return IUnknown_AddRef(&session->session_iface);
 183 }
 184
 185 ULONG WINAPI datasource_Release(IGetDataSource *iface)
 186 {
 187     struct msdasql_session *session = impl_from_IGetDataSource( iface );
 188     return IUnknown_Release(&session->session_iface);
 189 }
 190
 191 HRESULT WINAPI datasource_GetDataSource(IGetDataSource *iface, REFIID riid, IUnknown **datasource)
 192 {
 193     struct msdasql_session *session = impl_from_IGetDataSource( iface );
 194
 195     TRACE("%p, %s, %p stub\n", session, debugstr_guid(riid), datasource);
 196
 197     if (!datasource)
 198         return E_INVALIDARG;
 199
 200     return IUnknown_QueryInterface(session->datasource, riid, (void**)datasource);
 201 }
 202
 203 static const IGetDataSourceVtbl datasourceVtbl =
 204 {
 205     datasource_QueryInterface,
 206     datasource_AddRef,
 207     datasource_Release,
 208     datasource_GetDataSource
 209 };
 210
 211 HRESULT WINAPI openrowset_QueryInterface(IOpenRowset *iface, REFIID riid, void **out)
 212 {
 213     struct msdasql_session *session = impl_from_IOpenRowset( iface );
 214     return IUnknown_QueryInterface(&session->session_iface, riid, out);
 215 }
 216
 217 ULONG WINAPI openrowset_AddRef(IOpenRowset *iface)
 218 {
 219     struct msdasql_session *session = impl_from_IOpenRowset( iface );
 220     return IUnknown_AddRef(&session->session_iface);
 221 }
 222
 223 ULONG WINAPI openrowset_Release(IOpenRowset *iface)
 224 {
 225     struct msdasql_session *session = impl_from_IOpenRowset( iface );
 226     return IUnknown_Release(&session->session_iface);
 227 }
 228
 229 HRESULT WINAPI openrowset_OpenRowset(IOpenRowset *iface, IUnknown *pUnkOuter, DBID *table,
 230             DBID *index, REFIID riid, ULONG count, DBPROPSET propertysets[], IUnknown **rowset)
 231 {
 232     struct msdasql_session *session = impl_from_IOpenRowset( iface );
 233     FIXME("%p, %p, %p %p %s, %ld %p %p stub\n", session, pUnkOuter, table, index, debugstr_guid(riid),
 234             count, propertysets, rowset);
 235
 236     return E_NOTIMPL;
 237 }
 238
 239 static const IOpenRowsetVtbl openrowsetVtbl =
 240 {
 241     openrowset_QueryInterface,
 242     openrowset_AddRef,
 243     openrowset_Release,
 244     openrowset_OpenRowset
 245 };
 246
 247 static HRESULT WINAPI properties_QueryInterface(ISessionProperties *iface, REFIID riid, void **out)
 248 {
 249     struct msdasql_session *session = impl_from_ISessionProperties( iface );
 250     return IUnknown_QueryInterface(&session->session_iface, riid, out);
 251 }
 252
 253 static ULONG WINAPI properties_AddRef(ISessionProperties *iface)
 254 {
 255     struct msdasql_session *session = impl_from_ISessionProperties( iface );
 256     return IUnknown_AddRef(&session->session_iface);
 257 }
 258
 259 static ULONG WINAPI properties_Release(ISessionProperties *iface)
 260 {
 261     struct msdasql_session *session = impl_from_ISessionProperties( iface );
 262     return IUnknown_Release(&session->session_iface);
 263 }
 264
 265
 266 static HRESULT WINAPI properties_GetProperties(ISessionProperties *iface, ULONG set_count,
 267     const DBPROPIDSET id_sets[], ULONG *count, DBPROPSET **sets)
 268 {
 269     struct msdasql_session *session = impl_from_ISessionProperties( iface );
 270     FIXME("%p %lu %p %p %p\n", session, set_count, id_sets, count, sets);
 271
 272     return E_NOTIMPL;
 273 }
 274
 275 static HRESULT WINAPI properties_SetProperties(ISessionProperties *iface, ULONG count,
 276     DBPROPSET sets[])
 277 {
 278     struct msdasql_session *session = impl_from_ISessionProperties( iface );
 279     FIXME("%p %lu %p\n", session, count, sets);
 280
 281     return S_OK;
 282 }
 283
 284 static const ISessionPropertiesVtbl propertiesVtbl =
 285 {
 286     properties_QueryInterface,
 287     properties_AddRef,
 288     properties_Release,
 289     properties_GetProperties,
 290     properties_SetProperties
 291 };
 292
 293 static HRESULT WINAPI createcommand_QueryInterface(IDBCreateCommand *iface, REFIID riid, void **out)
 294 {
 295     struct msdasql_session *session = impl_from_IDBCreateCommand( iface );
 296     return IUnknown_QueryInterface(&session->session_iface, riid, out);
 297 }
 298
 299 static ULONG WINAPI createcommand_AddRef(IDBCreateCommand *iface)
 300 {
 301     struct msdasql_session *session = impl_from_IDBCreateCommand( iface );
 302     return IUnknown_AddRef(&session->session_iface);
 303 }
 304
 305 static ULONG WINAPI createcommand_Release(IDBCreateCommand *iface)
 306 {
 307     struct msdasql_session *session = impl_from_IDBCreateCommand( iface );
 308     return IUnknown_Release(&session->session_iface);
 309 }
 310
 311 struct command
 312 {
 313     ICommandText ICommandText_iface;
 314     ICommandProperties ICommandProperties_iface;
 315     IColumnsInfo IColumnsInfo_iface;
 316     IConvertType IConvertType_iface;
 317     ICommandPrepare ICommandPrepare_iface;
 318     ICommandWithParameters ICommandWithParameters_iface;
 319     LONG refs;
 320     WCHAR *query;
 321     IUnknown *session;
 322     HDBC hdbc;
 323     SQLHSTMT hstmt;
 324 };
 325
 326 static inline struct command *impl_from_ICommandText( ICommandText *iface )
 327 {
 328     return CONTAINING_RECORD( iface, struct command, ICommandText_iface );
 329 }
 330
 331 static inline struct command *impl_from_ICommandProperties( ICommandProperties *iface )
 332 {
 333     return CONTAINING_RECORD( iface, struct command, ICommandProperties_iface );
 334 }
 335
 336 static inline struct command *impl_from_IColumnsInfo( IColumnsInfo *iface )
 337 {
 338     return CONTAINING_RECORD( iface, struct command, IColumnsInfo_iface );
 339 }
 340
 341 static inline struct command *impl_from_IConvertType( IConvertType *iface )
 342 {
 343     return CONTAINING_RECORD( iface, struct command, IConvertType_iface );
 344 }
 345
 346 static inline struct command *impl_from_ICommandPrepare( ICommandPrepare *iface )
 347 {
 348     return CONTAINING_RECORD( iface, struct command, ICommandPrepare_iface );
 349 }
 350
 351 static inline struct command *impl_from_ICommandWithParameters( ICommandWithParameters *iface )
 352 {
 353     return CONTAINING_RECORD( iface, struct command, ICommandWithParameters_iface );
 354 }
 355
 356 static HRESULT WINAPI command_QueryInterface(ICommandText *iface, REFIID riid, void **ppv)
 357 {
 358     struct command *command = impl_from_ICommandText( iface );
 359
 360     TRACE( "%p, %s, %p\n", command, debugstr_guid(riid), ppv );
 361     *ppv = NULL;
 362
 363     if(IsEqualGUID(&IID_IUnknown, riid) ||
 364        IsEqualGUID(&IID_ICommand, riid) ||
 365        IsEqualGUID(&IID_ICommandText, riid))
 366     {
 367         *ppv = &command->ICommandText_iface;
 368     }
 369     else if(IsEqualGUID(&IID_ICommandProperties, riid))
 370     {
 371          *ppv = &command->ICommandProperties_iface;
 372     }
 373     else if(IsEqualGUID(&IID_IColumnsInfo, riid))
 374     {
 375          *ppv = &command->IColumnsInfo_iface;
 376     }
 377     else if(IsEqualGUID(&IID_IConvertType, riid))
 378     {
 379          *ppv = &command->IConvertType_iface;
 380     }
 381     else if(IsEqualGUID(&IID_ICommandPrepare, riid))
 382     {
 383          *ppv = &command->ICommandPrepare_iface;
 384     }
 385     else if(IsEqualGUID(&IID_ICommandWithParameters, riid))
 386     {
 387         *ppv = &command->ICommandWithParameters_iface;
 388     }
 389
 390     if(*ppv)
 391     {
 392         IUnknown_AddRef((IUnknown*)*ppv);
 393         return S_OK;
 394     }
 395     else if (IsEqualGUID(&IID_IMultipleResults, riid))
 396     {
 397         TRACE("IID_IMultipleResults not supported\n");
 398         return E_NOINTERFACE;
 399     }
 400     else if(IsEqualGUID(&IID_ICommandStream, riid))
 401     {
 402         TRACE("ICommandStream not support\n");
 403         return E_NOINTERFACE;
 404     }
 405     else if (IsEqualGUID(&IID_IRowsetChange, riid))
 406     {
 407         TRACE("IID_IRowsetChange not supported\n");
 408         return E_NOINTERFACE;
 409     }
 410     else if (IsEqualGUID(&IID_IRowsetUpdate, riid))
 411     {
 412         TRACE("IID_IRowsetUpdate not supported\n");
 413         return E_NOINTERFACE;
 414     }
 415     else if (IsEqualGUID(&IID_IRowsetLocate, riid))
 416     {
 417         TRACE("IID_IRowsetLocate not supported\n");
 418         return E_NOINTERFACE;
 419     }
 420
 421     FIXME("(%p)->(%s %p)\n", iface, debugstr_guid(riid), ppv);
 422     return E_NOINTERFACE;
 423 }
 424
 425 static ULONG WINAPI command_AddRef(ICommandText *iface)
 426 {
 427     struct command *command = impl_from_ICommandText( iface );
 428     LONG refs = InterlockedIncrement( &command->refs );
 429     TRACE( "%p new refcount %ld\n", command, refs );
 430     return refs;
 431 }
 432
 433 static ULONG WINAPI command_Release(ICommandText *iface)
 434 {
 435     struct command *command = impl_from_ICommandText( iface );
 436     LONG refs = InterlockedDecrement( &command->refs );
 437     TRACE( "%p new refcount %ld\n", command, refs );
 438     if (!refs)
 439     {
 440         TRACE( "destroying %p\n", command );
 441         if (command->session)
 442             IUnknown_Release(command->session);
 443
 444         if (command->hstmt)
 445             SQLFreeHandle(SQL_HANDLE_STMT, command->hstmt);
 446
 447         heap_free( command->query );
 448         heap_free( command );
 449     }
 450     return refs;
 451 }
 452
 453 static HRESULT WINAPI command_Cancel(ICommandText *iface)
 454 {
 455     struct command *command = impl_from_ICommandText( iface );
 456     FIXME("%p\n", command);
 457     return E_NOTIMPL;
 458 }
 459
 460 struct msdasql_rowset
 461 {
 462     IRowset IRowset_iface;
 463     IRowsetInfo IRowsetInfo_iface;
 464     IColumnsInfo IColumnsInfo_iface;
 465     IAccessor IAccessor_iface;
 466     IColumnsRowset IColumnsRowset_iface;
 467     IUnknown *caller;
 468     LONG refs;
 469 };
 470
 471 static inline struct msdasql_rowset *impl_from_IRowset( IRowset *iface )
 472 {
 473     return CONTAINING_RECORD( iface, struct msdasql_rowset, IRowset_iface );
 474 }
 475
 476 static inline struct msdasql_rowset *impl_from_IRowsetInfo( IRowsetInfo *iface )
 477 {
 478     return CONTAINING_RECORD( iface, struct msdasql_rowset, IRowsetInfo_iface );
 479 }
 480
 481 static inline struct msdasql_rowset *rowset_impl_from_IColumnsInfo( IColumnsInfo *iface )
 482 {
 483     return CONTAINING_RECORD( iface, struct msdasql_rowset, IColumnsInfo_iface );
 484 }
 485
 486 static inline struct msdasql_rowset *impl_from_IAccessor ( IAccessor *iface )
 487 {
 488     return CONTAINING_RECORD( iface, struct msdasql_rowset, IAccessor_iface );
 489 }
 490
 491 static inline struct msdasql_rowset *impl_from_IColumnsRowset ( IColumnsRowset *iface )
 492 {
 493     return CONTAINING_RECORD( iface, struct msdasql_rowset, IColumnsRowset_iface );
 494 }
 495
 496 static HRESULT WINAPI msdasql_rowset_QueryInterface(IRowset *iface, REFIID riid,  void **ppv)
 497 {
 498     struct msdasql_rowset *rowset = impl_from_IRowset( iface );
 499
 500     TRACE( "%p, %s, %p\n", rowset, debugstr_guid(riid), ppv );
 501
 502     *ppv = NULL;
 503     if(IsEqualGUID(&IID_IUnknown, riid) ||
 504        IsEqualGUID(&IID_IRowset, riid))
 505     {
 506         *ppv = &rowset->IRowset_iface;
 507     }
 508     else if (IsEqualGUID(&IID_IRowsetInfo, riid))
 509     {
 510         *ppv = &rowset->IRowsetInfo_iface;
 511     }
 512     else if (IsEqualGUID(&IID_IColumnsInfo, riid))
 513     {
 514         *ppv = &rowset->IColumnsInfo_iface;
 515     }
 516     else if(IsEqualGUID(&IID_IAccessor, riid))
 517     {
 518          *ppv = &rowset->IAccessor_iface;
 519     }
 520     else if(IsEqualGUID(&IID_IColumnsRowset, riid))
 521     {
 522          *ppv = &rowset->IColumnsRowset_iface;
 523     }
 524     else if (IsEqualGUID(&IID_IRowsetChange, riid))
 525     {
 526         TRACE("IID_IRowsetChange not supported\n");
 527         return E_NOINTERFACE;
 528     }
 529     else if (IsEqualGUID(&IID_IRowsetUpdate, riid))
 530     {
 531         TRACE("IID_IRowsetUpdate not supported\n");
 532         return E_NOINTERFACE;
 533     }
 534     else if (IsEqualGUID(&IID_IRowsetLocate, riid))
 535     {
 536         TRACE("IID_IRowsetLocate not supported\n");
 537         return E_NOINTERFACE;
 538     }
 539
 540     if(*ppv)
 541     {
 542         IUnknown_AddRef((IUnknown*)*ppv);
 543         return S_OK;
 544     }
 545
 546     FIXME("(%p)->(%s %p)\n", iface, debugstr_guid(riid), ppv);
 547     return E_NOINTERFACE;
 548 }
 549
 550 static ULONG WINAPI msdasql_rowset_AddRef(IRowset *iface)
 551 {
 552     struct msdasql_rowset *rowset = impl_from_IRowset( iface );
 553     LONG refs = InterlockedIncrement( &rowset->refs );
 554     TRACE( "%p new refcount %ld\n", rowset, refs );
 555     return refs;
 556 }
 557
 558 static ULONG WINAPI msdasql_rowset_Release(IRowset *iface)
 559 {
 560     struct msdasql_rowset *rowset = impl_from_IRowset( iface );
 561     LONG refs = InterlockedDecrement( &rowset->refs );
 562     TRACE( "%p new refcount %ld\n", rowset, refs );
 563     if (!refs)
 564     {
 565         TRACE( "destroying %p\n", rowset );
 566
 567         if (rowset->caller)
 568             IUnknown_Release(rowset->caller);
 569
 570         heap_free( rowset );
 571     }
 572     return refs;
 573 }
 574
 575 static HRESULT WINAPI msdasql_rowset_AddRefRows(IRowset *iface, DBCOUNTITEM count,
 576         const HROW rows[], DBREFCOUNT ref_counts[], DBROWSTATUS status[])
 577 {
 578     struct msdasql_rowset *rowset = impl_from_IRowset( iface );
 579     FIXME("%p, %Id, %p, %p, %p\n", rowset, count, rows, ref_counts, status);
 580     return E_NOTIMPL;
 581 }
 582
 583 static HRESULT WINAPI msdasql_rowset_GetData(IRowset *iface, HROW row, HACCESSOR accessor, void *data)
 584 {
 585     struct msdasql_rowset *rowset = impl_from_IRowset( iface );
 586     FIXME("%p, %Id, %Id, %p\n", rowset, row, accessor, data);
 587     return E_NOTIMPL;
 588 }
 589
 590 static HRESULT WINAPI msdasql_rowset_GetNextRows(IRowset *iface, HCHAPTER reserved, DBROWOFFSET offset,
 591         DBROWCOUNT count, DBCOUNTITEM *obtained, HROW **rows)
 592 {
 593     struct msdasql_rowset *rowset = impl_from_IRowset( iface );
 594     FIXME("%p, %Id, %Id, %Id, %p, %p\n", rowset, reserved, offset, count, obtained, rows);
 595     return E_NOTIMPL;
 596 }
 597
 598 static HRESULT WINAPI msdasql_rowset_ReleaseRows(IRowset *iface, DBCOUNTITEM count,
 599         const HROW rows[], DBROWOPTIONS options[], DBREFCOUNT ref_counts[], DBROWSTATUS status[])
 600 {
 601     struct msdasql_rowset *rowset = impl_from_IRowset( iface );
 602
 603     FIXME("%p, %Id, %p, %p, %p, %p\n", rowset, count, rows, options, ref_counts, status);
 604     return E_NOTIMPL;
 605 }
 606
 607 static HRESULT WINAPI msdasql_rowset_RestartPosition(IRowset *iface, HCHAPTER reserved)
 608 {
 609     struct msdasql_rowset *rowset = impl_from_IRowset( iface );
 610     FIXME("%p, %Id\n", rowset, reserved);
 611     return E_NOTIMPL;
 612 }
 613
 614 static const struct IRowsetVtbl msdasql_rowset_vtbl =
 615 {
 616     msdasql_rowset_QueryInterface,
 617     msdasql_rowset_AddRef,
 618     msdasql_rowset_Release,
 619     msdasql_rowset_AddRefRows,
 620     msdasql_rowset_GetData,
 621     msdasql_rowset_GetNextRows,
 622     msdasql_rowset_ReleaseRows,
 623     msdasql_rowset_RestartPosition
 624 };
 625
 626 static HRESULT WINAPI rowset_info_QueryInterface(IRowsetInfo *iface, REFIID riid, void **ppv)
 627 {
 628     struct msdasql_rowset *rowset = impl_from_IRowsetInfo( iface );
 629     return IRowset_QueryInterface(&rowset->IRowset_iface, riid, ppv);
 630 }
 631
 632 static ULONG WINAPI rowset_info_AddRef(IRowsetInfo *iface)
 633 {
 634     struct msdasql_rowset *rowset = impl_from_IRowsetInfo( iface );
 635     return IRowset_AddRef(&rowset->IRowset_iface);
 636 }
 637
 638 static ULONG WINAPI rowset_info_Release(IRowsetInfo *iface)
 639 {
 640     struct msdasql_rowset *rowset = impl_from_IRowsetInfo( iface );
 641     return IRowset_Release(&rowset->IRowset_iface);
 642 }
 643
 644 static HRESULT WINAPI rowset_info_GetProperties(IRowsetInfo *iface, const ULONG count,
 645         const DBPROPIDSET propertyidsets[], ULONG *out_count, DBPROPSET **propertysets)
 646 {
 647     struct msdasql_rowset *rowset = impl_from_IRowsetInfo( iface );
 648     FIXME("%p, %lu, %p, %p, %p\n", rowset, count, propertyidsets, out_count, propertysets);
 649     return E_NOTIMPL;
 650 }
 651
 652 static HRESULT WINAPI rowset_info_GetReferencedRowset(IRowsetInfo *iface, DBORDINAL ordinal,
 653         REFIID riid, IUnknown **unk)
 654 {
 655     struct msdasql_rowset *rowset = impl_from_IRowsetInfo( iface );
 656     FIXME("%p, %Id, %s, %p\n", rowset, ordinal, debugstr_guid(riid), unk);
 657     return E_NOTIMPL;
 658 }
 659
 660 static HRESULT WINAPI rowset_info_GetSpecification(IRowsetInfo *iface, REFIID riid,
 661         IUnknown **specification)
 662 {
 663     struct msdasql_rowset *rowset = impl_from_IRowsetInfo( iface );
 664
 665     TRACE("%p, %s, %p\n", rowset, debugstr_guid(riid), specification);
 666
 667     if (!specification)
 668         return E_INVALIDARG;
 669
 670     if (!rowset->caller)
 671         return S_FALSE;
 672
 673     return IUnknown_QueryInterface(rowset->caller, riid, (void**)specification);
 674 }
 675
 676 struct IRowsetInfoVtbl rowset_info_vtbl =
 677 {
 678     rowset_info_QueryInterface,
 679     rowset_info_AddRef,
 680     rowset_info_Release,
 681     rowset_info_GetProperties,
 682     rowset_info_GetReferencedRowset,
 683     rowset_info_GetSpecification
 684 };
 685
 686 static HRESULT WINAPI rowset_colsinfo_QueryInterface(IColumnsInfo *iface, REFIID riid, void **out)
 687 {
 688     struct msdasql_rowset *rowset = rowset_impl_from_IColumnsInfo( iface );
 689     return IRowset_QueryInterface(&rowset->IRowset_iface, riid, out);
 690 }
 691
 692 static ULONG WINAPI rowset_colsinfo_AddRef(IColumnsInfo *iface)
 693 {
 694     struct msdasql_rowset *rowset = rowset_impl_from_IColumnsInfo( iface );
 695     return IRowset_AddRef(&rowset->IRowset_iface);
 696 }
 697
 698 static ULONG  WINAPI rowset_colsinfo_Release(IColumnsInfo *iface)
 699 {
 700     struct msdasql_rowset *rowset = rowset_impl_from_IColumnsInfo( iface );
 701     return IRowset_Release(&rowset->IRowset_iface);
 702 }
 703
 704 static HRESULT WINAPI rowset_colsinfo_GetColumnInfo(IColumnsInfo *iface, DBORDINAL *columns,
 705         DBCOLUMNINFO **colinfo, OLECHAR **stringsbuffer)
 706 {
 707     struct msdasql_rowset *rowset = rowset_impl_from_IColumnsInfo( iface );
 708     FIXME("%p, %p, %p, %p\n", rowset, columns, colinfo, stringsbuffer);
 709     return E_NOTIMPL;
 710 }
 711
 712 static HRESULT WINAPI rowset_colsinfo_MapColumnIDs(IColumnsInfo *iface, DBORDINAL column_ids,
 713         const DBID *dbids, DBORDINAL *columns)
 714 {
 715     struct msdasql_rowset *rowset = rowset_impl_from_IColumnsInfo( iface );
 716     FIXME("%p, %Id, %p, %p\n", rowset, column_ids, dbids, columns);
 717     return E_NOTIMPL;
 718 }
 719
 720 static struct IColumnsInfoVtbl rowset_columninfo_vtbll =
 721 {
 722     rowset_colsinfo_QueryInterface,
 723     rowset_colsinfo_AddRef,
 724     rowset_colsinfo_Release,
 725     rowset_colsinfo_GetColumnInfo,
 726     rowset_colsinfo_MapColumnIDs
 727 };
 728
 729 static HRESULT WINAPI rowset_accessor_QueryInterface(IAccessor *iface, REFIID riid, void **out)
 730 {
 731     struct msdasql_rowset *rowset = impl_from_IAccessor( iface );
 732     return IRowset_QueryInterface(&rowset->IRowset_iface, riid, out);
 733 }
 734
 735 static ULONG WINAPI rowset_accessor_AddRef(IAccessor *iface)
 736 {
 737     struct msdasql_rowset *rowset = impl_from_IAccessor( iface );
 738     return IRowset_AddRef(&rowset->IRowset_iface);
 739 }
 740
 741 static ULONG  WINAPI rowset_accessor_Release(IAccessor *iface)
 742 {
 743     struct msdasql_rowset *rowset = impl_from_IAccessor( iface );
 744     return IRowset_Release(&rowset->IRowset_iface);
 745 }
 746
 747 static HRESULT WINAPI rowset_accessor_AddRefAccessor(IAccessor *iface, HACCESSOR accessor, DBREFCOUNT *count)
 748 {
 749     struct msdasql_rowset *rowset = impl_from_IAccessor( iface );
 750     FIXME("%p, %Id, %p\n", rowset, accessor, count);
 751     return E_NOTIMPL;
 752 }
 753
 754 static HRESULT WINAPI rowset_accessor_CreateAccessor(IAccessor *iface, DBACCESSORFLAGS flags,
 755         DBCOUNTITEM count, const DBBINDING bindings[], DBLENGTH row_size, HACCESSOR *accessor,
 756         DBBINDSTATUS status[])
 757 {
 758     struct msdasql_rowset *rowset = impl_from_IAccessor( iface );
 759     FIXME("%p, 0x%08lx, %Id, %p, %Id, %p, %p\n", rowset, flags, count, bindings, row_size, accessor, status);
 760     return E_NOTIMPL;
 761 }
 762
 763 static HRESULT WINAPI rowset_accessor_GetBindings(IAccessor *iface, HACCESSOR accessor,
 764         DBACCESSORFLAGS *flags, DBCOUNTITEM *count, DBBINDING **bindings)
 765 {
 766     struct msdasql_rowset *rowset = impl_from_IAccessor( iface );
 767     FIXME("%p, %Id, %p, %p, %p\n", rowset, accessor, flags, count, bindings);
 768     return E_NOTIMPL;
 769 }
 770
 771 static HRESULT WINAPI rowset_accessor_ReleaseAccessor(IAccessor *iface, HACCESSOR accessor, DBREFCOUNT *count)
 772 {
 773     struct msdasql_rowset *rowset = impl_from_IAccessor( iface );
 774     FIXME("%p, %Id, %p\n", rowset, accessor, count);
 775     return E_NOTIMPL;
 776 }
 777
 778 struct IAccessorVtbl accessor_vtbl =
 779 {
 780     rowset_accessor_QueryInterface,
 781     rowset_accessor_AddRef,
 782     rowset_accessor_Release,
 783     rowset_accessor_AddRefAccessor,
 784     rowset_accessor_CreateAccessor,
 785     rowset_accessor_GetBindings,
 786     rowset_accessor_ReleaseAccessor
 787 };
 788
 789 static HRESULT WINAPI column_rs_QueryInterface(IColumnsRowset *iface, REFIID riid, void **out)
 790 {
 791     struct msdasql_rowset *rowset = impl_from_IColumnsRowset( iface );
 792     return IRowset_QueryInterface(&rowset->IRowset_iface, riid, out);
 793 }
 794
 795 static ULONG WINAPI column_rs_AddRef(IColumnsRowset *iface)
 796 {
 797     struct msdasql_rowset *rowset = impl_from_IColumnsRowset( iface );
 798     return IRowset_AddRef(&rowset->IRowset_iface);
 799 }
 800
 801 static ULONG WINAPI column_rs_Release(IColumnsRowset *iface)
 802 {
 803     struct msdasql_rowset *rowset = impl_from_IColumnsRowset( iface );
 804     return IRowset_Release(&rowset->IRowset_iface);
 805 }
 806
 807 static HRESULT WINAPI column_rs_GetAvailableColumns(IColumnsRowset *iface, DBORDINAL *count, DBID **columns)
 808 {
 809     struct msdasql_rowset *rowset = impl_from_IColumnsRowset( iface );
 810     FIXME("%p, %p, %p\n", rowset, count, columns);
 811     return E_NOTIMPL;
 812 }
 813
 814 static HRESULT WINAPI column_rs_GetColumnsRowset(IColumnsRowset *iface, IUnknown *outer, DBORDINAL count,
 815         const DBID columns[], REFIID riid, ULONG property_cnt, DBPROPSET property_sets[], IUnknown **unk_rs)
 816 {
 817     struct msdasql_rowset *rowset = impl_from_IColumnsRowset( iface );
 818     FIXME("(%p)->(%p, %Id, %p, %s, %lu, %p, %p): stub\n", rowset, outer, count, columns, debugstr_guid(riid),
 819           property_cnt, property_sets, unk_rs);
 820     return E_NOTIMPL;
 821 }
 822
 823 struct IColumnsRowsetVtbl columnrs_rs_vtbl =
 824 {
 825     column_rs_QueryInterface,
 826     column_rs_AddRef,
 827     column_rs_Release,
 828     column_rs_GetAvailableColumns,
 829     column_rs_GetColumnsRowset
 830 };
 831
 832 static HRESULT WINAPI command_Execute(ICommandText *iface, IUnknown *outer, REFIID riid,
 833         DBPARAMS *params, DBROWCOUNT *affected, IUnknown **rowset)
 834 {
 835     struct command *command = impl_from_ICommandText( iface );
 836     struct msdasql_rowset *msrowset;
 837     HRESULT hr;
 838
 839     FIXME("%p, %p, %s, %p %p %p Semi Stub\n", command, outer, debugstr_guid(riid), params, affected, rowset);
 840
 841     msrowset = heap_alloc(sizeof(*msrowset));
 842     if (!msrowset)
 843         return E_OUTOFMEMORY;
 844
 845     msrowset->IRowset_iface.lpVtbl = &msdasql_rowset_vtbl;
 846     msrowset->IRowsetInfo_iface.lpVtbl = &rowset_info_vtbl;
 847     msrowset->IColumnsInfo_iface.lpVtbl = &rowset_columninfo_vtbll;
 848     msrowset->IAccessor_iface.lpVtbl = &accessor_vtbl;
 849     msrowset->IColumnsRowset_iface.lpVtbl = &columnrs_rs_vtbl;
 850     msrowset->refs = 1;
 851     ICommandText_QueryInterface(iface, &IID_IUnknown, (void**)&msrowset->caller);
 852
 853     if (affected)
 854         *affected = 0; /* FIXME */
 855
 856     hr = IRowset_QueryInterface(&msrowset->IRowset_iface, riid, (void**)rowset);
 857     IRowset_Release(&msrowset->IRowset_iface);
 858
 859     return hr;
 860 }
 861
 862 static HRESULT WINAPI command_GetDBSession(ICommandText *iface, REFIID riid, IUnknown **session)
 863 {
 864     struct command *command = impl_from_ICommandText( iface );
 865
 866     TRACE("%p, %s, %p\n", command, debugstr_guid(riid), session);
 867
 868     if (!session)
 869         return E_INVALIDARG;
 870
 871     *session = NULL;
 872
 873     if (!command->session)
 874         return S_FALSE;
 875
 876     return IUnknown_QueryInterface(command->session, riid, (void**)session);
 877 }
 878
 879 static HRESULT WINAPI command_GetCommandText(ICommandText *iface, GUID *dialect, LPOLESTR *commandstr)
 880 {
 881     struct command *command = impl_from_ICommandText( iface );
 882     HRESULT hr = S_OK;
 883     TRACE("%p, %p, %p\n", command, dialect, commandstr);
 884
 885     if (!command->query)
 886         return DB_E_NOCOMMAND;
 887
 888     if (dialect && !IsEqualGUID(&DBGUID_DEFAULT, dialect))
 889     {
 890         *dialect = DBGUID_DEFAULT;
 891         hr = DB_S_DIALECTIGNORED;
 892     }
 893
 894     *commandstr = heap_alloc((lstrlenW(command->query)+1)*sizeof(WCHAR));
 895     wcscpy(*commandstr, command->query);
 896     return hr;
 897 }
 898
 899 static HRESULT WINAPI command_SetCommandText(ICommandText *iface, REFGUID dialect, LPCOLESTR commandstr)
 900 {
 901     struct command *command = impl_from_ICommandText( iface );
 902     TRACE("%p, %s, %s\n", command, debugstr_guid(dialect), debugstr_w(commandstr));
 903
 904     if (!IsEqualGUID(&DBGUID_DEFAULT, dialect))
 905         FIXME("Currently non Default Dialect isn't supported\n");
 906
 907     heap_free(command->query);
 908
 909     if (commandstr)
 910     {
 911         command->query = heap_alloc((lstrlenW(commandstr)+1)*sizeof(WCHAR));
 912         if (!command->query)
 913             return E_OUTOFMEMORY;
 914
 915         wcscpy(command->query, commandstr);
 916     }
 917     else
 918         command->query = NULL;
 919     return S_OK;
 920 }
 921
 922 static const ICommandTextVtbl commandVtbl =
 923 {
 924     command_QueryInterface,
 925     command_AddRef,
 926     command_Release,
 927     command_Cancel,
 928     command_Execute,
 929     command_GetDBSession,
 930     command_GetCommandText,
 931     command_SetCommandText
 932 };
 933
 934 static HRESULT WINAPI command_prop_QueryInterface(ICommandProperties *iface, REFIID riid, void **out)
 935 {
 936     struct command *command = impl_from_ICommandProperties( iface );
 937     return ICommandText_QueryInterface(&command->ICommandText_iface, riid, out);
 938 }
 939
 940 static ULONG WINAPI command_prop_AddRef(ICommandProperties *iface)
 941 {
 942     struct command *command = impl_from_ICommandProperties( iface );
 943     return ICommandText_AddRef(&command->ICommandText_iface);
 944 }
 945
 946 static ULONG WINAPI command_prop_Release(ICommandProperties *iface)
 947 {
 948     struct command *command = impl_from_ICommandProperties( iface );
 949     return ICommandText_Release(&command->ICommandText_iface);
 950 }
 951
 952 static HRESULT WINAPI command_prop_GetProperties(ICommandProperties *iface, ULONG count,
 953         const DBPROPIDSET propertyidsets[], ULONG *sets_cnt, DBPROPSET **propertyset)
 954 {
 955     struct command *command = impl_from_ICommandProperties( iface );
 956     FIXME("%p %lu %p %p %p\n", command, count, propertyidsets, sets_cnt, propertyset);
 957     return E_NOTIMPL;
 958 }
 959
 960 static HRESULT WINAPI command_prop_SetProperties(ICommandProperties *iface, ULONG count,
 961         DBPROPSET propertyset[])
 962 {
 963     struct command *command = impl_from_ICommandProperties( iface );
 964     FIXME("%p, %lu, %p\n", command, count, propertyset);
 965     return S_OK;
 966 }
 967
 968 static const ICommandPropertiesVtbl commonpropsVtbl =
 969 {
 970     command_prop_QueryInterface,
 971     command_prop_AddRef,
 972     command_prop_Release,
 973     command_prop_GetProperties,
 974     command_prop_SetProperties
 975 };
 976
 977 static HRESULT WINAPI colsinfo_QueryInterface(IColumnsInfo *iface, REFIID riid, void **out)
 978 {
 979     struct command *command = impl_from_IColumnsInfo( iface );
 980     return ICommandText_QueryInterface(&command->ICommandText_iface, riid, out);
 981 }
 982
 983 static ULONG WINAPI colsinfo_AddRef(IColumnsInfo *iface)
 984 {
 985     struct command *command = impl_from_IColumnsInfo( iface );
 986     return ICommandText_AddRef(&command->ICommandText_iface);
 987 }
 988
 989 static ULONG  WINAPI colsinfo_Release(IColumnsInfo *iface)
 990 {
 991     struct command *command = impl_from_IColumnsInfo( iface );
 992     return ICommandText_Release(&command->ICommandText_iface);
 993 }
 994
 995 static HRESULT WINAPI colsinfo_GetColumnInfo(IColumnsInfo *iface, DBORDINAL *columns,
 996         DBCOLUMNINFO **colinfo, OLECHAR **stringsbuffer)
 997 {
 998     struct command *command = impl_from_IColumnsInfo( iface );
 999     FIXME("%p, %p, %p, %p\n", command, columns, colinfo, stringsbuffer);
1000     return E_NOTIMPL;
1001 }
1002
1003 static HRESULT WINAPI colsinfo_MapColumnIDs(IColumnsInfo *iface, DBORDINAL column_ids,
1004         const DBID *dbids, DBORDINAL *columns)
1005 {
1006     struct command *command = impl_from_IColumnsInfo( iface );
1007     FIXME("%p, %Iu, %p, %p\n", command, column_ids, dbids, columns);
1008     return E_NOTIMPL;
1009 }
1010
1011 static struct IColumnsInfoVtbl columninfoVtbl =
1012 {
1013     colsinfo_QueryInterface,
1014     colsinfo_AddRef,
1015     colsinfo_Release,
1016     colsinfo_GetColumnInfo,
1017     colsinfo_MapColumnIDs
1018 };
1019
1020 static HRESULT WINAPI converttype_QueryInterface(IConvertType *iface, REFIID riid, void **out)
1021 {
1022     struct command *command = impl_from_IConvertType( iface );
1023     return ICommandText_QueryInterface(&command->ICommandText_iface, riid, out);
1024 }
1025
1026 static ULONG WINAPI converttype_AddRef(IConvertType *iface)
1027 {
1028     struct command *command = impl_from_IConvertType( iface );
1029     return ICommandText_AddRef(&command->ICommandText_iface);
1030 }
1031
1032 static ULONG WINAPI converttype_Release(IConvertType *iface)
1033 {
1034     struct command *command = impl_from_IConvertType( iface );
1035     return ICommandText_Release(&command->ICommandText_iface);
1036 }
1037
1038 static HRESULT WINAPI converttype_CanConvert(IConvertType *iface, DBTYPE from, DBTYPE to, DBCONVERTFLAGS flags)
1039 {
1040     struct command *command = impl_from_IConvertType( iface );
1041     FIXME("%p, %u, %d, 0x%08lx\n", command, from, to, flags);
1042     return E_NOTIMPL;
1043 }
1044
1045 static struct IConvertTypeVtbl converttypeVtbl =
1046 {
1047     converttype_QueryInterface,
1048     converttype_AddRef,
1049     converttype_Release,
1050     converttype_CanConvert
1051 };
1052
1053 static HRESULT WINAPI commandprepare_QueryInterface(ICommandPrepare *iface, REFIID riid, void **out)
1054 {
1055     struct command *command = impl_from_ICommandPrepare( iface );
1056     return ICommandText_QueryInterface(&command->ICommandText_iface, riid, out);
1057 }
1058
1059 static ULONG WINAPI commandprepare_AddRef(ICommandPrepare *iface)
1060 {
1061     struct command *command = impl_from_ICommandPrepare( iface );
1062     return ICommandText_AddRef(&command->ICommandText_iface);
1063 }
1064
1065 static ULONG WINAPI commandprepare_Release(ICommandPrepare *iface)
1066 {
1067     struct command *command = impl_from_ICommandPrepare( iface );
1068     return ICommandText_Release(&command->ICommandText_iface);
1069 }
1070
1071 static HRESULT WINAPI commandprepare_Prepare(ICommandPrepare *iface, ULONG runs)
1072 {
1073     struct command *command = impl_from_ICommandPrepare( iface );
1074     RETCODE ret;
1075
1076     TRACE("%p, %lu\n", command, runs);
1077
1078     if (!command->query)
1079         return DB_E_NOCOMMAND;
1080
1081     if (command->hstmt)
1082         SQLFreeHandle(SQL_HANDLE_STMT, command->hstmt);
1083
1084     SQLAllocHandle(SQL_HANDLE_STMT, command->hdbc, &command->hstmt);
1085
1086     ret = SQLPrepareW(command->hstmt, command->query, SQL_NTS);
1087     if (ret != SQL_SUCCESS)
1088     {
1089         dump_sql_diag_records(SQL_HANDLE_STMT, command->hstmt);
1090         return E_FAIL;
1091     }
1092     return S_OK;
1093 }
1094
1095 static HRESULT WINAPI commandprepare_Unprepare(ICommandPrepare *iface)
1096 {
1097     struct command *command = impl_from_ICommandPrepare( iface );
1098     TRACE("%p\n", command);
1099     return S_OK;
1100 }
1101
1102 struct ICommandPrepareVtbl commandprepareVtbl =
1103 {
1104     commandprepare_QueryInterface,
1105     commandprepare_AddRef,
1106     commandprepare_Release,
1107     commandprepare_Prepare,
1108     commandprepare_Unprepare
1109 };
1110
1111 static HRESULT WINAPI cmd_with_params_QueryInterface(ICommandWithParameters *iface, REFIID riid, void **out)
1112 {
1113     struct command *command = impl_from_ICommandWithParameters( iface );
1114     return ICommandText_QueryInterface(&command->ICommandText_iface, riid, out);
1115 }
1116
1117 static ULONG WINAPI cmd_with_params_AddRef(ICommandWithParameters *iface)
1118 {
1119     struct command *command = impl_from_ICommandWithParameters( iface );
1120     return ICommandText_AddRef(&command->ICommandText_iface);
1121 }
1122
1123 static ULONG WINAPI cmd_with_params_Release(ICommandWithParameters *iface)
1124 {
1125     struct command *command = impl_from_ICommandWithParameters( iface );
1126     return ICommandText_Release(&command->ICommandText_iface);
1127 }
1128
1129 static HRESULT WINAPI cmd_with_params_GetParameterInfo(ICommandWithParameters *iface, DB_UPARAMS *uparams,
1130         DBPARAMINFO **info, OLECHAR **buffer)
1131 {
1132     struct command *command = impl_from_ICommandWithParameters( iface );
1133     FIXME("%p, %p, %p, %p\n", command, uparams, info, buffer);
1134     return E_NOTIMPL;
1135 }
1136
1137 static HRESULT WINAPI cmd_with_params_MapParameterNames(ICommandWithParameters *iface, DB_UPARAMS uparams,
1138         LPCWSTR names[], DB_LPARAMS ordinals[])
1139 {
1140     struct command *command = impl_from_ICommandWithParameters( iface );
1141     FIXME("%p, %Iu, %p, %p\n", command, uparams, names, ordinals);
1142     return E_NOTIMPL;
1143 }
1144
1145 static HRESULT WINAPI cmd_with_params_SetParameterInfo(ICommandWithParameters *iface, DB_UPARAMS uparams,
1146         const DB_UPARAMS ordinals[], const DBPARAMBINDINFO bindinfo[])
1147 {
1148     struct command *command = impl_from_ICommandWithParameters( iface );
1149     FIXME("%p, %Iu, %p, %p\n", command, uparams, ordinals, bindinfo);
1150     return E_NOTIMPL;
1151 }
1152
1153 struct ICommandWithParametersVtbl command_with_params_vtbl =
1154 {
1155     cmd_with_params_QueryInterface,
1156     cmd_with_params_AddRef,
1157     cmd_with_params_Release,
1158     cmd_with_params_GetParameterInfo,
1159     cmd_with_params_MapParameterNames,
1160     cmd_with_params_SetParameterInfo
1161 };
1162
1163 static HRESULT WINAPI createcommand_CreateCommand(IDBCreateCommand *iface, IUnknown *outer, REFIID riid,
1164                                             IUnknown **out)
1165 {
1166     struct msdasql_session *session = impl_from_IDBCreateCommand( iface );
1167     struct command *command;
1168     HRESULT hr;
1169
1170     TRACE("%p, %p, %s, %p\n", session, outer, debugstr_guid(riid), out);
1171
1172     if (outer)
1173         FIXME("Outer not currently supported\n");
1174
1175     command = heap_alloc(sizeof(*command));
1176     if (!command)
1177         return E_OUTOFMEMORY;
1178
1179     command->ICommandText_iface.lpVtbl = &commandVtbl;
1180     command->ICommandProperties_iface.lpVtbl = &commonpropsVtbl;
1181     command->IColumnsInfo_iface.lpVtbl = &columninfoVtbl;
1182     command->IConvertType_iface.lpVtbl = &converttypeVtbl;
1183     command->ICommandPrepare_iface.lpVtbl = &commandprepareVtbl;
1184     command->ICommandWithParameters_iface.lpVtbl = &command_with_params_vtbl;
1185     command->refs = 1;
1186     command->query = NULL;
1187     command->hdbc = session->hdbc;
1188     command->hstmt = NULL;
1189
1190     IUnknown_QueryInterface(&session->session_iface, &IID_IUnknown, (void**)&command->session);
1191
1192     hr = ICommandText_QueryInterface(&command->ICommandText_iface, riid, (void**)out);
1193     ICommandText_Release(&command->ICommandText_iface);
1194     return hr;
1195 }
1196
1197 static const IDBCreateCommandVtbl createcommandVtbl =
1198 {
1199     createcommand_QueryInterface,
1200     createcommand_AddRef,
1201     createcommand_Release,
1202     createcommand_CreateCommand
1203 };
1204
1205 static HRESULT WINAPI transjoin_QueryInterface(ITransactionJoin *iface, REFIID riid, void **out)
1206 {
1207     struct msdasql_session *session = impl_from_ITransactionJoin( iface );
1208     return IUnknown_QueryInterface(&session->session_iface, riid, out);
1209 }
1210
1211 static ULONG WINAPI transjoin_AddRef(ITransactionJoin *iface)
1212 {
1213     struct msdasql_session *session = impl_from_ITransactionJoin( iface );
1214     return IUnknown_AddRef(&session->session_iface);
1215 }
1216
1217 static ULONG WINAPI transjoin_Release(ITransactionJoin *iface)
1218 {
1219     struct msdasql_session *session = impl_from_ITransactionJoin( iface );
1220     return IUnknown_Release(&session->session_iface);
1221 }
1222
1223 static HRESULT WINAPI transjoin_GetOptionsObject(ITransactionJoin *iface, ITransactionOptions **options)
1224 {
1225     struct msdasql_session *session = impl_from_ITransactionJoin( iface );
1226
1227     FIXME("%p, %p\n", session, options);
1228
1229     return E_NOTIMPL;
1230 }
1231
1232 static HRESULT WINAPI transjoin_JoinTransaction(ITransactionJoin *iface, IUnknown *unk, ISOLEVEL level,
1233     ULONG flags, ITransactionOptions *options)
1234 {
1235     struct msdasql_session *session = impl_from_ITransactionJoin( iface );
1236
1237     FIXME("%p, %p, %lu, 0x%08lx, %p\n", session, unk, level, flags, options);
1238
1239     return E_NOTIMPL;
1240 }
1241
1242 static const ITransactionJoinVtbl transactionjoinVtbl =
1243 {
1244     transjoin_QueryInterface,
1245     transjoin_AddRef,
1246     transjoin_Release,
1247     transjoin_GetOptionsObject,
1248     transjoin_JoinTransaction
1249 };
1250
1251 HRESULT create_db_session(REFIID riid, IUnknown *datasource, HDBC hdbc, void **unk)
1252 {
1253     struct msdasql_session *session;
1254     HRESULT hr;
1255
1256     session = heap_alloc(sizeof(*session));
1257     if (!session)
1258         return E_OUTOFMEMORY;
1259
1260     session->session_iface.lpVtbl = &unkfactoryVtbl;
1261     session->IGetDataSource_iface.lpVtbl = &datasourceVtbl;
1262     session->IOpenRowset_iface.lpVtbl = &openrowsetVtbl;
1263     session->ISessionProperties_iface.lpVtbl = &propertiesVtbl;
1264     session->IDBCreateCommand_iface.lpVtbl = &createcommandVtbl;
1265     session->ITransactionJoin_iface.lpVtbl = &transactionjoinVtbl;
1266     IUnknown_QueryInterface(datasource, &IID_IUnknown, (void**)&session->datasource);
1267     session->refs = 1;
1268     session->hdbc = hdbc;
1269
1270     hr = IUnknown_QueryInterface(&session->session_iface, riid, unk);
1271     IUnknown_Release(&session->session_iface);
1272     return hr;
1273 }