Broadcaster used on this query runner to broadcast entity events.
Connection used by this query runner.
Stores temporarily user data. Useful for sharing data with subscribers.
Real database connection from a connection pool used to perform queries.
Indicates if connection for this query runner is released. Once its released, query runner cannot run queries anymore. Always false for mongodb since mongodb has a single query executor instance.
Indicates if transaction is active in this query executor. Always false for mongodb since mongodb does not support transactions.
All synchronized tables in the database.
Entity manager working only with current query runner.
Creates a new column from the column in the table.
Creates a new columns from the column in the table.
Execute an aggregation framework pipeline against the collection.
Perform a bulkWrite operation without a fluent API.
Changes a column in the table.
Changes a column in the table.
Removes all collections from the currently connected database. Be careful with using this method and avoid using it in production or migrations (because it can clear all your database).
Flushes all memorized sqls.
Drops collection.
Retrieve all the indexes on the collection.
Retrieves this collections index info.
Retrieve all the indexes on the collection.
Commits transaction.
For MongoDB database we don't create connection, because its single connection already created by a driver.
Count number of matching documents in the db to a query.
Creates a new check constraint.
Creates a new check constraints.
Creates an index on the db and collection.
Creates multiple indexes in the collection, this method is only supported for MongoDB 2.6 or higher. Earlier version of MongoDB will throw a command not supported error. Index specifications are defined at http://docs.mongodb.org/manual/reference/command/createIndexes/.
Creates a database if it's not created.
Creates a new foreign key.
Creates a new foreign keys.
Creates a new index.
Creates a new indices
Creates a new primary key.
Creates a new table schema.
Creates a new table from the given table and columns inside it.
Creates a new unique constraint.
Creates a new unique constraints.
Creates a cursor for a query that can be used to iterate over results from MongoDB.
Delete multiple documents on MongoDB.
Delete a document on MongoDB.
Disables special query runner mode in which sql queries won't be executed started by calling enableSqlMemory() method.
Previously memorized sql will be flushed.
The distinct command returns returns a list of distinct values for the given key across a collection.
Drops check constraint.
Drops check constraints.
Drops an index from this collection.
Drops all indexes from the collection.
Drops column in the table.
Drops the columns in the table.
Drops database.
Drops a foreign key from the table.
Drops a foreign keys from the table.
Drops an index from the table.
Drops an indices from the table.
Drops a primary key.
Drops table schema.
Drops the table.
Drops an unique constraint.
Drops an unique constraints.
Enables special query runner mode in which sql queries won't be executed, instead they will be memorized into a special variable inside query runner. You can get memorized sql using getMemorySql() method.
Executes down sql queries.
Executes up sql queries.
Find a document and delete it in one atomic operation, requires a write lock for the duration of the operation.
Find a document and replace it in one atomic operation, requires a write lock for the duration of the operation.
Find a document and update it in one atomic operation, requires a write lock for the duration of the operation.
Execute a geo search using a geo haystack index on a collection.
Execute the geoNear command to search for items in the collection.
Gets collection from the database with a given name.
Returns all available database names including system databases.
Gets sql stored in the memory. Parameters in the sql are already replaced.
Returns all available schema names including system schemas. If database parameter specified, returns schemas of that database.
Loads given table's data from the database.
Loads all tables (with given names) from the database and creates a Table from them.
Checks if column with the given name exist in the given table.
Checks if database with the given name exist.
Checks if schema with the given name exist.
Checks if table with the given name exist in the database.
Initiate an In order bulk write operation, operations will be serially executed in the order they are added, creating a new operation for each switch in types.
Initiate a Out of order batch write operation. All operations will be buffered into insert/update/remove commands executed out of order.
Inserts an array of documents into MongoDB.
Inserts a single document into MongoDB.
Returns if the collection is a capped collection.
Get the list of all indexes information for the collection.
Run Map Reduce across a collection. Be aware that the inline option for out will return an array of results not a collection.
Return N number of parallel cursors for a collection allowing parallel reading of entire collection. There are no ordering guarantees for returned results.
Executes a given SQL query.
Reindex all indexes on the collection Warning: reIndex is a blocking operation (indexes are rebuilt in the foreground) and will be slow for large collections.
For MongoDB database we don't release connection, because its single connection.
Reindex all indexes on the collection Warning: reIndex is a blocking operation (indexes are rebuilt in the foreground) and will be slow for large collections.
Renames column in the given table.
Replace a document on MongoDB.
Rollbacks transaction.
Starts transaction.
Get all the collection statistics.
Returns raw data stream.
Update multiple documents on MongoDB.
Update a single document on MongoDB.
Updates composite primary keys.
Generated using TypeDoc
Runs queries on a single MongoDB connection.