github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Feature - RedissonRegionNativeFactory added for Hibernate module

Browse Source
pull/6011/head
Nikita Koksharov 7 months ago
parent c60f0ddd44
commit ff83bd08f7
12 changed files with 655 additions and 2 deletions
Show Stats Download Patch File Download Diff File

69
redisson-hibernate/redisson-hibernate-4/src/main/java/org/redisson/hibernate/JndiRedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,69 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.cache.CacheException;
import org.hibernate.engine.jndi.internal.JndiServiceImpl;
import org.hibernate.internal.util.config.ConfigurationHelper;
import org.redisson.api.RedissonClient;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import java.util.Properties;
/**
* Hibernate Cache region factory based on Redisson.
* Uses Redisson instance located in JNDI.
*
* @author Nikita Koksharov
*
*/
public class JndiRedissonRegionNativeFactory extends RedissonRegionNativeFactory {
private static final long serialVersionUID = -4814502675083325567L;
public static final String JNDI_NAME = CONFIG_PREFIX + "jndi_name";
@Override
protected RedissonClient createRedissonClient(Properties properties) {
String jndiName = ConfigurationHelper.getString(JNDI_NAME, properties);
if (jndiName == null) {
throw new CacheException(JNDI_NAME + " property not set");
}
Properties jndiProperties = JndiServiceImpl.extractJndiProperties(properties);
InitialContext context = null;
try {
context = new InitialContext(jndiProperties);
return (RedissonClient) context.lookup(jndiName);
} catch (NamingException e) {
throw new CacheException("Unable to locate Redisson instance by name: " + jndiName, e);
} finally {
if (context != null) {
try {
context.close();
} catch (NamingException e) {
throw new CacheException("Unable to close JNDI context", e);
}
}
}
}
@Override
public void stop() {
}
}

64
redisson-hibernate/redisson-hibernate-4/src/main/java/org/redisson/hibernate/RedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,64 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.cache.CacheException;
import org.hibernate.cfg.Settings;
import org.redisson.MapCacheNativeWrapper;
import org.redisson.Redisson;
import org.redisson.api.RMapCache;
import org.redisson.api.RMapCacheNative;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
/**
*
* @author Nikita Koksharov
*
*/
public class RedissonRegionNativeFactory extends RedissonRegionFactory {
private static final long serialVersionUID = 4889779229712681692L;
@Override
public void start(Settings settings, Properties properties) throws CacheException {
Set<Map.Entry<Object, Object>> entrySet = properties.entrySet();
for (Map.Entry<Object, Object> entry : entrySet) {
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_ENTRIES_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".eviction.max_entries setting can't be non-zero");
}
}
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_IDLE_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".expiration.max_idle_time setting can't be non-zero");
}
}
}
super.start(settings, properties);
}
@Override
protected RMapCache<Object, Object> getCache(String regionName, Properties properties, String defaultKey) {
RMapCacheNative<Object, Object> cache = redisson.getMapCacheNative(regionName);
return new MapCacheNativeWrapper<>(cache, (Redisson) redisson);
}
}

69
redisson-hibernate/redisson-hibernate-5/src/main/java/org/redisson/hibernate/JndiRedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,69 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.cache.CacheException;
import org.hibernate.engine.jndi.internal.JndiServiceImpl;
import org.hibernate.internal.util.config.ConfigurationHelper;
import org.redisson.api.RedissonClient;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import java.util.Properties;
/**
* Hibernate Cache region factory based on Redisson.
* Uses Redisson instance located in JNDI.
*
* @author Nikita Koksharov
*
*/
public class JndiRedissonRegionNativeFactory extends RedissonRegionNativeFactory {
private static final long serialVersionUID = -4814502675083325567L;
public static final String JNDI_NAME = CONFIG_PREFIX + "jndi_name";
@Override
protected RedissonClient createRedissonClient(Properties properties) {
String jndiName = ConfigurationHelper.getString(JNDI_NAME, properties);
if (jndiName == null) {
throw new CacheException(JNDI_NAME + " property not set");
}
Properties jndiProperties = JndiServiceImpl.extractJndiProperties(properties);
InitialContext context = null;
try {
context = new InitialContext(jndiProperties);
return (RedissonClient) context.lookup(jndiName);
} catch (NamingException e) {
throw new CacheException("Unable to locate Redisson instance by name: " + jndiName, e);
} finally {
if (context != null) {
try {
context.close();
} catch (NamingException e) {
throw new CacheException("Unable to close JNDI context", e);
}
}
}
}
@Override
public void stop() {
}
}

64
redisson-hibernate/redisson-hibernate-5/src/main/java/org/redisson/hibernate/RedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,64 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.boot.spi.SessionFactoryOptions;
import org.hibernate.cache.CacheException;
import org.redisson.MapCacheNativeWrapper;
import org.redisson.Redisson;
import org.redisson.api.RMapCache;
import org.redisson.api.RMapCacheNative;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
/**
*
* @author Nikita Koksharov
*
*/
public class RedissonRegionNativeFactory extends RedissonRegionFactory {
private static final long serialVersionUID = 4889779229712681692L;
@Override
public void start(SessionFactoryOptions settings, Properties properties) throws CacheException {
Set<Map.Entry<Object, Object>> entrySet = properties.entrySet();
for (Map.Entry<Object, Object> entry : entrySet) {
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_ENTRIES_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".eviction.max_entries setting can't be non-zero");
}
}
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_IDLE_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".expiration.max_idle_time setting can't be non-zero");
}
}
}
super.start(settings, properties);
}
@Override
protected RMapCache<Object, Object> getCache(String regionName, Properties properties, String defaultKey) {
RMapCacheNative<Object, Object> cache = redisson.getMapCacheNative(regionName);
return new MapCacheNativeWrapper<>(cache, (Redisson) redisson);
}
}

69
redisson-hibernate/redisson-hibernate-52/src/main/java/org/redisson/hibernate/JndiRedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,69 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.cache.CacheException;
import org.hibernate.engine.jndi.internal.JndiServiceImpl;
import org.hibernate.internal.util.config.ConfigurationHelper;
import org.redisson.api.RedissonClient;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import java.util.Properties;
/**
* Hibernate Cache region factory based on Redisson.
* Uses Redisson instance located in JNDI.
*
* @author Nikita Koksharov
*
*/
public class JndiRedissonRegionNativeFactory extends RedissonRegionNativeFactory {
private static final long serialVersionUID = -4814502675083325567L;
public static final String JNDI_NAME = CONFIG_PREFIX + "jndi_name";
@Override
protected RedissonClient createRedissonClient(Properties properties) {
String jndiName = ConfigurationHelper.getString(JNDI_NAME, properties);
if (jndiName == null) {
throw new CacheException(JNDI_NAME + " property not set");
}
Properties jndiProperties = JndiServiceImpl.extractJndiProperties(properties);
InitialContext context = null;
try {
context = new InitialContext(jndiProperties);
return (RedissonClient) context.lookup(jndiName);
} catch (NamingException e) {
throw new CacheException("Unable to locate Redisson instance by name: " + jndiName, e);
} finally {
if (context != null) {
try {
context.close();
} catch (NamingException e) {
throw new CacheException("Unable to close JNDI context", e);
}
}
}
}
@Override
public void stop() {
}
}

64
redisson-hibernate/redisson-hibernate-52/src/main/java/org/redisson/hibernate/RedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,64 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.boot.spi.SessionFactoryOptions;
import org.hibernate.cache.CacheException;
import org.redisson.MapCacheNativeWrapper;
import org.redisson.Redisson;
import org.redisson.api.RMapCache;
import org.redisson.api.RMapCacheNative;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
/**
*
* @author Nikita Koksharov
*
*/
public class RedissonRegionNativeFactory extends RedissonRegionFactory {
private static final long serialVersionUID = 4889779229712681692L;
@Override
public void start(SessionFactoryOptions settings, Properties properties) throws CacheException {
Set<Map.Entry<Object, Object>> entrySet = properties.entrySet();
for (Map.Entry<Object, Object> entry : entrySet) {
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_ENTRIES_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".eviction.max_entries setting can't be non-zero");
}
}
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_IDLE_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".expiration.max_idle_time setting can't be non-zero");
}
}
}
super.start(settings, properties);
}
@Override
protected RMapCache<Object, Object> getCache(String regionName, Properties properties, String defaultKey) {
RMapCacheNative<Object, Object> cache = redisson.getMapCacheNative(regionName);
return new MapCacheNativeWrapper<>(cache, (Redisson) redisson);
}
}

70
redisson-hibernate/redisson-hibernate-53/src/main/java/org/redisson/hibernate/JndiRedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,70 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.cache.CacheException;
import org.hibernate.engine.jndi.internal.JndiServiceImpl;
import org.hibernate.internal.util.config.ConfigurationHelper;
import org.redisson.api.RedissonClient;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import java.util.Map;
import java.util.Properties;
/**
* Hibernate Cache region factory based on Redisson.
* Uses Redisson instance located in JNDI.
*
* @author Nikita Koksharov
*
*/
public class JndiRedissonRegionNativeFactory extends RedissonRegionNativeFactory {
private static final long serialVersionUID = -4814502675083325567L;
public static final String JNDI_NAME = CONFIG_PREFIX + "jndi_name";
@Override
protected RedissonClient createRedissonClient(Map properties) {
String jndiName = ConfigurationHelper.getString(JNDI_NAME, properties);
if (jndiName == null) {
throw new CacheException(JNDI_NAME + " property not set");
}
Properties jndiProperties = JndiServiceImpl.extractJndiProperties(properties);
InitialContext context = null;
try {
context = new InitialContext(jndiProperties);
return (RedissonClient) context.lookup(jndiName);
} catch (NamingException e) {
throw new CacheException("Unable to locate Redisson instance by name: " + jndiName, e);
} finally {
if (context != null) {
try {
context.close();
} catch (NamingException e) {
throw new CacheException("Unable to close JNDI context", e);
}
}
}
}
@Override
protected void releaseFromUse() {
}
}

2
redisson-hibernate/redisson-hibernate-53/src/main/java/org/redisson/hibernate/RedissonRegionFactory.java
Unescape Escape View File

@ -73,7 +73,7 @@ public class RedissonRegionFactory extends RegionFactoryTemplate {
public static final String FALLBACK = CONFIG_PREFIX + "fallback";
private RedissonClient redisson;
RedissonClient redisson;
private CacheKeysFactory cacheKeysFactory;
protected boolean fallback;

63
redisson-hibernate/redisson-hibernate-53/src/main/java/org/redisson/hibernate/RedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,63 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.boot.spi.SessionFactoryOptions;
import org.hibernate.cache.CacheException;
import org.redisson.MapCacheNativeWrapper;
import org.redisson.Redisson;
import org.redisson.api.RMapCache;
import org.redisson.api.RMapCacheNative;
import java.util.Map;
import java.util.Set;
/**
*
* @author Nikita Koksharov
*
*/
public class RedissonRegionNativeFactory extends RedissonRegionFactory {
private static final long serialVersionUID = 4889779229712681692L;
@Override
protected void prepareForUse(SessionFactoryOptions settings, Map properties) throws CacheException {
Set<Map.Entry> entrySet = properties.entrySet();
for (Map.Entry entry : entrySet) {
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_ENTRIES_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".eviction.max_entries setting can't be non-zero");
}
}
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_IDLE_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".expiration.max_idle_time setting can't be non-zero");
}
}
}
super.prepareForUse(settings, properties);
}
@Override
protected RMapCache<Object, Object> getCache(String regionName, Map properties, String defaultKey) {
RMapCacheNative<Object, Object> cache = redisson.getMapCacheNative(regionName);
return new MapCacheNativeWrapper<>(cache, (Redisson) redisson);
}
}

58
redisson-hibernate/redisson-hibernate-6/src/main/java/org/redisson/hibernate/JndiRedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,58 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.boot.registry.StandardServiceRegistry;
import org.hibernate.cache.CacheException;
import org.hibernate.engine.jndi.JndiException;
import org.hibernate.engine.jndi.spi.JndiService;
import org.hibernate.internal.util.config.ConfigurationHelper;
import org.redisson.api.RedissonClient;
import java.util.Map;
/**
* Hibernate Cache region factory based on Redisson.
* Uses Redisson instance located in JNDI.
*
* @author Nikita Koksharov
*
*/
public class JndiRedissonRegionNativeFactory extends RedissonRegionNativeFactory {
private static final long serialVersionUID = -4814502675083325567L;
public static final String JNDI_NAME = CONFIG_PREFIX + "jndi_name";
@Override
protected RedissonClient createRedissonClient(StandardServiceRegistry registry, Map properties) {
String jndiName = ConfigurationHelper.getString(JNDI_NAME, properties);
if (jndiName == null) {
throw new CacheException(JNDI_NAME + " property not set");
}
try {
return (RedissonClient) registry.getService(JndiService.class).locate(jndiName);
} catch (JndiException e) {
throw new CacheException(e);
}
}
@Override
protected void releaseFromUse() {
}
}

2
redisson-hibernate/redisson-hibernate-6/src/main/java/org/redisson/hibernate/RedissonRegionFactory.java
Unescape Escape View File

@ -74,7 +74,7 @@ public class RedissonRegionFactory extends RegionFactoryTemplate {
public static final String FALLBACK = CONFIG_PREFIX + "fallback";
private RedissonClient redisson;
RedissonClient redisson;
private CacheKeysFactory cacheKeysFactory;
protected boolean fallback;

63
redisson-hibernate/redisson-hibernate-6/src/main/java/org/redisson/hibernate/RedissonRegionNativeFactory.java
Unescape Escape View File

@ -0,0 +1,63 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.hibernate;
import org.hibernate.boot.spi.SessionFactoryOptions;
import org.hibernate.cache.CacheException;
import org.redisson.MapCacheNativeWrapper;
import org.redisson.Redisson;
import org.redisson.api.RMapCache;
import org.redisson.api.RMapCacheNative;
import java.util.Map;
import java.util.Set;
/**
*
* @author Nikita Koksharov
*
*/
public class RedissonRegionNativeFactory extends RedissonRegionFactory {
private static final long serialVersionUID = 4889779229712681692L;
@Override
protected void prepareForUse(SessionFactoryOptions settings, Map properties) throws CacheException {
Set<Map.Entry> entrySet = properties.entrySet();
for (Map.Entry entry : entrySet) {
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_ENTRIES_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".eviction.max_entries setting can't be non-zero");
}
}
if (entry.getKey().toString().endsWith(RedissonRegionFactory.MAX_IDLE_SUFFIX)) {
Integer value = Integer.valueOf(entry.getValue().toString());
if (value > 0) {
throw new IllegalArgumentException(".expiration.max_idle_time setting can't be non-zero");
}
}
}
super.prepareForUse(settings, properties);
}
@Override
protected RMapCache<Object, Object> getCache(String regionName, Map properties, String defaultKey) {
RMapCacheNative<Object, Object> cache = redisson.getMapCacheNative(regionName);
return new MapCacheNativeWrapper<>(cache, (Redisson) redisson);
}
}
Write Preview
Loading…
Cancel
Save