Mapstore无法从数据库Hazelcast加载数据 [英] Mapstore not loading data from data base Hazelcast
本文介绍了Mapstore无法从数据库Hazelcast加载数据的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我正在使用Hazelcast和mysql.
我在mysql中为我的表创建了一个mapstore.我想做的是从数据库中使用map.loadAll填充数据.我的地图商店的实现是
I am using Hazelcast and mysql.
I created a mapstore for my table in mysql. What i am trying to do is to populate data using map.loadAll from data base. My Map store implementation is this
public class CityMapStore
implements MapStore<Long, City>
{
private final Connection con;
public CityMapStore() {
try {
con = DriverManager.getConnection("jdbc:mysql://localhost:3306/hazel", "root", "root123");
con.createStatement().executeUpdate(
"create table if not exists City (id bigint, name varchar(45), primary key (id))");
} catch (SQLExpublic synchronized void delete(Long key) {
System.out.println("Delete:" + key);
try {
con.createStatement().executeUpdate(
String.format("delete from City where id = %s", key));
} catch (SQLException e) {
throw new RuntimeException(e);
}
}ception e) {
throw new RuntimeException(e);
}
}
public synchronized void delete( Long key )
{
System.out.println( "Delete:" + key );
try
{
con.createStatement().executeUpdate( String.format( "delete from City where id = %s", key ) );
}
catch ( SQLException e )
{
throw new RuntimeException( e );
}
}
public synchronized void deleteAll( Collection<Long> keys )
{
for ( Long key : keys )
delete( key );
}
public synchronized void storeAll( Map<Long, City> map )
{
for ( Map.Entry<Long, City> entry : map.entrySet() )
store( entry.getKey(), entry.getValue() );
}
public synchronized Map<Long, City> loadAll( Collection<Long> keys )
{
Map<Long, City> result = new HashMap<Long, City>();
for ( Long key : keys )
result.put( key, load( key ) );
return result;
}
public Set<Long> loadAllKeys()
{
return null;
}
}
我的负荷舱是这个
public class LoadAllCity
{
public static void main( String[] args )
{
final Long numberOfEntriesToAdd = 1000l;
final String mapName = LoadAllCity.class.getCanonicalName();
final Config config = createNewConfig( mapName );
final HazelcastInstance node = Hazelcast.newHazelcastInstance( config );
final IMap<Long, City> map = node.getMap( mapName );
populateMap( map, numberOfEntriesToAdd );
System.out.printf( "# After populating map size\t: %d\n", map.size() );
System.out.printf( "# Map store has %d elements\n", numberOfEntriesToAdd );
map.evictAll();
System.out.printf( "# After evictAll map size\t: %d\n", map.size() );
map.loadAll( true );
System.out.printf( "# After loadAll map size\t: %d\n", map.size() );
}
private static void populateMap( IMap<Long, City> map, Long itemCount )
{
for ( long i = 0; i < itemCount; i++ )
{
City city = new City( "Viren" + i );
// map.put(i, city);
}
}
private static Config createNewConfig( String mapName )
{
final CityMapStore cityStore = new CityMapStore();
XmlConfigBuilder configBuilder = new XmlConfigBuilder();
Config config = configBuilder.build();
MapConfig mapConfig = config.getMapConfig( mapName );
MapStoreConfig mapStoreConfig = new MapStoreConfig();
mapStoreConfig.setClassName( CityMapStore.class.getCanonicalName() );
mapStoreConfig.setImplementation( cityStore );
mapStoreConfig.setWriteDelaySeconds( 0 );
mapConfig.setMapStoreConfig( mapStoreConfig );
return config;
}
}
推荐答案
要在启动时加载数据,请首先覆盖loadAllKeys方法,或者如果不希望这样做,则可以使用选定的键通过oveloaded loadAll方法加载
To load data at start up override loadAllKeys method first or if you do not want it than use selected keys to load with oveloaded loadAll method
这篇关于Mapstore无法从数据库Hazelcast加载数据的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文