1*9b5730f6SAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
3*9b5730f6SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
4*9b5730f6SAndrew Rist * or more contributor license agreements. See the NOTICE file
5*9b5730f6SAndrew Rist * distributed with this work for additional information
6*9b5730f6SAndrew Rist * regarding copyright ownership. The ASF licenses this file
7*9b5730f6SAndrew Rist * to you under the Apache License, Version 2.0 (the
8*9b5730f6SAndrew Rist * "License"); you may not use this file except in compliance
9*9b5730f6SAndrew Rist * with the License. You may obtain a copy of the License at
10*9b5730f6SAndrew Rist *
11*9b5730f6SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
12*9b5730f6SAndrew Rist *
13*9b5730f6SAndrew Rist * Unless required by applicable law or agreed to in writing,
14*9b5730f6SAndrew Rist * software distributed under the License is distributed on an
15*9b5730f6SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*9b5730f6SAndrew Rist * KIND, either express or implied. See the License for the
17*9b5730f6SAndrew Rist * specific language governing permissions and limitations
18*9b5730f6SAndrew Rist * under the License.
19*9b5730f6SAndrew Rist *
20*9b5730f6SAndrew Rist *************************************************************/
21*9b5730f6SAndrew Rist
22*9b5730f6SAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25cdf0e10cSrcweir #include "precompiled_connectivity.hxx"
26cdf0e10cSrcweir #include "adabas/BUsers.hxx"
27cdf0e10cSrcweir #include "adabas/BUser.hxx"
28cdf0e10cSrcweir #include "adabas/BTable.hxx"
29cdf0e10cSrcweir #include <com/sun/star/sdbc/XRow.hpp>
30cdf0e10cSrcweir #include <com/sun/star/sdbc/XResultSet.hpp>
31cdf0e10cSrcweir #include "connectivity/sdbcx/IRefreshable.hxx"
32cdf0e10cSrcweir #include <comphelper/types.hxx>
33cdf0e10cSrcweir #include "connectivity/dbexception.hxx"
34cdf0e10cSrcweir #include "connectivity/dbtools.hxx"
35cdf0e10cSrcweir #include "resource/adabas_res.hrc"
36cdf0e10cSrcweir
37cdf0e10cSrcweir using namespace ::comphelper;
38cdf0e10cSrcweir using namespace connectivity;
39cdf0e10cSrcweir using namespace connectivity::adabas;
40cdf0e10cSrcweir using namespace ::com::sun::star::uno;
41cdf0e10cSrcweir using namespace ::com::sun::star::beans;
42cdf0e10cSrcweir // using namespace ::com::sun::star::sdbcx;
43cdf0e10cSrcweir using namespace ::com::sun::star::sdbc;
44cdf0e10cSrcweir using namespace ::com::sun::star::container;
45cdf0e10cSrcweir using namespace ::com::sun::star::lang;
46cdf0e10cSrcweir typedef connectivity::sdbcx::OCollection OCollection_TYPE;
47cdf0e10cSrcweir
createObject(const::rtl::OUString & _rName)48cdf0e10cSrcweir sdbcx::ObjectType OUsers::createObject(const ::rtl::OUString& _rName)
49cdf0e10cSrcweir {
50cdf0e10cSrcweir return new OAdabasUser(m_pConnection,_rName);
51cdf0e10cSrcweir }
52cdf0e10cSrcweir // -------------------------------------------------------------------------
impl_refresh()53cdf0e10cSrcweir void OUsers::impl_refresh() throw(RuntimeException)
54cdf0e10cSrcweir {
55cdf0e10cSrcweir m_pParent->refreshUsers();
56cdf0e10cSrcweir }
57cdf0e10cSrcweir // -------------------------------------------------------------------------
createDescriptor()58cdf0e10cSrcweir Reference< XPropertySet > OUsers::createDescriptor()
59cdf0e10cSrcweir {
60cdf0e10cSrcweir OUserExtend* pNew = new OUserExtend(m_pConnection);
61cdf0e10cSrcweir return pNew;
62cdf0e10cSrcweir }
63cdf0e10cSrcweir // -------------------------------------------------------------------------
64cdf0e10cSrcweir // XAppend
appendObject(const::rtl::OUString & _rForName,const Reference<XPropertySet> & descriptor)65cdf0e10cSrcweir sdbcx::ObjectType OUsers::appendObject( const ::rtl::OUString& _rForName, const Reference< XPropertySet >& descriptor )
66cdf0e10cSrcweir {
67cdf0e10cSrcweir ::rtl::OUString aSql = ::rtl::OUString::createFromAscii("CREATE USER ");
68cdf0e10cSrcweir ::rtl::OUString aQuote = m_pConnection->getMetaData()->getIdentifierQuoteString( );
69cdf0e10cSrcweir
70cdf0e10cSrcweir ::rtl::OUString sUserName( _rForName );
71cdf0e10cSrcweir sUserName = sUserName.toAsciiUpperCase();
72cdf0e10cSrcweir descriptor->setPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_NAME),makeAny(sUserName));
73cdf0e10cSrcweir aSql += ::dbtools::quoteName(aQuote,sUserName)
74cdf0e10cSrcweir + ::rtl::OUString::createFromAscii(" PASSWORD ")
75cdf0e10cSrcweir + getString(descriptor->getPropertyValue(OMetaConnection::getPropMap().getNameByIndex(PROPERTY_ID_PASSWORD)));
76cdf0e10cSrcweir aSql += ::rtl::OUString::createFromAscii(" RESOURCE NOT EXCLUSIVE");
77cdf0e10cSrcweir
78cdf0e10cSrcweir Reference< XStatement > xStmt = m_pConnection->createStatement( );
79cdf0e10cSrcweir if(xStmt.is())
80cdf0e10cSrcweir xStmt->execute(aSql);
81cdf0e10cSrcweir ::comphelper::disposeComponent(xStmt);
82cdf0e10cSrcweir
83cdf0e10cSrcweir return createObject( _rForName );
84cdf0e10cSrcweir }
85cdf0e10cSrcweir // -------------------------------------------------------------------------
86cdf0e10cSrcweir // XDrop
dropObject(sal_Int32,const::rtl::OUString _sElementName)87cdf0e10cSrcweir void OUsers::dropObject(sal_Int32 /*_nPos*/,const ::rtl::OUString _sElementName)
88cdf0e10cSrcweir {
89cdf0e10cSrcweir {
90cdf0e10cSrcweir // first we have to check if this user is live relevaant for the database
91cdf0e10cSrcweir // which means with out these users the database will miss more than one important system table
92cdf0e10cSrcweir ::rtl::OUString sUsers = ::rtl::OUString::createFromAscii("SELECT USERMODE,USERNAME FROM DOMAIN.USERS WHERE USERNAME = '");
93cdf0e10cSrcweir sUsers += _sElementName + ::rtl::OUString::createFromAscii("'");
94cdf0e10cSrcweir Reference< XStatement > xStmt = m_pConnection->createStatement();
95cdf0e10cSrcweir if(xStmt.is())
96cdf0e10cSrcweir {
97cdf0e10cSrcweir Reference<XResultSet> xRes = xStmt->executeQuery(sUsers);
98cdf0e10cSrcweir Reference<XRow> xRow(xRes,UNO_QUERY);
99cdf0e10cSrcweir if(xRes.is() && xRow.is() && xRes->next()) // there can only be one user with this name
100cdf0e10cSrcweir {
101cdf0e10cSrcweir static const ::rtl::OUString sDbaUser = ::rtl::OUString::createFromAscii("DBA");
102cdf0e10cSrcweir if(xRow->getString(1) == sDbaUser)
103cdf0e10cSrcweir {
104cdf0e10cSrcweir ::comphelper::disposeComponent(xStmt);
105cdf0e10cSrcweir m_pConnection->throwGenericSQLException(STR_USER_NO_DELETE,static_cast< XDrop* >( this ));
106cdf0e10cSrcweir }
107cdf0e10cSrcweir }
108cdf0e10cSrcweir ::comphelper::disposeComponent(xStmt);
109cdf0e10cSrcweir }
110cdf0e10cSrcweir }
111cdf0e10cSrcweir
112cdf0e10cSrcweir {
113cdf0e10cSrcweir ::rtl::OUString aSql = ::rtl::OUString::createFromAscii("DROP USER ");
114cdf0e10cSrcweir ::rtl::OUString aQuote = m_pConnection->getMetaData()->getIdentifierQuoteString( );
115cdf0e10cSrcweir aSql += ::dbtools::quoteName(aQuote,_sElementName);
116cdf0e10cSrcweir
117cdf0e10cSrcweir Reference< XStatement > xStmt = m_pConnection->createStatement( );
118cdf0e10cSrcweir if(xStmt.is())
119cdf0e10cSrcweir xStmt->execute(aSql);
120cdf0e10cSrcweir ::comphelper::disposeComponent(xStmt);
121cdf0e10cSrcweir }
122cdf0e10cSrcweir }
123cdf0e10cSrcweir
124cdf0e10cSrcweir // -------------------------------------------------------------------------
125