GigaSpaces XAP 7.0 API

com.gigaspaces.datasource.hibernate
Class HibernateMapDataSource

java.lang.Object
  extended by com.gigaspaces.datasource.hibernate.HibernateMapDataSource
All Implemented Interfaces:
BulkDataPersister, ManagedDataSource<Map.Entry<Object,Object>>, MapDataSource<Object,Object>, BasicCacheLoader<Object,Object>, CacheLoader, CacheStore

Deprecated. use org.openspaces.persistency.hibernate package instead

@Deprecated
public class HibernateMapDataSource
extends Object
implements MapDataSource<Object,Object>

 HibernateMapDataSource is a full Hibernate implementation of IMap external data source.
 Changing data - when map data is put/removed
 HibernateMapDataSource is responsible to perform the relevant changes at the external database.
 HibernateMapDataSource delegates these changes into external database via Hibernate 3.0 ORM.
 
 Reading data - when the space is queried about specific key and it is not  found in the space 
 HibernateMapDataSource is called to load the data from the database.

 CacheLoader and  CacheStore are used for data loading/storing.
 
 Bulk operations - in case of transactions and replication will invoke the BulkDataPersister methods for persisting data.
 
 See the  MapDataSource for full description of the methods mapping between the Map API and the HibernateMapDataSource methods.
Configuration To use the HibernateMapDataSource the space schema XML configuration file should include the following. <space-config> <persistent> <enabled>true</enabled> <StorageAdapterClass>com.j_spaces.sadapter.datasource.DataAdapter</StorageAdapterClass> </persistent> <external-data-source> <data-source-class>com.gigaspaces.datasource.hibernate.HibernateMapDataSource</data-source-class> <data-class>java.lang.Object</data-class> <supports-inheritance>true</supports-inheritance> <supports-version>false</supports-version> <usage>read-write</usage> </external-data-source> <engine> <cache_policy>0</cache_policy> </engine> </space-config> You may also use the following space properties: space-config.persistent.enabled=true<.b> space-config.persistent.StorageAdapterClass=com.j_spaces.sadapter.datasource.DataAdapter space-config.engine.cache_policy=0 space-config.external-data-source.data-source-class=com.gigaspaces.datasource.hibernate.HibernateMapDataSource space-config.external-data-source.init-properties-file=hibernate.properties When using the HibernateMapDataSource the space-config.external-data-source.init-properties the content of this file will be passed on init to the HibernateMapDataSource. You must use space-config.engine.cache_policy=0 (LRU policy) to activate the external datasource implementation. It is recommended to configure also the following to control the space memory usage and the eviction behavior: space-config.engine.memory_usage.enabled=true space-config.engine.memory_usage.high_watermark_percentage=95 space-config.engine.memory_usage.write_only_block_percentage=85 space-config.engine.memory_usage.write_only_check_percentage=76 space-config.engine.memory_usage.low_watermark_percentage=75 space-config.engine.memory_usage.eviction_batch_size=500

Since:
6.0
Author:
anna

Field Summary
protected  Hashtable<String,org.hibernate.metadata.ClassMetadata> _metaDataTable
          Deprecated.  
protected  org.hibernate.SessionFactory _sessionFactory
          Deprecated.  
 
Fields inherited from interface com.gigaspaces.datasource.ManagedDataSource
DATA_CLASS_PROPS, NUMBER_OF_PARTITIONS, STATIC_PARTITION_NUMBER
 
Constructor Summary
HibernateMapDataSource()
          Deprecated.  
 
Method Summary
 DataIterator<Map.Entry<Object,Object>> entries()
          Deprecated.  Creates and returns an iterator over all the entries in data source.
 void erase(Object key)
          Deprecated. Remove the specified key from the underlying store if present.
 void eraseAll(Collection keys)
          Deprecated. Remove the specified keys from the underlying store if present
 void executeBulk(List<BulkItem> bulk)
          Deprecated. This method is called in the following scenarios: 1.
protected  Object getId(Object template)
          Deprecated. Return pojo identifier
protected  String getMapObjectsClass()
          Deprecated. Return map objects class name
protected  org.hibernate.metadata.ClassMetadata getMetadata(Object entry)
          Deprecated. Return pojo entry metadata
 void init(Properties properties)
          Deprecated. Initialize and configure the data source using given properties.
 DataIterator<Map.Entry<Object,Object>> initialLoad()
          Deprecated.  Creates and returns an iterator over all the entries that should be loaded into space.
 Object load(Object key)
          Deprecated. Loads value from secondary data storage in case if it's not in cache.
 Map loadAll(Collection keys)
          Deprecated. Loads multiple values from secondary data storage in case they are not in cache.
 void shutdown()
          Deprecated. Close the data source and clean any used resources.
 void store(Object key, Object value)
          Deprecated. Store the specified values under the specified keys in the store.
 void storeAll(Map map)
          Deprecated. Store the specified values under the specified keys in the underlying store.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_sessionFactory

protected org.hibernate.SessionFactory _sessionFactory
Deprecated. 

_metaDataTable

protected Hashtable<String,org.hibernate.metadata.ClassMetadata> _metaDataTable
Deprecated. 
Constructor Detail

HibernateMapDataSource

public HibernateMapDataSource()
Deprecated. 
Method Detail

init

public void init(Properties properties)
          throws DataSourceException
Deprecated. 
Description copied from interface: ManagedDataSource
Initialize and configure the data source using given properties.
Called when space is started.
The properties are loaded from a file that can be defined in the space schema or as a property named:

space-config.ExternalDataSource.properties-file partitionId and number of partitions are also in the Properties - can be read with STATIC_PARTITION_NUMBER and NUMBER_OF_PARTITIONS

Specified by:
init in interface ManagedDataSource<Map.Entry<Object,Object>>
Parameters:
properties - - contains user defined param and Partition data
Throws:
DataSourceException

shutdown

public void shutdown()
              throws DataSourceException
Deprecated. 
Description copied from interface: ManagedDataSource
Close the data source and clean any used resources.
Called before space shutdown.

Specified by:
shutdown in interface ManagedDataSource<Map.Entry<Object,Object>>
Throws:
DataSourceException

load

public Object load(Object key)
Deprecated. 
Loads value from secondary data storage in case if it's not in cache.

Specified by:
load in interface CacheLoader
Parameters:
key - Key of the object to load.
Returns:
Object returned by load; can be null
Space API Implementation Example:

        public Object load(Object key) {

                Object values[] = null;
                Object loaded_object = null;

                try {
                        Object myObject = getObject((IGSEntry) key);
                        int keyValue = 0;
                        if (myObject instanceof Person) {
                                Person person = null;
                                // This is the template we got - must have ID
                                person = (Person) myObject;
                                // getting primary key value - another option could be via
                                // ((IGSEntry) key).getPrimaryKeyName()
                                keyValue = person.getId().intValue();
                                // Constructing the query
                                Connection con = getConnection();

                                PreparedStatement stP = con.prepareStatement(
                                                "select * from  "
                                                                + tableNames.get(((IGSEntry) key)
                                                                                .getClassName()) + " where ID = ? ");
                                stP.setInt(1, keyValue);

                                ResultSet rs = stP.executeQuery();
                                int sz = rs.getMetaData().getColumnCount();

                                values = new Object[sz];
                                while (rs.next()) {
                                        for (int i = 0; i < sz; i++) {
                                                values[i] = rs.getObject(i + 1);

                                        }
                                        // here we construct the loaded Person object
                                        loaded_object = new Person(String.valueOf(values[0]),
                                                        String.valueOf(values[1]), Integer.valueOf(String
                                                                        .valueOf(values[2])));
                                        break;
                                }
                                rs.close();
                                rs.close();
                                con.close();
                        }
                } catch (Exception e) {
                        e.printStackTrace();
                        throw new RuntimeException(e);
                }
                return getConvertor().toIGSEntry(loaded_object);
        }


Map API Implementation Example:
          
        public Object load(Object key) {

                Object values[] = null;
                Person loaded_person = null;
                Connection con = null;
                try {
                        con = getConnection();
                        int keyValue = 0;
                        Map.Entry mEntry = ((IGSEntry) key).getMapEntry();

                        if (mEntry != null) {
                                keyValue = ((Integer) mEntry.getKey()).intValue();
                        } else {
                                keyValue = ((Integer) getId((IGSEntry) key)).intValue();
                        }

                        PreparedStatement stP = con.prepareStatement("select * from  " + tableNames.get(Person.class.getName())
                                                        + " where ID = ? ");
                        stP.setInt(1, keyValue);

                        ResultSet rs = stP.executeQuery();
                        int sz = rs.getMetaData().getColumnCount();

                        values = new Object[sz];
                        while (rs.next()) {
                                for (int i = 0; i < sz; i++) {
                                        values[i] = rs.getObject(i + 1);
                                }
                                // HERE WE MAP table row to Person object
                                loaded_person = new Person(String.valueOf(values[0]), String
                                                .valueOf(values[1]), Integer.valueOf(String
                                                .valueOf(values[2])));
                                break;
                        }
                        rs.close();
                        con.close();

                } catch (Exception e) {
                        try {
                                con.close();
                        } catch (SQLException e1) {
                                e1.printStackTrace();
                        }
                        e.printStackTrace();
                }
                return getConvertor().toIGSEntry(loaded_person);
        }

                

loadAll

public Map loadAll(Collection keys)
Deprecated. 
Description copied from interface: CacheLoader
Loads multiple values from secondary data storage in case they are not in cache.

Specified by:
loadAll in interface CacheLoader
Parameters:
keys - Collection of (CacheQuery) Keys to load by.
Returns:
Map of key-value pairs loaded from data storage.
Space API Implementation Example

        public Map loadAll(Collection keys) {
                HashMap map = new HashMap();
                Iterator keyIter = keys.iterator();
                while (keyIter.hasNext()) {
                        CacheQuery exprationEntry = (CacheQuery) keyIter.next();
                        Object query = exprationEntry.getQuery();
                        String querystr = null;
                        // null template
                        if (query instanceof IGSEntry) {
                                IGSEntry igsentry = (IGSEntry) query;
                                if (!tableNames.containsKey(igsentry.getClassName())) {
                                        System.out.println("Do not have mapping for class "
                                                        + igsentry.getClassName());

                                        if (igsentry.getClassName().equals("java.lang.Object")) {
                                                System.out.println("HERE YOU CAN LOAD DATA INTO THE SPACE WHEN IT IS STARTED!");
                                        }
                                        // return empty map - indicates no objects loaded from database
                                        return map;
                                }
                                querystr = "select * from "
                                                + tableNames.get(igsentry.getClassName());
                        }
                        // non null template or SQLQuery used
                        if (query instanceof SQLQuery) {
                                SQLQuery sqlquery = (SQLQuery) query;
                                if (!tableNames.containsKey(sqlquery.getClassName())) {
                                        System.out.println("Do not have mapping for class "
                                                        + sqlquery.getClassName());
                                        // return empty map - indicates no objects loaded from database
                                        return map;
                                }
                                querystr = "select * from "
                                                + tableNames.get(sqlquery.getClassName());
                                querystr += " where " + sqlquery.getQuery();
                        }
                        try {
                                Connection con = getConnection();
                                PreparedStatement stP = con.prepareStatement(
                                                querystr);

                                ResultSet rs = stP.executeQuery();
                                IGSEntry value = null;
                                while (rs.next()) {
                                        Integer id = new Integer(rs.getInt(3));
                                        Person person = new Person(rs.getString(1),
                                                        rs.getString(2), id);

                                        value = getConvertor().toIGSEntry(person);
                                        map.put(value, value);
                                }
                                rs.close();
                                con.close();
                        } catch (Exception e) {
                                e.printStackTrace();
                                throw new RuntimeException(e);
                        }
                }

                return map;
        }


Map API Implementation Example

        public Map loadAll(Collection keys) {
                HashMap map = new HashMap();

                Iterator keyIter = keys.iterator();
                while (keyIter.hasNext()) {
                        CacheQuery cacheQuery = (CacheQuery) keyIter.next();
                        Object query = cacheQuery.getQuery();
                        String sqlstr = null;
                        sqlstr = "select * from Person";
                        Map.Entry mapentry = null;
                        if (query instanceof Map.Entry)
                        {
                                mapentry  = (Map.Entry)query;
                                sqlstr += " where id = " + Integer.valueOf(mapentry.getKey().toString()).intValue();
                        }
                        else if (query instanceof IGSEntry)
                        {
                                // All entries - for example IMap.values() call 
                                IGSEntry igsentry = (IGSEntry)query;
                                if (igsentry.getClassName().equals("java.lang.Object"))
                                {
                                        return map;
                                }
                        }
                        else if (query instanceof SQLQuery)
                        {
                                SQLQuery sqlquery = (SQLQuery)query;
                                if (sqlquery.getClassName().equals("java.lang.Object"))
                                {
                                        return map;
                                }
                                sqlstr += " where " + sqlquery.getQuery();
                        }
                        PreparedStatement stP =null; 
                        ResultSet rs = null;
                        Connection con = null;
                        try {
                                con = getConnection();
                                stP = con.prepareStatement(sqlstr);
                                rs = stP.executeQuery();
                                while (rs.next()) {
                                        Integer id = new Integer(rs.getInt(3));
                                        Person person = new Person(rs.getString(1),
                                                        rs.getString(2), id);
                                        IGSEntry  igsEntry = getConvertor().toIGSEntry(person);
                                        map.put( igsEntry ,  igsEntry );
                                }
                                rs.close();
                                con.close();
                        } catch (Exception e) {
                                try {
                                        rs.close();
                                } catch (SQLException e1) {
                                        e1.printStackTrace();
                                }
                                try {
                                        con.close();
                                } catch (SQLException e1) {
                                        e1.printStackTrace();
                                }
                                e.printStackTrace();
                                throw new RuntimeException(e);
                        }
                }
                return map;
        }


store

public void store(Object key,
                  Object value)
Deprecated. 
Store the specified values under the specified keys in the store. This method should support both create and update for the specified key.

Specified by:
store in interface CacheStore
Parameters:
key - key to store the value under
value - value to be stored

storeAll

public void storeAll(Map map)
Deprecated. 
Store the specified values under the specified keys in the underlying store. This method is intended to support both key/value creation and value update for the specified keys.

Specified by:
storeAll in interface CacheStore
Parameters:
map - a Map of any number of keys and values to store

erase

public void erase(Object key)
Deprecated. 
Remove the specified key from the underlying store if present.

Specified by:
erase in interface CacheStore
Parameters:
key - key whose mapping is being removed from the cache

eraseAll

public void eraseAll(Collection keys)
Deprecated. 
Description copied from interface: CacheStore
Remove the specified keys from the underlying store if present

Specified by:
eraseAll in interface CacheStore
Parameters:
keys - keys whose mappings are being removed from the cache

executeBulk

public void executeBulk(List<BulkItem> bulk)
                 throws DataSourceException
Deprecated. 
This method is called in the following scenarios:

1. Transaction commit
2. Asynchronize persistency mode This method can throw DataSourceException. This exception will be delivered to the client application wrapped by com.j_spaces.javax.cache.CacheException

Specified by:
executeBulk in interface BulkDataPersister
Parameters:
bulk - This bulkSet contains set of BulkItem
Throws:
DataSourceException

getId

protected Object getId(Object template)
Deprecated. 
Return pojo identifier

Parameters:
template -
Returns:

getMetadata

protected org.hibernate.metadata.ClassMetadata getMetadata(Object entry)
Deprecated. 
Return pojo entry metadata

Parameters:
entry -
Returns:
returns the ClassMetadata associated with the given entity name; may return null.

getMapObjectsClass

protected String getMapObjectsClass()
Deprecated. 
Return map objects class name

Returns:

initialLoad

public DataIterator<Map.Entry<Object,Object>> initialLoad()
                                                   throws DataSourceException
Deprecated. 
Description copied from interface: ManagedDataSource
Creates and returns an iterator over all the entries that should be loaded into space.

Specified by:
initialLoad in interface ManagedDataSource<Map.Entry<Object,Object>>
Returns:
a DataIterator or null if no data should be loaded into space
Throws:
DataSourceException

entries

public DataIterator<Map.Entry<Object,Object>> entries()
                                               throws DataSourceException
Deprecated. 
Description copied from interface: BasicCacheLoader
Creates and returns an iterator over all the entries in data source. Invoked on values() method

Specified by:
entries in interface BasicCacheLoader<Object,Object>
Returns:
a DataIterator or null if no data should be loaded into space
Throws:
DataSourceException

GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.