[hibernate-commits] Hibernate SVN: r12751 - in shards/trunk/src: java/org/hibernate/shards/cfg and 2 other directories.
hibernate-commits at lists.jboss.org
hibernate-commits at lists.jboss.org
Wed Jul 11 02:43:23 EDT 2007
Author: max.ross
Date: 2007-07-11 02:43:23 -0400 (Wed, 11 Jul 2007)
New Revision: 12751
Modified:
shards/trunk/src/java/org/hibernate/shards/ShardedConfiguration.java
shards/trunk/src/java/org/hibernate/shards/cfg/ConfigurationToShardConfigurationAdapter.java
shards/trunk/src/java/org/hibernate/shards/cfg/ShardConfiguration.java
shards/trunk/src/test/org/hibernate/shards/ShardedConfigurationTest.java
shards/trunk/src/test/org/hibernate/shards/defaultmock/ShardConfigurationDefaultMock.java
Log:
HSHARDS-38
Allow cache region prefix to vary across shards.
Modified: shards/trunk/src/java/org/hibernate/shards/ShardedConfiguration.java
===================================================================
--- shards/trunk/src/java/org/hibernate/shards/ShardedConfiguration.java 2007-07-09 12:51:32 UTC (rev 12750)
+++ shards/trunk/src/java/org/hibernate/shards/ShardedConfiguration.java 2007-07-11 06:43:23 UTC (rev 12751)
@@ -229,6 +229,7 @@
safeSet(prototypeConfiguration, Environment.PASS, config.getShardPassword());
safeSet(prototypeConfiguration, Environment.URL, config.getShardUrl());
safeSet(prototypeConfiguration, Environment.DATASOURCE, config.getShardDatasource());
+ safeSet(prototypeConfiguration, Environment.CACHE_REGION_PREFIX, config.getShardCacheRegionPrefix());
safeSet(prototypeConfiguration, Environment.SESSION_FACTORY_NAME, config.getShardSessionFactoryName());
safeSet(prototypeConfiguration, ShardedEnvironment.SHARD_ID_PROPERTY, config.getShardId().toString());
}
Modified: shards/trunk/src/java/org/hibernate/shards/cfg/ConfigurationToShardConfigurationAdapter.java
===================================================================
--- shards/trunk/src/java/org/hibernate/shards/cfg/ConfigurationToShardConfigurationAdapter.java 2007-07-09 12:51:32 UTC (rev 12750)
+++ shards/trunk/src/java/org/hibernate/shards/cfg/ConfigurationToShardConfigurationAdapter.java 2007-07-11 06:43:23 UTC (rev 12751)
@@ -56,4 +56,8 @@
public String getShardDatasource() {
return config.getProperty(Environment.DATASOURCE);
}
+
+ public String getShardCacheRegionPrefix() {
+ return config.getProperty(Environment.CACHE_REGION_PREFIX);
+ }
}
Modified: shards/trunk/src/java/org/hibernate/shards/cfg/ShardConfiguration.java
===================================================================
--- shards/trunk/src/java/org/hibernate/shards/cfg/ShardConfiguration.java 2007-07-09 12:51:32 UTC (rev 12750)
+++ shards/trunk/src/java/org/hibernate/shards/cfg/ShardConfiguration.java 2007-07-11 06:43:23 UTC (rev 12751)
@@ -59,4 +59,10 @@
* @return the datasource for the shard
*/
String getShardDatasource();
+
+ /**
+ * @see org.hibernate.cfg.Environment#CACHE_REGION_PREFIX
+ * @return the cache region prefix for the shard
+ */
+ String getShardCacheRegionPrefix();
}
Modified: shards/trunk/src/test/org/hibernate/shards/ShardedConfigurationTest.java
===================================================================
--- shards/trunk/src/test/org/hibernate/shards/ShardedConfigurationTest.java 2007-07-09 12:51:32 UTC (rev 12750)
+++ shards/trunk/src/test/org/hibernate/shards/ShardedConfigurationTest.java 2007-07-11 06:43:23 UTC (rev 12751)
@@ -54,7 +54,7 @@
shardStrategyFactory = new MyShardStrategyFactory();
Configuration protoConfig = new Configuration();
protoConfig.setProperty(Environment.DIALECT, HSQLDialect.class.getName());
- shardConfig = new MyShardConfig("user", "url", "pwd", "sfname", 33);
+ shardConfig = new MyShardConfig("user", "url", "pwd", "sfname", "prefix", 33);
shardedConfiguration =
new ShardedConfiguration(
@@ -90,7 +90,8 @@
}
public void testShardIdRequired() {
- ShardConfiguration config = new MyShardConfig("user", "url", "pwd", "sfname", null);
+ ShardConfiguration config =
+ new MyShardConfig("user", "url", "pwd", "sfname", null, null);
try {
shardedConfiguration.populatePrototypeWithVariableProperties(config);
fail("expected npe");
@@ -132,14 +133,16 @@
private final String url;
private final String password;
private final String sessionFactoryName;
+ private final String cacheRegionPrefix;
private final Integer shardId;
public MyShardConfig(String user, String url, String password,
- String sessionFactoryName, Integer shardId) {
+ String sessionFactoryName, String cacheRegionPrefix, Integer shardId) {
this.user = user;
this.url = url;
this.password = password;
this.sessionFactoryName = sessionFactoryName;
+ this.cacheRegionPrefix = cacheRegionPrefix;
this.shardId = shardId;
}
@@ -166,5 +169,9 @@
public String getShardDatasource() {
return null;
}
+
+ public String getShardCacheRegionPrefix() {
+ return cacheRegionPrefix;
+ }
}
}
Modified: shards/trunk/src/test/org/hibernate/shards/defaultmock/ShardConfigurationDefaultMock.java
===================================================================
--- shards/trunk/src/test/org/hibernate/shards/defaultmock/ShardConfigurationDefaultMock.java 2007-07-09 12:51:32 UTC (rev 12750)
+++ shards/trunk/src/test/org/hibernate/shards/defaultmock/ShardConfigurationDefaultMock.java 2007-07-11 06:43:23 UTC (rev 12751)
@@ -47,5 +47,9 @@
public String getShardDatasource() {
throw new UnsupportedOperationException();
}
+
+ public String getShardCacheRegionPrefix() {
+ throw new UnsupportedOperationException();
+ }
}
More information about the hibernate-commits
mailing list