import org.openrdf.repository.config.RepositoryFactory; //导入依赖的package包/类
@Test
public void testGetRepository() throws Exception {
    MarkLogicRepositoryConfig config = new MarkLogicRepositoryConfig();
    config.setHost(host);
    config.setPort(port);
    config.setUser(adminUser);
    config.setPassword(adminPassword);
    config.setAuth("DIGEST");

    RepositoryFactory factory = new MarkLogicRepositoryFactory();
    Assert.assertEquals("marklogic:MarkLogicRepository", factory.getRepositoryType());

    Repository repo = factory.getRepository(config);
    repo.initialize();
    Assert.assertTrue(repo.getConnection() instanceof MarkLogicRepositoryConnection);

    Repository otherrepo = factory.getRepository(config);
    otherrepo.initialize();
    RepositoryConnection oconn = otherrepo.getConnection();
    Assert.assertTrue(oconn instanceof MarkLogicRepositoryConnection);
}
 

import org.openrdf.repository.config.RepositoryFactory; //导入依赖的package包/类
@Test
public void testGetRepositoryWithAllInOneConstructor() throws Exception {
    MarkLogicRepositoryConfig config = new MarkLogicRepositoryConfig(host, port, user, password, "DIGEST");

    RepositoryFactory factory = new MarkLogicRepositoryFactory();
    Assert.assertEquals("marklogic:MarkLogicRepository", factory.getRepositoryType());

    Repository repo = factory.getRepository(config);
    repo.initialize();
    Assert.assertTrue(repo.getConnection() instanceof MarkLogicRepositoryConnection);

    Repository otherrepo = factory.getRepository(config);
    otherrepo.initialize();
    Assert.assertTrue(otherrepo.getConnection() instanceof RepositoryConnection);
}
 

import org.openrdf.repository.config.RepositoryFactory; //导入依赖的package包/类
@Before
  public void testGetRepository() throws Exception {
      MarkLogicRepositoryConfig config = new MarkLogicRepositoryConfig();

      config.setHost(host);
      config.setPort(restPort);
      config.setUser("admin");
      config.setPassword("admin");
      config.setAuth("DIGEST");

      RepositoryFactory factory = new MarkLogicRepositoryFactory();
      Assert.assertEquals("marklogic:MarkLogicRepository", factory.getRepositoryType());
      testRepository = (MarkLogicRepository) factory.getRepository(config);
      testRepository.initialize();
      vf = testRepository.getValueFactory();
      testConn = testRepository.getConnection();
      Assert.assertTrue(testRepository.getConnection() instanceof MarkLogicRepositoryConnection);

  	try{
  		 Repository otherrepo = factory.getRepository(config);
  		 RepositoryConnection conn = otherrepo.getConnection();
	Assert.assertTrue(2>1);
}
catch(Exception e){
	Assert.assertTrue(e instanceof RepositoryException);
}
   
  }
 

import org.openrdf.repository.config.RepositoryFactory; //导入依赖的package包/类
/**
 * Returns a (un-initialized) Repository instance that has been configured
 * based on the supplied configuration data.
 * 
 * @param configuration The repository configuration data.
 * @return The created (but un-initialized) repository.
 * @throws ConfigurationException If no repository could be created due to
 *         invalid or incomplete configuration data.
 */
private Repository getRepositoryInstance(Graph configuration) throws ConfigurationException {
	
	RepositoryConfig repoConfig = null;
	try {
		
		// read configuration
		repoConfig = RepositoryConfig.create(configuration, null);
		repoConfig.validate();
		RepositoryImplConfig repoImplConfig = repoConfig.getRepositoryImplConfig();
		
		// initialize repository factory
		RepositoryRegistry registry = RepositoryRegistry.getInstance();
		RepositoryFactory factory = registry.get(repoImplConfig.getType());
		if (factory == null) {
			throw new ConfigurationException("Unsupported repository type: "
					+ repoImplConfig.getType()
					+ " in repository definition (id:" + repoConfig.getID()
					+ ", title:" + repoConfig.getTitle() + ")");
		}
		
		// create repository
		return factory.getRepository(repoImplConfig);
		
	} catch (RepositoryConfigException e) {
		String reason = "error creating repository";
		if (repoConfig != null)
			reason += " (id:" + repoConfig.getID() + ", title:" + repoConfig.getTitle() + ")";
		throw new ConfigurationException(reason + ": " + e.getMessage());
	}
}
 

import org.openrdf.repository.config.RepositoryFactory; //导入依赖的package包/类
private Repository createRepositoryStack(RepositoryImplConfig config) {
	RepositoryFactory factory = RepositoryRegistry.getInstance().get(config.getType());
	if (factory == null) {
		throw new SesameManagerException("Unsupported repository type: " + config.getType());
	}

	Repository repository;
   try {
     repository = factory.getRepository(config);
   } catch (RepositoryConfigException ex) {
     throw new SesameManagerException("Could not get repository from factory",ex);
   }

	if (config instanceof DelegatingRepositoryImplConfig) {
		RepositoryImplConfig delegateConfig = ((DelegatingRepositoryImplConfig)config).getDelegate();

		Repository delegate = createRepositoryStack(delegateConfig);

		try {
			((DelegatingRepository)repository).setDelegate(delegate);
		}
		catch (ClassCastException e) {
			throw new SesameManagerException(
					"Delegate specified for repository that is not a DelegatingRepository: "
							+ delegate.getClass());
		}
	}

	return repository;
}