import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Singleton
@Provides
LinkRestRuntime provideLinkRestRuntime(
        Injector injector,
        Set<LrFeatureProvider> featureProviders,
        Set<LinkRestAdapter> adapters) {

    LinkRestBuilder builder;

    Binding<ServerRuntime> binding = injector.getExistingBinding(Key.get(ServerRuntime.class));
    if (binding == null) {
        builder = new LinkRestBuilder().cayenneService(new PojoCayennePersister());
    } else {
        ServerRuntime cayenneRuntime = binding.getProvider().get();
        builder = new LinkRestBuilder().cayenneRuntime(cayenneRuntime);
    }

    featureProviders.forEach(builder::feature);
    adapters.forEach(builder::adapter);

    return builder.build();
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
static Table[] tablesInInsertOrder(BQRuntime runtime, Collection<DbEntity> dbEntities) {

        // note: do not obtain sorter from Cayenne DI. It is not a singleton and will come
        // uninitialized
        ServerRuntime serverRuntime = runtime.getInstance(ServerRuntime.class);
        EntitySorter sorter = serverRuntime.getDataDomain().getEntitySorter();

        List<DbEntity> list = new ArrayList<>(dbEntities);
        sorter.sortDbEntities(list, false);

        DatabaseChannel channel = DatabaseChannel.get(runtime);

        Table[] tables = new Table[list.size()];
        for (int i = 0; i < tables.length; i++) {
            tables[i] = createTableModel(channel, list.get(i));
        }
        return tables;
    }
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
/**
 * Creates and returns a preconfigured {@link ServerRuntimeBuilder} with
 * Cayenne config, name, Java8 integration module and a DataSource. Override
 * to add custom modules, extra projects, etc.
 *
 * @param dataSourceFactory injected Bootique {@link DataSourceFactory}
 * @return a {@link ServerRuntimeBuilder} that can be extended in
 * subclasses.
 */
protected ServerRuntimeBuilder cayenneBuilder(DataSourceFactory dataSourceFactory) {

    // building our own Cayenne extensions module...
    return ServerRuntime.builder(name).addModule(binder -> {

        // provide schema creation hook
        if (createSchema) {
            binder.bind(SchemaUpdateStrategyFactory.class).toInstance(descriptor -> new CreateIfNoSchemaStrategy());
        }

        DefaultDataSourceName defaultDataSourceName = defaultDataSourceName(dataSourceFactory);
        binder.bind(Key.get(DefaultDataSourceName.class)).toInstance(defaultDataSourceName);
        binder.bindList(DataMapConfig.class).addAll(maps);

        // provide default DataNode
        // TODO: copied from Cayenne, as the corresponding provider is not public or rather
        // until https://issues.apache.org/jira/browse/CAY-2095 is implemented
        binder.bind(DataDomain.class).toProvider(SyntheticNodeDataDomainProvider.class);

        // Bootique DataSource hooks...
        BQCayenneDataSourceFactory bqCayenneDSFactory =
                new BQCayenneDataSourceFactory(dataSourceFactory, datasource, maps);
        binder.bind(org.apache.cayenne.configuration.server.DataSourceFactory.class).toInstance(bqCayenneDSFactory);
    });
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Test
public void testCreateCayenneRuntime_NoName() {
	ServerRuntimeFactory factory = new ServerRuntimeFactory();
	factory.setDatasource("ds1");

	ServerRuntime runtime = factory.createCayenneRuntime(mockDSFactory, Collections.emptyList());
	try {
		DataDomain domain = runtime.getDataDomain();
		assertEquals("cayenne", domain.getName());

		assertEquals(1, domain.getDataNodes().size());
		assertNotNull(domain.getDefaultNode());
		assertEquals("cayenne", domain.getDefaultNode().getName());

	} finally {
		runtime.shutdown();
	}
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Test
public void testCreateCayenneRuntime_Name() {
	ServerRuntimeFactory factory = new ServerRuntimeFactory();
	factory.setConfigs(asList("cayenne-project1.xml"));
	factory.setDatasource("ds1");
	factory.setName("me");

	ServerRuntime runtime = factory.createCayenneRuntime(mockDSFactory, Collections.emptyList());
	try {

		DataDomain domain = runtime.getDataDomain();
		assertEquals("me", domain.getName());

		assertEquals(1, domain.getDataNodes().size());
		assertNotNull(domain.getDefaultNode());
		assertEquals("me", domain.getDefaultNode().getName());

	} finally {
		runtime.shutdown();
	}
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Test
public void testCreateCayenneRuntime_Configs() {
	ServerRuntimeFactory factory = new ServerRuntimeFactory();
	factory.setDatasource("ds1");
	factory.setConfigs(asList("cayenne-project2.xml", "cayenne-project1.xml"));

	ServerRuntime runtime = factory.createCayenneRuntime(mockDSFactory, Collections.emptyList());
	try {

		DataDomain domain = runtime.getDataDomain();
		assertNotNull(domain.getEntityResolver().getDbEntity("db_entity"));
		assertNotNull(domain.getEntityResolver().getDbEntity("db_entity2"));

	} finally {
		runtime.shutdown();
	}
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Test
public void testConfig_ExplicitMaps_SharedDatasource() {

    ServerRuntime runtime = testFactory.app("--config=classpath:config_explicit_maps.yml")
            .autoLoadModules()
            .createRuntime()
            .getInstance(ServerRuntime.class);

    DataDomain domain = runtime.getDataDomain();
    assertNotNull(domain.getEntityResolver().getDbEntity("db_entity"));
    assertNotNull(domain.getEntityResolver().getDbEntity("db_entity2"));

    // trigger a DB op
    SQLSelect.dataRowQuery("map1", "SELECT * FROM db_entity").select(runtime.newContext());
    SQLSelect.dataRowQuery("map2", "SELECT * FROM db_entity2").select(runtime.newContext());
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Test
public void testConfig_ExplicitMaps_DifferentDatasources() {

    ServerRuntime runtime = testFactory.app("--config=classpath:config_explicit_maps_2.yml")
            .autoLoadModules()
            .createRuntime()
            .getInstance(ServerRuntime.class);

    DataDomain domain = runtime.getDataDomain();
    assertNotNull(domain.getEntityResolver().getDbEntity("db_entity"));
    assertNotNull(domain.getEntityResolver().getDbEntity("db_entity2"));

    // trigger a DB op
    SQLSelect.dataRowQuery("map1", "SELECT * FROM db_entity").select(runtime.newContext());
    SQLSelect.dataRowQuery("map2", "SELECT * FROM db_entity2").select(runtime.newContext());
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Test
public void testDefaultDataSource() throws SQLException {

    ServerRuntime runtime = testFactory.app("--config=classpath:noconfig.yml")
            .autoLoadModules()
            .createRuntime()
            .getInstance(ServerRuntime.class);

    DataDomain domain = runtime.getDataDomain();
    assertNotNull(domain.getDataNode("cayenne"));

    try(Connection c = domain.getDataNode("cayenne").getDataSource().getConnection();) {
        DatabaseMetaData md = c.getMetaData();
        assertEquals("jdbc:derby:target/derby/bqjdbc_noconfig", md.getURL());
    }
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Test
public void testUndefinedDataSource() throws SQLException {

    ServerRuntime runtime = testFactory.app("--config=classpath:noconfig_2ds.yml")
            .autoLoadModules()
            .createRuntime()
            .getInstance(ServerRuntime.class);

    try {
        runtime.getDataDomain();
    }
    catch (DataDomainLoadException e) {
        assertTrue(e.getCause().getMessage()
                .startsWith("Can't map Cayenne DataSource: 'cayenne.datasource' is missing."));
    }
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Test
public void testUnmatchedDataSource() throws SQLException {

    ServerRuntime runtime = testFactory.app("--config=classpath:noconfig_2ds_unmatched.yml")
            .autoLoadModules()
            .createRuntime()
            .getInstance(ServerRuntime.class);

    try {
        runtime.getDataDomain();
        fail();
    }
    catch (DataDomainLoadException e) {
        String message = e.getCause().getMessage();
        assertEquals("No configuration present for DataSource named 'ds3'", message);
    }
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Test
public void testContributeModules() {

    Module guiceModule = b -> {
        org.apache.cayenne.di.Module cayenneModule = (cb) -> cb.bind(CayenneModuleIT.class).toInstance(this);
        CayenneModule.extend(b).addModule(cayenneModule);
    };

    ServerRuntime runtime = testFactory.app("--config=classpath:fullconfig.yml")
            .autoLoadModules()
            .module(guiceModule)
            .createRuntime()
            .getInstance(ServerRuntime.class);

    assertSame(this, runtime.getInjector().getInstance(CayenneModuleIT.class));
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@BeforeClass
public static void beforeClass() {

    InvalidationHandler invalidationHandler = type -> {
        if (type.getAnnotation(CacheGroups.class) != null) {
            return null;
        }

        return p -> asList(new CacheGroupDescriptor("cayenne1"), new CacheGroupDescriptor("nocayenne1"));
    };

    TEST_RUNTIME = TEST_FACTORY.app("-c", "classpath:bq1.yml")
            .autoLoadModules()
            .module(b -> CayenneJCacheModule.extend(b).addInvalidationHandler(invalidationHandler))
            .createRuntime();
    SERVER_RUNTIME = TEST_RUNTIME.getInstance(ServerRuntime.class);
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Before
public void before() {

	ds1 = mock(DataSource.class);
	ds2 = mock(DataSource.class);

	DataNode dn1 = mock(DataNode.class);
	when(dn1.getName()).thenReturn("dn1");
	when(dn1.getDataSource()).thenReturn(ds1);

	DataNode dn2 = mock(DataNode.class);
	when(dn2.getName()).thenReturn("dn2");
	when(dn2.getDataSource()).thenReturn(ds2);

	DataDomain domain = new DataDomain("dd");
	domain.addNode(dn1);
	domain.addNode(dn2);

	ServerRuntime runtime = mock(ServerRuntime.class);
	when(runtime.getDataDomain()).thenReturn(domain);

	cayenneService = new TargetCayenneService(runtime);
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Override
public Application configure() {

	EntityResolver mockResolver = mock(EntityResolver.class);
	DataChannel mockChannel = mock(DataChannel.class);
	when(mockChannel.getEntityResolver()).thenReturn(mockResolver);

	ServerRuntime runtime = mock(ServerRuntime.class);
	when(runtime.getChannel()).thenReturn(mockChannel);

	Feature lrFeature = LinkRestBuilder.build(runtime);

	Feature testFeature = new Feature() {

		@Override
		public boolean configure(FeatureContext context) {
			context.register(ExceptionResource.class);
			return true;
		}
	};

	return new ResourceConfig().register(testFeature).register(lrFeature);
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Override
public Application configure() {

	EntityResolver mockResolver = mock(EntityResolver.class);
	DataChannel mockChannel = mock(DataChannel.class);
	when(mockChannel.getEntityResolver()).thenReturn(mockResolver);

	ServerRuntime runtime = mock(ServerRuntime.class);
	when(runtime.getChannel()).thenReturn(mockChannel);

	Feature lrFeature = LinkRestBuilder.build(runtime);

	Feature feature = new Feature() {

		@Override
		public boolean configure(FeatureContext context) {
			context.register(SimpleResponseResource.class);
			return true;
		}
	};

	return new ResourceConfig().register(feature).register(lrFeature);
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
DefaultCayenneService(Context context) {
    // Build Cayenne runtime with custom resource locator, to be able load it from Android assets.
    runtime = ServerRuntime.builder()
            .addModule(binder -> binder.bind(ResourceLocator.class).to(AssetsResourceLocator.class))
            .addConfig("assets:cayenne-project.xml")
            .build();
    sharedContext = runtime.newContext();
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
private static ServerRuntime createCayenne(String url, String driver) {

		return new ServerRuntimeBuilder().jdbcDriver(driver).url(url).addConfig("cayenne-project.xml")
				// this would ensure test schema creation on the first run
				.addModule(binder -> binder.bind(SchemaUpdateStrategy.class).to(CreateIfNoSchemaStrategy.class))
				.build();
	}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
@Provides
public LmRuntime createLinkMoveRuntime(
        ConfigurationFactory configFactory,
        Injector injector,
        ServerRuntime targetRuntime,
        Set<LinkMoveBuilderCallback> buildCallbacks) {

    return configFactory
            .config(LinkMoveFactory.class, configPrefix)
            .createLinkMove(injector, targetRuntime, buildCallbacks);
}
 

import org.apache.cayenne.configuration.server.ServerRuntime; //导入依赖的package包/类
public LmRuntime createLinkMove(
        Injector injector,
        ServerRuntime targetRuntime,
        Set<LinkMoveBuilderCallback> builderCallbacks) {

    ResourceResolver resolver = createResolver();
    LmRuntimeBuilder builder = new LmRuntimeBuilder()
            .withTargetRuntime(targetRuntime)
            .extractorResolver(resolver);

    connectorFactories.forEach(factory -> addToBuilder(builder, factory, injector));

    builderCallbacks.forEach(c -> c.build(builder));
    return builder.build();
}