Package org.teiid.translator.mongodb
Class MongoDBUpdateVisitor
- java.lang.Object
-
- org.teiid.language.visitor.AbstractLanguageVisitor
-
- org.teiid.language.visitor.HierarchyVisitor
-
- org.teiid.translator.mongodb.MongoDBSelectVisitor
-
- org.teiid.translator.mongodb.MongoDBUpdateVisitor
-
- All Implemented Interfaces:
LanguageObjectVisitor
public class MongoDBUpdateVisitor extends MongoDBSelectVisitor
-
-
Field Summary
Fields Modifier and Type Field Description protected LinkedHashMap<String,Object>
columnValues
protected Stack<com.mongodb.DBObject>
onGoingPullCriteria
protected TranslatorException
pullException
-
Fields inherited from class org.teiid.translator.mongodb.MongoDBSelectVisitor
exceptions, executionFactory, expressionMap, group, having, joinedDocuments, limit, match, mergePlanner, metadata, mongoDoc, onGoingExpression, pendingConditions, project, projectBeforeMatch, selectColumnReferences, selectColumns, skip, sort
-
-
Constructor Summary
Constructors Constructor Description MongoDBUpdateVisitor(MongoDBExecutionFactory executionFactory, RuntimeMetadata metadata, com.mongodb.DB mongoDB)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.mongodb.BasicDBObject
getInsert(LinkedHashMap<String,com.mongodb.DBObject> embeddedDocuments)
com.mongodb.BasicDBObject
getPullQuery()
com.mongodb.BasicDBObject
getUpdate(LinkedHashMap<String,com.mongodb.DBObject> embeddedDocuments)
boolean
updateDelete(com.mongodb.BasicDBList previousRows, org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo parentKey, com.mongodb.BasicDBList updated)
boolean
updateMerge(com.mongodb.BasicDBList previousRows, org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo parentKey, com.mongodb.BasicDBList updated)
boolean
updateMerge(com.mongodb.BasicDBObject previousRow, org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo parentKey)
void
visit(AndOr obj)
void
visit(Comparison obj)
void
visit(Delete obj)
void
visit(Function obj)
void
visit(In obj)
void
visit(Insert obj)
void
visit(IsNull obj)
void
visit(Like obj)
void
visit(Update obj)
-
Methods inherited from class org.teiid.translator.mongodb.MongoDBSelectVisitor
append, append, append, buildComparisionQuery, buildFunctionQuery, buildInQuery, buildIsNullQuery, buildLikeQuery, getColumnName, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit
-
Methods inherited from class org.teiid.language.visitor.HierarchyVisitor
visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit
-
Methods inherited from class org.teiid.language.visitor.AbstractLanguageVisitor
visit, visit, visit, visitNode, visitNodes, visitNodes
-
-
-
-
Field Detail
-
columnValues
protected LinkedHashMap<String,Object> columnValues
-
onGoingPullCriteria
protected Stack<com.mongodb.DBObject> onGoingPullCriteria
-
pullException
protected TranslatorException pullException
-
-
Constructor Detail
-
MongoDBUpdateVisitor
public MongoDBUpdateVisitor(MongoDBExecutionFactory executionFactory, RuntimeMetadata metadata, com.mongodb.DB mongoDB)
-
-
Method Detail
-
visit
public void visit(Insert obj)
- Specified by:
visit
in interfaceLanguageObjectVisitor
- Overrides:
visit
in classHierarchyVisitor
-
visit
public void visit(Update obj)
- Specified by:
visit
in interfaceLanguageObjectVisitor
- Overrides:
visit
in classHierarchyVisitor
-
visit
public void visit(Delete obj)
- Specified by:
visit
in interfaceLanguageObjectVisitor
- Overrides:
visit
in classHierarchyVisitor
-
getInsert
public com.mongodb.BasicDBObject getInsert(LinkedHashMap<String,com.mongodb.DBObject> embeddedDocuments)
-
getUpdate
public com.mongodb.BasicDBObject getUpdate(LinkedHashMap<String,com.mongodb.DBObject> embeddedDocuments) throws TranslatorException
- Throws:
TranslatorException
-
getPullQuery
public com.mongodb.BasicDBObject getPullQuery() throws TranslatorException
- Throws:
TranslatorException
-
updateMerge
public boolean updateMerge(com.mongodb.BasicDBList previousRows, org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo parentKey, com.mongodb.BasicDBList updated) throws TranslatorException
- Throws:
TranslatorException
-
updateDelete
public boolean updateDelete(com.mongodb.BasicDBList previousRows, org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo parentKey, com.mongodb.BasicDBList updated) throws TranslatorException
- Throws:
TranslatorException
-
updateMerge
public boolean updateMerge(com.mongodb.BasicDBObject previousRow, org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo parentKey) throws TranslatorException
- Throws:
TranslatorException
-
visit
public void visit(Comparison obj)
- Specified by:
visit
in interfaceLanguageObjectVisitor
- Overrides:
visit
in classMongoDBSelectVisitor
-
visit
public void visit(AndOr obj)
- Specified by:
visit
in interfaceLanguageObjectVisitor
- Overrides:
visit
in classMongoDBSelectVisitor
-
visit
public void visit(Function obj)
- Specified by:
visit
in interfaceLanguageObjectVisitor
- Overrides:
visit
in classMongoDBSelectVisitor
-
visit
public void visit(In obj)
- Specified by:
visit
in interfaceLanguageObjectVisitor
- Overrides:
visit
in classMongoDBSelectVisitor
-
visit
public void visit(IsNull obj)
- Specified by:
visit
in interfaceLanguageObjectVisitor
- Overrides:
visit
in classMongoDBSelectVisitor
-
visit
public void visit(Like obj)
- Specified by:
visit
in interfaceLanguageObjectVisitor
- Overrides:
visit
in classMongoDBSelectVisitor
-
-