Line data Source code
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 <config_folders.h>
21 :
22 : #include "hsqldb/HDriver.hxx"
23 : #include "hsqldb/HConnection.hxx"
24 : #include <osl/diagnose.h>
25 : #include "connectivity/dbexception.hxx"
26 : #include <com/sun/star/configuration/theDefaultProvider.hpp>
27 : #include <com/sun/star/sdbc/DriverManager.hpp>
28 : #include <com/sun/star/sdbc/XDriverAccess.hpp>
29 : #include <com/sun/star/sdbc/XResultSet.hpp>
30 : #include <com/sun/star/sdbc/XRow.hpp>
31 : #include <com/sun/star/embed/XTransactionBroadcaster.hpp>
32 : #include <com/sun/star/embed/ElementModes.hpp>
33 : #include "TConnection.hxx"
34 : #include "hsqldb/HStorageMap.hxx"
35 : #include <jvmfwk/framework.h>
36 : #include <com/sun/star/reflection/XProxyFactory.hpp>
37 : #include <com/sun/star/embed/XStorage.hpp>
38 : #include <com/sun/star/frame/Desktop.hpp>
39 : #include <com/sun/star/lang/Locale.hpp>
40 : #include <com/sun/star/util/XFlushable.hpp>
41 : #include "HTerminateListener.hxx"
42 : #include "hsqldb/HCatalog.hxx"
43 : #include "diagnose_ex.h"
44 : #include <rtl/ustrbuf.hxx>
45 : #include <osl/file.h>
46 : #include <osl/process.h>
47 : #include <connectivity/dbexception.hxx>
48 : #include <comphelper/namedvaluecollection.hxx>
49 : #include <comphelper/processfactory.hxx>
50 : #include <comphelper/string.hxx>
51 : #include <cppuhelper/supportsservice.hxx>
52 : #include <unotools/confignode.hxx>
53 : #include <unotools/ucbstreamhelper.hxx>
54 : #include "resource/hsqldb_res.hrc"
55 : #include "resource/sharedresources.hxx"
56 : #include <i18nlangtag/languagetag.hxx>
57 :
58 : #include <o3tl/compat_functional.hxx>
59 :
60 : #include <boost/scoped_ptr.hpp>
61 :
62 :
63 : namespace connectivity
64 : {
65 :
66 : using namespace hsqldb;
67 : using namespace ::com::sun::star::uno;
68 : using namespace ::com::sun::star::sdbc;
69 : using namespace ::com::sun::star::sdbcx;
70 : using namespace ::com::sun::star::beans;
71 : using namespace ::com::sun::star::frame;
72 : using namespace ::com::sun::star::lang;
73 : using namespace ::com::sun::star::embed;
74 : using namespace ::com::sun::star::io;
75 : using namespace ::com::sun::star::task;
76 : using namespace ::com::sun::star::util;
77 : using namespace ::com::sun::star::reflection;
78 :
79 : namespace hsqldb
80 : {
81 1 : Reference< XInterface > SAL_CALL ODriverDelegator_CreateInstance(const Reference< ::com::sun::star::lang::XMultiServiceFactory >& _rxFac) throw( Exception )
82 : {
83 1 : return *(new ODriverDelegator(comphelper::getComponentContext(_rxFac)));
84 : }
85 : }
86 :
87 :
88 :
89 :
90 : //= ODriverDelegator
91 :
92 :
93 1 : ODriverDelegator::ODriverDelegator(const Reference< XComponentContext >& _rxContext)
94 : : ODriverDelegator_BASE(m_aMutex)
95 : ,m_xContext(_rxContext)
96 1 : ,m_bInShutDownConnections(sal_False)
97 : {
98 1 : }
99 :
100 :
101 0 : ODriverDelegator::~ODriverDelegator()
102 : {
103 : try
104 : {
105 0 : ::comphelper::disposeComponent(m_xDriver);
106 : }
107 0 : catch(const Exception&)
108 : {
109 : }
110 0 : }
111 :
112 :
113 0 : void SAL_CALL ODriverDelegator::disposing()
114 : {
115 0 : ::osl::MutexGuard aGuard(m_aMutex);
116 :
117 : try
118 : {
119 0 : for (TWeakPairVector::iterator i = m_aConnections.begin(); m_aConnections.end() != i; ++i)
120 : {
121 0 : Reference<XInterface > xTemp = i->first.get();
122 0 : ::comphelper::disposeComponent(xTemp);
123 0 : }
124 : }
125 0 : catch(Exception&)
126 : {
127 : // not interested in
128 : }
129 0 : m_aConnections.clear();
130 0 : TWeakPairVector().swap(m_aConnections);
131 :
132 0 : cppu::WeakComponentImplHelperBase::disposing();
133 0 : }
134 :
135 1 : Reference< XDriver > ODriverDelegator::loadDriver( )
136 : {
137 1 : if ( !m_xDriver.is() )
138 : {
139 1 : OUString sURL("jdbc:hsqldb:db");
140 2 : Reference<XDriverManager2> xDriverAccess = DriverManager::create( m_xContext );
141 2 : m_xDriver = xDriverAccess->getDriverByURL(sURL);
142 : }
143 :
144 1 : return m_xDriver;
145 : }
146 :
147 :
148 : namespace
149 : {
150 1 : OUString lcl_getPermittedJavaMethods_nothrow( const Reference< XComponentContext >& _rxContext )
151 : {
152 1 : OUStringBuffer aConfigPath;
153 1 : aConfigPath.appendAscii( "/org.openoffice.Office.DataAccess/DriverSettings/" );
154 1 : aConfigPath.append ( ODriverDelegator::getImplementationName_Static() );
155 1 : aConfigPath.appendAscii( "/PermittedJavaMethods" );
156 : ::utl::OConfigurationTreeRoot aConfig( ::utl::OConfigurationTreeRoot::createWithComponentContext(
157 2 : _rxContext, aConfigPath.makeStringAndClear() ) );
158 :
159 2 : OUStringBuffer aPermittedMethods;
160 2 : Sequence< OUString > aNodeNames( aConfig.getNodeNames() );
161 2 : for ( const OUString* pNodeNames = aNodeNames.getConstArray();
162 1 : pNodeNames != aNodeNames.getConstArray() + aNodeNames.getLength();
163 : ++pNodeNames
164 : )
165 : {
166 0 : OUString sPermittedMethod;
167 0 : OSL_VERIFY( aConfig.getNodeValue( *pNodeNames ) >>= sPermittedMethod );
168 :
169 0 : if ( !aPermittedMethods.isEmpty() )
170 0 : aPermittedMethods.append( ';' );
171 0 : aPermittedMethods.append( sPermittedMethod );
172 0 : }
173 :
174 2 : return aPermittedMethods.makeStringAndClear();
175 : }
176 : }
177 :
178 :
179 1 : Reference< XConnection > SAL_CALL ODriverDelegator::connect( const OUString& url, const Sequence< PropertyValue >& info ) throw (SQLException, RuntimeException, std::exception)
180 : {
181 1 : Reference< XConnection > xConnection;
182 1 : if ( acceptsURL(url) )
183 : {
184 1 : Reference< XDriver > xDriver = loadDriver();
185 1 : if ( xDriver.is() )
186 : {
187 1 : OUString sURL;
188 2 : Reference<XStorage> xStorage;
189 1 : const PropertyValue* pIter = info.getConstArray();
190 1 : const PropertyValue* pEnd = pIter + info.getLength();
191 :
192 5 : for (;pIter != pEnd; ++pIter)
193 : {
194 4 : if ( pIter->Name == "Storage" )
195 : {
196 1 : xStorage.set(pIter->Value,UNO_QUERY);
197 : }
198 3 : else if ( pIter->Name == "URL" )
199 : {
200 1 : pIter->Value >>= sURL;
201 : }
202 : }
203 :
204 1 : if ( !xStorage.is() || sURL.isEmpty() )
205 : {
206 0 : ::connectivity::SharedResources aResources;
207 0 : const OUString sMessage = aResources.getResourceString(STR_NO_STORAGE);
208 0 : ::dbtools::throwGenericSQLException(sMessage ,*this);
209 : }
210 :
211 2 : OUString sSystemPath;
212 1 : osl_getSystemPathFromFileURL( sURL.pData, &sSystemPath.pData );
213 1 : if ( sURL.isEmpty() || sSystemPath.isEmpty() )
214 : {
215 0 : ::connectivity::SharedResources aResources;
216 0 : const OUString sMessage = aResources.getResourceString(STR_INVALID_FILE_URL);
217 0 : ::dbtools::throwGenericSQLException(sMessage ,*this);
218 : }
219 :
220 1 : bool bIsNewDatabase = !xStorage->hasElements();
221 :
222 2 : ::comphelper::NamedValueCollection aProperties;
223 :
224 : // properties for accessing the embedded storage
225 2 : OUString sKey = StorageContainer::registerStorage( xStorage, sSystemPath );
226 1 : aProperties.put( "storage_key", sKey );
227 : aProperties.put( "storage_class_name",
228 1 : OUString( "com.sun.star.sdbcx.comp.hsqldb.StorageAccess" ) );
229 : aProperties.put( "fileaccess_class_name",
230 1 : OUString( "com.sun.star.sdbcx.comp.hsqldb.StorageFileAccess" ) );
231 :
232 : // JDBC driver and driver's classpath
233 : aProperties.put( "JavaDriverClass",
234 1 : OUString( "org.hsqldb.jdbcDriver" ) );
235 : aProperties.put( "JavaDriverClassPath",
236 : OUString(
237 : #ifdef SYSTEM_HSQLDB
238 : HSQLDB_JAR
239 : #else
240 : "vnd.sun.star.expand:$LO_JAVA_DIR/hsqldb.jar"
241 : #endif
242 : " vnd.sun.star.expand:$LO_JAVA_DIR/sdbc_hsqldb.jar"
243 1 : ) );
244 :
245 : // auto increment handling
246 1 : aProperties.put( "IsAutoRetrievingEnabled", true );
247 : aProperties.put( "AutoRetrievingStatement",
248 1 : OUString( "CALL IDENTITY()" ) );
249 1 : aProperties.put( "IgnoreDriverPrivileges", true );
250 :
251 : // don't want to expose HSQLDB's schema capabilities which exist since 1.8.0RC10
252 : aProperties.put( "default_schema",
253 1 : OUString( "true" ) );
254 :
255 : // security: permitted Java classes
256 : NamedValue aPermittedClasses(
257 : OUString( "hsqldb.method_class_names" ),
258 : makeAny( lcl_getPermittedJavaMethods_nothrow( m_xContext ) )
259 2 : );
260 1 : aProperties.put( "SystemProperties", Sequence< NamedValue >( &aPermittedClasses, 1 ) );
261 :
262 2 : const OUString sProperties( "properties" );
263 2 : OUString sMessage;
264 : try
265 : {
266 1 : if ( !bIsNewDatabase && xStorage->isStreamElement(sProperties) )
267 : {
268 1 : Reference<XStream > xStream = xStorage->openStreamElement(sProperties,ElementModes::READ);
269 1 : if ( xStream.is() )
270 : {
271 1 : boost::scoped_ptr<SvStream> pStream( ::utl::UcbStreamHelper::CreateStream(xStream) );
272 1 : if ( pStream.get() )
273 : {
274 1 : OString sLine;
275 2 : OString sVersionString;
276 20 : while ( pStream->ReadLine(sLine) )
277 : {
278 18 : if ( sLine.isEmpty() )
279 0 : continue;
280 18 : const OString sIniKey = comphelper::string::getToken(sLine, 0, '=');
281 36 : const OString sValue = comphelper::string::getToken(sLine, 1, '=');
282 18 : if( sIniKey == "hsqldb.compatible_version" )
283 : {
284 1 : sVersionString = sValue;
285 : }
286 : else
287 : {
288 17 : if (sIniKey == "version" && sVersionString.isEmpty())
289 : {
290 1 : sVersionString = sValue;
291 : }
292 : }
293 18 : }
294 1 : if (!sVersionString.isEmpty())
295 : {
296 : using comphelper::string::getToken;
297 1 : const sal_Int32 nMajor = getToken(sVersionString, 0, '.').toInt32();
298 1 : const sal_Int32 nMinor = getToken(sVersionString, 1, '.').toInt32();
299 1 : const sal_Int32 nMicro = getToken(sVersionString, 2, '.').toInt32();
300 1 : if ( nMajor > 1
301 1 : || ( nMajor == 1 && nMinor > 8 )
302 1 : || ( nMajor == 1 && nMinor == 8 && nMicro > 0 ) )
303 : {
304 0 : ::connectivity::SharedResources aResources;
305 0 : sMessage = aResources.getResourceString(STR_ERROR_NEW_VERSION);
306 : }
307 1 : }
308 1 : }
309 : } // if ( xStream.is() )
310 1 : ::comphelper::disposeComponent(xStream);
311 : }
312 : }
313 0 : catch(Exception&)
314 : {
315 : }
316 1 : if ( !sMessage.isEmpty() )
317 : {
318 0 : ::dbtools::throwGenericSQLException(sMessage ,*this);
319 : }
320 :
321 : // readonly?
322 2 : Reference<XPropertySet> xProp(xStorage,UNO_QUERY);
323 1 : if ( xProp.is() )
324 : {
325 1 : sal_Int32 nMode = 0;
326 1 : xProp->getPropertyValue("OpenMode") >>= nMode;
327 1 : if ( (nMode & ElementModes::WRITE) != ElementModes::WRITE )
328 : {
329 0 : aProperties.put( "readonly", OUString( "true" ) );
330 : }
331 : }
332 :
333 2 : Sequence< PropertyValue > aConnectionArgs;
334 1 : aProperties >>= aConnectionArgs;
335 :
336 2 : OUString sConnectURL("jdbc:hsqldb:");
337 :
338 1 : sConnectURL += sSystemPath;
339 2 : Reference<XConnection> xOrig;
340 : try
341 : {
342 1 : xOrig = xDriver->connect( sConnectURL, aConnectionArgs );
343 : }
344 0 : catch(const Exception& e)
345 : {
346 0 : StorageContainer::revokeStorage(sKey,NULL);
347 : (void)e;
348 0 : throw;
349 : }
350 :
351 : // if the storage is completely empty, then we just created a new HSQLDB
352 : // In this case, do some initializations.
353 1 : if ( bIsNewDatabase && xOrig.is() )
354 0 : onConnectedNewDatabase( xOrig );
355 :
356 1 : if ( xOrig.is() )
357 : {
358 1 : OMetaConnection* pMetaConnection = NULL;
359 : // now we have to set the URL to get the correct answer for metadata()->getURL()
360 1 : Reference< XUnoTunnel> xTunnel(xOrig,UNO_QUERY);
361 1 : if ( xTunnel.is() )
362 : {
363 1 : pMetaConnection = reinterpret_cast<OMetaConnection*>(xTunnel->getSomething( OMetaConnection::getUnoTunnelImplementationId() ));
364 1 : if ( pMetaConnection )
365 1 : pMetaConnection->setURL(url);
366 : }
367 :
368 2 : Reference<XComponent> xComp(xOrig,UNO_QUERY);
369 1 : if ( xComp.is() )
370 1 : xComp->addEventListener(this);
371 :
372 : // we want to close all connections when the office shuts down
373 1 : static Reference< XTerminateListener> s_xTerminateListener;
374 1 : if( !s_xTerminateListener.is() )
375 : {
376 1 : Reference< XDesktop2 > xDesktop = Desktop::create( m_xContext );
377 :
378 1 : s_xTerminateListener = new OConnectionController(this);
379 1 : xDesktop->addTerminateListener(s_xTerminateListener);
380 : }
381 2 : Reference< XComponent> xIfc = new OHsqlConnection( this, xOrig, m_xContext );
382 1 : xConnection.set(xIfc,UNO_QUERY);
383 1 : m_aConnections.push_back(TWeakPair(WeakReferenceHelper(xOrig),TWeakConnectionPair(sKey,TWeakRefPair(WeakReferenceHelper(xConnection),WeakReferenceHelper()))));
384 :
385 2 : Reference<XTransactionBroadcaster> xBroad(xStorage,UNO_QUERY);
386 1 : if ( xBroad.is() )
387 : {
388 1 : Reference<XTransactionListener> xListener(*this,UNO_QUERY);
389 1 : xBroad->addTransactionListener(xListener);
390 1 : }
391 1 : }
392 1 : }
393 : }
394 1 : return xConnection;
395 : }
396 :
397 :
398 6 : sal_Bool SAL_CALL ODriverDelegator::acceptsURL( const OUString& url ) throw (SQLException, RuntimeException, std::exception)
399 : {
400 6 : sal_Bool bEnabled = sal_False;
401 6 : javaFrameworkError e = jfw_getEnabled(&bEnabled);
402 6 : switch (e) {
403 : case JFW_E_NONE:
404 6 : break;
405 : case JFW_E_DIRECT_MODE:
406 : SAL_INFO(
407 : "connectivity.hsqldb",
408 : "jfw_getEnabled: JFW_E_DIRECT_MODE, assuming true");
409 0 : bEnabled = true;
410 0 : break;
411 : default:
412 : SAL_WARN(
413 : "connectivity.hsqldb", "jfw_getEnabled: error code " << +e);
414 0 : break;
415 : }
416 6 : return bEnabled && url.equals("sdbc:embedded:hsqldb");
417 : }
418 :
419 :
420 1 : Sequence< DriverPropertyInfo > SAL_CALL ODriverDelegator::getPropertyInfo( const OUString& url, const Sequence< PropertyValue >& /*info*/ ) throw (SQLException, RuntimeException, std::exception)
421 : {
422 1 : if ( !acceptsURL(url) )
423 0 : return Sequence< DriverPropertyInfo >();
424 1 : ::std::vector< DriverPropertyInfo > aDriverInfo;
425 : aDriverInfo.push_back(DriverPropertyInfo(
426 : OUString("Storage")
427 : ,OUString("Defines the storage where the database will be stored.")
428 : ,sal_True
429 : ,OUString()
430 : ,Sequence< OUString >())
431 1 : );
432 : aDriverInfo.push_back(DriverPropertyInfo(
433 : OUString("URL")
434 : ,OUString("Defines the url of the data source.")
435 : ,sal_True
436 : ,OUString()
437 : ,Sequence< OUString >())
438 1 : );
439 : aDriverInfo.push_back(DriverPropertyInfo(
440 : OUString("AutoRetrievingStatement")
441 : ,OUString("Defines the statement which will be executed to retrieve auto increment values.")
442 : ,sal_False
443 : ,OUString("CALL IDENTITY()")
444 : ,Sequence< OUString >())
445 1 : );
446 1 : return Sequence< DriverPropertyInfo >(&aDriverInfo[0],aDriverInfo.size());
447 : }
448 :
449 :
450 0 : sal_Int32 SAL_CALL ODriverDelegator::getMajorVersion( ) throw (RuntimeException, std::exception)
451 : {
452 0 : return 1;
453 : }
454 :
455 :
456 0 : sal_Int32 SAL_CALL ODriverDelegator::getMinorVersion( ) throw (RuntimeException, std::exception)
457 : {
458 0 : return 0;
459 : }
460 :
461 :
462 1 : Reference< XTablesSupplier > SAL_CALL ODriverDelegator::getDataDefinitionByConnection( const Reference< XConnection >& connection ) throw (SQLException, RuntimeException, std::exception)
463 : {
464 1 : ::osl::MutexGuard aGuard( m_aMutex );
465 1 : checkDisposed(ODriverDelegator_BASE::rBHelper.bDisposed);
466 :
467 1 : Reference< XTablesSupplier > xTab;
468 :
469 1 : TWeakPairVector::iterator aEnd = m_aConnections.end();
470 1 : for (TWeakPairVector::iterator i = m_aConnections.begin(); aEnd != i; ++i)
471 : {
472 1 : if ( i->second.second.first.get() == connection.get() )
473 : {
474 1 : xTab = Reference< XTablesSupplier >(i->second.second.second.get().get(),UNO_QUERY);
475 1 : if ( !xTab.is() )
476 : {
477 1 : xTab = new OHCatalog(connection);
478 1 : i->second.second.second = WeakReferenceHelper(xTab);
479 : }
480 1 : break;
481 : }
482 : }
483 :
484 1 : return xTab;
485 : }
486 :
487 :
488 0 : Reference< XTablesSupplier > SAL_CALL ODriverDelegator::getDataDefinitionByURL( const OUString& url, const Sequence< PropertyValue >& info ) throw (SQLException, RuntimeException, std::exception)
489 : {
490 0 : if ( ! acceptsURL(url) )
491 : {
492 0 : ::connectivity::SharedResources aResources;
493 0 : const OUString sMessage = aResources.getResourceString(STR_URI_SYNTAX_ERROR);
494 0 : ::dbtools::throwGenericSQLException(sMessage ,*this);
495 : }
496 :
497 0 : return getDataDefinitionByConnection(connect(url,info));
498 : }
499 :
500 : // XServiceInfo
501 :
502 :
503 2 : OUString ODriverDelegator::getImplementationName_Static( ) throw(RuntimeException)
504 : {
505 2 : return OUString("com.sun.star.sdbcx.comp.hsqldb.Driver");
506 : }
507 :
508 1 : Sequence< OUString > ODriverDelegator::getSupportedServiceNames_Static( ) throw (RuntimeException)
509 : {
510 1 : Sequence< OUString > aSNS( 2 );
511 1 : aSNS[0] = "com.sun.star.sdbc.Driver";
512 1 : aSNS[1] = "com.sun.star.sdbcx.Driver";
513 1 : return aSNS;
514 : }
515 :
516 0 : OUString SAL_CALL ODriverDelegator::getImplementationName( ) throw(RuntimeException, std::exception)
517 : {
518 0 : return getImplementationName_Static();
519 : }
520 :
521 0 : sal_Bool SAL_CALL ODriverDelegator::supportsService( const OUString& _rServiceName ) throw(RuntimeException, std::exception)
522 : {
523 0 : return cppu::supportsService(this, _rServiceName);
524 : }
525 :
526 0 : Sequence< OUString > SAL_CALL ODriverDelegator::getSupportedServiceNames( ) throw(RuntimeException, std::exception)
527 : {
528 0 : return getSupportedServiceNames_Static();
529 : }
530 :
531 0 : void SAL_CALL ODriverDelegator::createCatalog( const Sequence< PropertyValue >& /*info*/ ) throw (SQLException, ::com::sun::star::container::ElementExistException, RuntimeException, std::exception)
532 : {
533 0 : ::dbtools::throwFeatureNotImplementedException( "XCreateCatalog::createCatalog", *this );
534 0 : }
535 :
536 1 : void ODriverDelegator::shutdownConnection(const TWeakPairVector::iterator& _aIter )
537 : {
538 : OSL_ENSURE(m_aConnections.end() != _aIter,"Iterator equals .end()");
539 1 : sal_Bool bLastOne = sal_True;
540 : try
541 : {
542 1 : Reference<XConnection> _xConnection(_aIter->first.get(),UNO_QUERY);
543 :
544 1 : if ( _xConnection.is() )
545 : {
546 1 : Reference<XStatement> xStmt = _xConnection->createStatement();
547 1 : if ( xStmt.is() )
548 : {
549 1 : Reference<XResultSet> xRes(xStmt->executeQuery(OUString("SELECT COUNT(*) FROM INFORMATION_SCHEMA.SYSTEM_SESSIONS WHERE USER_NAME ='SA'")),UNO_QUERY);
550 2 : Reference<XRow> xRow(xRes,UNO_QUERY);
551 1 : if ( xRow.is() && xRes->next() )
552 1 : bLastOne = xRow->getInt(1) == 1;
553 1 : if ( bLastOne )
554 2 : xStmt->execute(OUString("SHUTDOWN"));
555 1 : }
556 1 : }
557 : }
558 0 : catch(Exception&)
559 : {
560 : }
561 1 : if ( bLastOne )
562 : {
563 : // Reference<XTransactionListener> xListener(*this,UNO_QUERY);
564 : // a shutdown should commit all changes to the db files
565 1 : StorageContainer::revokeStorage(_aIter->second.first,NULL);
566 : }
567 1 : if ( !m_bInShutDownConnections )
568 1 : m_aConnections.erase(_aIter);
569 1 : }
570 :
571 2 : void SAL_CALL ODriverDelegator::disposing( const ::com::sun::star::lang::EventObject& Source ) throw(::com::sun::star::uno::RuntimeException, std::exception)
572 : {
573 2 : ::osl::MutexGuard aGuard(m_aMutex);
574 4 : Reference<XConnection> xCon(Source.Source,UNO_QUERY);
575 2 : if ( xCon.is() )
576 : {
577 1 : TWeakPairVector::iterator i = m_aConnections.begin();
578 1 : for (; m_aConnections.end() != i; ++i)
579 : {
580 1 : if ( i->first.get() == xCon.get() )
581 : {
582 1 : shutdownConnection(i);
583 1 : break;
584 : }
585 : }
586 : }
587 : else
588 : {
589 1 : Reference< XStorage> xStorage(Source.Source,UNO_QUERY);
590 1 : if ( xStorage.is() )
591 : {
592 1 : OUString sKey = StorageContainer::getRegisteredKey(xStorage);
593 : TWeakPairVector::iterator i = ::std::find_if(m_aConnections.begin(),m_aConnections.end(),::o3tl::compose1(
594 : ::std::bind2nd(::std::equal_to< OUString >(),sKey)
595 1 : ,::o3tl::compose1(::o3tl::select1st<TWeakConnectionPair>(),::o3tl::select2nd< TWeakPair >())));
596 1 : if ( i != m_aConnections.end() )
597 0 : shutdownConnection(i);
598 1 : }
599 2 : }
600 2 : }
601 :
602 0 : void ODriverDelegator::shutdownConnections()
603 : {
604 0 : m_bInShutDownConnections = sal_True;
605 0 : TWeakPairVector::iterator aEnd = m_aConnections.end();
606 0 : for (TWeakPairVector::iterator i = m_aConnections.begin(); aEnd != i; ++i)
607 : {
608 : try
609 : {
610 0 : Reference<XConnection> xCon(i->first,UNO_QUERY);
611 0 : ::comphelper::disposeComponent(xCon);
612 : }
613 0 : catch(Exception&)
614 : {
615 : }
616 : }
617 0 : m_aConnections.clear();
618 0 : m_bInShutDownConnections = sal_True;
619 0 : }
620 :
621 0 : void ODriverDelegator::flushConnections()
622 : {
623 0 : TWeakPairVector::iterator aEnd = m_aConnections.end();
624 0 : for (TWeakPairVector::iterator i = m_aConnections.begin(); aEnd != i; ++i)
625 : {
626 : try
627 : {
628 0 : Reference<XFlushable> xCon(i->second.second.first.get(),UNO_QUERY);
629 0 : xCon->flush();
630 : }
631 0 : catch(Exception&)
632 : {
633 : }
634 : }
635 0 : }
636 :
637 1 : void SAL_CALL ODriverDelegator::preCommit( const ::com::sun::star::lang::EventObject& aEvent ) throw (::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception)
638 : {
639 1 : ::osl::MutexGuard aGuard(m_aMutex);
640 :
641 2 : Reference< XStorage> xStorage(aEvent.Source,UNO_QUERY);
642 2 : OUString sKey = StorageContainer::getRegisteredKey(xStorage);
643 1 : if ( !sKey.isEmpty() )
644 : {
645 : TWeakPairVector::iterator i = ::std::find_if(m_aConnections.begin(),m_aConnections.end(),::o3tl::compose1(
646 : ::std::bind2nd(::std::equal_to< OUString >(),sKey)
647 0 : ,::o3tl::compose1(::o3tl::select1st<TWeakConnectionPair>(),::o3tl::select2nd< TWeakPair >())));
648 : OSL_ENSURE( i != m_aConnections.end(), "ODriverDelegator::preCommit: they're committing a storage which I do not know!" );
649 0 : if ( i != m_aConnections.end() )
650 : {
651 : try
652 : {
653 0 : Reference<XConnection> xConnection(i->first,UNO_QUERY);
654 0 : if ( xConnection.is() )
655 : {
656 0 : Reference< XStatement> xStmt = xConnection->createStatement();
657 : OSL_ENSURE( xStmt.is(), "ODriverDelegator::preCommit: no statement!" );
658 0 : if ( xStmt.is() )
659 0 : xStmt->execute( OUString( "SET WRITE_DELAY 0" ) );
660 :
661 0 : sal_Bool bPreviousAutoCommit = xConnection->getAutoCommit();
662 0 : xConnection->setAutoCommit( sal_False );
663 0 : xConnection->commit();
664 0 : xConnection->setAutoCommit( bPreviousAutoCommit );
665 :
666 0 : if ( xStmt.is() )
667 0 : xStmt->execute( OUString( "SET WRITE_DELAY 60" ) );
668 0 : }
669 : }
670 0 : catch(Exception&)
671 : {
672 : OSL_FAIL( "ODriverDelegator::preCommit: caught an exception!" );
673 : }
674 : }
675 1 : }
676 1 : }
677 :
678 1 : void SAL_CALL ODriverDelegator::commited( const ::com::sun::star::lang::EventObject& /*aEvent*/ ) throw (::com::sun::star::uno::RuntimeException, std::exception)
679 : {
680 1 : }
681 :
682 0 : void SAL_CALL ODriverDelegator::preRevert( const ::com::sun::star::lang::EventObject& /*aEvent*/ ) throw (::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception)
683 : {
684 0 : }
685 :
686 0 : void SAL_CALL ODriverDelegator::reverted( const ::com::sun::star::lang::EventObject& /*aEvent*/ ) throw (::com::sun::star::uno::RuntimeException, std::exception)
687 : {
688 0 : }
689 :
690 : namespace
691 : {
692 :
693 0 : const sal_Char* lcl_getCollationForLocale( const OUString& _rLocaleString, bool _bAcceptCountryMismatch = false )
694 : {
695 : static const sal_Char* pTranslations[] =
696 : {
697 : "af-ZA", "Afrikaans",
698 : "am-ET", "Amharic",
699 : "ar", "Arabic",
700 : "as-IN", "Assamese",
701 : "az-AZ", "Azerbaijani_Latin",
702 : "az-cyrillic", "Azerbaijani_Cyrillic",
703 : "be-BY", "Belarusian",
704 : "bg-BG", "Bulgarian",
705 : "bn-IN", "Bengali",
706 : "bo-CN", "Tibetan",
707 : "bs-BA", "Bosnian",
708 : "ca-ES", "Catalan",
709 : "cs-CZ", "Czech",
710 : "cy-GB", "Welsh",
711 : "da-DK", "Danish",
712 : "de-DE", "German",
713 : "el-GR", "Greek",
714 : "en-US", "Latin1_General",
715 : "es-ES", "Spanish",
716 : "et-EE", "Estonian",
717 : "eu", "Basque",
718 : "fi-FI", "Finnish",
719 : "fr-FR", "French",
720 : "gn-PY", "Guarani",
721 : "gu-IN", "Gujarati",
722 : "ha-NG", "Hausa",
723 : "he-IL", "Hebrew",
724 : "hi-IN", "Hindi",
725 : "hr-HR", "Croatian",
726 : "hu-HU", "Hungarian",
727 : "hy-AM", "Armenian",
728 : "id-ID", "Indonesian",
729 : "ig-NG", "Igbo",
730 : "is-IS", "Icelandic",
731 : "it-IT", "Italian",
732 : "iu-CA", "Inuktitut",
733 : "ja-JP", "Japanese",
734 : "ka-GE", "Georgian",
735 : "kk-KZ", "Kazakh",
736 : "km-KH", "Khmer",
737 : "kn-IN", "Kannada",
738 : "ko-KR", "Korean",
739 : "kok-IN", "Konkani",
740 : "ks", "Kashmiri",
741 : "ky-KG", "Kirghiz",
742 : "lo-LA", "Lao",
743 : "lt-LT", "Lithuanian",
744 : "lv-LV", "Latvian",
745 : "mi-NZ", "Maori",
746 : "mk-MK", "Macedonian",
747 : "ml-IN", "Malayalam",
748 : "mn-MN", "Mongolian",
749 : "mni-IN", "Manipuri",
750 : "mr-IN", "Marathi",
751 : "ms-MY", "Malay",
752 : "mt-MT", "Maltese",
753 : "my-MM", "Burmese",
754 : "nb-NO", "Danish_Norwegian",
755 : "ne-NP", "Nepali",
756 : "nl-NL", "Dutch",
757 : "nn-NO", "Norwegian",
758 : "or-IN", "Odia",
759 : "pa-IN", "Punjabi",
760 : "pl-PL", "Polish",
761 : "ps-AF", "Pashto",
762 : "pt-PT", "Portuguese",
763 : "ro-RO", "Romanian",
764 : "ru-RU", "Russian",
765 : "sa-IN", "Sanskrit",
766 : "sd-IN", "Sindhi",
767 : "sk-SK", "Slovak",
768 : "sl-SI", "Slovenian",
769 : "so-SO", "Somali",
770 : "sq-AL", "Albanian",
771 : "sr-YU", "Serbian_Cyrillic",
772 : "sv-SE", "Swedish",
773 : "sw-KE", "Swahili",
774 : "ta-IN", "Tamil",
775 : "te-IN", "Telugu",
776 : "tg-TJ", "Tajik",
777 : "th-TH", "Thai",
778 : "tk-TM", "Turkmen",
779 : "tn-BW", "Tswana",
780 : "tr-TR", "Turkish",
781 : "tt-RU", "Tatar",
782 : "uk-UA", "Ukrainian",
783 : "ur-PK", "Urdu",
784 : "uz-UZ", "Uzbek_Latin",
785 : "ven-ZA", "Venda",
786 : "vi-VN", "Vietnamese",
787 : "yo-NG", "Yoruba",
788 : "zh-CN", "Chinese",
789 : "zu-ZA", "Zulu",
790 : NULL, NULL
791 : };
792 :
793 0 : OUString sLocaleString( _rLocaleString );
794 0 : sal_Char nCompareTermination = 0;
795 :
796 0 : if ( _bAcceptCountryMismatch )
797 : {
798 : // strip the country part from the compare string
799 0 : sal_Int32 nCountrySep = sLocaleString.indexOf( '-' );
800 0 : if ( nCountrySep > -1 )
801 0 : sLocaleString = sLocaleString.copy( 0, nCountrySep );
802 :
803 : // the entries in the translation table are compared until the
804 : // - character only, not until the terminating 0
805 0 : nCompareTermination = '-';
806 : }
807 :
808 0 : const sal_Char** pLookup = pTranslations;
809 0 : for ( ; *pLookup; pLookup +=2 )
810 : {
811 0 : sal_Int32 nCompareUntil = 0;
812 0 : while ( (*pLookup)[ nCompareUntil ] != nCompareTermination && (*pLookup)[ nCompareUntil ] != 0 )
813 0 : ++nCompareUntil;
814 :
815 0 : if ( sLocaleString.equalsAsciiL( *pLookup, nCompareUntil ) )
816 0 : return *( pLookup + 1 );
817 : }
818 :
819 0 : if ( !_bAcceptCountryMismatch )
820 : // second round, this time without matching the country
821 0 : return lcl_getCollationForLocale( _rLocaleString, true );
822 :
823 : OSL_FAIL( "lcl_getCollationForLocale: unknown locale string, falling back to Latin1_General!" );
824 0 : return "Latin1_General";
825 : }
826 :
827 :
828 0 : OUString lcl_getSystemLocale( const Reference< XComponentContext >& _rxContext )
829 : {
830 0 : OUString sLocaleString = "en-US";
831 : try
832 : {
833 :
834 : Reference< XMultiServiceFactory > xConfigProvider(
835 0 : com::sun::star::configuration::theDefaultProvider::get( _rxContext ) );
836 :
837 :
838 : // arguments for creating the config access
839 0 : Sequence< Any > aArguments(2);
840 : // the path to the node to open
841 0 : OUString sNodePath("/org.openoffice.Setup/L10N" );
842 0 : aArguments[0] <<= PropertyValue( OUString("nodepath"), 0,
843 : makeAny( sNodePath ), PropertyState_DIRECT_VALUE
844 0 : );
845 : // the depth: -1 means unlimited
846 0 : aArguments[1] <<= PropertyValue(
847 : OUString("depth"), 0,
848 : makeAny( (sal_Int32)-1 ), PropertyState_DIRECT_VALUE
849 0 : );
850 :
851 :
852 : // create the access
853 : Reference< XPropertySet > xNode(
854 0 : xConfigProvider->createInstanceWithArguments(
855 : OUString("com.sun.star.configuration.ConfigurationAccess"),
856 0 : aArguments ),
857 0 : UNO_QUERY );
858 : OSL_ENSURE( xNode.is(), "lcl_getSystemLocale: invalid access returned (should throw an exception instead)!" );
859 :
860 :
861 : // ask for the system locale setting
862 0 : if ( xNode.is() )
863 0 : xNode->getPropertyValue("ooSetupSystemLocale") >>= sLocaleString;
864 : }
865 0 : catch( const Exception& )
866 : {
867 : OSL_FAIL( "lcl_getSystemLocale: caught an exception!" );
868 : }
869 0 : if ( sLocaleString.isEmpty() )
870 : {
871 0 : rtl_Locale* pProcessLocale = NULL;
872 0 : osl_getProcessLocale( &pProcessLocale );
873 0 : sLocaleString = LanguageTag( *pProcessLocale).getBcp47();
874 : }
875 0 : return sLocaleString;
876 : }
877 : }
878 :
879 0 : void ODriverDelegator::onConnectedNewDatabase( const Reference< XConnection >& _rxConnection )
880 : {
881 : try
882 : {
883 0 : Reference< XStatement > xStatement = _rxConnection->createStatement();
884 : OSL_ENSURE( xStatement.is(), "ODriverDelegator::onConnectedNewDatabase: could not create a statement!" );
885 0 : if ( xStatement.is() )
886 : {
887 0 : OUStringBuffer aStatement;
888 0 : aStatement.appendAscii( "SET DATABASE COLLATION \"" );
889 0 : aStatement.appendAscii( lcl_getCollationForLocale( lcl_getSystemLocale( m_xContext ) ) );
890 0 : aStatement.appendAscii( "\"" );
891 :
892 0 : xStatement->execute( aStatement.makeStringAndClear() );
893 0 : }
894 : }
895 0 : catch( const Exception& )
896 : {
897 : OSL_FAIL( "ODriverDelegator::onConnectedNewDatabase: caught an exception!" );
898 : }
899 0 : }
900 :
901 :
902 :
903 :
904 : } // namespace connectivity
905 :
906 :
907 : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
