qadevOOo/runner/util/db/DataSource.java

   1 /*
   2  * This file is part of the LibreOffice project.
   3  *
   4  * This Source Code Form is subject to the terms of the Mozilla Public
   5  * License, v. 2.0. If a copy of the MPL was not distributed with this
   6  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   7  *
   8  * This file incorporates work covered by the following license notice:
   9  *
  10  *   Licensed to the Apache Software Foundation (ASF) under one or more
  11  *   contributor license agreements. See the NOTICE file distributed
  12  *   with this work for additional information regarding copyright
  13  *   ownership. The ASF licenses this file to you under the Apache
  14  *   License, Version 2.0 (the "License"); you may not use this file
  15  *   except in compliance with the License. You may obtain a copy of
  16  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  17  */
  18
  19 package util.db;
  20
  21 import com.sun.star.beans.XPropertySet;
  22 import com.sun.star.container.NoSuchElementException;
  23 import com.sun.star.lang.XMultiServiceFactory;
  24 import com.sun.star.sdbc.XDataSource;
  25 import com.sun.star.uno.Exception;
  26 import com.sun.star.uno.UnoRuntime;
  27 import com.sun.star.uno.XNamingService;
  28 import lib.StatusException;
  29
  30 /** wraps a com.sun.star.sdb.DataSource
  31  */
  32 public class DataSource
  33 {
  34     protected DataSource( XMultiServiceFactory _orb, DataSourceDescriptor _descriptor )
  35     {
  36         m_orb = _orb;
  37         try
  38         {
  39             m_dataSource = UnoRuntime.queryInterface( XDataSource.class,
  40                 m_orb.createInstance( "com.sun.star.sdb.DataSource" ) );
  41             m_properties = UnoRuntime.queryInterface( XPropertySet.class,
  42                 m_dataSource );
  43
  44             Object[] descriptorProperties = new Object[] {
  45                 null, _descriptor.URL, _descriptor.Info, _descriptor.User, _descriptor.Password,
  46                 _descriptor.IsPasswordRequired };
  47             String[] propertyNames = new String[] {
  48                 "Name", "URL", "Info", "User", "Password", "IsPasswordRequired" };
  49             for ( int i=0; i < descriptorProperties.length; ++i )
  50                 if ( descriptorProperties[i] != null )
  51                     m_properties.setPropertyValue( propertyNames[i], descriptorProperties[i] );
  52         }
  53         catch ( Exception e )
  54         {
  55             throw new StatusException( "could not create/fill a css.sdb.DataSource object", e );
  56         }
  57     }
  58
  59     public XDataSource getDataSource()
  60     {
  61         return m_dataSource;
  62     }
  63
  64     /**
  65      * retrieves the css.sdb.OfficeDatabaseDocument associated with the data source
  66      */
  67     public synchronized DatabaseDocument getDatabaseDocument()
  68     {
  69         if ( m_document == null )
  70             m_document = new DatabaseDocument( this );
  71         return m_document;
  72     }
  73
  74     public void revokeRegistration()
  75     {
  76         String dataSourceName = "";
  77         try
  78         {
  79             dataSourceName = (String)m_properties.getPropertyValue( "Name" );
  80             XNamingService dbContext = UnoRuntime.queryInterface( XNamingService.class,
  81             m_orb.createInstance( "com.sun.star.sdb.DatabaseContext" ) );
  82             dbContext.revokeObject( dataSourceName );
  83         }
  84         catch ( Exception e )
  85         {
  86             throw new StatusException( "DataSource.revokeRegistration: could not revoke the object (" + dataSourceName + ")", e );
  87         }
  88     }
  89
  90     public void registerAs( final String _registrationName, final boolean _revokeIfRegistered )
  91     {
  92         String doing = null;
  93         try
  94         {
  95             doing = "creating database context";
  96             XNamingService dbContext = UnoRuntime.queryInterface( XNamingService.class,
  97                 m_orb.createInstance( "com.sun.star.sdb.DatabaseContext" ) );
  98
  99             if ( _revokeIfRegistered )
 100             {
 101                 doing = "revoking previously registered data source";
 102                 try
 103                 {
 104                     dbContext.revokeObject( _registrationName );
 105                 }
 106                 catch( NoSuchElementException e )
 107                 {  /* allowed here */ }
 108             }
 109
 110             // if the document associated with the database document has not yet been saved, then we need to do so
 111             DatabaseDocument doc = getDatabaseDocument();
 112             String docURL = doc.getURL();
 113             if ( docURL.length() == 0 )
 114             {
 115                 final java.io.File tempFile = java.io.File.createTempFile( _registrationName + "_", ".odb" );
 116                 if ( tempFile.exists() ) {
 117                     // we did not really want to create that file, we just wanted its local name, but
 118                     // createTempFile actually creates it => throw it away
 119                     // (This is necessary since some JVM/platform combinations seem to actually lock the file)
 120                     boolean bDeleteOk = tempFile.delete();
 121                     if (!bDeleteOk) {
 122                          System.out.println("delete failed");
 123                     }
 124                 }
 125                 String localPart = tempFile.toURI().toURL().toString();
 126                 localPart = localPart.substring( localPart.lastIndexOf( '/' ) + 1 );
 127                 docURL = util.utils.getOfficeTemp( m_orb ) + localPart;
 128                 doing = "storing database document to temporary location (" + docURL + ")";
 129                 doc.storeAsURL( docURL );
 130             }
 131
 132             // register the data source
 133             doing = "registering the data source at the database context";
 134             dbContext.registerObject( _registrationName, m_dataSource );
 135         }
 136         catch( final java.lang.Exception e )
 137         {
 138             throw new StatusException( "DataSource.registerAs: error during " + doing, e );
 139         }
 140     }
 141
 142     private final XMultiServiceFactory    m_orb;
 143     private final XDataSource             m_dataSource;
 144     private final XPropertySet            m_properties;
 145     private DatabaseDocument        m_document = null;
 146 }