Package com.gigaspaces.persistency

Class MongoClientConnector

java.lang.Object

com.gigaspaces.persistency.MongoClientConnector

public class MongoClientConnector
extends Object

MongoDB driver client wrapper

Author:

Shadi Massalha

Constructor Summary

Constructors

Constructor	Description
MongoClientConnector(com.mongodb.MongoClient client, String db)
MongoClientConnector(com.mongodb.MongoClient client, String db, boolean prefferPojo)

Method Summary

Modifier and Type	Method	Description
void	close()
void	ensureIndexes(AddIndexData addIndexData)
com.mongodb.DBCollection	getCollection(String collectionName)
com.mongodb.DB	getConnection()
Collection<SpaceTypeDescriptor>	getSortedTypes()
void	introduceType(SpaceTypeDescriptor typeDescriptor)
void	introduceType(IntroduceTypeData introduceTypeData)
Collection<SpaceTypeDescriptor>	loadMetadata()
void	performBatch(DataSyncOperation[] operations)
void	performBatch(List<BatchUnit> rows)
boolean	prefferPojo()

Methods inherited from class java.lang.Object

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

Constructor Details

MongoClientConnector

public MongoClientConnector(com.mongodb.MongoClient client,
 String db)

MongoClientConnector

public MongoClientConnector(com.mongodb.MongoClient client,
 String db,
 boolean prefferPojo)

Method Details

prefferPojo

public boolean prefferPojo()

close

public void close()
           throws IOException

Throws:

IOException

introduceType

public void introduceType(IntroduceTypeData introduceTypeData)

introduceType

public void introduceType(SpaceTypeDescriptor typeDescriptor)

getConnection

public com.mongodb.DB getConnection()

getCollection

public com.mongodb.DBCollection getCollection(String collectionName)

performBatch

public void performBatch(DataSyncOperation[] operations)

performBatch

public void performBatch(List<BatchUnit> rows)

loadMetadata

public Collection<SpaceTypeDescriptor> loadMetadata()

getSortedTypes

public Collection<SpaceTypeDescriptor> getSortedTypes()

ensureIndexes

public void ensureIndexes(AddIndexData addIndexData)