dbaccess/source/core/api/BookmarkSet.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: BookmarkSet.cxx,v $
  10  * $Revision: 1.21 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_dbaccess.hxx"
  33 #ifndef DBACCESS_CORE_API_BOOKMARKSET_HXX
  34 #include "BookmarkSet.hxx"
  35 #endif
  36 #ifndef _DBA_CORE_RESOURCE_HXX_
  37 #include "core_resource.hxx"
  38 #endif
  39 #ifndef _DBA_CORE_RESOURCE_HRC_
  40 #include "core_resource.hrc"
  41 #endif
  42 #ifndef _COM_SUN_STAR_SDBC_XRESULTSETUPDATE_HPP_
  43 #include <com/sun/star/sdbc/XResultSetUpdate.hpp>
  44 #endif
  45 #ifndef _DBHELPER_DBEXCEPTION_HXX_
  46 #include <connectivity/dbexception.hxx>
  47 #endif
  48 #include <rtl/logfile.hxx>
  49
  50 #include <limits>
  51
  52 using namespace dbaccess;
  53 using namespace ::connectivity;
  54 using namespace ::dbtools;
  55 using namespace ::com::sun::star::uno;
  56 using namespace ::com::sun::star::beans;
  57 using namespace ::com::sun::star::sdbc;
  58 //      using namespace ::com::sun::star::sdb;
  59 using namespace ::com::sun::star::sdbcx;
  60 using namespace ::com::sun::star::container;
  61 using namespace ::com::sun::star::lang;
  62 //      using namespace ::cppu;
  63 using namespace ::osl;
  64
  65 void OBookmarkSet::construct(const Reference< XResultSet>& _xDriverSet)
  66 {
  67     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::construct" );
  68     OCacheSet::construct(_xDriverSet);
  69     m_xRowLocate.set(_xDriverSet,UNO_QUERY);
  70 }
  71 // -----------------------------------------------------------------------------
  72 Any SAL_CALL OBookmarkSet::getBookmark() throw(SQLException, RuntimeException)
  73 {
  74     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::getBookmark" );
  75     return m_xRowLocate->getBookmark();
  76 }
  77 // -------------------------------------------------------------------------
  78 sal_Bool SAL_CALL OBookmarkSet::moveToBookmark( const Any& bookmark ) throw(SQLException, RuntimeException)
  79 {
  80     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::moveToBookmark" );
  81     return m_xRowLocate->moveToBookmark(bookmark);
  82 }
  83 // -------------------------------------------------------------------------
  84 sal_Bool SAL_CALL OBookmarkSet::moveRelativeToBookmark( const Any& bookmark, sal_Int32 rows ) throw(SQLException, RuntimeException)
  85 {
  86     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::moveRelativeToBookmark" );
  87     return m_xRowLocate->moveRelativeToBookmark(bookmark,rows);
  88 }
  89 // -------------------------------------------------------------------------
  90 sal_Int32 SAL_CALL OBookmarkSet::compareBookmarks( const Any& _first, const Any& _second ) throw(SQLException, RuntimeException)
  91 {
  92     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::compareBookmarks" );
  93     return m_xRowLocate->compareBookmarks(_first,_second);
  94 }
  95 // -------------------------------------------------------------------------
  96 sal_Bool SAL_CALL OBookmarkSet::hasOrderedBookmarks(  ) throw(SQLException, RuntimeException)
  97 {
  98     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::hasOrderedBookmarks" );
  99     return m_xRowLocate->hasOrderedBookmarks();
 100 }
 101 // -------------------------------------------------------------------------
 102 sal_Int32 SAL_CALL OBookmarkSet::hashBookmark( const Any& bookmark ) throw(SQLException, RuntimeException)
 103 {
 104     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::hashBookmark" );
 105     return m_xRowLocate->hashBookmark(bookmark);
 106 }
 107 // -------------------------------------------------------------------------
 108 // ::com::sun::star::sdbcx::XDeleteRows
 109 Sequence< sal_Int32 > SAL_CALL OBookmarkSet::deleteRows( const Sequence< Any >& rows ,const connectivity::OSQLTable& /*_xTable*/) throw(SQLException, RuntimeException)
 110 {
 111     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::deleteRows" );
 112     Reference< ::com::sun::star::sdbcx::XDeleteRows> xDeleteRow(m_xRowLocate,UNO_QUERY);
 113     if(xDeleteRow.is())
 114     {
 115         return xDeleteRow->deleteRows(rows);
 116     }
 117     return Sequence< sal_Int32 >();
 118 }
 119 // -------------------------------------------------------------------------
 120 void SAL_CALL OBookmarkSet::insertRow( const ORowSetRow& _rInsertRow,const connectivity::OSQLTable& /*_xTable*/ ) throw(SQLException, RuntimeException)
 121 {
 122     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::insertRow" );
 123     Reference<XRowUpdate> xUpdRow(m_xRowLocate,UNO_QUERY);
 124     if(!xUpdRow.is())
 125         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_XROWUPDATE ), SQL_GENERAL_ERROR, *this );
 126
 127     Reference<XResultSetUpdate> xUpd(m_xRowLocate,UNO_QUERY);
 128     if(xUpd.is())
 129     {
 130         xUpd->moveToInsertRow();
 131         sal_Int32 i = 1;
 132         connectivity::ORowVector< ORowSetValue > ::Vector::iterator aEnd = _rInsertRow->get().end();
 133         for(connectivity::ORowVector< ORowSetValue > ::Vector::iterator aIter = _rInsertRow->get().begin()+1;aIter != aEnd;++aIter,++i)
 134         {
 135             aIter->setSigned(m_aSignedFlags[i-1]);
 136             updateColumn(i,xUpdRow,*aIter);
 137         }
 138         xUpd->insertRow();
 139         (*_rInsertRow->get().begin()) = m_xRowLocate->getBookmark();
 140     }
 141     else
 142         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_XRESULTSETUPDATE ), SQL_GENERAL_ERROR, *this );
 143 }
 144 // -------------------------------------------------------------------------
 145 void SAL_CALL OBookmarkSet::updateRow(const ORowSetRow& _rInsertRow ,const ORowSetRow& _rOrginalRow,const connectivity::OSQLTable& /*_xTable*/  ) throw(SQLException, RuntimeException)
 146 {
 147     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::updateRow" );
 148     //  OCacheSet::updateRow( _rInsertRow,_rOrginalRow,_xTable);
 149     Reference<XRowUpdate> xUpdRow(m_xRowLocate,UNO_QUERY);
 150     if(!xUpdRow.is())
 151         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_XROWUPDATE ), SQL_GENERAL_ERROR, *this );
 152
 153     sal_Int32 i = 1;
 154     connectivity::ORowVector< ORowSetValue > ::Vector::const_iterator aOrgIter = _rOrginalRow->get().begin()+1;
 155     connectivity::ORowVector< ORowSetValue > ::Vector::iterator aEnd = _rInsertRow->get().end();
 156     for(connectivity::ORowVector< ORowSetValue > ::Vector::iterator aIter = _rInsertRow->get().begin()+1;aIter != aEnd;++aIter,++i,++aOrgIter)
 157     {
 158         aIter->setSigned(aOrgIter->isSigned());
 159         updateColumn(i,xUpdRow,*aIter);
 160     }
 161
 162
 163     Reference<XResultSetUpdate> xUpd(m_xRowLocate,UNO_QUERY);
 164     if(xUpd.is())
 165         xUpd->updateRow();
 166     else
 167         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_XRESULTSETUPDATE ), SQL_GENERAL_ERROR, *this );
 168 }
 169 // -------------------------------------------------------------------------
 170 void SAL_CALL OBookmarkSet::deleteRow(const ORowSetRow& /*_rDeleteRow*/ ,const connectivity::OSQLTable& /*_xTable*/  ) throw(SQLException, RuntimeException)
 171 {
 172     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::deleteRow" );
 173     Reference<XResultSetUpdate> xUpd(m_xRowLocate,UNO_QUERY);
 174
 175     xUpd->deleteRow();
 176 }
 177 // -------------------------------------------------------------------------
 178 void SAL_CALL OBookmarkSet::cancelRowUpdates(  ) throw(SQLException, RuntimeException)
 179 {
 180     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::cancelRowUpdates" );
 181 }
 182 // -------------------------------------------------------------------------
 183 void SAL_CALL OBookmarkSet::moveToInsertRow(  ) throw(SQLException, RuntimeException)
 184 {
 185     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::moveToInsertRow" );
 186     Reference<XResultSetUpdate> xUpd(m_xRowLocate,UNO_QUERY);
 187     if(xUpd.is())
 188         xUpd->moveToInsertRow();
 189 }
 190 // -------------------------------------------------------------------------
 191 void SAL_CALL OBookmarkSet::moveToCurrentRow(  ) throw(SQLException, RuntimeException)
 192 {
 193     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::moveToCurrentRow" );
 194 }
 195 // -------------------------------------------------------------------------
 196 void OBookmarkSet::fillValueRow(ORowSetRow& _rRow,sal_Int32 _nPosition)
 197 {
 198     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::fillValueRow" );
 199     OCacheSet::fillValueRow(_rRow,_nPosition);
 200 }
 201 // -------------------------------------------------------------------------
 202 void OBookmarkSet::updateColumn(sal_Int32 nPos,Reference< XRowUpdate > _xParameter,const ORowSetValue& _rValue)
 203 {
 204     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::updateColumn" );
 205     if(_rValue.isBound() && _rValue.isModified())
 206     {
 207         if(_rValue.isNull())
 208             _xParameter->updateNull(nPos);
 209         else
 210         {
 211
 212             switch(_rValue.getTypeKind())
 213             {
 214                 case DataType::DECIMAL:
 215                 case DataType::NUMERIC:
 216                     _xParameter->updateNumericObject(nPos,_rValue.makeAny(),m_xSetMetaData->getScale(nPos));
 217                     break;
 218                 case DataType::CHAR:
 219                 case DataType::VARCHAR:
 220                 //case DataType::DECIMAL:
 221                 //case DataType::NUMERIC:
 222                     _xParameter->updateString(nPos,_rValue);
 223                     break;
 224                 case DataType::BIGINT:
 225                     if ( _rValue.isSigned() )
 226                         _xParameter->updateLong(nPos,_rValue);
 227                     else
 228                         _xParameter->updateString(nPos,_rValue);
 229                     break;
 230                 case DataType::BIT:
 231                 case DataType::BOOLEAN:
 232                     _xParameter->updateBoolean(nPos,_rValue);
 233                     break;
 234                 case DataType::TINYINT:
 235                     if ( _rValue.isSigned() )
 236                         _xParameter->updateByte(nPos,_rValue);
 237                     else
 238                         _xParameter->updateShort(nPos,_rValue);
 239                     break;
 240                 case DataType::SMALLINT:
 241                     if ( _rValue.isSigned() )
 242                         _xParameter->updateShort(nPos,_rValue);
 243                     else
 244                         _xParameter->updateInt(nPos,_rValue);
 245                     break;
 246                 case DataType::INTEGER:
 247                     if ( _rValue.isSigned() )
 248                         _xParameter->updateInt(nPos,_rValue);
 249                     else
 250                         _xParameter->updateLong(nPos,_rValue);
 251                     break;
 252                 case DataType::FLOAT:
 253                     _xParameter->updateFloat(nPos,_rValue);
 254                     break;
 255                 case DataType::DOUBLE:
 256                 case DataType::REAL:
 257                     _xParameter->updateDouble(nPos,_rValue);
 258                     break;
 259                 case DataType::DATE:
 260                     _xParameter->updateDate(nPos,_rValue);
 261                     break;
 262                 case DataType::TIME:
 263                     _xParameter->updateTime(nPos,_rValue);
 264                     break;
 265                 case DataType::TIMESTAMP:
 266                     _xParameter->updateTimestamp(nPos,_rValue);
 267                     break;
 268                 case DataType::BINARY:
 269                 case DataType::VARBINARY:
 270                 case DataType::LONGVARBINARY:
 271                     _xParameter->updateBytes(nPos,_rValue);
 272                     break;
 273
 274             }
 275         }
 276     }
 277 }
 278