com.github.vincentrussell.query.mongodb.sql.converter

Class QueryConverter

java.lang.Object

com.github.vincentrussell.query.mongodb.sql.converter.QueryConverter

public class QueryConverter
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	D_AGGREGATION_ALLOW_DISK_USE
static String	D_AGGREGATION_BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
QueryConverter(InputStream inputStream) Create a QueryConverter with a string
QueryConverter(InputStream inputStream, Map<String,FieldType> fieldNameToFieldTypeMapping, FieldType defaultFieldType) Create a QueryConverter with an InputStream
QueryConverter(String sql) Create a QueryConverter with a string
QueryConverter(String sql, FieldType fieldType) Create a QueryConverter with a string
QueryConverter(String sql, Map<String,FieldType> fieldNameToFieldTypeMapping) Create a QueryConverter with a string
QueryConverter(String sql, Map<String,FieldType> fieldNameToFieldTypeMapping, FieldType defaultFieldType) Create a QueryConverter with a string

Method Summary

Modifier and Type	Method and Description
MongoDBQueryHolder	getMongoQuery() get the object that you need to submit a query
<T> T	run(com.mongodb.client.MongoDatabase mongoDatabase)
void	write(OutputStream outputStream) Build a mongo shell statement with the code to run the specified query.

Methods inherited from class java.lang.Object

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

Field Detail

D_AGGREGATION_ALLOW_DISK_USE

public static final String D_AGGREGATION_ALLOW_DISK_USE

See Also:

Constant Field Values

D_AGGREGATION_BATCH_SIZE

public static final String D_AGGREGATION_BATCH_SIZE

See Also:

Constant Field Values

Constructor Detail

QueryConverter

public QueryConverter(String sql)
               throws ParseException

Create a QueryConverter with a string

Parameters:

sql - the sql statement

Throws:

ParseException - when the sql query cannot be parsed

QueryConverter

public QueryConverter(String sql,
                      Map<String,FieldType> fieldNameToFieldTypeMapping)
               throws ParseException

Create a QueryConverter with a string

Parameters:

sql - the sql statement

fieldNameToFieldTypeMapping - mapping for each field

Throws:

ParseException - when the sql query cannot be parsed

QueryConverter

public QueryConverter(String sql,
                      FieldType fieldType)
               throws ParseException

Create a QueryConverter with a string

Parameters:

sql - sql string

fieldType - the default FieldType to be used

Throws:

ParseException

QueryConverter

public QueryConverter(String sql,
                      Map<String,FieldType> fieldNameToFieldTypeMapping,
                      FieldType defaultFieldType)
               throws ParseException

Create a QueryConverter with a string

Parameters:

sql - sql string

fieldNameToFieldTypeMapping - mapping for each field

defaultFieldType - defaultFieldType the default FieldType to be used

Throws:

ParseException

QueryConverter

public QueryConverter(InputStream inputStream)
               throws ParseException

Create a QueryConverter with a string

Parameters:

inputStream - an input stream that has the sql statement in it

Throws:

ParseException - when the sql query cannot be parsed

QueryConverter

public QueryConverter(InputStream inputStream,
                      Map<String,FieldType> fieldNameToFieldTypeMapping,
                      FieldType defaultFieldType)
               throws ParseException

Create a QueryConverter with an InputStream

Parameters:

inputStream - an input stream that has the sql statement in it

fieldNameToFieldTypeMapping - mapping for each field

defaultFieldType - the default FieldType to be used

Throws:

ParseException - when the sql query cannot be parsed

Method Detail

getMongoQuery

public MongoDBQueryHolder getMongoQuery()

get the object that you need to submit a query

Returns:

the MongoDBQueryHolder that contains all that is needed to describe the query to be run.

write

public void write(OutputStream outputStream)
           throws IOException

Build a mongo shell statement with the code to run the specified query.

Parameters:

outputStream - the OutputStream to write the data to

Throws:

IOException - when there is an issue writing to the OutputStream

run

public <T> T run(com.mongodb.client.MongoDatabase mongoDatabase)

Type Parameters:

T - variable based on the type of query run.

Parameters:

mongoDatabase - the database to run the query against.

Returns:

When query does a find will return QueryResultIterator<Document> When query does a count will return a Long When query does a distinct will return QueryResultIterator<String>