com.caucho.distcache.jdbc

Class JdbcMnodeStore

java.lang.Object

com.caucho.server.distcache.MnodeStore

com.caucho.distcache.jdbc.JdbcMnodeStore

public class JdbcMnodeStore
extends MnodeStore

Manages backing for the cache map.

Nested Class Summary

Nested classes/interfaces inherited from class com.caucho.server.distcache.MnodeStore

MnodeStore.ExpiredMnode, MnodeStore.ExpiredState, MnodeStore.Mnode

Constructor Summary

Constructors

Constructor and Description
JdbcMnodeStore(javax.sql.DataSource dataSource, java.lang.String tableName, java.lang.String serverName)

Method Summary

Modifier and Type	Method and Description
void	close()
void	destroy()
long	getCount() Clears the expired data
javax.sql.DataSource	getDataSource() Returns the data source.
java.util.ArrayList<CacheData>	getGlobalUpdates(long updateTime, int offset) Returns the maximum update time on startup
long	getStartupLastUpdateTime() Returns the max update time detected on startup.
java.lang.String	getTableName() Returns the data source.
java.util.ArrayList<CacheData>	getUpdates(long updateTime, int offset) Returns the maximum update time on startup
void	init()
protected void	initDatabase() Create the database, initializing if necessary.
boolean	insert(HashKey id, HashKey cacheKey, MnodeValue mnodeUpdate, long valueDataId, long valueDataTime, long lastAccessTime, long lastModifiedTime) Stores the data, returning true on success
MnodeEntry	load(HashKey id) Reads the object from the data store.
java.lang.String	toString()
boolean	updateAccessTime(HashKey id, long itemVersion, long accessTimeout, long accessTime) Updates the update time, returning true on success
boolean	updateSave(byte[] keyHash, byte[] cacheHash, MnodeValue mnodeUpdate, long valueDataId, long valueDataTime, long lastAccessTime, long lastModifiedTime) Stores the data, returning true on success

Methods inherited from class com.caucho.server.distcache.MnodeStore

createExpiredState, getKeys, getStartupLastUpdateTime, getUpdates, remove

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

JdbcMnodeStore

public JdbcMnodeStore(javax.sql.DataSource dataSource,
                      java.lang.String tableName,
                      java.lang.String serverName)
               throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

getDataSource

public javax.sql.DataSource getDataSource()

Returns the data source.

Overrides:

getDataSource in class MnodeStore

getTableName

public java.lang.String getTableName()

Returns the data source.

Overrides:

getTableName in class MnodeStore

getStartupLastUpdateTime

public long getStartupLastUpdateTime()

Returns the max update time detected on startup.

Overrides:

getStartupLastUpdateTime in class MnodeStore

init

public void init()
          throws java.lang.Exception

Overrides:

init in class MnodeStore

Throws:

java.lang.Exception

initDatabase

protected void initDatabase()
                     throws java.lang.Exception

Create the database, initializing if necessary.

Overrides:

initDatabase in class MnodeStore

Throws:

java.lang.Exception

close

public void close()

Overrides:

close in class MnodeStore

getUpdates

public java.util.ArrayList<CacheData> getUpdates(long updateTime,
                                                 int offset)

Returns the maximum update time on startup

Overrides:

getUpdates in class MnodeStore

getGlobalUpdates

public java.util.ArrayList<CacheData> getGlobalUpdates(long updateTime,
                                                       int offset)

Returns the maximum update time on startup

load

public MnodeEntry load(HashKey id)

Reads the object from the data store.

Overrides:

load in class MnodeStore

Parameters:

id - the hash identifier for the data

Returns:

true on successful load

insert

public boolean insert(HashKey id,
                      HashKey cacheKey,
                      MnodeValue mnodeUpdate,
                      long valueDataId,
                      long valueDataTime,
                      long lastAccessTime,
                      long lastModifiedTime)

Stores the data, returning true on success

Overrides:

insert in class MnodeStore

Parameters:

id - the key hash

value - the value hash

idleTimeout - the item's timeout

updateSave

public boolean updateSave(byte[] keyHash,
                          byte[] cacheHash,
                          MnodeValue mnodeUpdate,
                          long valueDataId,
                          long valueDataTime,
                          long lastAccessTime,
                          long lastModifiedTime)

Stores the data, returning true on success

Overrides:

updateSave in class MnodeStore

Parameters:

id - the key hash

value - the value hash

idleTimeout - the item's timeout

updateAccessTime

public boolean updateAccessTime(HashKey id,
                                long itemVersion,
                                long accessTimeout,
                                long accessTime)

Updates the update time, returning true on success

Overrides:

updateAccessTime in class MnodeStore

Parameters:

id - the key hash

itemVersion - the value version

accessTimeout - the item's timeout

accessTime - the item's timeout

getCount

public long getCount()

Clears the expired data

Overrides:

getCount in class MnodeStore

destroy

public void destroy()

Overrides:

destroy in class MnodeStore

toString

public java.lang.String toString()

Overrides:

toString in class MnodeStore