1*cdf0e10cSrcweir /*************************************************************************
2*cdf0e10cSrcweir  *
3*cdf0e10cSrcweir  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4*cdf0e10cSrcweir  *
5*cdf0e10cSrcweir  * Copyright 2000, 2010 Oracle and/or its affiliates.
6*cdf0e10cSrcweir  *
7*cdf0e10cSrcweir  * OpenOffice.org - a multi-platform office productivity suite
8*cdf0e10cSrcweir  *
9*cdf0e10cSrcweir  * This file is part of OpenOffice.org.
10*cdf0e10cSrcweir  *
11*cdf0e10cSrcweir  * OpenOffice.org is free software: you can redistribute it and/or modify
12*cdf0e10cSrcweir  * it under the terms of the GNU Lesser General Public License version 3
13*cdf0e10cSrcweir  * only, as published by the Free Software Foundation.
14*cdf0e10cSrcweir  *
15*cdf0e10cSrcweir  * OpenOffice.org is distributed in the hope that it will be useful,
16*cdf0e10cSrcweir  * but WITHOUT ANY WARRANTY; without even the implied warranty of
17*cdf0e10cSrcweir  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18*cdf0e10cSrcweir  * GNU Lesser General Public License version 3 for more details
19*cdf0e10cSrcweir  * (a copy is included in the LICENSE file that accompanied this code).
20*cdf0e10cSrcweir  *
21*cdf0e10cSrcweir  * You should have received a copy of the GNU Lesser General Public License
22*cdf0e10cSrcweir  * version 3 along with OpenOffice.org.  If not, see
23*cdf0e10cSrcweir  * <http://www.openoffice.org/license.html>
24*cdf0e10cSrcweir  * for a copy of the LGPLv3 License.
25*cdf0e10cSrcweir  *
26*cdf0e10cSrcweir  ************************************************************************/
27*cdf0e10cSrcweir 
28*cdf0e10cSrcweir import com.sun.star.beans.XPropertySet;
29*cdf0e10cSrcweir import com.sun.star.container.XIndexAccess;
30*cdf0e10cSrcweir import com.sun.star.container.XNameAccess;
31*cdf0e10cSrcweir import com.sun.star.io.XInputStream;
32*cdf0e10cSrcweir import com.sun.star.lang.XMultiServiceFactory;
33*cdf0e10cSrcweir import com.sun.star.sdbc.SQLException;
34*cdf0e10cSrcweir import com.sun.star.sdbc.XArray;
35*cdf0e10cSrcweir import com.sun.star.sdbc.XBlob;
36*cdf0e10cSrcweir import com.sun.star.sdbc.XClob;
37*cdf0e10cSrcweir import com.sun.star.sdbc.XRef;
38*cdf0e10cSrcweir import com.sun.star.sdbc.XRow;
39*cdf0e10cSrcweir import com.sun.star.sdbc.XRowSet;
40*cdf0e10cSrcweir import com.sun.star.sdbc.XRowSetListener;
41*cdf0e10cSrcweir import com.sun.star.sdbcx.XColumnsSupplier;
42*cdf0e10cSrcweir import com.sun.star.uno.UnoRuntime;
43*cdf0e10cSrcweir import com.sun.star.uno.XComponentContext;
44*cdf0e10cSrcweir import com.sun.star.util.Date;
45*cdf0e10cSrcweir import com.sun.star.util.DateTime;
46*cdf0e10cSrcweir import com.sun.star.util.Time;
47*cdf0e10cSrcweir 
48*cdf0e10cSrcweir public class RowSet implements XRowSet, XRow
49*cdf0e10cSrcweir {
50*cdf0e10cSrcweir     private XRowSet                 m_rowSet;
51*cdf0e10cSrcweir     private XRow                    m_row;
52*cdf0e10cSrcweir     private XPropertySet            m_rowSetProps;
53*cdf0e10cSrcweir 
54*cdf0e10cSrcweir     public RowSet( XComponentContext _context, String _dataSource, int _commandType, String _command )
55*cdf0e10cSrcweir     {
56*cdf0e10cSrcweir         try
57*cdf0e10cSrcweir         {
58*cdf0e10cSrcweir             m_rowSetProps = (XPropertySet)UnoRuntime.queryInterface(
59*cdf0e10cSrcweir                 XPropertySet.class, _context.getServiceManager().createInstanceWithContext( "com.sun.star.sdb.RowSet", _context ) );
60*cdf0e10cSrcweir             m_rowSetProps.setPropertyValue( "DataSourceName", _dataSource );
61*cdf0e10cSrcweir             m_rowSetProps.setPropertyValue( "CommandType", new Integer( _commandType ) );
62*cdf0e10cSrcweir             m_rowSetProps.setPropertyValue( "Command", _command );
63*cdf0e10cSrcweir 
64*cdf0e10cSrcweir             m_rowSet = (XRowSet)UnoRuntime.queryInterface( XRowSet.class, m_rowSetProps );
65*cdf0e10cSrcweir             m_row = (XRow)UnoRuntime.queryInterface( XRow.class, m_rowSetProps );
66*cdf0e10cSrcweir         }
67*cdf0e10cSrcweir         catch ( Exception e )
68*cdf0e10cSrcweir         {
69*cdf0e10cSrcweir             e.printStackTrace(System.err);
70*cdf0e10cSrcweir             throw new java.lang.InstantiationError();
71*cdf0e10cSrcweir         }
72*cdf0e10cSrcweir     }
73*cdf0e10cSrcweir 
74*cdf0e10cSrcweir     // misc
75*cdf0e10cSrcweir     public int getColumnCount()
76*cdf0e10cSrcweir     {
77*cdf0e10cSrcweir         XColumnsSupplier suppCols = (XColumnsSupplier)UnoRuntime.queryInterface(
78*cdf0e10cSrcweir             XColumnsSupplier.class, m_rowSet );
79*cdf0e10cSrcweir         XIndexAccess columns = (XIndexAccess)UnoRuntime.queryInterface(
80*cdf0e10cSrcweir             XIndexAccess.class, suppCols.getColumns() );
81*cdf0e10cSrcweir         return columns.getCount();
82*cdf0e10cSrcweir     }
83*cdf0e10cSrcweir 
84*cdf0e10cSrcweir     // XRowSet
85*cdf0e10cSrcweir     public void execute() throws SQLException
86*cdf0e10cSrcweir     {
87*cdf0e10cSrcweir         m_rowSet.execute();
88*cdf0e10cSrcweir     }
89*cdf0e10cSrcweir 
90*cdf0e10cSrcweir     public void addRowSetListener( XRowSetListener _listener )
91*cdf0e10cSrcweir     {
92*cdf0e10cSrcweir         m_rowSet.addRowSetListener( _listener );
93*cdf0e10cSrcweir     }
94*cdf0e10cSrcweir 
95*cdf0e10cSrcweir     public void removeRowSetListener( XRowSetListener _listener )
96*cdf0e10cSrcweir     {
97*cdf0e10cSrcweir         m_rowSet.removeRowSetListener( _listener );
98*cdf0e10cSrcweir     }
99*cdf0e10cSrcweir 
100*cdf0e10cSrcweir     public boolean next() throws SQLException
101*cdf0e10cSrcweir     {
102*cdf0e10cSrcweir         return m_rowSet.next();
103*cdf0e10cSrcweir     }
104*cdf0e10cSrcweir 
105*cdf0e10cSrcweir     public boolean isBeforeFirst() throws SQLException
106*cdf0e10cSrcweir     {
107*cdf0e10cSrcweir         return m_rowSet.isBeforeFirst();
108*cdf0e10cSrcweir     }
109*cdf0e10cSrcweir 
110*cdf0e10cSrcweir     public boolean isAfterLast() throws SQLException
111*cdf0e10cSrcweir     {
112*cdf0e10cSrcweir         return m_rowSet.isAfterLast();
113*cdf0e10cSrcweir     }
114*cdf0e10cSrcweir 
115*cdf0e10cSrcweir     public boolean isFirst() throws SQLException
116*cdf0e10cSrcweir     {
117*cdf0e10cSrcweir         return m_rowSet.isFirst();
118*cdf0e10cSrcweir     }
119*cdf0e10cSrcweir 
120*cdf0e10cSrcweir     public boolean isLast() throws SQLException
121*cdf0e10cSrcweir     {
122*cdf0e10cSrcweir         return m_rowSet.isLast();
123*cdf0e10cSrcweir     }
124*cdf0e10cSrcweir 
125*cdf0e10cSrcweir     public void beforeFirst() throws SQLException
126*cdf0e10cSrcweir     {
127*cdf0e10cSrcweir         m_rowSet.beforeFirst();
128*cdf0e10cSrcweir     }
129*cdf0e10cSrcweir 
130*cdf0e10cSrcweir     public void afterLast() throws SQLException
131*cdf0e10cSrcweir     {
132*cdf0e10cSrcweir         m_rowSet.afterLast();
133*cdf0e10cSrcweir     }
134*cdf0e10cSrcweir 
135*cdf0e10cSrcweir     public boolean first() throws SQLException
136*cdf0e10cSrcweir     {
137*cdf0e10cSrcweir         return m_rowSet.first();
138*cdf0e10cSrcweir     }
139*cdf0e10cSrcweir 
140*cdf0e10cSrcweir     public boolean last() throws SQLException
141*cdf0e10cSrcweir     {
142*cdf0e10cSrcweir         return m_rowSet.last();
143*cdf0e10cSrcweir     }
144*cdf0e10cSrcweir 
145*cdf0e10cSrcweir     public int getRow() throws SQLException
146*cdf0e10cSrcweir     {
147*cdf0e10cSrcweir         return m_rowSet.getRow();
148*cdf0e10cSrcweir     }
149*cdf0e10cSrcweir 
150*cdf0e10cSrcweir     public boolean absolute(int i) throws SQLException
151*cdf0e10cSrcweir     {
152*cdf0e10cSrcweir         return m_rowSet.absolute(i);
153*cdf0e10cSrcweir     }
154*cdf0e10cSrcweir 
155*cdf0e10cSrcweir     public boolean relative(int i) throws SQLException
156*cdf0e10cSrcweir     {
157*cdf0e10cSrcweir         return m_rowSet.relative(i);
158*cdf0e10cSrcweir     }
159*cdf0e10cSrcweir 
160*cdf0e10cSrcweir     public boolean previous() throws SQLException
161*cdf0e10cSrcweir     {
162*cdf0e10cSrcweir         return m_rowSet.previous();
163*cdf0e10cSrcweir     }
164*cdf0e10cSrcweir 
165*cdf0e10cSrcweir     public void refreshRow() throws SQLException
166*cdf0e10cSrcweir     {
167*cdf0e10cSrcweir         m_rowSet.refreshRow();
168*cdf0e10cSrcweir     }
169*cdf0e10cSrcweir 
170*cdf0e10cSrcweir     public boolean rowUpdated() throws SQLException
171*cdf0e10cSrcweir     {
172*cdf0e10cSrcweir         return m_rowSet.rowUpdated();
173*cdf0e10cSrcweir     }
174*cdf0e10cSrcweir 
175*cdf0e10cSrcweir     public boolean rowInserted() throws SQLException
176*cdf0e10cSrcweir     {
177*cdf0e10cSrcweir         return m_rowSet.rowInserted();
178*cdf0e10cSrcweir     }
179*cdf0e10cSrcweir 
180*cdf0e10cSrcweir     public boolean rowDeleted() throws SQLException
181*cdf0e10cSrcweir     {
182*cdf0e10cSrcweir         return m_rowSet.rowDeleted();
183*cdf0e10cSrcweir     }
184*cdf0e10cSrcweir 
185*cdf0e10cSrcweir     // XRow
186*cdf0e10cSrcweir     public Object getStatement() throws SQLException
187*cdf0e10cSrcweir     {
188*cdf0e10cSrcweir         return m_rowSet.getStatement();
189*cdf0e10cSrcweir     }
190*cdf0e10cSrcweir 
191*cdf0e10cSrcweir     public boolean wasNull() throws SQLException
192*cdf0e10cSrcweir     {
193*cdf0e10cSrcweir         return m_row.wasNull();
194*cdf0e10cSrcweir     }
195*cdf0e10cSrcweir 
196*cdf0e10cSrcweir     public String getString(int i) throws SQLException
197*cdf0e10cSrcweir     {
198*cdf0e10cSrcweir         return m_row.getString(i);
199*cdf0e10cSrcweir     }
200*cdf0e10cSrcweir 
201*cdf0e10cSrcweir     public boolean getBoolean(int i) throws SQLException
202*cdf0e10cSrcweir     {
203*cdf0e10cSrcweir         return m_row.getBoolean(i);
204*cdf0e10cSrcweir     }
205*cdf0e10cSrcweir 
206*cdf0e10cSrcweir     public byte getByte(int i) throws SQLException
207*cdf0e10cSrcweir     {
208*cdf0e10cSrcweir         return m_row.getByte(i);
209*cdf0e10cSrcweir     }
210*cdf0e10cSrcweir 
211*cdf0e10cSrcweir     public short getShort(int i) throws SQLException
212*cdf0e10cSrcweir     {
213*cdf0e10cSrcweir         return m_row.getShort(i);
214*cdf0e10cSrcweir     }
215*cdf0e10cSrcweir 
216*cdf0e10cSrcweir     public int getInt(int i) throws SQLException
217*cdf0e10cSrcweir     {
218*cdf0e10cSrcweir         return m_row.getInt(i);
219*cdf0e10cSrcweir     }
220*cdf0e10cSrcweir 
221*cdf0e10cSrcweir     public long getLong(int i) throws SQLException
222*cdf0e10cSrcweir     {
223*cdf0e10cSrcweir         return m_row.getLong(i);
224*cdf0e10cSrcweir     }
225*cdf0e10cSrcweir 
226*cdf0e10cSrcweir     public float getFloat(int i) throws SQLException
227*cdf0e10cSrcweir     {
228*cdf0e10cSrcweir         return m_row.getFloat(i);
229*cdf0e10cSrcweir     }
230*cdf0e10cSrcweir 
231*cdf0e10cSrcweir     public double getDouble(int i) throws SQLException
232*cdf0e10cSrcweir     {
233*cdf0e10cSrcweir         return m_row.getDouble(i);
234*cdf0e10cSrcweir     }
235*cdf0e10cSrcweir 
236*cdf0e10cSrcweir     public byte[] getBytes(int i) throws SQLException
237*cdf0e10cSrcweir     {
238*cdf0e10cSrcweir         return m_row.getBytes(i);
239*cdf0e10cSrcweir     }
240*cdf0e10cSrcweir 
241*cdf0e10cSrcweir     public Date getDate(int i) throws SQLException
242*cdf0e10cSrcweir     {
243*cdf0e10cSrcweir         return m_row.getDate(i);
244*cdf0e10cSrcweir     }
245*cdf0e10cSrcweir 
246*cdf0e10cSrcweir     public Time getTime(int i) throws SQLException
247*cdf0e10cSrcweir     {
248*cdf0e10cSrcweir         return m_row.getTime(i);
249*cdf0e10cSrcweir     }
250*cdf0e10cSrcweir 
251*cdf0e10cSrcweir     public DateTime getTimestamp(int i) throws SQLException
252*cdf0e10cSrcweir     {
253*cdf0e10cSrcweir         return m_row.getTimestamp(i);
254*cdf0e10cSrcweir     }
255*cdf0e10cSrcweir 
256*cdf0e10cSrcweir     public XInputStream getBinaryStream(int i) throws SQLException
257*cdf0e10cSrcweir     {
258*cdf0e10cSrcweir         return m_row.getBinaryStream(i);
259*cdf0e10cSrcweir     }
260*cdf0e10cSrcweir 
261*cdf0e10cSrcweir     public XInputStream getCharacterStream(int i) throws SQLException
262*cdf0e10cSrcweir     {
263*cdf0e10cSrcweir         return m_row.getCharacterStream(i);
264*cdf0e10cSrcweir     }
265*cdf0e10cSrcweir 
266*cdf0e10cSrcweir     public Object getObject(int i, XNameAccess xNameAccess) throws SQLException
267*cdf0e10cSrcweir     {
268*cdf0e10cSrcweir         return m_row.getObject(i, xNameAccess);
269*cdf0e10cSrcweir     }
270*cdf0e10cSrcweir 
271*cdf0e10cSrcweir     public XRef getRef(int i) throws SQLException
272*cdf0e10cSrcweir     {
273*cdf0e10cSrcweir         return m_row.getRef(i);
274*cdf0e10cSrcweir     }
275*cdf0e10cSrcweir 
276*cdf0e10cSrcweir     public XBlob getBlob(int i) throws SQLException
277*cdf0e10cSrcweir     {
278*cdf0e10cSrcweir         return m_row.getBlob(i);
279*cdf0e10cSrcweir     }
280*cdf0e10cSrcweir 
281*cdf0e10cSrcweir     public XClob getClob(int i) throws SQLException
282*cdf0e10cSrcweir     {
283*cdf0e10cSrcweir         return m_row.getClob(i);
284*cdf0e10cSrcweir     }
285*cdf0e10cSrcweir 
286*cdf0e10cSrcweir     public XArray getArray(int i) throws SQLException
287*cdf0e10cSrcweir     {
288*cdf0e10cSrcweir         return m_row.getArray(i);
289*cdf0e10cSrcweir     }
290*cdf0e10cSrcweir };
291