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.
>
>
|