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