/************************************************************** * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. * *************************************************************/ // MARKER(update_precomp.py): autogen include statement, do not remove #include "precompiled_connectivity.hxx" #include #include #include "connectivity/dbexception.hxx" #include "ado/Awrapado.hxx" #include "ado/adoimp.hxx" #include #include using namespace connectivity::ado; using namespace com::sun::star::uno; using namespace com::sun::star::sdbc; using namespace com::sun::star::sdbcx; #define MYADOID(l) {l, 0,0x10,0x80,0,0,0xAA,0,0x6D,0x2E,0xA4}; const CLSID ADOS::CLSID_ADOCONNECTION_21 = MYADOID(0x00000514); const IID ADOS::IID_ADOCONNECTION_21 = MYADOID(0x00000550); const CLSID ADOS::CLSID_ADOCOMMAND_21 = MYADOID(0x00000507); const IID ADOS::IID_ADOCOMMAND_21 = MYADOID(0x0000054E); const CLSID ADOS::CLSID_ADORECORDSET_21 = MYADOID(0x00000535); const IID ADOS::IID_ADORECORDSET_21 = MYADOID(0x0000054F); const CLSID ADOS::CLSID_ADOCATALOG_25 = MYADOID(0x00000602); const IID ADOS::IID_ADOCATALOG_25 = MYADOID(0x00000603); const CLSID ADOS::CLSID_ADOINDEX_25 = MYADOID(0x0000061E); const IID ADOS::IID_ADOINDEX_25 = MYADOID(0x0000061F); const CLSID ADOS::CLSID_ADOTABLE_25 = MYADOID(0x00000609); const IID ADOS::IID_ADOTABLE_25 = MYADOID(0x00000610); const CLSID ADOS::CLSID_ADOKEY_25 = MYADOID(0x00000621); const IID ADOS::IID_ADOKEY_25 = MYADOID(0x00000622); const CLSID ADOS::CLSID_ADOCOLUMN_25 = MYADOID(0x0000061B); const IID ADOS::IID_ADOCOLUMN_25 = MYADOID(0x0000061C); const CLSID ADOS::CLSID_ADOGROUP_25 = MYADOID(0x00000615); const IID ADOS::IID_ADOGROUP_25 = MYADOID(0x00000616); const CLSID ADOS::CLSID_ADOUSER_25 = MYADOID(0x00000618); const IID ADOS::IID_ADOUSER_25 = MYADOID(0x00000619); const CLSID ADOS::CLSID_ADOVIEW_25 = MYADOID(0x00000612); const IID ADOS::IID_ADOVIEW_25 = MYADOID(0x00000613); OLEString& ADOS::GetKeyStr() { static OLEString sKeyStr(::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("gxwaezucfyqpwjgqbcmtsncuhwsnyhiohwxz"))); return sKeyStr; } // ------------------------------------------------------------------------- sal_Int32 ADOS::MapADOType2Jdbc(DataTypeEnum eType) { sal_Int32 nType = DataType::VARCHAR;; switch (eType) { case adUnsignedSmallInt: case adSmallInt: nType = DataType::SMALLINT; break; case adUnsignedInt: case adInteger: nType = DataType::INTEGER; break; case adUnsignedBigInt: case adBigInt: nType = DataType::BIGINT; break; case adSingle: nType = DataType::FLOAT; break; case adDouble: nType = DataType::DOUBLE; break; case adCurrency: nType = DataType::DOUBLE; break; case adVarNumeric: case adNumeric: nType = DataType::NUMERIC; break; case adDecimal: nType = DataType::DECIMAL; break; case adDBDate: nType = DataType::DATE; break; case adDBTime: nType = DataType::TIME; break; case adDate: case adDBTimeStamp: nType = DataType::TIMESTAMP; break; case adBoolean: nType = DataType::BOOLEAN; break; // case adArray: nType = DataType::ARRAY; break; case adBinary: nType = DataType::BINARY; break; case adGUID: nType = DataType::OBJECT; break; case adBSTR: case adVarWChar: case adWChar: case adVarChar: nType = DataType::VARCHAR; break; case adLongVarWChar: case adLongVarChar: nType = DataType::LONGVARCHAR; break; case adVarBinary: nType = DataType::VARBINARY; break; case adLongVarBinary: nType = DataType::LONGVARBINARY;break; case adChar: nType = DataType::CHAR; break; case adUnsignedTinyInt: case adTinyInt: nType = DataType::TINYINT; break; case adEmpty: nType = DataType::SQLNULL; break; case adUserDefined: case adPropVariant: case adFileTime: case adChapter: case adIDispatch: case adIUnknown: case adError: case adVariant: nType = DataType::OTHER; break; default: OSL_ENSURE(0,"MapADOType2Jdbc: Unknown Type!"); ; } return nType; } // ------------------------------------------------------------------------- DataTypeEnum ADOS::MapJdbc2ADOType(sal_Int32 _nType,sal_Int32 _nJetEngine) { switch (_nType) { case DataType::SMALLINT: return adSmallInt; break; case DataType::INTEGER: return adInteger; break; case DataType::BIGINT: return adBigInt; break; case DataType::FLOAT: return adSingle; break; case DataType::DOUBLE: return adDouble; break; case DataType::NUMERIC: return adNumeric; break; case DataType::DECIMAL: return adDecimal; break; case DataType::DATE: return isJetEngine(_nJetEngine) ? adDate : adDBDate; break; case DataType::TIME: return adDBTime; break; case DataType::TIMESTAMP: return isJetEngine(_nJetEngine) ? adDate : adDBTimeStamp; break; case DataType::BOOLEAN: case DataType::BIT: return adBoolean; break; case DataType::BINARY: return adBinary; break; case DataType::VARCHAR: return adVarWChar; break; case DataType::CLOB: case DataType::LONGVARCHAR: return adLongVarWChar; break; case DataType::VARBINARY: return adVarBinary; break; case DataType::BLOB: case DataType::LONGVARBINARY: return adLongVarBinary; break; case DataType::CHAR: return adWChar; break; case DataType::TINYINT: return isJetEngine(_nJetEngine) ? adUnsignedTinyInt : adTinyInt;break; case DataType::OBJECT: return adGUID; break; default: OSL_ENSURE(0,"MapJdbc2ADOType: Unknown Type!"); ; } return adEmpty; } // ----------------------------------------------------------------------------- const int JET_ENGINETYPE_UNKNOWN = 0; const int JET_ENGINETYPE_JET10 = 1; const int JET_ENGINETYPE_JET11 = 2; const int JET_ENGINETYPE_JET20 = 3; const int JET_ENGINETYPE_JET3X = 4; const int JET_ENGINETYPE_JET4X = 5; const int JET_ENGINETYPE_DBASE3 = 10; const int JET_ENGINETYPE_DBASE4 = 11; const int JET_ENGINETYPE_DBASE5 = 12; const int JET_ENGINETYPE_EXCEL30 = 20; const int JET_ENGINETYPE_EXCEL40 = 21; const int JET_ENGINETYPE_EXCEL50 = 22; const int JET_ENGINETYPE_EXCEL80 = 23; const int JET_ENGINETYPE_EXCEL90 = 24; const int JET_ENGINETYPE_EXCHANGE4 = 30; const int JET_ENGINETYPE_LOTUSWK1 = 40; const int JET_ENGINETYPE_LOTUSWK3 = 41; const int JET_ENGINETYPE_LOTUSWK4 = 42; const int JET_ENGINETYPE_PARADOX3X = 50; const int JET_ENGINETYPE_PARADOX4X = 51; const int JET_ENGINETYPE_PARADOX5X = 52; const int JET_ENGINETYPE_PARADOX7X = 53; const int JET_ENGINETYPE_TEXT1X = 60; const int JET_ENGINETYPE_HTML1X = 70; sal_Bool ADOS::isJetEngine(sal_Int32 _nEngineType) { sal_Bool bRet = sal_False; switch(_nEngineType) { case JET_ENGINETYPE_UNKNOWN: case JET_ENGINETYPE_JET10: case JET_ENGINETYPE_JET11: case JET_ENGINETYPE_JET20: case JET_ENGINETYPE_JET3X: case JET_ENGINETYPE_JET4X: case JET_ENGINETYPE_DBASE3: case JET_ENGINETYPE_DBASE4: case JET_ENGINETYPE_DBASE5: case JET_ENGINETYPE_EXCEL30: case JET_ENGINETYPE_EXCEL40: case JET_ENGINETYPE_EXCEL50: case JET_ENGINETYPE_EXCEL80: case JET_ENGINETYPE_EXCEL90: case JET_ENGINETYPE_EXCHANGE4: case JET_ENGINETYPE_LOTUSWK1: case JET_ENGINETYPE_LOTUSWK3: case JET_ENGINETYPE_LOTUSWK4: case JET_ENGINETYPE_PARADOX3X: case JET_ENGINETYPE_PARADOX4X: case JET_ENGINETYPE_PARADOX5X: case JET_ENGINETYPE_PARADOX7X: case JET_ENGINETYPE_TEXT1X: case JET_ENGINETYPE_HTML1X: bRet = sal_True; break; } return bRet; } // ----------------------------------------------------------------------------- ObjectTypeEnum ADOS::mapObjectType2Ado(sal_Int32 objType) { ObjectTypeEnum eType = adPermObjTable; switch(objType) { case PrivilegeObject::TABLE: eType = adPermObjTable; break; case PrivilegeObject::VIEW: eType = adPermObjView; break; case PrivilegeObject::COLUMN: eType = adPermObjColumn; break; } return eType; } // ----------------------------------------------------------------------------- sal_Int32 ADOS::mapAdoType2Object(ObjectTypeEnum objType) { sal_Int32 nType = PrivilegeObject::TABLE; switch(objType) { case adPermObjTable: nType = PrivilegeObject::TABLE; break; case adPermObjView: nType = PrivilegeObject::VIEW; break; case adPermObjColumn: nType = PrivilegeObject::COLUMN; break; default: OSL_ENSURE( false, "ADOS::mapAdoType2Object: privilege type cannot be translated!" ); break; } return nType; } #ifdef DELETE #undef DELETE #endif // ----------------------------------------------------------------------------- sal_Int32 ADOS::mapAdoRights2Sdbc(RightsEnum eRights) { sal_Int32 nRights = 0; if((eRights & adRightInsert) == adRightInsert) nRights |= Privilege::INSERT; if((eRights & adRightDelete) == adRightDelete) nRights |= ::com::sun::star::sdbcx::Privilege::DELETE; if((eRights & adRightUpdate) == adRightUpdate) nRights |= Privilege::UPDATE; if((eRights & adRightWriteDesign) == adRightWriteDesign) nRights |= Privilege::ALTER; if((eRights & adRightRead) == adRightRead) nRights |= Privilege::SELECT; if((eRights & adRightReference) == adRightReference) nRights |= Privilege::REFERENCE; if((eRights & adRightDrop) == adRightDrop) nRights |= Privilege::DROP; return nRights; } // ----------------------------------------------------------------------------- sal_Int32 ADOS::mapRights2Ado(sal_Int32 nRights) { sal_Int32 eRights = adRightNone; if((nRights & Privilege::INSERT) == Privilege::INSERT) eRights |= adRightInsert; if((nRights & Privilege::DELETE) == Privilege::DELETE) eRights |= adRightDelete; if((nRights & Privilege::UPDATE) == Privilege::UPDATE) eRights |= adRightUpdate; if((nRights & Privilege::ALTER) == Privilege::ALTER) eRights |= adRightWriteDesign; if((nRights & Privilege::SELECT) == Privilege::SELECT) eRights |= adRightRead; if((nRights & Privilege::REFERENCE) == Privilege::REFERENCE) eRights |= adRightReference; if((nRights & Privilege::DROP) == Privilege::DROP) eRights |= adRightDrop; return eRights; } // ----------------------------------------------------------------------------- WpADOField ADOS::getField(ADORecordset* _pRecordSet,sal_Int32 _nColumnIndex) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException) { if ( !_pRecordSet ) return WpADOField(); ADOFields* pFields = NULL; _pRecordSet->get_Fields(&pFields); WpOLEAppendCollection aFields(pFields); if(_nColumnIndex <= 0 || _nColumnIndex > aFields.GetItemCount()) ::dbtools::throwInvalidIndexException(NULL); WpADOField aField(aFields.GetItem(_nColumnIndex-1)); if(!aField.IsValid()) ::dbtools::throwInvalidIndexException(NULL); return aField; } // -----------------------------------------------------------------------------