tomee-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Romain Manni-Bucau <rmannibu...@gmail.com>
Subject Re: AW: AW: Fired cron trigger not available
Date Tue, 03 Sep 2013 15:44:58 GMT
here is a sample test
http://svn.apache.org/repos/asf/tomee/tomee/trunk/container/openejb-core/src/test/java/org/apache/openejb/timer/QuartzPersistenceForEJBTimersTest.java

it uses this init script:
http://svn.apache.org/repos/asf/tomee/tomee/trunk/container/openejb-core/src/test/resources/import-QuartzPersistenceForEJBTimersDBNoTx.sql

*Romain Manni-Bucau*
*Twitter: @rmannibucau <https://twitter.com/rmannibucau>*
*Blog: **http://rmannibucau.wordpress.com/*<http://rmannibucau.wordpress.com/>
*LinkedIn: **http://fr.linkedin.com/in/rmannibucau*
*Github: https://github.com/rmannibucau*



2013/9/3 Romain Manni-Bucau <rmannibucau@gmail.com>

> /*
> * Licensed to the Apache Software Foundation (ASF) under one or more
> * contributor license agreements.  See the NOTICE file distributed with
> * this work for additional information regarding copyright ownership.
> * The ASF licenses this file to You under the Apache License, Version 2.0
> * (the "License"); you may not use this file except in compliance with
> * the License.  You may obtain a copy of the License at
> *
> *     http://www.apache.org/licenses/LICENSE-2.0
> *
> * Unless required by applicable law or agreed to in writing, software
> * distributed under the License is distributed on an "AS IS" BASIS,
> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
> * See the License for the specific language governing permissions and
> * limitations under the License.
> */
> package org.apache.openejb.resource.jdbc;
>
> import org.apache.openejb.jee.EjbJar;
> import org.apache.openejb.jee.SingletonBean;
> import org.apache.openejb.junit.ApplicationComposer;
> import org.apache.openejb.testing.Configuration;
> import org.apache.openejb.testing.Module;
> import org.apache.openejb.resource.jdbc.managed.local.ManagedConnection;
> import org.junit.After;
> import org.junit.BeforeClass;
> import org.junit.Test;
> import org.junit.runner.RunWith;
>
> import javax.annotation.Resource;
> import javax.ejb.EJB;
> import javax.ejb.EJBContext;
> import javax.ejb.LocalBean;
> import javax.ejb.Singleton;
> import javax.ejb.TransactionAttribute;
> import javax.ejb.TransactionAttributeType;
> import javax.sql.DataSource;
> import javax.transaction.Transaction;
> import java.lang.reflect.Field;
> import java.sql.Connection;
> import java.sql.DriverManager;
> import java.sql.ResultSet;
> import java.sql.SQLException;
> import java.sql.Statement;
> import java.util.Map;
> import java.util.Properties;
>
> import static org.junit.Assert.assertEquals;
> import static org.junit.Assert.assertFalse;
> import static org.junit.Assert.assertTrue;
>
> @RunWith(ApplicationComposer.class)
> public class ManagedDataSourceTest {
>     private static final String URL =
> "jdbc:hsqldb:mem:managed;hsqldb.tx=MVCC"; // mvcc otherwise multiple
> transaction tests will fail
>     private static final String USER = "sa";
>     private static final String PASSWORD = "";
>     private static final String TABLE = "PUBLIC.MANAGED_DATASOURCE_TEST";
>
>     @EJB
>     private Persister persistManager;
>
>     @Resource
>     private DataSource ds;
>
>     @BeforeClass
>     public static void createTable() throws SQLException,
> ClassNotFoundException {
>         Class.forName("org.hsqldb.jdbcDriver");
>
>         final Connection connection = DriverManager.getConnection(URL,
> USER, PASSWORD);
>         final Statement statement = connection.createStatement();
>         statement.execute("CREATE TABLE " + TABLE + "(ID INTEGER)");
>         statement.close();
>         connection.commit();
>         connection.close();
>     }
>
>     @Configuration
>     public Properties config() {
>         final Properties p = new Properties();
>         p.put("openejb.jdbc.datasource-creator", "dbcp-alternative");
>
>         p.put("managed", "new://Resource?type=DataSource");
>         p.put("managed.JdbcDriver", "org.hsqldb.jdbcDriver");
>         p.put("managed.JdbcUrl", URL);
>         p.put("managed.UserName", USER);
>         p.put("managed.Password", PASSWORD);
>         p.put("managed.JtaManaged", "true");
>         return p;
>     }
>
>     @Module
>     public EjbJar app() throws Exception {
>         return new EjbJar()
>                 .enterpriseBean(new
> SingletonBean(Persister.class).localBean())
>                 .enterpriseBean(new
> SingletonBean(OtherPersister.class).localBean());
>     }
>
>     @LocalBean
>     @Singleton
>     @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
>     public static class OtherPersister {
>         @Resource(name = "managed")
>         private DataSource ds;
>
>         @Resource
>         private EJBContext context;
>
>         public void save() throws SQLException {
>             ManagedDataSourceTest.save(ds, 10);
>         }
>
>         public void saveAndRollback() throws SQLException {
>             ManagedDataSourceTest.save(ds, 11);
>             context.setRollbackOnly();
>         }
>     }
>
>     @LocalBean
>     @Singleton
>     public static class Persister {
>         @Resource(name = "managed")
>         private DataSource ds;
>
>         @Resource
>         private EJBContext context;
>
>         @EJB
>         private OtherPersister other;
>
>         public void save() throws SQLException {
>             ManagedDataSourceTest.save(ds, 1);
>         }
>
>         public void saveAndRollback() throws SQLException {
>             ManagedDataSourceTest.save(ds, 2);
>             context.setRollbackOnly();
>         }
>
>         public void saveTwice() throws SQLException {
>             ManagedDataSourceTest.save(ds, 3);
>             ManagedDataSourceTest.save(ds, 4);
>     }
>
>         public void rollbackMultipleSave() throws SQLException {
>             ManagedDataSourceTest.save(ds, 5);
>             ManagedDataSourceTest.save(ds, 6);
>             context.setRollbackOnly();
>         }
>
>         public void saveInThisTxAndAnotherOne() throws SQLException {
>             ManagedDataSourceTest.save(ds, 7);
>             other.save();
>         }
>
>         public void saveInThisTxAndRollbackInAnotherOne() throws
> SQLException {
>             ManagedDataSourceTest.save(ds, 8);
>             other.saveAndRollback();
>         }
>     }
>
>     @Test
>     public void commit() throws SQLException {
>         persistManager.save();
>         assertTrue(exists(1));
>     }
>
>     @Test
>     public void rollback() throws SQLException {
>         persistManager.saveAndRollback();
>         assertFalse(exists(2));
>     }
>
>     @Test
>     public void commit2() throws SQLException {
>         persistManager.saveTwice();
>         assertTrue(exists(3));
>         assertTrue(exists(4));
>     }
>
>     @Test
>     public void rollback2() throws SQLException {
>         persistManager.rollbackMultipleSave();
>         assertFalse(exists(5));
>         assertFalse(exists(6));
>     }
>
>     @Test
>     public void saveDifferentTx() throws SQLException {
>         persistManager.saveInThisTxAndAnotherOne();
>         assertTrue(exists(7));
>         assertTrue(exists(10));
>     }
>
>     @Test
>     public void saveRollbackDifferentTx() throws SQLException {
>         persistManager.saveInThisTxAndRollbackInAnotherOne();
>         assertTrue(exists(8));
>         assertFalse(exists(12));
>     }
>
>     @After
>     public void checkTxMapIsEmpty() throws Exception { // avoid memory leak
>         final Field map =
> ManagedConnection.class.getDeclaredField("CONNECTION_BY_TX_BY_DS");
>         map.setAccessible(true);
>         final Map<DataSource, Map<Transaction, Connection>>  instance =
> (Map<DataSource, Map<Transaction, Connection>> ) map.get(null);
>         assertEquals(1, instance.size());
>         assertEquals(0, instance.values().iterator().next().size());
>     }
>
>     private static boolean exists(int id) throws SQLException {
>         final Connection connection = DriverManager.getConnection(URL,
> USER, PASSWORD);
>         final Statement statement = connection.createStatement();
>         final ResultSet result = statement.executeQuery("SELECT count(*)
> AS NB FROM " + TABLE + " WHERE ID = " + id);
>         try {
>             assertTrue(result.next());
>             return result.getInt(1) == 1;
>         } finally {
>             statement.close();
>             connection.close();
>         }
>     }
>
>     private static void save(final DataSource ds, int id) throws
> SQLException {
>         execute(ds, "INSERT INTO " + TABLE + "(ID) VALUES(" + id + ")");
>     }
>
>     private static void execute(final DataSource ds, final String sql)
> throws SQLException {
>         final Connection connection = ds.getConnection();
>         final Statement statement = connection.createStatement();
>         statement.executeUpdate(sql);
>         statement.close();
>         connection.close();
>     }
> }
> Le 3 sept. 2013 12:01, "tschuler" <thomas.schuler@opentext.com> a écrit :
>
>  Hi Romain!
>>
>> Can you directly post the ManagedDataSourceTest.java file because I got
>> connection timeouts accessing the apache tomee svn repository.
>>
>> Best regards,
>>                 Thomas
>>
>> Von: Romain Manni-Bucau [via OpenEJB] [mailto:
>> ml-node+s979440n4664964h94@n4.nabble.com]
>> Gesendet: Dienstag, 3. September 2013 09:50
>> An: Thomas Schuler
>> Betreff: Re: AW: Fired cron trigger not available
>>
>> Hi
>>
>> This test defines a datasource called 'managed'
>>
>> http://svn.apache.org/repos/asf/tomee/tomee/trunk/container/openejb-core/src/test/java/org/apache/openejb/resource/jdbc/ManagedDataSourceTest.java
>>
>> Just add in src/test/resources a file import-managed.sql with a statement
>> by line created from hsql scripts of quartz
>> Le 3 sept. 2013 09:33, "tschuler" <[hidden
>> email]</user/SendEmail.jtp?type=node&node=4664964&i=0>> a écrit
:
>>
>> > Hi Romain!
>> >
>> > As I am neither familiar with the application composer and the in memory
>> > database:
>> > Can you provide me a running example how to initialize and use the in
>> > memory
>> > database for tests?
>> >
>> > Best regards,
>> > Thomas
>> >
>> >
>> >
>> > --
>> > View this message in context:
>> >
>> http://openejb.979440.n4.nabble.com/Fired-cron-trigger-not-available-tp4664936p4664963.html
>> > Sent from the OpenEJB User mailing list archive at Nabble.com.
>> >
>>
>> ________________________________
>> If you reply to this email, your message will be added to the discussion
>> below:
>>
>> http://openejb.979440.n4.nabble.com/Fired-cron-trigger-not-available-tp4664936p4664964.html
>> To unsubscribe from Fired cron trigger not available, click here<
>> http://openejb.979440.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=4664936&code=dGhvbWFzLnNjaHVsZXJAb3BlbnRleHQuY29tfDQ2NjQ5MzZ8LTE4NTIyNTQ0OTI=
>> >.
>> NAML<
>> http://openejb.979440.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml
>> >
>>
>>
>>
>>
>> --
>> View this message in context:
>> http://openejb.979440.n4.nabble.com/Fired-cron-trigger-not-available-tp4664936p4664969.html
>> Sent from the OpenEJB User mailing list archive at Nabble.com.
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message