dbaccess/source/core/api/BookmarkSet.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include "BookmarkSet.hxx"
  21 #include "core_resource.hxx"
  22 #include "core_resource.hrc"
  23 #include <com/sun/star/sdbc/XResultSetUpdate.hpp>
  24 #include <connectivity/dbexception.hxx>
  25 #include <rtl/logfile.hxx>
  26
  27 #include <limits>
  28
  29 using namespace dbaccess;
  30 using namespace ::connectivity;
  31 using namespace ::dbtools;
  32 using namespace ::com::sun::star::uno;
  33 using namespace ::com::sun::star::beans;
  34 using namespace ::com::sun::star::sdbc;
  35 using namespace ::com::sun::star::sdbcx;
  36 using namespace ::com::sun::star::container;
  37 using namespace ::com::sun::star::lang;
  38 using namespace ::osl;
  39
  40 void OBookmarkSet::construct(const Reference< XResultSet>& _xDriverSet,const ::rtl::OUString& i_sRowSetFilter)
  41 {
  42     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::construct" );
  43     OCacheSet::construct(_xDriverSet,i_sRowSetFilter);
  44     m_xRowLocate.set(_xDriverSet,UNO_QUERY);
  45 }
  46
  47 Any SAL_CALL OBookmarkSet::getBookmark() throw(SQLException, RuntimeException)
  48 {
  49     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::getBookmark" );
  50     return m_xRowLocate->getBookmark();
  51 }
  52
  53 sal_Bool SAL_CALL OBookmarkSet::moveToBookmark( const Any& bookmark ) throw(SQLException, RuntimeException)
  54 {
  55     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::moveToBookmark" );
  56     return m_xRowLocate->moveToBookmark(bookmark);
  57 }
  58
  59 sal_Bool SAL_CALL OBookmarkSet::moveRelativeToBookmark( const Any& bookmark, sal_Int32 rows ) throw(SQLException, RuntimeException)
  60 {
  61     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::moveRelativeToBookmark" );
  62     return m_xRowLocate->moveRelativeToBookmark(bookmark,rows);
  63 }
  64
  65 sal_Int32 SAL_CALL OBookmarkSet::compareBookmarks( const Any& _first, const Any& _second ) throw(SQLException, RuntimeException)
  66 {
  67     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::compareBookmarks" );
  68     return m_xRowLocate->compareBookmarks(_first,_second);
  69 }
  70
  71 sal_Bool SAL_CALL OBookmarkSet::hasOrderedBookmarks(  ) throw(SQLException, RuntimeException)
  72 {
  73     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::hasOrderedBookmarks" );
  74     return m_xRowLocate->hasOrderedBookmarks();
  75 }
  76
  77 sal_Int32 SAL_CALL OBookmarkSet::hashBookmark( const Any& bookmark ) throw(SQLException, RuntimeException)
  78 {
  79     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::hashBookmark" );
  80     return m_xRowLocate->hashBookmark(bookmark);
  81 }
  82
  83 // ::com::sun::star::sdbcx::XDeleteRows
  84 Sequence< sal_Int32 > SAL_CALL OBookmarkSet::deleteRows( const Sequence< Any >& rows ,const connectivity::OSQLTable& /*_xTable*/) throw(SQLException, RuntimeException)
  85 {
  86     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::deleteRows" );
  87     Reference< ::com::sun::star::sdbcx::XDeleteRows> xDeleteRow(m_xRowLocate,UNO_QUERY);
  88     if(xDeleteRow.is())
  89     {
  90         return xDeleteRow->deleteRows(rows);
  91     }
  92     return Sequence< sal_Int32 >();
  93 }
  94
  95 void SAL_CALL OBookmarkSet::insertRow( const ORowSetRow& _rInsertRow,const connectivity::OSQLTable& /*_xTable*/ ) throw(SQLException, RuntimeException)
  96 {
  97     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::insertRow" );
  98     Reference<XRowUpdate> xUpdRow(m_xRowLocate,UNO_QUERY);
  99     if(!xUpdRow.is())
 100         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_XROWUPDATE ), SQL_GENERAL_ERROR, *this );
 101
 102     Reference<XResultSetUpdate> xUpd(m_xRowLocate,UNO_QUERY);
 103     if(xUpd.is())
 104     {
 105         xUpd->moveToInsertRow();
 106         sal_Int32 i = 1;
 107         connectivity::ORowVector< ORowSetValue > ::Vector::iterator aEnd = _rInsertRow->get().end();
 108         for(connectivity::ORowVector< ORowSetValue > ::Vector::iterator aIter = _rInsertRow->get().begin()+1;aIter != aEnd;++aIter,++i)
 109         {
 110             aIter->setSigned(m_aSignedFlags[i-1]);
 111             updateColumn(i,xUpdRow,*aIter);
 112         }
 113         xUpd->insertRow();
 114         (*_rInsertRow->get().begin()) = m_xRowLocate->getBookmark();
 115     }
 116     else
 117         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_XRESULTSETUPDATE ), SQL_GENERAL_ERROR, *this );
 118 }
 119
 120 void SAL_CALL OBookmarkSet::updateRow(const ORowSetRow& _rInsertRow ,const ORowSetRow& _rOrginalRow,const connectivity::OSQLTable& /*_xTable*/  ) throw(SQLException, RuntimeException)
 121 {
 122     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::updateRow" );
 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     sal_Int32 i = 1;
 128     connectivity::ORowVector< ORowSetValue > ::Vector::const_iterator aOrgIter = _rOrginalRow->get().begin()+1;
 129     connectivity::ORowVector< ORowSetValue > ::Vector::iterator aEnd = _rInsertRow->get().end();
 130     for(connectivity::ORowVector< ORowSetValue > ::Vector::iterator aIter = _rInsertRow->get().begin()+1;aIter != aEnd;++aIter,++i,++aOrgIter)
 131     {
 132         aIter->setSigned(aOrgIter->isSigned());
 133         updateColumn(i,xUpdRow,*aIter);
 134     }
 135
 136
 137     Reference<XResultSetUpdate> xUpd(m_xRowLocate,UNO_QUERY);
 138     if(xUpd.is())
 139         xUpd->updateRow();
 140     else
 141         ::dbtools::throwSQLException( DBACORE_RESSTRING( RID_STR_NO_XRESULTSETUPDATE ), SQL_GENERAL_ERROR, *this );
 142 }
 143
 144 void SAL_CALL OBookmarkSet::deleteRow(const ORowSetRow& /*_rDeleteRow*/ ,const connectivity::OSQLTable& /*_xTable*/  ) throw(SQLException, RuntimeException)
 145 {
 146     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::deleteRow" );
 147     Reference<XResultSetUpdate> xUpd(m_xRowLocate,UNO_QUERY);
 148
 149     xUpd->deleteRow();
 150 }
 151
 152 void SAL_CALL OBookmarkSet::cancelRowUpdates(  ) throw(SQLException, RuntimeException)
 153 {
 154     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::cancelRowUpdates" );
 155 }
 156
 157 void SAL_CALL OBookmarkSet::moveToInsertRow(  ) throw(SQLException, RuntimeException)
 158 {
 159     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::moveToInsertRow" );
 160     Reference<XResultSetUpdate> xUpd(m_xRowLocate,UNO_QUERY);
 161     if(xUpd.is())
 162         xUpd->moveToInsertRow();
 163 }
 164
 165 void SAL_CALL OBookmarkSet::moveToCurrentRow(  ) throw(SQLException, RuntimeException)
 166 {
 167     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::moveToCurrentRow" );
 168 }
 169
 170 void OBookmarkSet::fillValueRow(ORowSetRow& _rRow,sal_Int32 _nPosition)
 171 {
 172     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::fillValueRow" );
 173     OCacheSet::fillValueRow(_rRow,_nPosition);
 174 }
 175
 176 void OBookmarkSet::updateColumn(sal_Int32 nPos,Reference< XRowUpdate > _xParameter,const ORowSetValue& _rValue)
 177 {
 178     RTL_LOGFILE_CONTEXT_AUTHOR( aLogger, "dbaccess", "Ocke.Janssen@sun.com", "OBookmarkSet::updateColumn" );
 179     if(_rValue.isBound() && _rValue.isModified())
 180     {
 181         if(_rValue.isNull())
 182             _xParameter->updateNull(nPos);
 183         else
 184         {
 185
 186             switch(_rValue.getTypeKind())
 187             {
 188                 case DataType::DECIMAL:
 189                 case DataType::NUMERIC:
 190                     _xParameter->updateNumericObject(nPos,_rValue.makeAny(),m_xSetMetaData->getScale(nPos));
 191                     break;
 192                 case DataType::CHAR:
 193                 case DataType::VARCHAR:
 194                     _xParameter->updateString(nPos,_rValue);
 195                     break;
 196                 case DataType::BIGINT:
 197                     if ( _rValue.isSigned() )
 198                         _xParameter->updateLong(nPos,_rValue);
 199                     else
 200                         _xParameter->updateString(nPos,_rValue);
 201                     break;
 202                 case DataType::BIT:
 203                 case DataType::BOOLEAN:
 204                     _xParameter->updateBoolean(nPos,_rValue);
 205                     break;
 206                 case DataType::TINYINT:
 207                     if ( _rValue.isSigned() )
 208                         _xParameter->updateByte(nPos,_rValue);
 209                     else
 210                         _xParameter->updateShort(nPos,_rValue);
 211                     break;
 212                 case DataType::SMALLINT:
 213                     if ( _rValue.isSigned() )
 214                         _xParameter->updateShort(nPos,_rValue);
 215                     else
 216                         _xParameter->updateInt(nPos,_rValue);
 217                     break;
 218                 case DataType::INTEGER:
 219                     if ( _rValue.isSigned() )
 220                         _xParameter->updateInt(nPos,_rValue);
 221                     else
 222                         _xParameter->updateLong(nPos,_rValue);
 223                     break;
 224                 case DataType::FLOAT:
 225                     _xParameter->updateFloat(nPos,_rValue);
 226                     break;
 227                 case DataType::DOUBLE:
 228                 case DataType::REAL:
 229                     _xParameter->updateDouble(nPos,_rValue);
 230                     break;
 231                 case DataType::DATE:
 232                     _xParameter->updateDate(nPos,_rValue);
 233                     break;
 234                 case DataType::TIME:
 235                     _xParameter->updateTime(nPos,_rValue);
 236                     break;
 237                 case DataType::TIMESTAMP:
 238                     _xParameter->updateTimestamp(nPos,_rValue);
 239                     break;
 240                 case DataType::BINARY:
 241                 case DataType::VARBINARY:
 242                 case DataType::LONGVARBINARY:
 243                     _xParameter->updateBytes(nPos,_rValue);
 244                     break;
 245                 case DataType::BLOB:
 246                 case DataType::CLOB:
 247                     _xParameter->updateObject(nPos,_rValue.getAny());
 248                     break;
 249             }
 250         }
 251     }
 252 }
 253 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */