org.unict.ing.pds.dhtdb.replica.storage

Class MongoDBStorage

java.lang.Object

org.unict.ing.pds.dhtdb.replica.storage.MongoDBStorage

All Implemented Interfaces:

Storage

public class MongoDBStorage
extends Object
implements Storage

An implementation of the Storage interface for MongoDB

Field Summary

Fields

Modifier and Type	Field and Description
private org.jongo.MongoCollection	collection
private com.mongodb.DB	db

Constructor Summary

Constructors

Constructor and Description
MongoDBStorage(com.mongodb.DB db)

Method Summary

Modifier and Type	Method and Description
List<GenericValue>	find(Key key)
private List<GenericValue>	findBy(String query)
void	insert(GenericValue elem) Insert
void	insertMany(List<GenericValue> elems)
List<GenericValue>	lessThanAndRemove(Key key)
void	remove(Key key)
private void	removeBy(String query)
void	update(GenericValue elem, Key key)

Methods inherited from class java.lang.Object

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

Field Detail

db

private final com.mongodb.DB db

collection

private final org.jongo.MongoCollection collection

Constructor Detail

MongoDBStorage

public MongoDBStorage(com.mongodb.DB db)

Method Detail

insert

public void insert(GenericValue elem)

Insert

Specified by:

insert in interface Storage

Parameters:

elem - |

insertMany

public void insertMany(List<GenericValue> elems)

Specified by:

insertMany in interface Storage

Parameters:

elems - |

remove

public void remove(Key key)

Specified by:

remove in interface Storage

Parameters:

key - |

find

public List<GenericValue> find(Key key)

Specified by:

find in interface Storage

Parameters:

key - |

Returns:

|

lessThanAndRemove

public List<GenericValue> lessThanAndRemove(Key key)

Specified by:

lessThanAndRemove in interface Storage

Parameters:

key - |

Returns:

|

update

public void update(GenericValue elem,
                   Key key)

Specified by:

update in interface Storage

Parameters:

elem - |

key - |

removeBy

private void removeBy(String query)

Parameters:

query - |

findBy

private List<GenericValue> findBy(String query)

Parameters:

query - |

Returns:

|