1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_connectivity.hxx"
26*b1cdbd2cSJim Jagielski #include "flat/EConnection.hxx"
27*b1cdbd2cSJim Jagielski #include "flat/EDatabaseMetaData.hxx"
28*b1cdbd2cSJim Jagielski #include "flat/ECatalog.hxx"
29*b1cdbd2cSJim Jagielski #ifndef _CONNECTIVITY_FLAT_ODRIVER_HXX_
30*b1cdbd2cSJim Jagielski #include "flat/EDriver.hxx"
31*b1cdbd2cSJim Jagielski #endif
32*b1cdbd2cSJim Jagielski #include <com/sun/star/lang/DisposedException.hpp>
33*b1cdbd2cSJim Jagielski #include <tools/urlobj.hxx>
34*b1cdbd2cSJim Jagielski #include "flat/EPreparedStatement.hxx"
35*b1cdbd2cSJim Jagielski #ifndef _CONNECTIVITY_FLAT_DSTATEMENT_HXX_
36*b1cdbd2cSJim Jagielski #include "flat/EStatement.hxx"
37*b1cdbd2cSJim Jagielski #endif
38*b1cdbd2cSJim Jagielski #include <comphelper/extract.hxx>
39*b1cdbd2cSJim Jagielski #include <connectivity/dbexception.hxx>
40*b1cdbd2cSJim Jagielski
41*b1cdbd2cSJim Jagielski using namespace connectivity::flat;
42*b1cdbd2cSJim Jagielski using namespace connectivity::file;
43*b1cdbd2cSJim Jagielski
44*b1cdbd2cSJim Jagielski typedef connectivity::file::OConnection OConnection_B;
45*b1cdbd2cSJim Jagielski
46*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
47*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::uno;
48*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::beans;
49*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::sdbcx;
50*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::sdbc;
51*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::lang;
52*b1cdbd2cSJim Jagielski
53*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
OFlatConnection(ODriver * _pDriver)54*b1cdbd2cSJim Jagielski OFlatConnection::OFlatConnection(ODriver* _pDriver) : OConnection(_pDriver)
55*b1cdbd2cSJim Jagielski ,m_nMaxRowsToScan(50)
56*b1cdbd2cSJim Jagielski ,m_bHeaderLine(sal_True)
57*b1cdbd2cSJim Jagielski ,m_cFieldDelimiter(';')
58*b1cdbd2cSJim Jagielski ,m_cStringDelimiter('"')
59*b1cdbd2cSJim Jagielski ,m_cDecimalDelimiter(',')
60*b1cdbd2cSJim Jagielski ,m_cThousandDelimiter('.')
61*b1cdbd2cSJim Jagielski {
62*b1cdbd2cSJim Jagielski }
63*b1cdbd2cSJim Jagielski //-----------------------------------------------------------------------------
~OFlatConnection()64*b1cdbd2cSJim Jagielski OFlatConnection::~OFlatConnection()
65*b1cdbd2cSJim Jagielski {
66*b1cdbd2cSJim Jagielski }
67*b1cdbd2cSJim Jagielski
68*b1cdbd2cSJim Jagielski // XServiceInfo
69*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
70*b1cdbd2cSJim Jagielski IMPLEMENT_SERVICE_INFO(OFlatConnection, "com.sun.star.sdbc.drivers.flat.Connection", "com.sun.star.sdbc.Connection")
71*b1cdbd2cSJim Jagielski
72*b1cdbd2cSJim Jagielski //-----------------------------------------------------------------------------
construct(const::rtl::OUString & url,const Sequence<PropertyValue> & info)73*b1cdbd2cSJim Jagielski void OFlatConnection::construct(const ::rtl::OUString& url,const Sequence< PropertyValue >& info) throw(SQLException)
74*b1cdbd2cSJim Jagielski {
75*b1cdbd2cSJim Jagielski osl_incrementInterlockedCount( &m_refCount );
76*b1cdbd2cSJim Jagielski
77*b1cdbd2cSJim Jagielski ::rtl::OUString aExt;
78*b1cdbd2cSJim Jagielski const PropertyValue *pBegin = info.getConstArray();
79*b1cdbd2cSJim Jagielski const PropertyValue *pEnd = pBegin + info.getLength();
80*b1cdbd2cSJim Jagielski for(;pBegin != pEnd;++pBegin)
81*b1cdbd2cSJim Jagielski {
82*b1cdbd2cSJim Jagielski if(!pBegin->Name.compareToAscii("HeaderLine"))
83*b1cdbd2cSJim Jagielski OSL_VERIFY( pBegin->Value >>= m_bHeaderLine );
84*b1cdbd2cSJim Jagielski else if(!pBegin->Name.compareToAscii("FieldDelimiter"))
85*b1cdbd2cSJim Jagielski {
86*b1cdbd2cSJim Jagielski ::rtl::OUString aVal;
87*b1cdbd2cSJim Jagielski OSL_VERIFY( pBegin->Value >>= aVal );
88*b1cdbd2cSJim Jagielski m_cFieldDelimiter = aVal.toChar();
89*b1cdbd2cSJim Jagielski }
90*b1cdbd2cSJim Jagielski else if(!pBegin->Name.compareToAscii("StringDelimiter"))
91*b1cdbd2cSJim Jagielski {
92*b1cdbd2cSJim Jagielski ::rtl::OUString aVal;
93*b1cdbd2cSJim Jagielski OSL_VERIFY( pBegin->Value >>= aVal );
94*b1cdbd2cSJim Jagielski m_cStringDelimiter = aVal.toChar();
95*b1cdbd2cSJim Jagielski }
96*b1cdbd2cSJim Jagielski else if(!pBegin->Name.compareToAscii("DecimalDelimiter"))
97*b1cdbd2cSJim Jagielski {
98*b1cdbd2cSJim Jagielski ::rtl::OUString aVal;
99*b1cdbd2cSJim Jagielski OSL_VERIFY( pBegin->Value >>= aVal );
100*b1cdbd2cSJim Jagielski m_cDecimalDelimiter = aVal.toChar();
101*b1cdbd2cSJim Jagielski }
102*b1cdbd2cSJim Jagielski else if(!pBegin->Name.compareToAscii("ThousandDelimiter"))
103*b1cdbd2cSJim Jagielski {
104*b1cdbd2cSJim Jagielski ::rtl::OUString aVal;
105*b1cdbd2cSJim Jagielski OSL_VERIFY( pBegin->Value >>= aVal );
106*b1cdbd2cSJim Jagielski m_cThousandDelimiter = aVal.toChar();
107*b1cdbd2cSJim Jagielski }
108*b1cdbd2cSJim Jagielski else if ( !pBegin->Name.compareToAscii("MaxRowScan") )
109*b1cdbd2cSJim Jagielski {
110*b1cdbd2cSJim Jagielski pBegin->Value >>= m_nMaxRowsToScan;
111*b1cdbd2cSJim Jagielski }
112*b1cdbd2cSJim Jagielski }
113*b1cdbd2cSJim Jagielski
114*b1cdbd2cSJim Jagielski osl_decrementInterlockedCount( &m_refCount );
115*b1cdbd2cSJim Jagielski OConnection::construct(url,info);
116*b1cdbd2cSJim Jagielski m_bShowDeleted = sal_True; // we do not supported rows for this type
117*b1cdbd2cSJim Jagielski }
118*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
getMetaData()119*b1cdbd2cSJim Jagielski Reference< XDatabaseMetaData > SAL_CALL OFlatConnection::getMetaData( ) throw(SQLException, RuntimeException)
120*b1cdbd2cSJim Jagielski {
121*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
122*b1cdbd2cSJim Jagielski checkDisposed(OConnection_B::rBHelper.bDisposed);
123*b1cdbd2cSJim Jagielski
124*b1cdbd2cSJim Jagielski
125*b1cdbd2cSJim Jagielski Reference< XDatabaseMetaData > xMetaData = m_xMetaData;
126*b1cdbd2cSJim Jagielski if(!xMetaData.is())
127*b1cdbd2cSJim Jagielski {
128*b1cdbd2cSJim Jagielski xMetaData = new OFlatDatabaseMetaData(this);
129*b1cdbd2cSJim Jagielski m_xMetaData = xMetaData;
130*b1cdbd2cSJim Jagielski }
131*b1cdbd2cSJim Jagielski
132*b1cdbd2cSJim Jagielski return xMetaData;
133*b1cdbd2cSJim Jagielski }
134*b1cdbd2cSJim Jagielski //------------------------------------------------------------------------------
createCatalog()135*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Reference< XTablesSupplier > OFlatConnection::createCatalog()
136*b1cdbd2cSJim Jagielski {
137*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
138*b1cdbd2cSJim Jagielski Reference< XTablesSupplier > xTab = m_xCatalog;
139*b1cdbd2cSJim Jagielski if(!xTab.is())
140*b1cdbd2cSJim Jagielski {
141*b1cdbd2cSJim Jagielski OFlatCatalog *pCat = new OFlatCatalog(this);
142*b1cdbd2cSJim Jagielski xTab = pCat;
143*b1cdbd2cSJim Jagielski m_xCatalog = xTab;
144*b1cdbd2cSJim Jagielski }
145*b1cdbd2cSJim Jagielski return xTab;
146*b1cdbd2cSJim Jagielski }
147*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
createStatement()148*b1cdbd2cSJim Jagielski Reference< XStatement > SAL_CALL OFlatConnection::createStatement( ) throw(SQLException, RuntimeException)
149*b1cdbd2cSJim Jagielski {
150*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
151*b1cdbd2cSJim Jagielski checkDisposed(OConnection_B::rBHelper.bDisposed);
152*b1cdbd2cSJim Jagielski
153*b1cdbd2cSJim Jagielski OFlatStatement* pStmt = new OFlatStatement(this);
154*b1cdbd2cSJim Jagielski
155*b1cdbd2cSJim Jagielski Reference< XStatement > xStmt = pStmt;
156*b1cdbd2cSJim Jagielski m_aStatements.push_back(WeakReferenceHelper(*pStmt));
157*b1cdbd2cSJim Jagielski return xStmt;
158*b1cdbd2cSJim Jagielski }
159*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
prepareStatement(const::rtl::OUString & sql)160*b1cdbd2cSJim Jagielski Reference< XPreparedStatement > SAL_CALL OFlatConnection::prepareStatement( const ::rtl::OUString& sql ) throw(SQLException, RuntimeException)
161*b1cdbd2cSJim Jagielski {
162*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
163*b1cdbd2cSJim Jagielski checkDisposed(OConnection_B::rBHelper.bDisposed);
164*b1cdbd2cSJim Jagielski
165*b1cdbd2cSJim Jagielski
166*b1cdbd2cSJim Jagielski OFlatPreparedStatement* pStmt = new OFlatPreparedStatement(this);
167*b1cdbd2cSJim Jagielski Reference< XPreparedStatement > xStmt = pStmt;
168*b1cdbd2cSJim Jagielski pStmt->construct(sql);
169*b1cdbd2cSJim Jagielski
170*b1cdbd2cSJim Jagielski m_aStatements.push_back(WeakReferenceHelper(*pStmt));
171*b1cdbd2cSJim Jagielski return xStmt;
172*b1cdbd2cSJim Jagielski }
173*b1cdbd2cSJim Jagielski // --------------------------------------------------------------------------------
prepareCall(const::rtl::OUString &)174*b1cdbd2cSJim Jagielski Reference< XPreparedStatement > SAL_CALL OFlatConnection::prepareCall( const ::rtl::OUString& /*sql*/ ) throw(SQLException, RuntimeException)
175*b1cdbd2cSJim Jagielski {
176*b1cdbd2cSJim Jagielski ::osl::MutexGuard aGuard( m_aMutex );
177*b1cdbd2cSJim Jagielski checkDisposed(OConnection_B::rBHelper.bDisposed);
178*b1cdbd2cSJim Jagielski
179*b1cdbd2cSJim Jagielski ::dbtools::throwFeatureNotImplementedException( "XConnection::prepareCall", *this );
180*b1cdbd2cSJim Jagielski return NULL;
181*b1cdbd2cSJim Jagielski }
182*b1cdbd2cSJim Jagielski
183*b1cdbd2cSJim Jagielski
184