connectivity/source/drivers/flat/EConnection.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 "flat/EConnection.hxx"
  21 #include "flat/EDatabaseMetaData.hxx"
  22 #include "flat/ECatalog.hxx"
  23 #include "flat/EDriver.hxx"
  24 #include <com/sun/star/lang/DisposedException.hpp>
  25 #include "flat/EPreparedStatement.hxx"
  26 #include "flat/EStatement.hxx"
  27 #include <comphelper/extract.hxx>
  28 #include <connectivity/dbexception.hxx>
  29
  30 using namespace connectivity::flat;
  31 using namespace connectivity::file;
  32
  33 typedef connectivity::file::OConnection  OConnection_B;
  34
  35
  36 using namespace ::com::sun::star::uno;
  37 using namespace ::com::sun::star::beans;
  38 using namespace ::com::sun::star::sdbcx;
  39 using namespace ::com::sun::star::sdbc;
  40 using namespace ::com::sun::star::lang;
  41
  42
  43 OFlatConnection::OFlatConnection(ODriver*   _pDriver) : OConnection(_pDriver)
  44     ,m_nMaxRowsToScan(50)
  45     ,m_bHeaderLine(true)
  46     ,m_cFieldDelimiter(';')
  47     ,m_cStringDelimiter('"')
  48     ,m_cDecimalDelimiter(',')
  49     ,m_cThousandDelimiter('.')
  50 {
  51 }
  52
  53 OFlatConnection::~OFlatConnection()
  54 {
  55 }
  56
  57 // XServiceInfo
  58
  59 IMPLEMENT_SERVICE_INFO(OFlatConnection, "com.sun.star.sdbc.drivers.flat.Connection", "com.sun.star.sdbc.Connection")
  60
  61
  62 void OFlatConnection::construct(const OUString& url,const Sequence< PropertyValue >& info)
  63     throw(css::sdbc::SQLException, css::uno::RuntimeException)
  64 {
  65     osl_atomic_increment( &m_refCount );
  66
  67     const PropertyValue *pBegin  = info.getConstArray();
  68     const PropertyValue *pEnd    = pBegin + info.getLength();
  69     for(;pBegin != pEnd;++pBegin)
  70     {
  71         if(pBegin->Name.equalsAscii("HeaderLine"))
  72             OSL_VERIFY( pBegin->Value >>= m_bHeaderLine );
  73         else if(pBegin->Name.equalsAscii("FieldDelimiter"))
  74         {
  75             OUString aVal;
  76             OSL_VERIFY( pBegin->Value >>= aVal );
  77             m_cFieldDelimiter = aVal.toChar();
  78         }
  79         else if(pBegin->Name.equalsAscii("StringDelimiter"))
  80         {
  81             OUString aVal;
  82             OSL_VERIFY( pBegin->Value >>= aVal );
  83             m_cStringDelimiter = aVal.toChar();
  84         }
  85         else if(pBegin->Name.equalsAscii("DecimalDelimiter"))
  86         {
  87             OUString aVal;
  88             OSL_VERIFY( pBegin->Value >>= aVal );
  89             m_cDecimalDelimiter = aVal.toChar();
  90         }
  91         else if(pBegin->Name.equalsAscii("ThousandDelimiter"))
  92         {
  93             OUString aVal;
  94             OSL_VERIFY( pBegin->Value >>= aVal );
  95             m_cThousandDelimiter = aVal.toChar();
  96         }
  97         else if ( pBegin->Name.equalsAscii("MaxRowScan") )
  98         {
  99             pBegin->Value >>= m_nMaxRowsToScan;
 100         }
 101     }
 102
 103     osl_atomic_decrement( &m_refCount );
 104     OConnection::construct(url,info);
 105     m_bShowDeleted = true; // we do not supported rows for this type
 106 }
 107
 108 Reference< XDatabaseMetaData > SAL_CALL OFlatConnection::getMetaData(  ) throw(SQLException, RuntimeException, std::exception)
 109 {
 110     ::osl::MutexGuard aGuard( m_aMutex );
 111     checkDisposed(OConnection_B::rBHelper.bDisposed);
 112
 113
 114     Reference< XDatabaseMetaData > xMetaData = m_xMetaData;
 115     if(!xMetaData.is())
 116     {
 117         xMetaData = new OFlatDatabaseMetaData(this);
 118         m_xMetaData = xMetaData;
 119     }
 120
 121     return xMetaData;
 122 }
 123
 124 ::com::sun::star::uno::Reference< XTablesSupplier > OFlatConnection::createCatalog()
 125 {
 126     ::osl::MutexGuard aGuard( m_aMutex );
 127     Reference< XTablesSupplier > xTab = m_xCatalog;
 128     if(!xTab.is())
 129     {
 130         OFlatCatalog *pCat = new OFlatCatalog(this);
 131         xTab = pCat;
 132         m_xCatalog = xTab;
 133     }
 134     return xTab;
 135 }
 136
 137 Reference< XStatement > SAL_CALL OFlatConnection::createStatement(  ) throw(SQLException, RuntimeException, std::exception)
 138 {
 139     ::osl::MutexGuard aGuard( m_aMutex );
 140     checkDisposed(OConnection_B::rBHelper.bDisposed);
 141
 142     OFlatStatement* pStmt = new OFlatStatement(this);
 143
 144     Reference< XStatement > xStmt = pStmt;
 145     m_aStatements.push_back(WeakReferenceHelper(*pStmt));
 146     return xStmt;
 147 }
 148
 149 Reference< XPreparedStatement > SAL_CALL OFlatConnection::prepareStatement( const OUString& sql ) throw(SQLException, RuntimeException, std::exception)
 150 {
 151     ::osl::MutexGuard aGuard( m_aMutex );
 152     checkDisposed(OConnection_B::rBHelper.bDisposed);
 153
 154
 155     OFlatPreparedStatement* pStmt = new OFlatPreparedStatement(this);
 156     Reference< XPreparedStatement > xStmt = pStmt;
 157     pStmt->construct(sql);
 158
 159     m_aStatements.push_back(WeakReferenceHelper(*pStmt));
 160     return xStmt;
 161 }
 162
 163 Reference< XPreparedStatement > SAL_CALL OFlatConnection::prepareCall( const OUString& /*sql*/ ) throw(SQLException, RuntimeException, std::exception)
 164 {
 165     ::osl::MutexGuard aGuard( m_aMutex );
 166     checkDisposed(OConnection_B::rBHelper.bDisposed);
 167
 168     ::dbtools::throwFeatureNotImplementedException( "XConnection::prepareCall", *this );
 169     return NULL;
 170 }
 171
 172
 173 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */