@Bean(name="quikdoPU")
public LocalContainerEntityManagerFactoryBean quikdoPU() throws PropertyVetoException {
	// Workaround :(
	SoluvasMultiTenantConnectionProviderImpl.dataSource = dataSource();
	SoluvasTenantIdentifierResolver.appCtx = appCtx;
	
	/**
	  * So the list of possible options are,
	  *  
	  *     validate: validate the schema, makes no changes to the database. 
	  *     update: update the schema. 
	  *     create: creates the schema, destroying previous data. 
	  *     create-drop: drop the schema at the end of the session. 
	  */
	final String jpaHbm2DdlAuto = env.getRequiredProperty("jpaHbm2DdlAuto");
	log.info("JPA schema configuration: hbm2ddlauto={}", jpaHbm2DdlAuto);
	final LocalContainerEntityManagerFactoryBean factoryBean = new LocalContainerEntityManagerFactoryBean();
	factoryBean.setPersistenceUnitName("quikdoPU"); // persistence.xml
	factoryBean.setDataSource(dataSource());
	factoryBean.setJpaVendorAdapter(jpaVendorAdapter());
	factoryBean.setPackagesToScan(
			"com.quikdo.schema.core.jpa"
		);
	final ImmutableMap.Builder<String, Object> propb = ImmutableMap.builder();
	propb.put(org.hibernate.cfg.Environment.HBM2DDL_AUTO, jpaHbm2DdlAuto);
    // Must be supplied, otherwise you won't get JPA 2.1 @Index support
    // "You must specify a SQL Dialect via the hibernate.dialect property when using schema generation"
	propb.put(org.hibernate.cfg.Environment.DIALECT, PostgreSQL82Dialect.class.getName());
	// Write all SQL statements to the <b>console</b> (which we don't want, since we use shell). 
	// This is an alternative to setting the log category org.hibernate.SQL to debug.
	// So please configure via logback.xml instead.
	propb.put(org.hibernate.cfg.Environment.SHOW_SQL, false);
	propb.put(org.hibernate.cfg.Environment.FORMAT_SQL, true);
	propb.put(org.hibernate.cfg.Environment.USE_SQL_COMMENTS, true);
	// https://hibernate.atlassian.net/browse/ANN-99?focusedCommentId=22432&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-22432
	propb.put(org.hibernate.ejb.HibernatePersistence.NAMING_STRATEGY, DefaultComponentSafeNamingStrategy.class.getName());
	// Schema-based Multi-tenancy
	// http://docs.jboss.org/hibernate/core/4.2/devguide/en-US/html/ch16.html
	// https://community.jboss.org/message/838997
	propb.put(org.hibernate.cfg.Environment.MULTI_TENANT, 
			MultiTenancyStrategy.SCHEMA);
	propb.put(org.hibernate.cfg.Environment.MULTI_TENANT_CONNECTION_PROVIDER, 
			SoluvasMultiTenantConnectionProviderImpl.class);
	propb.put(org.hibernate.cfg.Environment.MULTI_TENANT_IDENTIFIER_RESOLVER,
			SoluvasTenantIdentifierResolver.class);
	final Map<String, Object> propertyMap = propb.build();
	factoryBean.setJpaPropertyMap(propertyMap);
	return factoryBean;
}

public class SoluvasMultiTenantConnectionProviderImpl implements MultiTenantConnectionProvider, Stoppable {

	private static final long serialVersionUID = 1L;
	private static final Logger log = LoggerFactory
			.getLogger(SoluvasMultiTenantConnectionProviderImpl.class);
	public static final String PUBLIC_SCHEMA = "public";
	
//	@Inject
	public static DataSource dataSource;

	@Override
	public boolean isUnwrappableAs(Class unwrapType) {
		return MultiTenantConnectionProvider.class.equals( unwrapType ) ||
				SoluvasMultiTenantConnectionProviderImpl.class.isAssignableFrom( unwrapType );
	}

	@Override
	public <T> T unwrap(Class<T> unwrapType) {
		if ( isUnwrappableAs( unwrapType ) ) {
			return (T) this;
		}
		else {
			throw new UnknownUnwrapTypeException( unwrapType );
		}
	}

	@Override
	public void stop() {
	}

	@Override
	public Connection getAnyConnection() throws SQLException {
		Preconditions.checkNotNull(dataSource, "dataSource must be provided");
		return dataSource.getConnection();
	}

	@Override
	public void releaseAnyConnection(Connection connection) throws SQLException {
		connection.close();
	}

	@Override
	public Connection getConnection(String tenantIdentifier)
			throws SQLException {
		Preconditions.checkNotNull(dataSource, "dataSource must be provided");
		final Connection conn = dataSource.getConnection();
		try {
			final PreparedStatement st = conn.prepareStatement("SET SCHEMA ?");
			st.setString(1, tenantIdentifier);
			st.execute();
		} catch (SQLException e) {
			throw new RuntimeException(
					"Could not alter JDBC connection to specified schema [" + tenantIdentifier + "]", e);
		}
		return conn;
	}

	@Override
	public void releaseConnection(String tenantIdentifier, Connection connection)
			throws SQLException {
		try {
			final PreparedStatement st = connection.prepareStatement("SET SCHEMA ?");
			st.setString(1, PUBLIC_SCHEMA);
			st.execute();
		} catch (SQLException e) {
			// on error, throw an exception to make sure the connection is not returned to the pool.
			// your requirements may differ
			throw new RuntimeException(
					"Could not alter released JDBC connection from schema '" + tenantIdentifier + "' to schema '" + PUBLIC_SCHEMA + "'", e);
		}
		connection.close();
	}

	@Override
	public boolean supportsAggressiveRelease() {
		return true;
	}

}

public class SoluvasTenantIdentifierResolver implements
		CurrentTenantIdentifierResolver {
	
	public static ApplicationContext appCtx;

	/* (non-Javadoc)
	 * @see org.hibernate.context.spi.CurrentTenantIdentifierResolver#resolveCurrentTenantIdentifier()
	 */
	@Override @Nullable
	public String resolveCurrentTenantIdentifier() {
		try {
			TenantRef tenantRef = appCtx.getBean(TenantRef.class);
//			final RequestAttributes requestAttrs = RequestOrCommandScope.currentRequestAttributes();
//			final TenantRef tenantRef = Preconditions.checkNotNull((TenantRef) requestAttrs.resolveReference("tenantRef"),
//					"Cannot resolve 'tenantRef' attribute from RequestAttributes");
//			final Set<String> attributeNames = ImmutableSet.copyOf(requestAttrs.getAttributeNames(RequestAttributes.SCOPE_REQUEST));
//			final TenantRef tenantRef = Preconditions.checkNotNull((TenantRef) requestAttrs.getAttribute("tenantRef", RequestAttributes.SCOPE_REQUEST),
//					"Cannot get 'tenantRef' SCOPE_REQUEST attribute from RequestAttributes, known attribute names: %s", attributeNames);
			return tenantRef.getTenantId();
		} catch (IllegalStateException e) {
			// not in request or command scope
			return null;
		}
	}

	/* (non-Javadoc)
	 * @see org.hibernate.context.spi.CurrentTenantIdentifierResolver#validateExistingCurrentSessions()
	 */
	@Override
	public boolean validateExistingCurrentSessions() {
		return resolveCurrentTenantIdentifier() != null;
	}

}