thredds.inventory.bdb

Class MetadataManager

java.lang.Object

thredds.inventory.bdb.MetadataManager

All Implemented Interfaces:

StoreKeyValue

public class MetadataManager
extends java.lang.Object
implements StoreKeyValue

MetadataManager using Berkeley DB Java Edition. Single environment, with multiple databases. All threads share one environment; multiple processes can only have one writer at a time. Each collection is a "database". Each database has a set of key/value pairs. default root dir is ${user.home}/.unidata/bdb default TDS uses {tomcat_home}/content/thredds/cache/collection

Since:

Aug 20, 2008

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MetadataManager.KeyValue

Nested classes/interfaces inherited from interface thredds.inventory.StoreKeyValue

StoreKeyValue.Factory

Constructor Summary

Constructors

Constructor and Description
MetadataManager(java.lang.String collectionName)

Method Summary

Modifier and Type	Method and Description
void	close()
static void	closeAll()
void	delete(java.util.Map<java.lang.String,MFile> current)
void	delete(java.lang.String theKey)
static void	delete(java.lang.String collectionName, java.lang.String key)
static void	deleteCollection(java.lang.String collectionName)
byte[]	get(byte[] key)
java.lang.String	get(java.lang.String key)
byte[]	getBytes(java.lang.String key)
static java.lang.String	getCacheLocation()
static java.util.List<java.lang.String>	getCollectionNames()
java.util.List<MetadataManager.KeyValue>	getContent()
static StoreKeyValue.Factory	getFactory()
static void	main(java.lang.String[] args)
void	put(byte[] key, byte[] value)
void	put(java.lang.String key, byte[] value)
void	put(java.lang.String key, java.lang.String value)
static void	setCacheDirectory(java.lang.String dir, long _maxSizeBytes, int _jvmPercent)
static void	showEnvStats(java.util.Formatter f)
void	showStats(java.util.Formatter f)
static void	sync()

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataManager

public MetadataManager(java.lang.String collectionName)
                throws com.sleepycat.je.DatabaseException,
                       java.io.IOException

Throws:

com.sleepycat.je.DatabaseException

java.io.IOException

Method Detail

setCacheDirectory

public static void setCacheDirectory(java.lang.String dir,
                                     long _maxSizeBytes,
                                     int _jvmPercent)

closeAll

public static void closeAll()

showEnvStats

public static void showEnvStats(java.util.Formatter f)

getCacheLocation

public static java.lang.String getCacheLocation()

sync

public static void sync()

getCollectionNames

public static java.util.List<java.lang.String> getCollectionNames()

deleteCollection

public static void deleteCollection(java.lang.String collectionName)
                             throws java.lang.Exception

Throws:

java.lang.Exception

delete

public static void delete(java.lang.String collectionName,
                          java.lang.String key)

getFactory

public static StoreKeyValue.Factory getFactory()

put

public void put(java.lang.String key,
                java.lang.String value)

put

public void put(byte[] key,
                byte[] value)

put

public void put(java.lang.String key,
                byte[] value)

Specified by:

put in interface StoreKeyValue

get

public byte[] get(byte[] key)

getBytes

public byte[] getBytes(java.lang.String key)

Specified by:

getBytes in interface StoreKeyValue

get

public java.lang.String get(java.lang.String key)

delete

public void delete(java.lang.String theKey)

delete

public void delete(java.util.Map<java.lang.String,MFile> current)

close

public void close()

Specified by:

close in interface StoreKeyValue

showStats

public void showStats(java.util.Formatter f)

getContent

public java.util.List<MetadataManager.KeyValue> getContent()
                                                    throws com.sleepycat.je.DatabaseException,
                                                           java.io.UnsupportedEncodingException

Throws:

com.sleepycat.je.DatabaseException

java.io.UnsupportedEncodingException

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception