package com.j_spaces.examples.cachestore;
 
import java.io.Serializable;
 
public class Person  implements Serializable  {
       public String firstName;
       public String lastName;
       public Integer id;
 
       // must have empty constructor
       public Person() {
       }
 
       public Person(String firstName, String lastName, Integer id) {
              this.firstName = firstName;
              this.lastName = lastName;
              this.id = id;
       }
 
       public String toString ()
       {
       return "ID:" +id +   " firstName:"+firstName + " lastName:"+lastName;
       }
}

package com.j_spaces.examples.cacheloader;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Properties;
import java.util.Vector;
 
import com.j_spaces.core.client.ClientUIDHandler;
import com.j_spaces.javax.cache.Cache;
import com.j_spaces.javax.cache.CacheLifeCycleManager;
import com.j_spaces.javax.cache.CacheLoader;
import com.j_spaces.sadapter.GenericPA.*;
 
public class CacheLoaderImpl  implements
              CacheLoader, CacheLifeCycleManager, ISpaceFilter{
       String tableName = "Person";
       IMap          cache;
       IJSpace              space;
       Connection dbConnection;
 
       public CacheLoaderImpl() {
 
       }
 
// ISpaceFilter init - Called after the CacheLoader init method
public void init(IJSpace space, String filterId, String url,int priority)
  {
              this.space = space;
  }
 
// ISpaceFilter process
public Object  process(SpaceContext context, ISpaceFilterEntry entry, int operationCode)       {
          if( operationCode == FilterOperationCodes.ON_INIT)
          {
              System.out.println("\nCalling CacheLoader Init >>>> ["+operationCode +"]\n");
              if (this.cache == null)
                     this.cache = new GSMapImpl(space);
                    
              Vector keyVec = new Vector();    
              keyVec.add( new Integer(1002));
              keyVec.add( new Integer(1003));
              keyVec.add( new Integer(1004));
 
              try {
              cache.getAll(keyVec);
 
                } catch (CacheException e) {
                     e.printStackTrace();
                }
              System.out.println("\nCacheLoader Init completed>>>>\n");
    }
              return null;
       }
       /**
        * @param dbUrl
        * @param user
        * @param password
        * @param properties
        *
        * @return database connection
        */
       public void init(String dbUrl, String user,
                    String password, Properties properties) {
              try {
                    Class.forName("org.hsqldb.jdbcDriver").newInstance();
                    System.out.println("Connection to HSQL database - URL:" + dbUrl);
                    dbConnection = DriverManager.getConnection(dbUrl, "sa", "");
                    System.out.println();
                    System.out.println(" ********* CACHE LOADER STARTED ********* ");
                    System.out.println();
              } catch (Exception e) {
                    e.printStackTrace();
              }
       }
 
       /**
        * @param key
        * @return value
        */
       public Object load(Object key) {
 
              Object values[] = null;
              Person person = null;
 
              /*
               * This is where a call to the external data source needs to be made and
               * load the data to the cache from an external data source. The
               * application performs a call to the appropriate database table, reads
        * the data using an appropriate query and fills in the relevant object
               */
              try {
 
                    PreparedStatement stP = dbConnection
                                  .prepareStatement("select * from  " + this.tableName
                                                + " where ID = ? ");
                    ResultSet rs = stP.executeQuery();
                    int sz = rs.getMetaData().getColumnCount();
                   
                    while (rs.next()) {
                           for (int i = 0; i < sz; i++) {
                                  values[i] = rs.getObject(i + 1);
                           }
                           // HERE WE MAP table row to Person object
                           person = new Person(String.valueOf(values[0]), String.valueOf(values[1]) ,
                            Integer.valueOf(String.valueOf(values[2])));
                           break;
                    }
              } catch (Exception e) {
                    e.printStackTrace();
              }
              //System.out.println("return:" + person);
              return person;
       }
 
       /**
        * @param keys
        * @return collection of values
        */
       public Map loadAll(Collection keys) {
              Iterator iter = keys.iterator();
              HashMap msgMap = new HashMap();
              while (iter.hasNext()) {
                    msgMap.put(keys, load(iter.next()));
              }
              return msgMap;
       }
 
       public void shutdown() {
       }
 
       public void eraseAll() {
       }
}