ucb/source/ucp/odma/odma_datasupplier.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*************************************************************************
   3  *
   4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5  *
   6  * Copyright 2000, 2010 Oracle and/or its affiliates.
   7  *
   8  * OpenOffice.org - a multi-platform office productivity suite
   9  *
  10  * This file is part of OpenOffice.org.
  11  *
  12  * OpenOffice.org is free software: you can redistribute it and/or modify
  13  * it under the terms of the GNU Lesser General Public License version 3
  14  * only, as published by the Free Software Foundation.
  15  *
  16  * OpenOffice.org is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19  * GNU Lesser General Public License version 3 for more details
  20  * (a copy is included in the LICENSE file that accompanied this code).
  21  *
  22  * You should have received a copy of the GNU Lesser General Public License
  23  * version 3 along with OpenOffice.org.  If not, see
  24  * <http://www.openoffice.org/license.html>
  25  * for a copy of the LGPLv3 License.
  26  *
  27  ************************************************************************/
  28
  29
  30 #ifdef WNT
  31 #include <windows.h>
  32 #endif
  33 #include <vector>
  34 #include <ucbhelper/contentidentifier.hxx>
  35 #include <ucbhelper/providerhelper.hxx>
  36 #include "odma_datasupplier.hxx"
  37 #include "odma_content.hxx"
  38 #include "odma_contentprops.hxx"
  39 #include "odma_provider.hxx"
  40
  41 using namespace com::sun::star::beans;
  42 using namespace com::sun::star::lang;
  43 using namespace com::sun::star::ucb;
  44 using namespace com::sun::star::uno;
  45 using namespace com::sun::star::sdbc;
  46
  47 using namespace odma;
  48
  49 namespace odma
  50 {
  51
  52 //=========================================================================
  53 //
  54 // struct ResultListEntry.
  55 //
  56 //=========================================================================
  57
  58 struct ResultListEntry
  59 {
  60     ::rtl::OUString                     aId;
  61     Reference< XContentIdentifier >     xId;
  62     Reference< XContent >               xContent;
  63     Reference< XRow >                   xRow;
  64     ::rtl::Reference<ContentProperties> rData;
  65
  66     ResultListEntry( const ::rtl::Reference<ContentProperties>& rEntry ) : rData( rEntry ) {}
  67 };
  68
  69 //=========================================================================
  70 //
  71 // ResultList.
  72 //
  73 //=========================================================================
  74
  75 typedef std::vector< ResultListEntry* > ResultList;
  76
  77 //=========================================================================
  78 //
  79 // struct DataSupplier_Impl.
  80 //
  81 //=========================================================================
  82
  83 struct DataSupplier_Impl
  84 {
  85     osl::Mutex                        m_aMutex;
  86     ResultList                        m_aResults;
  87     rtl::Reference< Content >         m_xContent;
  88     Reference< XMultiServiceFactory > m_xSMgr;
  89 // @@@ The data source and an iterator for it
  90 //  Entry                             m_aFolder;
  91 //  Entry::iterator                   m_aIterator;
  92       sal_Int32                       m_nOpenMode;
  93       sal_Bool                        m_bCountFinal;
  94
  95     DataSupplier_Impl( const Reference< XMultiServiceFactory >& rxSMgr,
  96                        const rtl::Reference< Content >& rContent,
  97                        sal_Int32 nOpenMode )
  98     : m_xContent( rContent ), m_xSMgr( rxSMgr ),
  99 //    m_aFolder( rxSMgr, rContent->getIdentifier()->getContentIdentifier() ),
 100       m_nOpenMode( nOpenMode ), m_bCountFinal( sal_False ) {}
 101     ~DataSupplier_Impl();
 102 };
 103
 104 //=========================================================================
 105 DataSupplier_Impl::~DataSupplier_Impl()
 106 {
 107     ResultList::const_iterator it  = m_aResults.begin();
 108     ResultList::const_iterator end = m_aResults.end();
 109
 110     while ( it != end )
 111     {
 112         delete (*it);
 113         ++it;
 114     }
 115 }
 116
 117 }
 118
 119 //=========================================================================
 120 //=========================================================================
 121 //
 122 // DataSupplier Implementation.
 123 //
 124 //=========================================================================
 125 //=========================================================================
 126
 127 DataSupplier::DataSupplier( const Reference<XMultiServiceFactory >& rxSMgr,
 128                            const rtl::Reference< ::odma::Content >& rContent,
 129                             sal_Int32 nOpenMode )
 130 : m_pImpl( new DataSupplier_Impl( rxSMgr, rContent, nOpenMode ) )
 131 {
 132 }
 133
 134 //=========================================================================
 135 // virtual
 136 DataSupplier::~DataSupplier()
 137 {
 138     delete m_pImpl;
 139 }
 140
 141 //=========================================================================
 142 // virtual
 143 ::rtl::OUString DataSupplier::queryContentIdentifierString( sal_uInt32 nIndex )
 144 {
 145     osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
 146
 147     if ( nIndex < m_pImpl->m_aResults.size() )
 148     {
 149         ::rtl::OUString aId = m_pImpl->m_aResults[ nIndex ]->aId;
 150         if ( aId.getLength() )
 151         {
 152             // Already cached.
 153             return aId;
 154         }
 155     }
 156
 157     if ( getResult( nIndex ) )
 158     {
 159         ::rtl::OUString aId
 160             = m_pImpl->m_xContent->getIdentifier()->getContentIdentifier();
 161
 162         aId += m_pImpl->m_aResults[ nIndex ]->rData->m_sTitle;
 163
 164         m_pImpl->m_aResults[ nIndex ]->aId = aId;
 165         return aId;
 166     }
 167     return ::rtl::OUString();
 168 }
 169
 170 //=========================================================================
 171 // virtual
 172 Reference< XContentIdentifier > DataSupplier::queryContentIdentifier(
 173                                                         sal_uInt32 nIndex )
 174 {
 175     osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
 176
 177     if ( nIndex < m_pImpl->m_aResults.size() )
 178     {
 179         Reference< XContentIdentifier > xId
 180                                 = m_pImpl->m_aResults[ nIndex ]->xId;
 181         if ( xId.is() )
 182         {
 183             // Already cached.
 184             return xId;
 185         }
 186     }
 187
 188     ::rtl::OUString aId = queryContentIdentifierString( nIndex );
 189     if ( aId.getLength() )
 190     {
 191         Reference< XContentIdentifier > xId
 192             = new ucbhelper::ContentIdentifier( aId );
 193         m_pImpl->m_aResults[ nIndex ]->xId = xId;
 194         return xId;
 195     }
 196     return Reference< XContentIdentifier >();
 197 }
 198
 199 //=========================================================================
 200 // virtual
 201 Reference< XContent > DataSupplier::queryContent( sal_uInt32 nIndex )
 202 {
 203     osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
 204
 205     if ( nIndex < m_pImpl->m_aResults.size() )
 206     {
 207         Reference< XContent > xContent
 208                                 = m_pImpl->m_aResults[ nIndex ]->xContent;
 209         if ( xContent.is() )
 210         {
 211             // Already cached.
 212             return xContent;
 213         }
 214     }
 215
 216     Reference< XContentIdentifier > xId = queryContentIdentifier( nIndex );
 217     if ( xId.is() )
 218     {
 219         try
 220         {
 221             Reference< XContent > xContent
 222                 = m_pImpl->m_xContent->getProvider()->queryContent( xId );
 223             m_pImpl->m_aResults[ nIndex ]->xContent = xContent;
 224             return xContent;
 225
 226         }
 227         catch ( IllegalIdentifierException& )
 228         {
 229         }
 230     }
 231     return Reference< XContent >();
 232 }
 233
 234 //=========================================================================
 235 // virtual
 236 sal_Bool DataSupplier::getResult( sal_uInt32 nIndex )
 237 {
 238     osl::ClearableGuard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
 239
 240     if ( m_pImpl->m_aResults.size() > nIndex )
 241     {
 242         // Result already present.
 243         return sal_True;
 244     }
 245
 246     // Result not (yet) present.
 247
 248     if ( m_pImpl->m_bCountFinal )
 249         return sal_False;
 250
 251     // Try to obtain result...
 252
 253     sal_uInt32 nOldCount = m_pImpl->m_aResults.size();
 254     sal_Bool bFound = sal_False;
 255 //  sal_uInt32 nPos = nOldCount;
 256
 257     // @@@ Obtain data and put it into result list...
 258 /*
 259     while ( m_pImpl->m_aFolder.next( m_pImpl->m_aIterator ) )
 260     {
 261         m_pImpl->m_aResults.push_back(
 262                         new ResultListEntry( *m_pImpl->m_aIterator ) );
 263
 264         if ( nPos == nIndex )
 265         {
 266             // Result obtained.
 267             bFound = sal_True;
 268             break;
 269         }
 270
 271         nPos++;
 272     }
 273 */
 274     // now query for all documents in the DMS
 275     OSL_ENSURE(ContentProvider::getHandle(),"No Handle!");
 276     sal_Char* pQueryId      = new sal_Char[ODM_QUERYID_MAX];
 277     sal_Char* lpszDMSList   = new sal_Char[ODM_DMSID_MAX];
 278
 279     ODMSTATUS odm = NODMGetDMS(ODMA_ODMA_REGNAME, lpszDMSList);
 280     lpszDMSList[strlen(lpszDMSList)+1] = '\0';
 281
 282     const char sQuery[] = "SELECT ODM_DOCID_LATEST, ODM_NAME";
 283
 284     DWORD dwFlags = ODM_SPECIFIC;
 285     odm = NODMQueryExecute(ContentProvider::getHandle(), sQuery, dwFlags, lpszDMSList, pQueryId );
 286     if(odm != ODM_SUCCESS) {
 287         delete[] pQueryId;
 288         delete[] lpszDMSList;
 289         return sal_False;
 290     }
 291
 292     sal_uInt16 nCount       = 10;
 293     sal_uInt16 nMaxCount    = 10;
 294     sal_Char* lpszDocId     = new sal_Char[ODM_DOCID_MAX * nMaxCount];
 295     sal_Char* lpszDocName   = new sal_Char[ODM_NAME_MAX * nMaxCount];
 296
 297
 298     ::rtl::OUString sContentType(RTL_CONSTASCII_USTRINGPARAM(ODMA_CONTENT_TYPE));
 299     sal_uInt32 nCurrentCount = 0;
 300     do
 301     {
 302         if(nCount >= nMaxCount)
 303         {
 304             nCount = nMaxCount;
 305             odm = NODMQueryGetResults(ContentProvider::getHandle(), pQueryId,lpszDocId, lpszDocName, ODM_NAME_MAX, (WORD*)&nCount);
 306             nCurrentCount += nCount;
 307         }
 308         if(odm == ODM_SUCCESS && nIndex < nCurrentCount)
 309         {
 310             bFound = sal_True;
 311             for(sal_uInt16 i = 0; i < nCount; ++i)
 312             {
 313                 ::rtl::Reference<ContentProperties> rProps = new ContentProperties();
 314                 rProps->m_sDocumentId   = ::rtl::OString(&lpszDocId[ODM_DOCID_MAX*i]);
 315                 rProps->m_sContentType  = sContentType;
 316                 m_pImpl->m_xContent->getContentProvider()->append(rProps);
 317                 m_pImpl->m_aResults.push_back( new ResultListEntry(rProps));
 318             }
 319         }
 320     }
 321     while(nCount > nMaxCount);
 322
 323
 324     // now close the query
 325     odm = NODMQueryClose(ContentProvider::getHandle(), pQueryId);
 326
 327     delete [] lpszDMSList;
 328     delete [] pQueryId;
 329     delete [] lpszDocId;
 330     delete [] lpszDocName;
 331
 332     if ( !bFound )
 333         m_pImpl->m_bCountFinal = sal_True;
 334
 335     rtl::Reference< ucbhelper::ResultSet > xResultSet = getResultSet();
 336     if ( xResultSet.is() )
 337     {
 338         // Callbacks follow!
 339         aGuard.clear();
 340
 341         if ( nOldCount < m_pImpl->m_aResults.size() )
 342             xResultSet->rowCountChanged(
 343                                     nOldCount, m_pImpl->m_aResults.size() );
 344
 345         if ( m_pImpl->m_bCountFinal )
 346             xResultSet->rowCountFinal();
 347     }
 348
 349     return bFound;
 350 }
 351
 352 //=========================================================================
 353 // virtual
 354 sal_uInt32 DataSupplier::totalCount()
 355 {
 356     osl::ClearableGuard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
 357
 358     if ( m_pImpl->m_bCountFinal )
 359         return m_pImpl->m_aResults.size();
 360
 361     sal_uInt32 nOldCount = m_pImpl->m_aResults.size();
 362
 363     // @@@ Obtain data and put it into result list...
 364 /*
 365     while ( m_pImpl->m_aFolder.next( m_pImpl->m_aIterator ) )
 366         m_pImpl->m_aResults.push_back(
 367                         new ResultListEntry( *m_pImpl->m_aIterator ) );
 368 */
 369     m_pImpl->m_bCountFinal = sal_True;
 370
 371     rtl::Reference< ucbhelper::ResultSet > xResultSet = getResultSet();
 372     if ( xResultSet.is() )
 373     {
 374         // Callbacks follow!
 375         aGuard.clear();
 376
 377         if ( nOldCount < m_pImpl->m_aResults.size() )
 378             xResultSet->rowCountChanged(
 379                                     nOldCount, m_pImpl->m_aResults.size() );
 380
 381         xResultSet->rowCountFinal();
 382     }
 383
 384     return m_pImpl->m_aResults.size();
 385 }
 386
 387 //=========================================================================
 388 // virtual
 389 sal_uInt32 DataSupplier::currentCount()
 390 {
 391     return m_pImpl->m_aResults.size();
 392 }
 393
 394 //=========================================================================
 395 // virtual
 396 sal_Bool DataSupplier::isCountFinal()
 397 {
 398     return m_pImpl->m_bCountFinal;
 399 }
 400
 401 //=========================================================================
 402 // virtual
 403 Reference< XRow > DataSupplier::queryPropertyValues( sal_uInt32 nIndex  )
 404 {
 405     osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
 406
 407     if ( nIndex < m_pImpl->m_aResults.size() )
 408     {
 409         Reference< XRow > xRow = m_pImpl->m_aResults[ nIndex ]->xRow;
 410         if ( xRow.is() )
 411         {
 412             // Already cached.
 413             return xRow;
 414         }
 415     }
 416
 417     if ( getResult( nIndex ) )
 418     {
 419         Reference< XRow > xRow = Content::getPropertyValues(
 420                                     m_pImpl->m_xSMgr,
 421                                     getResultSet()->getProperties(),
 422                                     m_pImpl->m_aResults[ nIndex ]->rData,
 423                                     m_pImpl->m_xContent->getProvider(),
 424                                     queryContentIdentifierString( nIndex ) );
 425         m_pImpl->m_aResults[ nIndex ]->xRow = xRow;
 426         return xRow;
 427     }
 428
 429     return Reference< XRow >();
 430 }
 431
 432 //=========================================================================
 433 // virtual
 434 void DataSupplier::releasePropertyValues( sal_uInt32 nIndex )
 435 {
 436     osl::Guard< osl::Mutex > aGuard( m_pImpl->m_aMutex );
 437
 438     if ( nIndex < m_pImpl->m_aResults.size() )
 439         m_pImpl->m_aResults[ nIndex ]->xRow = Reference< XRow >();
 440 }
 441
 442 //=========================================================================
 443 // virtual
 444 void DataSupplier::close()
 445 {
 446 }
 447
 448 //=========================================================================
 449 // virtual
 450 void DataSupplier::validate()
 451     throw( ResultSetException )
 452 {
 453 }
 454
 455 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */