1 /************************************************************** 2 * 3 * Licensed to the Apache Software Foundation (ASF) under one 4 * or more contributor license agreements. See the NOTICE file 5 * distributed with this work for additional information 6 * regarding copyright ownership. The ASF licenses this file 7 * to you under the Apache License, Version 2.0 (the 8 * "License"); you may not use this file except in compliance 9 * with the License. You may obtain a copy of the License at 10 * 11 * http://www.apache.org/licenses/LICENSE-2.0 12 * 13 * Unless required by applicable law or agreed to in writing, 14 * software distributed under the License is distributed on an 15 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 16 * KIND, either express or implied. See the License for the 17 * specific language governing permissions and limitations 18 * under the License. 19 * 20 *************************************************************/ 21 22 23 24 import com.sun.star.beans.XPropertySet; 25 import com.sun.star.container.XIndexAccess; 26 import com.sun.star.container.XNameAccess; 27 import com.sun.star.io.XInputStream; 28 import com.sun.star.lang.XMultiServiceFactory; 29 import com.sun.star.sdbc.SQLException; 30 import com.sun.star.sdbc.XArray; 31 import com.sun.star.sdbc.XBlob; 32 import com.sun.star.sdbc.XClob; 33 import com.sun.star.sdbc.XRef; 34 import com.sun.star.sdbc.XRow; 35 import com.sun.star.sdbc.XRowSet; 36 import com.sun.star.sdbc.XRowSetListener; 37 import com.sun.star.sdbcx.XColumnsSupplier; 38 import com.sun.star.uno.UnoRuntime; 39 import com.sun.star.uno.XComponentContext; 40 import com.sun.star.util.Date; 41 import com.sun.star.util.DateTime; 42 import com.sun.star.util.Time; 43 44 public class RowSet implements XRowSet, XRow 45 { 46 private XRowSet m_rowSet; 47 private XRow m_row; 48 private XPropertySet m_rowSetProps; 49 50 public RowSet( XComponentContext _context, String _dataSource, int _commandType, String _command ) 51 { 52 try 53 { 54 m_rowSetProps = (XPropertySet)UnoRuntime.queryInterface( 55 XPropertySet.class, _context.getServiceManager().createInstanceWithContext( "com.sun.star.sdb.RowSet", _context ) ); 56 m_rowSetProps.setPropertyValue( "DataSourceName", _dataSource ); 57 m_rowSetProps.setPropertyValue( "CommandType", new Integer( _commandType ) ); 58 m_rowSetProps.setPropertyValue( "Command", _command ); 59 60 m_rowSet = (XRowSet)UnoRuntime.queryInterface( XRowSet.class, m_rowSetProps ); 61 m_row = (XRow)UnoRuntime.queryInterface( XRow.class, m_rowSetProps ); 62 } 63 catch ( Exception e ) 64 { 65 e.printStackTrace(System.err); 66 throw new java.lang.InstantiationError(); 67 } 68 } 69 70 // misc 71 public int getColumnCount() 72 { 73 XColumnsSupplier suppCols = (XColumnsSupplier)UnoRuntime.queryInterface( 74 XColumnsSupplier.class, m_rowSet ); 75 XIndexAccess columns = (XIndexAccess)UnoRuntime.queryInterface( 76 XIndexAccess.class, suppCols.getColumns() ); 77 return columns.getCount(); 78 } 79 80 // XRowSet 81 public void execute() throws SQLException 82 { 83 m_rowSet.execute(); 84 } 85 86 public void addRowSetListener( XRowSetListener _listener ) 87 { 88 m_rowSet.addRowSetListener( _listener ); 89 } 90 91 public void removeRowSetListener( XRowSetListener _listener ) 92 { 93 m_rowSet.removeRowSetListener( _listener ); 94 } 95 96 public boolean next() throws SQLException 97 { 98 return m_rowSet.next(); 99 } 100 101 public boolean isBeforeFirst() throws SQLException 102 { 103 return m_rowSet.isBeforeFirst(); 104 } 105 106 public boolean isAfterLast() throws SQLException 107 { 108 return m_rowSet.isAfterLast(); 109 } 110 111 public boolean isFirst() throws SQLException 112 { 113 return m_rowSet.isFirst(); 114 } 115 116 public boolean isLast() throws SQLException 117 { 118 return m_rowSet.isLast(); 119 } 120 121 public void beforeFirst() throws SQLException 122 { 123 m_rowSet.beforeFirst(); 124 } 125 126 public void afterLast() throws SQLException 127 { 128 m_rowSet.afterLast(); 129 } 130 131 public boolean first() throws SQLException 132 { 133 return m_rowSet.first(); 134 } 135 136 public boolean last() throws SQLException 137 { 138 return m_rowSet.last(); 139 } 140 141 public int getRow() throws SQLException 142 { 143 return m_rowSet.getRow(); 144 } 145 146 public boolean absolute(int i) throws SQLException 147 { 148 return m_rowSet.absolute(i); 149 } 150 151 public boolean relative(int i) throws SQLException 152 { 153 return m_rowSet.relative(i); 154 } 155 156 public boolean previous() throws SQLException 157 { 158 return m_rowSet.previous(); 159 } 160 161 public void refreshRow() throws SQLException 162 { 163 m_rowSet.refreshRow(); 164 } 165 166 public boolean rowUpdated() throws SQLException 167 { 168 return m_rowSet.rowUpdated(); 169 } 170 171 public boolean rowInserted() throws SQLException 172 { 173 return m_rowSet.rowInserted(); 174 } 175 176 public boolean rowDeleted() throws SQLException 177 { 178 return m_rowSet.rowDeleted(); 179 } 180 181 // XRow 182 public Object getStatement() throws SQLException 183 { 184 return m_rowSet.getStatement(); 185 } 186 187 public boolean wasNull() throws SQLException 188 { 189 return m_row.wasNull(); 190 } 191 192 public String getString(int i) throws SQLException 193 { 194 return m_row.getString(i); 195 } 196 197 public boolean getBoolean(int i) throws SQLException 198 { 199 return m_row.getBoolean(i); 200 } 201 202 public byte getByte(int i) throws SQLException 203 { 204 return m_row.getByte(i); 205 } 206 207 public short getShort(int i) throws SQLException 208 { 209 return m_row.getShort(i); 210 } 211 212 public int getInt(int i) throws SQLException 213 { 214 return m_row.getInt(i); 215 } 216 217 public long getLong(int i) throws SQLException 218 { 219 return m_row.getLong(i); 220 } 221 222 public float getFloat(int i) throws SQLException 223 { 224 return m_row.getFloat(i); 225 } 226 227 public double getDouble(int i) throws SQLException 228 { 229 return m_row.getDouble(i); 230 } 231 232 public byte[] getBytes(int i) throws SQLException 233 { 234 return m_row.getBytes(i); 235 } 236 237 public Date getDate(int i) throws SQLException 238 { 239 return m_row.getDate(i); 240 } 241 242 public Time getTime(int i) throws SQLException 243 { 244 return m_row.getTime(i); 245 } 246 247 public DateTime getTimestamp(int i) throws SQLException 248 { 249 return m_row.getTimestamp(i); 250 } 251 252 public XInputStream getBinaryStream(int i) throws SQLException 253 { 254 return m_row.getBinaryStream(i); 255 } 256 257 public XInputStream getCharacterStream(int i) throws SQLException 258 { 259 return m_row.getCharacterStream(i); 260 } 261 262 public Object getObject(int i, XNameAccess xNameAccess) throws SQLException 263 { 264 return m_row.getObject(i, xNameAccess); 265 } 266 267 public XRef getRef(int i) throws SQLException 268 { 269 return m_row.getRef(i); 270 } 271 272 public XBlob getBlob(int i) throws SQLException 273 { 274 return m_row.getBlob(i); 275 } 276 277 public XClob getClob(int i) throws SQLException 278 { 279 return m_row.getClob(i); 280 } 281 282 public XArray getArray(int i) throws SQLException 283 { 284 return m_row.getArray(i); 285 } 286 }; 287