Examples of org.apache.derby.jdbc.EmbeddedDataSource

org.apache.derby.jdbc.EmbeddedDataSource
me is the database name // if create is true, create the database if necessary javax.sql.DataSource makeDataSource (String dbname, boolean create) throws Throwable { EmbeddedDataSource ds = new EmbeddedDataSource(); ds.setDatabaseName(dbname); if (create) ds.setCreateDatabase("create"); return ds; }
Example of setting properties thru reflection. This code is typically generated by tools or written by a system integrator:
```
 javax.sql.DataSource makeDataSource(String dbname)  throws Throwable  { Class[] parameter = new Class[1]; parameter[0] = dbname.getClass(); DataSource ds =  new EmbeddedDataSource(); Class cl = ds.getClass(); Method setName = cl.getMethod("setDatabaseName", parameter); Object[] arg = new Object[1]; arg[0] = dbname; setName.invoke(ds, arg); return ds; } 
```
Example on how to register a data source object with a JNDI naming service.
```
 DataSource ds = makeDataSource("mydb"); Context ctx = new InitialContext(); ctx.bind("jdbc/MyDB", ds); 
```
Example on how to retrieve a data source object from a JNDI naming service.
```
 Context ctx = new InitialContext(); DataSource ds = (DataSource)ctx.lookup("jdbc/MyDB"); 
```

     * It attempts to recreate the tables everytime the test is executed.
     *
     * @return PersistenceAdapter - persistence adapter.
     */
    protected PersistenceAdapter createPersistenceAdapter() {
        EmbeddedDataSource ds = new EmbeddedDataSource();
        ds.setDatabaseName("testdb");
        if (!init) {
            ds.setCreateDatabase("create");
        }


        JDBCPersistenceAdapter persistenceAdapter = new JDBCPersistenceAdapter(ds, new DefaultWireFormat());


        if (!init) {

View Full Code Here

        broker.start();
    }


    private void stopDerby() {
        LOG.info("STOPPING DB!@!!!!");
        final EmbeddedDataSource ds = dataSource;
        try {
            ds.setShutdownDatabase("shutdown");
            ds.getConnection();
        } catch (Exception ignored) {
        }


    }

View Full Code Here

 */
public class JDBCDurableSubscriptionTest extends DurableSubscriptionTestSupport {


    protected PersistenceAdapter createPersistenceAdapter() throws IOException {
        JDBCPersistenceAdapter jdbc = new JDBCPersistenceAdapter();
        EmbeddedDataSource dataSource = new EmbeddedDataSource();
        dataSource.setDatabaseName("derbyDb");
        dataSource.setCreateDatabase("create");
        jdbc.setDataSource(dataSource);
        jdbc.setCleanupPeriod(1000); // set up small cleanup period
        return jdbc;
    }

View Full Code Here

    JDBCPersistenceAdapter jdbc;


    @Override
    protected PersistenceAdapter createPersistenceAdapter(boolean delete) throws Exception {
        jdbc = new JDBCPersistenceAdapter();
        dataSource = new EmbeddedDataSource();
        dataSource.setDatabaseName("derbyDb");
        dataSource.setCreateDatabase("create");
        dataSource.setShutdownDatabase(null);
        jdbc.setDataSource(dataSource);
        jdbc.deleteAllMessages();

View Full Code Here

public class JDBCStoreBrokerTest extends BrokerTest {


    protected BrokerService createBroker() throws Exception {
        BrokerService broker = new BrokerService();
        JDBCPersistenceAdapter jdbc = new JDBCPersistenceAdapter();
        EmbeddedDataSource dataSource = new EmbeddedDataSource();
        dataSource.setDatabaseName("derbyDb");
        dataSource.setCreateDatabase("create");
        jdbc.setDataSource(dataSource);
        
        jdbc.deleteAllMessages();
        broker.setPersistenceAdapter(jdbc);
        return broker;

View Full Code Here

    }
    
    protected BrokerService createRestartedBroker() throws Exception {
        BrokerService broker = new BrokerService();
        JDBCPersistenceAdapter jdbc = new JDBCPersistenceAdapter();
        EmbeddedDataSource dataSource = new EmbeddedDataSource();
        dataSource.setDatabaseName("derbyDb");
        dataSource.setCreateDatabase("create");
        jdbc.setDataSource(dataSource);
        broker.setPersistenceAdapter(jdbc);
        return broker;
    }

View Full Code Here

        jdbc.setEnableAudit(true);
        
        brokerService.setSchedulerSupport(false);
        brokerService.setPersistenceAdapter(jdbc);
        jdbc.setBrokerService(brokerService);
        EmbeddedDataSource dataSource = new EmbeddedDataSource();
        dataSource.setDatabaseName("derbyDb");
        dataSource.setCreateDatabase("create");
        jdbc.setDataSource(dataSource);
        if( delete ) {
            jdbc.deleteAllMessages();
        }
        return jdbc;

View Full Code Here

    protected BrokerService createBroker() throws Exception {


        BrokerService broker = new BrokerService();
        jdbc = new BrokenPersistenceAdapter();


        dataSource = new EmbeddedDataSource();
        dataSource.setDatabaseName("target/derbyDb");
        dataSource.setCreateDatabase("create");


        jdbc.setDataSource(dataSource);
        jdbc.setUseLock(false);

View Full Code Here

    
     @Override
     protected void setPersistentAdapter(BrokerService brokerService)
             throws Exception {
        JDBCPersistenceAdapter jdbc = new JDBCPersistenceAdapter();
        EmbeddedDataSource dataSource = new EmbeddedDataSource();
        dataSource.setDatabaseName("derbyDb");
        dataSource.setCreateDatabase("create");
        jdbc.setDataSource(dataSource);
        brokerService.setPersistenceAdapter(jdbc);
    }

View Full Code Here


public class JDBCNetworkBrokerDetachTest extends NetworkBrokerDetachTest {


    protected void configureBroker(BrokerService broker) throws Exception {
        JDBCPersistenceAdapter jdbc = new JDBCPersistenceAdapter();
        EmbeddedDataSource dataSource = new EmbeddedDataSource();
        dataSource.setDatabaseName(broker.getBrokerName());
        dataSource.setCreateDatabase("create");
        jdbc.setDataSource(dataSource);
        jdbc.deleteAllMessages();
        broker.setPersistenceAdapter(jdbc);
        broker.setUseVirtualTopics(false);
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.apache.derby.jdbc.EmbeddedDataSource

ca.eandb.jdcp.console.HubState

ca.eandb.jdcp.console.ServerState

ca.eandb.jdcp.console.WorkerState

ca.eandb.jdcp.server.JobServerMain

ca.eandb.jdcp.worker.MainWindow

com.googlecode.righettod.jse7.NewFeaturesExplorationTest

DatabaseManager

net.lr.tutorial.karaf.db.example.DbExampleTest

net.lr.tutorial.karaf.db.examplejpa.PersonServiceImplTest

org.activemq.broker.impl.DefaultPersistenceAdapterFactory

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.