User: obo Date: 2006/07/10 07:59:30 Modified: dba/dbaccess/qa/complex/dbaccess/RowSet.java
Log: INTEGRATION: CWS qiq (1.6.56); FILE MERGED 2006/06/26 21:16:41 fs 1.6.56.2: testConcurrentAccess: be more challenging 2006/06/26 21:09:09 fs 1.6.56.1: moved HsqlDatabase to package connectivity.tools File Changes: Directory: /dba/dbaccess/qa/complex/dbaccess/ ============================================= File [changed]: RowSet.java Url: http://dba.openoffice.org/source/browse/dba/dbaccess/qa/complex/dbaccess/RowSet.java?r1=1.6&r2=1.7 Delta lines: +10 -15 --------------------- --- RowSet.java 6 Feb 2006 16:53:01 -0000 1.6 +++ RowSet.java 10 Jul 2006 14:59:27 -0000 1.7 @@ -34,27 +34,18 @@ ************************************************************************/ package complex.dbaccess; -import com.sun.star.awt.XWindow; -import com.sun.star.frame.*; -import com.sun.star.text.XTextDocument; import com.sun.star.uno.UnoRuntime; -import com.sun.star.util.XCloseable; import com.sun.star.beans.*; import com.sun.star.lang.*; import com.sun.star.sdbcx.*; import com.sun.star.sdbc.*; import com.sun.star.sdb.*; -import com.sun.star.container.*; import com.sun.star.lang.XMultiServiceFactory; +import com.sun.star.util.XRefreshable; +import connectivity.tools.HsqlDatabase; import complexlib.ComplexTestCase; - -import java.io.PrintWriter; -import java.io.File; -import java.util.Random; - -import util.utils; -import util.dbg; +import complexlib.ComplexTestCase.AssureException; public class RowSet extends ComplexTestCase { @@ -218,8 +209,8 @@ // -------------------------------------------------------------------------------------------------------- void createStruture() throws SQLException { - m_database.executeStatement( "DROP TABLE \"TEST1\" IF EXISTS" ); - m_database.executeStatement( "CREATE TABLE \"TEST1\" (\"ID\" integer not null primary key, \"col2\" varchar(50) )" ); + m_database.executeSQL( "DROP TABLE \"TEST1\" IF EXISTS" ); + m_database.executeSQL( "CREATE TABLE \"TEST1\" (\"ID\" integer not null primary key, \"col2\" varchar(50) )" ); XConnection connection = m_database.defaultConnection(); XPreparedStatement prep = connection.prepareStatement("INSERT INTO \"TEST1\" values (?,?)"); @@ -229,6 +220,10 @@ para.setString(2, "Test" + i); prep.executeUpdate(); } + + XTablesSupplier suppTables = (XTablesSupplier)UnoRuntime.queryInterface( XTablesSupplier.class, connection ); + XRefreshable refresh = (XRefreshable)UnoRuntime.queryInterface( XRefreshable.class, suppTables.getTables() ); + refresh.refresh(); } // -------------------------------------------------------------------------------------------------------- @@ -328,7 +323,7 @@ XRow _row = (XRow)UnoRuntime.queryInterface(XRow.class,_resultSet); _resultSet.beforeFirst(); - final int numberOfThreads = 2; + final int numberOfThreads = 10; Thread threads[] = new Thread[numberOfThreads]; for ( int i=0; i<numberOfThreads; ++i ) --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
