Sweden-Number/dlls/oledb32/rowpos.c

315 lines
8.7 KiB
C
Raw Normal View History

2013-08-01 05:48:13 +02:00
/* OLE DB Row Position library
*
* Copyright 2013 Nikolay Sivov
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
*/
#define COBJMACROS
#include "windef.h"
#include "ole2.h"
#include "oledb.h"
#include "oledberr.h"
2013-08-01 05:48:13 +02:00
#include "oledb_private.h"
#include "wine/debug.h"
WINE_DEFAULT_DEBUG_CHANNEL(oledb);
typedef struct rowpos rowpos;
2013-08-01 05:48:13 +02:00
typedef struct
{
IConnectionPoint IConnectionPoint_iface;
rowpos *container;
} rowpos_cp;
struct rowpos
2013-08-01 05:48:13 +02:00
{
IRowPosition IRowPosition_iface;
IConnectionPointContainer IConnectionPointContainer_iface;
2013-08-01 05:48:13 +02:00
LONG ref;
IRowset *rowset;
rowpos_cp cp;
};
2013-08-01 05:48:13 +02:00
static inline rowpos *impl_from_IRowPosition(IRowPosition *iface)
{
return CONTAINING_RECORD(iface, rowpos, IRowPosition_iface);
}
static inline rowpos *impl_from_IConnectionPointContainer(IConnectionPointContainer *iface)
{
return CONTAINING_RECORD(iface, rowpos, IConnectionPointContainer_iface);
}
static inline rowpos_cp *impl_from_IConnectionPoint(IConnectionPoint *iface)
{
return CONTAINING_RECORD(iface, rowpos_cp, IConnectionPoint_iface);
}
2013-08-01 05:48:13 +02:00
static HRESULT WINAPI rowpos_QueryInterface(IRowPosition* iface, REFIID riid, void **obj)
{
rowpos *This = impl_from_IRowPosition(iface);
TRACE("(%p)->(%s, %p)\n", This, debugstr_guid(riid), obj);
*obj = NULL;
if (IsEqualIID(riid, &IID_IUnknown) ||
IsEqualIID(riid, &IID_IRowPosition))
{
*obj = iface;
}
else if (IsEqualIID(riid, &IID_IConnectionPointContainer))
{
*obj = &This->IConnectionPointContainer_iface;
}
2013-08-01 05:48:13 +02:00
else
{
FIXME("interface %s not implemented\n", debugstr_guid(riid));
return E_NOINTERFACE;
}
IRowPosition_AddRef(iface);
return S_OK;
}
static ULONG WINAPI rowpos_AddRef(IRowPosition* iface)
{
rowpos *This = impl_from_IRowPosition(iface);
ULONG ref = InterlockedIncrement(&This->ref);
TRACE("(%p)->(%d)\n", This, ref);
return ref;
}
static ULONG WINAPI rowpos_Release(IRowPosition* iface)
{
rowpos *This = impl_from_IRowPosition(iface);
LONG ref = InterlockedDecrement(&This->ref);
TRACE("(%p)->(%d)\n", This, ref);
if (ref == 0)
{
if (This->rowset) IRowset_Release(This->rowset);
heap_free(This);
}
2013-08-01 05:48:13 +02:00
return ref;
}
static HRESULT WINAPI rowpos_ClearRowPosition(IRowPosition* iface)
{
rowpos *This = impl_from_IRowPosition(iface);
FIXME("(%p): stub\n", This);
return E_NOTIMPL;
}
static HRESULT WINAPI rowpos_GetRowPosition(IRowPosition *iface, HCHAPTER *chapter,
HROW *row, DBPOSITIONFLAGS *flags)
{
rowpos *This = impl_from_IRowPosition(iface);
FIXME("(%p)->(%p %p %p): stub\n", This, chapter, row, flags);
return E_NOTIMPL;
}
static HRESULT WINAPI rowpos_GetRowset(IRowPosition *iface, REFIID riid, IUnknown **rowset)
{
rowpos *This = impl_from_IRowPosition(iface);
FIXME("(%p)->(%s %p): stub\n", This, debugstr_guid(riid), rowset);
return E_NOTIMPL;
}
static HRESULT WINAPI rowpos_Initialize(IRowPosition *iface, IUnknown *rowset)
{
rowpos *This = impl_from_IRowPosition(iface);
TRACE("(%p)->(%p)\n", This, rowset);
if (This->rowset) return DB_E_ALREADYINITIALIZED;
return IUnknown_QueryInterface(rowset, &IID_IRowset, (void**)&This->rowset);
2013-08-01 05:48:13 +02:00
}
static HRESULT WINAPI rowpos_SetRowPosition(IRowPosition *iface, HCHAPTER chapter,
HROW row, DBPOSITIONFLAGS flags)
{
rowpos *This = impl_from_IRowPosition(iface);
FIXME("(%p)->(%lx %lx %d): stub\n", This, chapter, row, flags);
return E_NOTIMPL;
}
static const struct IRowPositionVtbl rowpos_vtbl =
{
rowpos_QueryInterface,
rowpos_AddRef,
rowpos_Release,
rowpos_ClearRowPosition,
rowpos_GetRowPosition,
rowpos_GetRowset,
rowpos_Initialize,
rowpos_SetRowPosition
};
static HRESULT WINAPI cpc_QueryInterface(IConnectionPointContainer *iface, REFIID riid, void **obj)
{
rowpos *This = impl_from_IConnectionPointContainer(iface);
return IRowPosition_QueryInterface(&This->IRowPosition_iface, riid, obj);
}
static ULONG WINAPI cpc_AddRef(IConnectionPointContainer *iface)
{
rowpos *This = impl_from_IConnectionPointContainer(iface);
return IRowPosition_AddRef(&This->IRowPosition_iface);
}
static ULONG WINAPI cpc_Release(IConnectionPointContainer *iface)
{
rowpos *This = impl_from_IConnectionPointContainer(iface);
return IRowPosition_Release(&This->IRowPosition_iface);
}
static HRESULT WINAPI cpc_EnumConnectionPoints(IConnectionPointContainer *iface, IEnumConnectionPoints **enum_points)
{
rowpos *This = impl_from_IConnectionPointContainer(iface);
FIXME("(%p)->(%p): stub\n", This, enum_points);
return E_NOTIMPL;
}
static HRESULT WINAPI cpc_FindConnectionPoint(IConnectionPointContainer *iface, REFIID riid, IConnectionPoint **point)
{
rowpos *This = impl_from_IConnectionPointContainer(iface);
FIXME("(%p)->(%s %p): stub\n", This, debugstr_guid(riid), point);
return E_NOTIMPL;
}
static const struct IConnectionPointContainerVtbl rowpos_cpc_vtbl =
{
cpc_QueryInterface,
cpc_AddRef,
cpc_Release,
cpc_EnumConnectionPoints,
cpc_FindConnectionPoint
};
static HRESULT WINAPI rowpos_cp_QueryInterface(IConnectionPoint *iface, REFIID riid, void **obj)
{
rowpos_cp *This = impl_from_IConnectionPoint(iface);
return IConnectionPointContainer_QueryInterface(&This->container->IConnectionPointContainer_iface, riid, obj);
}
static ULONG WINAPI rowpos_cp_AddRef(IConnectionPoint *iface)
{
rowpos_cp *This = impl_from_IConnectionPoint(iface);
return IConnectionPointContainer_AddRef(&This->container->IConnectionPointContainer_iface);
}
static ULONG WINAPI rowpos_cp_Release(IConnectionPoint *iface)
{
rowpos_cp *This = impl_from_IConnectionPoint(iface);
return IConnectionPointContainer_Release(&This->container->IConnectionPointContainer_iface);
}
static HRESULT WINAPI rowpos_cp_GetConnectionInterface(IConnectionPoint *iface, IID *iid)
{
rowpos_cp *This = impl_from_IConnectionPoint(iface);
TRACE("(%p)->(%p)\n", This, iid);
if (!iid) return E_POINTER;
*iid = IID_IRowPositionChange;
return S_OK;
}
static HRESULT WINAPI rowpos_cp_GetConnectionPointContainer(IConnectionPoint *iface, IConnectionPointContainer **container)
{
rowpos_cp *This = impl_from_IConnectionPoint(iface);
TRACE("(%p)->(%p)\n", This, container);
if (!container) return E_POINTER;
*container = &This->container->IConnectionPointContainer_iface;
IConnectionPointContainer_AddRef(*container);
return S_OK;
}
static HRESULT WINAPI rowpos_cp_Advise(IConnectionPoint *iface, IUnknown *sink, DWORD *cookie)
{
rowpos_cp *This = impl_from_IConnectionPoint(iface);
FIXME("(%p)->(%p %p): stub\n", This, sink, cookie);
return E_NOTIMPL;
}
static HRESULT WINAPI rowpos_cp_Unadvise(IConnectionPoint *iface, DWORD cookie)
{
rowpos_cp *This = impl_from_IConnectionPoint(iface);
FIXME("(%p)->(%d): stub\n", This, cookie);
return E_NOTIMPL;
}
static HRESULT WINAPI rowpos_cp_EnumConnections(IConnectionPoint *iface, IEnumConnections **enum_c)
{
rowpos_cp *This = impl_from_IConnectionPoint(iface);
FIXME("(%p)->(%p): stub\n", This, enum_c);
return E_NOTIMPL;
}
static const struct IConnectionPointVtbl rowpos_cp_vtbl =
{
rowpos_cp_QueryInterface,
rowpos_cp_AddRef,
rowpos_cp_Release,
rowpos_cp_GetConnectionInterface,
rowpos_cp_GetConnectionPointContainer,
rowpos_cp_Advise,
rowpos_cp_Unadvise,
rowpos_cp_EnumConnections
};
static void rowposchange_cp_init(rowpos_cp *cp, rowpos *container)
{
cp->IConnectionPoint_iface.lpVtbl = &rowpos_cp_vtbl;
cp->container = container;
}
2013-08-01 05:48:13 +02:00
HRESULT create_oledb_rowpos(IUnknown *outer, void **obj)
{
rowpos *This;
TRACE("(%p, %p)\n", outer, obj);
*obj = NULL;
if(outer) return CLASS_E_NOAGGREGATION;
This = heap_alloc(sizeof(*This));
2013-08-01 05:48:13 +02:00
if(!This) return E_OUTOFMEMORY;
This->IRowPosition_iface.lpVtbl = &rowpos_vtbl;
This->IConnectionPointContainer_iface.lpVtbl = &rowpos_cpc_vtbl;
2013-08-01 05:48:13 +02:00
This->ref = 1;
This->rowset = NULL;
rowposchange_cp_init(&This->cp, This);
2013-08-01 05:48:13 +02:00
*obj = &This->IRowPosition_iface;
return S_OK;
}