RDBMS
Overview
MongoDB is a cross-platform document-based NoSQL database. It uses JSON/BSON like documents with schema.
- MongoDB stores data in flexible, JSON-like documents, meaning fields can vary from document to document and data structure can be changed over time.
- The document model maps to the objects in your application code, making data easy to work with.
- Ad hoc queries, indexing, and real time aggregation provide powerful ways to access and analyze your data.
- MongoDB is a distributed database at its core, so high availability, horizontal scaling, and geographic distribution are built in and easy to use.
Features of MongoDB
The following are some of the features of MongoDB.
- Queries: MongoDb supports ad-hoc queries and document-based queries. It also supports searching by field, range queries, and regular expressions.
- Indexing: You can index any field in the document.
- Replication: MongoDB supports master slave replication. MongoDB uses native application to maintain multiple copies of data.
- Multiple Servers: The database can run over multiple servers. Data is duplicated to bullet proof the system in case of hardware failure.
- Auto-Sharding: This process distributes data across multiple physical partitions called shards. Due to sharding, MongoDB has an automatic load-balancing feature.
- MapReduce: Supports MapReduce and flexible aggregation tools.
For more information on the features of MongoDB, see the MongoDB official website.
Install MongoDB
To install MongoDB for your OS, see the MongoDB download center.
MongoDB vs RDBMS – a comparison
|
MongoDB |
---|---|
Database |
Database |
Table |
Collection |
Tuple/Row |
Document |
column |
Field |
Table Join |
Embedded Documents |
Primary Key |
Primary Key (Default key _id provided by mongodb itself) |
In MongoDB, ObjectIds or primary keys are 12 bytes long, made up of several 2-4 byte chains. The following values make up the full 12 byte combination:
- a 4-byte value representing the seconds since the Unix epoch
- a 3-byte machine identifier
- a 2-byte process id
- a 3-byte counter, starting with a random value
Install cfmongodb package
Adobe ColdFusion (2021 release) is modularized, if you are only using the ZIP installer. By default, the module for MongoDB is not installed. The first step is to install the MongoDB package in ColdFusion. For the purpose of convenience though, this module is pre-installed in case of the GUI installer.
Note: If you are using the GUI installer, the packages are pre-installed.
The package for SQS is called cfmongodb.
To install the package cfmongodb, follow the steps below:
- Navigate to <CF_HOME>/cfusion/bin.
- Enter the command:
- Windows: cfpm.bat
- Linux: cfpm.sh
- Enter the command, install cfmongodb.
Wait for the MongoDB package to get installed.
Install from ColdFusion Administrator
- In ColdFusion Administrator > Package Manager, expand the section Available Packages.
- From the list of packages, select cfmongodb.
- Click Install.
Integration with ColdFusion
In Application.cfc, in the property datasources, create a connection to MongoDB by specifying the MongoDB host (server/localhost) and port, as shown below:
component { this.name = "mongotest77123"; this.serialization.preservecaseforstructkey=true this.enableNullSupport=true this.datasources = { "local"= { type="mongodb" }, "mymongodb"= { type="mongodb", host="mongodb://127.0.0.1:27017/", "init"= true } } }
Create MongoDB datasource via ColdFusion Administrator
In ColdFusion Administrator, click Data & Services > NoSQL Data Sources.
Add and manage your NoSql data source connections and Data Source Names (DSNs).
Enter the name of the datasource and choose Driver as MongoDB.
Click Add.
Add the configuration details, such as, host, port, Enable SSL, etc. For more information, see the NoSQL options.
Create MongoDB datasource via Admin APIs
CFC: CFIDE.adminapi.nosql_datasource
setMongoDataSource
Creates or modifies a MongoDb datasource.
Syntax
public void setMongoDataSource ( required string name, required string type, required string host, string port="27017", string replicaSet, boolean ssl, boolean dnsSeedList, string authMechanism, string username, string password, string authSource, string gssapiServiceName, string readConcern, string readPreference, string w, string wtimeout, boolean j, string connectTimeout, string maxPoolSize, string minPoolSize, string maxConnectionLifeTime, string maxConnectionIdleTime, string maxWaitQueueTimeout, string maxWaitQueueSize, string heartbeatFrequency, string minHeartbeatFrequency
Parameters
- name: string, required, name - ColdFusion datasource name.
- type: string, required, type - Database type.
- host: string, required, host - Database server host name or IP address.
- port: string, optional, port - Port that is used to access the database server. (default 27017)
- replicaSet: string, optional, replicaSet - Specifies the name of the replica set, if the mongod is a member of a replica set.
- ssl: boolean, optional, ssl - Whether to enable or disable TLS/SSL for the connection
- dnsSeedList: boolean, optional, dnsSeedList
- authMechanism: string, optional, authMechanism
- username: string, optional, username
- password: string, optional, password
- authSource: string, optional, authSource
- gssapiServiceName: string, optional, - Specify the GSSAPI service name if the authMechanism is gssapi.
- readConcern: string, optional, readConcern - Read Concern allows clients to choose a level of isolation for their reads from replica sets.
- readPreference: string, optional, readPreference - Read preferences describe the behavior of read operations with regards to replica sets.
- w: string, optional, w - The w option requests acknowledgement that the write operation has propagated to a specified number of mongod instances or to mongod instances with specified tags.
- wtimeout: string, optional, wtimeout - This specifies a time limit, in milliseconds, for the write concern.
- j: boolean, optional, j - The journal option requests acknowledgement from MongoDB that the write operation has been written to the journal.
- connectTimeout: string, optional, connectTimeout - The time in milliseconds to attempt a connection before timing out.
- maxPoolSize: string, optional, maxPoolSize - The maximum number of connections in the connection pool.
- minPoolSize: string, optional, minPoolSize - The minimum number of connections in the connection pool.
- maxConnectionLifeTime: string, optional, maxConnectionLifeTime - The maximum lifetime of a connection.
- maxConnectionIdleTime: string, optional, maxConnectionIdleTime - The maximum number of milliseconds that a connection can remain idle in the pool before being removed and closed.
- maxWaitQueueTimeout: string, optional, maxWaitQueueTimeout
- maxWaitQueueSize: string, optional, maxWaitQueueSize - The maximum number of connections in the connection pool.
- heartbeatFrequency: string, optional, heartbeatFrequency - Heartbeat frequency controls when the driver checks the state of the MongoDB deployment.
- minHeartbeatFrequency: string, optional, minHeartbeatFrequency
Example
<cfscript> // Create an object of administrator component and call the login method adminObj = createObject("component","cfide.adminapi.administrator"); adminObj.login("admin"); // Create an object of datasource component dsnObj = createObject("component","cfide.adminapi.nosql_datasource"); // Setting up the parameter values for mongodb datasource mongoDSN.name = "mongo1" mongoDSN.type = "mongodb" mongoDSN.host = "127.0.0.1" mongoDSN.port = "27017" mongoDSN.caseSensitivity = "false" // Create MongoDB datasource mResponse=dsnObj.setMongoDataSource(mongoDSN.name,mongoDSN.type,mongoDSN.host, mongoDSN.port,mongoDSN.caseSensitivity) </cfscript>
getDataSources
Returns a structure containing all data sources or a specified data source.
Syntax
public any getDatasources (dsnName)
Parameters
- dsnName: any, optional, dsnName - The name of the data source for which a structure is returned.
Example
<cfscript> // Create an object of administrator component and call the login method adminObj = createObject("component","cfide.adminapi.administrator"); adminObj.login("admin"); // Create an object of datasource component dsnObj = createObject("component","cfide.adminapi.nosql_datasource"); res=dsnObj.getDatasources() writeDump(res) </cfscript>
deleteMongoDatasource
Deletes the specified data source.
Syntax
public void deleteMongoDatasource ( required dsnName )
Parameters
- dsnName: any, required, dsnName - The name of the data source to be deleted.
Example
<cfscript> // Create an object of administrator component and call the login method adminObj = createObject("component","cfide.adminapi.administrator"); adminObj.login("admin"); // Create an object of datasource component dsnObj = createObject("component","cfide.adminapi.nosql_datasource"); // Get datasource res=dsnObj.getDatasources() writedump(res) // Delete datasource ds1 dsnObj.deleteMongoDatasource(res.ds1.name) </cfscript>
verifyMongoDatasource
Verifies a given data source name.
Syntax
public Any verifyMongoDatasource ( required dsnName )
Parameters
- dsnName: any, required, dsnName - Name that ColdFusion uses to connect to the data source.
Example
<cfscript> // Create an object of administrator component and call the login method adminObj = createObject("component","cfide.adminapi.administrator"); adminObj.login("admin"); // Create an object of datasource component dsnObj = createObject("component","cfide.adminapi.nosql_datasource"); // Get datasource res=dsnObj.getDatasources() writedump(res) // Verify datasource ds1 verifyRes=dsnObj.verifyMongoDatasource(res.ds1.name) writeDump(verifyRes) </cfscript>
Add datasource using CFSetup
add nosql name=testset mongoport=27017 mongoHost=see-wv-a403 driverName=MONGODB maxStalenessSeconds=2000 MAXWAITQUEUETIMEOUT=2000 MAXWAITQUEUESIZE=10 MAXPOOLSIZE=20 MAXCONNECTIONLIFETIME=2000 HEARTBEATFREQUENCY=10 MAXCONNECTIONIDLETIME=2000 MINHEARTBEATFREQUENCY=2 CONNECTTIMEOUT=2000 READPREFERENCE=PRIMARY SSL=YES REPLICASET=replica READCONCERN=majority dnsSeedList=true <alias>
Collection
A collection is equivalent to a table of a relational db. A collection stores documents that do not conform to a structure. This is because MongoDB is a schema-free database.
Create a collection
To create a collection, you must create a MongoDB database object and create the collection inside the db. A db can consist of multiple collections. See the code below for the syntax:
<cfscript> // mymongodb is the name of the connection to MongoDB, defined in Application.cfc db = getMongoService("mymongodb").db("newdb") // create a db db.createCollection("Coll_1") // create a collection db.createCollection("Coll_2") // create another collection </cfscript>
Create a document
Once you create a collection, you must insert one or more documents into the collection.
Insert one document
Here is how you can insert a single document in a collection using the insert method.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.createCollection("newcolThree") // create a collection // insert a single document db.newcolThree.insert({ "_id": 1, "name":"John Lennon", "band":"Beatles" }) </cfscript>
Note: If you do not explicitly set an Objectid set when defining the document, MongoDB, by default, assigns one to the document. The snippet contains an explicitly set Objectid, which gets displayed.
Insert many documents
You can insert multiple documents, as an array of structs, in a collection using the insertMany method.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.newcolThree.drop() // drop the collection db.createCollection("newcolThree") // create a collection // insert a single document db.newcolThree.insert({ "_id": 1, "name":"John Lennon", "band":"Beatles" }) // insert another document db.newcolThree.insertOne({ "_id": 2, "name":"Paul McCartney", "band":"Beatles" }) // insert many documents db.newcolThree.insertMany([ { "_id": 3, "name":"George Harrison", "band":"Beatles" }, { "_id": 4, "name":"Ringo Starr", "band":"Beatles" } ]) </cfscript>
Create a capped collection
Capped collections are fixed-size circular collections that follow the insertion order to support high performance for create, read, and delete operations. By circular, it means that when the fixed size allocated to the collection is exhausted, it will start deleting the oldest document in the collection without providing any explicit commands.
Capped collections restrict updates to the documents if the update results in increased document size. Since capped collections store documents in the
order of the disk storage, it ensures that the document size does not increase the size allocated on the disk. Capped collections are best for storing log information, cache data, or any other high volume data.
For more information, see Capped collections in MongoDB.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db // create a capped collection by passing capped flag as true, // size of collection, // and max number of documents db.createCollection("cappedLogCollection",{capped:true,size:10000,max:1000}) </cfscript>
If you set capped to true, you must also set a maximum size in the size field.
To check if a collection is capped, use the method isCapped.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db ifCapped=db.cappedLogCollection.isCapped() writeOutput("Is collection capped: "& ifCapped) </cfscript>
To convert an existing non-capped collection to a capped one, use the code below. You can use the convertToCapped method to convert to a capped collection.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.convertToCapped.drop() // create an un-capped collection db.createCollection("convertToCapped") // create a collection //convert an existing non-capped collection to a capped collection db.convertToCapped({"convertToCapped":"posts",size:10000}) </cfscript>
Query a collection
The find method selects documents in a collection or returns a cursor to the selected documents.
The find method has two parameters, query struct and projection, both optional. For more information, see the doc for find.
In the sample below, the find method does not use any parameter.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.createCollection("colFindDemo") // create a collection db.colFindDemo.insertMany([ { "_id" : 1, "name" : "Ian Gillan", "instrument" : "Vocals","born": 1945 }, { "_id" : 2, "name" : "Ian Paice", "instrument" : "Drums", "born" : 1948 }, { "_id" : 3, "name" : "Roger Glover", "instrument" : "Bass", "born" : 1945 }, { "_id" : 4, "name" : "Steve Morse", "instrument" : "Guitar", "born" : 1954 }, { "_id" : 5, "name" : "Don Airey", "instrument" : "Keyboards", "born" : 1948 }, { "_id" : 6, "name" : "Jeff Martin", "instrument" : "Vocals", "born" : 1969 }, { "_id" : 7, "name" : "Jeff Burrows", "instrument" : "Drums", "born" : 1968 }, { "_id" : 8, "name" : "Stuart Chatwood", "instrument" : "Bass", "born" : 1969 } ]) // return all documents db.colFindDemo.find() </cfscript>
To find the document(s) that match a query criteria, for example, where _id equals 4, see the sample below:
<cfscript>
db.colFindDemo.find({"_id":4})
</cfscript>
Another example that matches the criteria where instrument equals drums is shown below:
<cfscript>
db.colFindDemo.find({"instrument":"Drums"})
</cfscript>
Find using query operators
The examples below show the usage of query operators to find documents in a collection.
<cfscript>
df.colFindDemo.find({"_id":{$gt:4}}) // find _ids greater than 4
</cfscript>
<cfscript>
df.colFindDemo.find({"instrument":{$regex:"^B"}}) // find instruments that start with B
</cfscript>
<cfscript>
db.colFindDemo.find({"name":{$in:["Ian Gillan","Ian Paice"]}}) // find documents that match the names
</cfscript>
<cfscript>
db.colFindDemo.find({"born":{$all:[1948]}}) // find documents that match born, which contains the year 1948
</cfscript>
Update a collection
You can update a collection using these methods:
- update
- updateOne
- updateMany
update
The update method modifies an existing document or documents in a collection. For more information, see update method docs.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.colUpdDemo.drop() db.createCollection("colUpdDemo") // create a collection db.colUpdDemo.insertMany([ { "_id":1, "product_name": "sildenafil citrate", "supplier": "Wisozk Inc", "quantity": 261, "unit_cost": "$10.47" }, { "_id":2, "product_name": "Mountain Juniperus ashei", "supplier": "Keebler-Hilpert", "quantity": 292, "unit_cost": "$8.74" }, { "_id":3, "product_name": "Dextromathorphan HBr", "supplier": "Schmitt-Weissnat", "quantity": 211, "unit_cost": "$20.53" } ]) // increment quantity by 10 for _id:1 db.colUpdDemo.update({"_id":1},{$inc:{"quantity":10}}) // update unit cost from 8.74 to 10.74 db.colUpdDemo.update({"_id":2},{$set:{"unit_cost": "$10.74"}}) </cfscript>
update with pipeline
The aggregation pipeline is a framework that is modeled on the idea of data processing via pipelines in stages. Documents enter a multi-stage pipeline that transforms the documents into aggregated results.
For more information, see Aggregated pipelines in MongoDB.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); db.members.drop() res = db.members.insertMany([ { "_id" : 1, "member" : "abc123", "status" : "A", "points" : 2, "misc1" : "note to self: confirm status", "misc2" : "Need to activate" }, { "_id" : 2, "member" : "xyz123", "status" : "A", "points" : 60, "misc1" : "reminder: ping me at 100pts", "misc2" : "Some random comment" } ]) writedump(res) db.members.find().foreach((s) => { writedump(s) }) writeoutput("apply update pipeline") res = db.members.update( { }, [ { $set: { status: "Modified", comments: [ "$misc1", "$misc2" ] } }, { $unset: [ "misc1", "misc2" ] } ], { multi: true } ) writedump(res) db.members.find().foreach((s) => { writedump(s) }) db.members.drop() </cfscript>
updateOne
The method, based on a specified filter, updates a single document in a collection. For more information, see updateOne method docs.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.colUpdDemo.drop() db.createCollection("colUpdDemo") // create a collection db.colUpdDemo.insertMany([ { "_id":1, "product_name": "sildenafil citrate", "supplier": "Wisozk Inc", "quantity": 261, "unit_cost": "$10.47", "stock":10000 }, { "_id":2, "product_name": "Mountain Juniperus ashei", "supplier": "Keebler-Hilpert", "quantity": 292, "unit_cost": "$8.74", "stock":15000 }, { "_id":3, "product_name": "Dextromathorphan HBr", "supplier": "Schmitt-Weissnat", "quantity": 211, "unit_cost": "$20.53", "stock":20000 } ]) db.colUpdDemo.updateOne({"supplier": "Keebler-Hilpert"},{$set:{"stock":16000}}) </cfscript>
Using Try-Catch
Using try-catch statements, you can handle certain exceptions when a certain value is missing or incorrect. For example,
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.colUpdOneDemo.drop() db.createCollection("colUpdOneDemo") // create a collection db.colUpdOneDemo.insertMany([ { "_id" : 1, "name" : "Central Perk Cafe", "Borough" : "Manhattan" }, { "_id" : 2, "name" : "Rock A Feller Bar and Grill", "Borough" : "Queens", "violations" : 2 }, { "_id" : 3, "name" : "Empire State Pub", "Borough" : "Brooklyn", "violations" : 0 } ]) try { db.restaurant.updateOne( { "name" : "Central Perk Cafe New" }, // specify incorrect value { $set: { "violations" : 3 } } ) } catch (any e) { WriteOutput("Error: " & e.message) } </cfscript>
updateMany
The method, based on a specified filter, updates multiple documents in a collection. For more information, see updateMany method docs.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.colUpdManyDemo.drop() db.createCollection("colUpdManyDemo") // create a collection db.colUpdManyDemo.insertMany([ { "_id":1, "product_name": "sildenafil citrate", "supplier": "Wisozk Inc", "quantity": 261, "unit_cost": "$10.47", "stock":10000 }, { "_id":2, "product_name": "Mountain Juniperus ashei", "supplier": "Keebler-Hilpert", "quantity": 292, "unit_cost": "$8.74", "stock":15000 }, { "_id":3, "product_name": "Dextromathorphan HBr", "supplier": "Schmitt-Weissnat", "quantity": 211, "unit_cost": "$20.53", "stock":20000 } ]) // update more than one document based on the specified filter db.collection.updateMany( {"quantity" : {$gt: 250 }}, {$set: { "stock" : 50000 } } ); </cfscript>
Support for advanced data types
Employee.cfc
component accessors="true" { property string empName; property numeric age; property string dept; }
Serialize CFC object
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students emp = new Employee({empName="James", age=26, dept="000"}); serializedStr = serializeJSON(emp); collection.insertMany([{ key: serializedStr, name: "John Doe" }]); //Read from mongo result = collection.find({"name" : {$eq: "John Doe"}}).first() fileDataFromMongo = structFind(result, "key"); fileInJSON = DeserializeJSON(fileDataFromMongo); </cfscript>
CFC JSON
test.cfc
{ name="John", age="26" }
cfcjson.cfm
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students fileToRead = "#ExpandPath('./test.cfc')#"; jsonContent = FileRead(fileToRead); serializedStr = serializeJSON(jsonContent); collection.insertMany([{ key: serializedStr, name: "John Doe" }]); //Read from mongo result = collection.find({"name" : {$eq: "John Doe"}}).first() fileDataFromMongo = structFind(result, "key"); fileInJSON = DeserializeJSON(fileDataFromMongo); </cfscript>
Serialize Array
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students percentages = [22.5 , 33 , 45]; collection.insertMany([{ name: "John Doe", marks:{ total: 15, percentage : percentages } }]); //Read from mongo result = collection.find().first() writedump(result) </cfscript>
Serialize BigDecimal
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students percent = 3333333444222244.457777778900673 collection.insertMany([{ name: "John Doe", marks:{ total: 15, percent = 3333333444222244.457777778900673 } }]); //Read from mongo result = collection.find({"name" : {$eq: "John Doe"}}).first() writedump(result) </cfscript>
Serialize PDF
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students collection.insertMany([{ name: "John Doe", marks:{ key: test, name:"John Doe" } }]); //Read from mongo result = collection.find({"name" : {$eq: "John Doe"}}).first() writedump(result) fileDataFromMongo = structFind(result, "key"); myFile=GetDirectoryFromPath(GetCurrentTemplatePath()) & "test.pdf" FileWrite(file=myFile, data= fileDataFromMongo) </cfscript> <cfpdf action="extracttext" pages = "1" source="#myFile#" name="myXML" />
Serialize Query
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students myquery = QueryExecute('SELECT * FROM artists', [], {datasource = 'cfartgallery'}) jsonqueryresult = SerializeJSON(myquery) </cfscript> <cfset Start = 1> <cfset End = 1> <cfloop query="myquery" startRow = "#Start#" endRow = "#End#"> <cfset address = #myquery.ADDRESS#> </cfloop> <cfscript> collection.insertMany([{ key: myquery, name: "John Doe", }]); //Read from mongo result = collection.find({"name" : {$eq: "John Doe"}}).first() fileDataFromMongo = structFind(result, "key") </cfscript>
Serialize Image
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students fileToRead = "#ExpandPath('./test1.png')#" myfile = FileOpen(fileToRead, "readBinary"); binaryFileContent = FileRead(myfile, 1000); stringContentForBinaryFile = toString(binaryFileContent) collection.insertMany([{ key: binaryFileContent, name: "John Doe" }]); //Read from mongo result = collection.find({"name" : {$eq: "John Doe"}}).first() fileDataFromMongo = structFind(result, "key"); fileInString = ToString(ToBinary(fileDataFromMongo)) </cfscript>
Serialize Spreadsheet
<cfscript> theDir=GetDirectoryFromPath(GetCurrentTemplatePath()); theFile=theDir & "courses.xls"; </cfscript> <cfspreadsheet action="read" src="#theFile#" sheetname="courses" name="spreadsheetData"> <cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students data = spreadsheetData collection.insertMany([{ key: data, name: "John Doe" }]); //Read from mongo result = collection.find({"name" : {$eq: "John Doe"}}).first() MongoResultSheet = spreadsheetRead(result.key) writedump(MongoResultSheet.ROWCOUNT) </cfscript>
Serialize XML
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students myxml = fileRead(expandPath("./supportFiles/test.xml")); mydoc = XmlParse(myxml) collection.insertMany([{ key: mydoc , name: "John Doe" }]); //Read from mongo result = collection.find({"name" : {$eq: "John Doe"}}).first() fileDataFromMongo = structFind(result, "key"); fileInXML = DeserializeXML(fileDataFromMongo) </cfscript>
Serialize RegEx
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students percent = 44 collection.insertMany([{ name: "John Doe", marks:{ total: 15, percentage: 66-22 } }]); //Read from mongo result = collection.find({"name" : {$eq: "John Doe"}}).first() if( result.marks.percentage eq percent){ writeoutput("Pass"); } </cfscript>
GetMongoBsonMinKey and GetMongoBsonMaxKey
<cfscript> // Retrieve database connection db = getmongoservice("mymongodb").db("cf_local") collection = db.students // Insert many documents res = collection.insertMany([{ enrollno: "110470116021", name: "John Adams", college: GetMongoBsonMinKey() }, { enrollno: "110470116022", name: "Jane Madison", college: GetMongoBsonMaxKey() }]) res = collection.find().toArray() </cfscript>
Other data types
- Date
- BigInt
- MongoObjectIdNew
- MongoRegExpNew
- MongoDBRefNew
- MongoBsonJSNew
- DataBaseReference
Database operations
Create a database
To create a db in MongoDB, use the service handler function getmongoservice and create the database.
<cfscript> db = getmongoservice("mymongodb").db("mynewdb") // create a db writeDump(db) </cfscript>
Create a collection
After you create a database, you must insert a collection in the database. To create a collection, you must create a MongoDB database object and create the collection inside the db. A db can consist of multiple collections.
<cfscript> db = getmongoservice("mymongodb").db("mynewdb") // create a db db.createCollection("mynewdbcollection") // create a collection called mynewdbcollection </cfscript>
Drop a database
<cfscript> db = getmongoservice("mymongodb").db("mynewdb") // create a db db.dropDatabase() // Removes the database </cfscript>
Get the name of a database
Use the getName method to retrieve the name of the database. For more information, see Get name of a database.
<cfscript> db = getmongoservice("mymongodb").db("deeppurple") // create a db db.createCollection("members") // create a collection db.members.insertMany([ { "_id" : 1, "name" : "Ian Gillan", "instrument" : "Vocals","born": 1945 }, { "_id" : 2, "name" : "Ian Paice", "instrument" : "Drums", "born" : 1948 }, { "_id" : 3, "name" : "Roger Glover", "instrument" : "Bass", "born" : 1945 }, { "_id" : 4, "name" : "Steve Morse", "instrument" : "Guitar", "born" : 1954 }, { "_id" : 5, "name" : "Don Airey", "instrument" : "Keyboards", "born" : 1948 }, { "_id" : 6, "name" : "Jeff Martin", "instrument" : "Vocals", "born" : 1969 }, { "_id" : 7, "name" : "Jeff Burrows", "instrument" : "Drums", "born" : 1968 }, { "_id" : 8, "name" : "Stuart Chatwood", "instrument" : "Bass", "born" : 1969 } ]) get_name=db.members.getName() writeOutput("The name of the database is: " & get_name) </cfscript>
Get the names of collections in a database
Use the getCollectionNames method to retrieve the names of all the collections in a database. For more information, see getCollectionNames docs. The output is an array of collection names.
<cfscript> db = getmongoservice("mymongodb").db("rockband") // create a db db.deeppurple.drop() db.kingcrimson.drop() db.createCollection("deeppurple") // create a collection db.deeppurple.insertMany([ { "_id" : 1, "name" : "Ian Gillan", "instrument" : "Vocals","born": 1945 }, { "_id" : 2, "name" : "Ian Paice", "instrument" : "Drums", "born" : 1948 }, { "_id" : 3, "name" : "Roger Glover", "instrument" : "Bass", "born" : 1945 }, { "_id" : 4, "name" : "Steve Morse", "instrument" : "Guitar", "born" : 1954 }, { "_id" : 5, "name" : "Don Airey", "instrument" : "Keyboards", "born" : 1948 }, { "_id" : 6, "name" : "Jeff Martin", "instrument" : "Vocals", "born" : 1969 }, { "_id" : 7, "name" : "Jeff Burrows", "instrument" : "Drums", "born" : 1968 }, { "_id" : 8, "name" : "Stuart Chatwood", "instrument" : "Bass", "born" : 1969 } ]) db.createCollection("kingcrimson") // create another collection db.kingcrimson.insertMany([ {"_id":1,"name":"Robert Fripp","instrument":"Guitar", "_id":2, "name": "Greg Lake","instrument":"Bass", "_id":3, "name": "Ian McDonald","instrument":"Keyboard", "_id":4, "name": "Michael Giles", "instrument":"Drums"} ]) collection_names=db.getCollectionNames() writeDump(collection_names) </cfscript>
Get information about a collection
The getCollectionInfos method returns an array of documents with collection or view information, such as name and options, for the current database. For more information, see getCollectionInfos docs.
<cfscript> // The following returns information for all collections in the rockband database db = getmongoservice("mymongodb").db("rockband") all_collections=db.getCollectionInfos() writeDump(all_collections) </cfscript>
To request collection information for a specific collection, specify the collection name when calling the function.
<cfscript> // The following returns information for all collections in the rockband database db = getmongoservice("mymongodb").db("rockband") out=db.getCollectionInfos({"born":1948}) writeDump(out) </cfscript>
Collection- CRUD methods
db.collection.count
Counts the number of documents in a collection. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // Members collection countResponse=db.members.count() writeDump(countResponse) // Returns all documents in the collection // Count all documents that match a query countResponse1=db.members.count( { born: { $gt: 1950 } } ) writeDump(countResponse1) // Returns documents that match the criteria </cfscript>
db.collection.countdocuments
This function returns the count of documents that match the query for a collection.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // Members collection countResponse=db.members.countDocuments() writeDump(countResponse) // Returns all documents in the collection // Count all documents that match a query countResponse1=db.members.countDocuments( { born: { $gt: 1950 } } ) writeDump(countResponse1) // Returns documents that match the criteria </cfscript>
db.collection.estimatedDocumentCount
This function returns the count of documents in a collection or view.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // Members collection countResponse=db.members.countDocuments() writeDump(countResponse) // Returns all documents in the collection // Count all documents that match a query countResponse1=db.members.estimatedDocumentCount( { born: { $gt: 1950 } } ) writeDump(countResponse1) // Returns documents that match the criteria </cfscript>
db.collection.deleteOne
This function Removes a single document from a collection.
<cfscript> // Retrieve database db = getmongoservice("cosmos").db("mydb") collection = db.collection collection.drop() writeOutput("number of documents in the collection: <b>" & collection.count() & " </b><br/>") writeOutput("<b> Insert a document </b><br/>") // Insert many documents res = collection.insertMany([{ enrollno: "1001", name: "John Doe", college: "Any college", course: { courseName: "Any course", duration: "4 Years" }, address: { city: "Any city", state: "Any state", country: "Any country" } }, { enrollno: "1002", name: "Jane Doe", college: "Some college", course: { courseName: "Some course", duration: "4 Years" }, address: { city: "Some city", state: "Some state", country: "Some country" } }]) //count number of documents in the collection writeOutput("number of documents in the collection: <b>" & collection.count() & " </b><br/>") writeOutput("<b> Delete a document </b><br/>") collection.deleteOne({name: MongoRegExp("John Doe","i")}) writeOutput("number of documents in the collection: <b>" & collection.count() & " </b><br/>") </cfscript>
db.collection.deleteOne
This function removes all documents that match a filter condition from a collection.
<cfscript> db = getmongoservice("mongodb").db("imdb"); db.orders.drop() db.orders.insertOne({ _id: MongoObjectId("563237a41a4d68582c2509da"), stock: "Brent Crude Futures", qty: 250, type: "buy-limit", limit: 48.90, creationts: ParseDateTime("2015-11-01T12:30:15Z"), expiryts: ParseDateTime("2015-11-01T12:35:15Z"), client: "Crude Traders Inc." }) writeoutput("count: " & db.orders.count() & " <br/>"); res = db.orders.deleteMany( { "client" : "Crude Traders Inc." } ); writedump(Res) writeoutput("count: " & db.orders.count() & " <br/>"); res = db.orders.deleteMany( { "stock" : "Brent Crude Futures", "limit" : { $gt : 48.88 } } ); writedump(Res) res = db.orders.deleteMany( { "client" : "Crude Traders Inc." }, { w : "majority", wtimeout : 100 } ); writedump(Res) writeoutput("collation example") db.mycoll.drop(); res = db.mycoll.insert([{ _id: 1, category: "café", status: "A" }, { _id: 2, category: "cafe", status: "a" }, { _id: 3, category: "cafE", status: "a" }]) writedump(res) res = db.myColl.deleteMany( { category: "cafe", status: "A" }, { collation: { locale: "fr", strength: 1 } } ) writedump(res) db.myColl.find().foreach((s) => { writedump(s) }) db.mycoll.drop(); db.orders.drop() </cfscript>
db.collection.distinct
This function finds distinct values for a specified field in a single collection.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); res = db.myColl1.insertMany([ { _id: 1, category: "café", status: 01 }, { _id: 2, category: "cafe", status: 02 }, { _id: 3, category: "cafE", status: 03 } ]) res = db.myColl1.distinct( "category", {}, { collation: { locale: "fr", strength: 1 } } ) writedump(res) </cfscript>
db.collection.drop
This function removes a collection from a database.
<cfscript> db = getmongoservice("mymongodb").db("mynewdb") // create a db db.createCollection("mynewdbcollection") // create a collection called mynewdbcollection try { db.mynewdbcollection.drop() // Removes the collection writeOutput("Collection removed sucessfully.") } catch (any e){ writeOutput("Unable to remove collection.") } // </cfscript>
db.collection.explain
This function returns information for the mthods listed in this doc.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // Members collection // Count function explainResponse1=db.members.explain().count({ born:{$gt:1950} }) writeDump(explainResponse1) </cfscript>
db.collection.find
This function selects documents in a collection or view. For more information, see db.collection.fine.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db //db.colFindDemo.drop() db.createCollection("colFindDemo") // create a collection db.colFindDemo.insertMany([ { "_id" : 1, "name" : "Ian Gillan", "instrument" : "Vocals","born": 1945 }, { "_id" : 2, "name" : "Ian Paice", "instrument" : "Drums", "born" : 1948 }, { "_id" : 3, "name" : "Roger Glover", "instrument" : "Bass", "born" : 1945 }, { "_id" : 4, "name" : "Steve Morse", "instrument" : "Guitar", "born" : 1954 }, { "_id" : 5, "name" : "Don Airey", "instrument" : "Keyboards", "born" : 1948 }, { "_id" : 6, "name" : "Jeff Martin", "instrument" : "Vocals", "born" : 1969 }, { "_id" : 7, "name" : "Jeff Burrows", "instrument" : "Drums", "born" : 1968 }, { "_id" : 8, "name" : "Stuart Chatwood", "instrument" : "Bass", "born" : 1969 } ]) // return all documents db.colFindDemo.find() writedump(res) </cfscript>
Other snippets-
<cfscript> db.colFindDemo.find({"_id":4}) </cfscript> <cfscript> db.colFindDemo.find({"instrument":"Drums"}) </cfscript> <cfscript> df.colFindDemo.find({"_id":{$gt:4}}) // find _ids greater than 4 </cfscript> <cfscript> df.colFindDemo.find({"instrument":{$regex:"^B"}}) // find instruments that start with B </cfscript> <cfscript> db.colFindDemo.find({"name":{$in:["Ian Gillan","Ian Paice"]}}) // find documents that match the names </cfscript> <cfscript> db.colFindDemo.find({"born":{$all:[1948]}}) // find documents that match born, which contains the year 1948 </cfscript> <cfscript> // find all documents where instrument is Drums or the year of birth is 1948 db.colFindDemo.find({$or:[{"instrument":"Drums"},{"born":1948}]}) </cfscript>
db.collection.insert
This function inserts a document or documents into a collection.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.createCollection("newcolThree") // create a collection // insert a single document db.newcolThree.insert({ "_id": 1, "name":"John Lennon", "band":"Beatles" }) </cfscript>
db.collection.insertOne
This function inserts a single document into a collection.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.newcolThree.drop() // drop the collection db.createCollection("newcolThree") // create a collection // insert a single document db.newcolThree.insert({ "_id": 1, "name":"John Lennon", "band":"Beatles" }) // insert another document db.newcolThree.insertOne({ "_id": 2, "name":"Paul McCartney", "band":"Beatles" }) // insert many documents db.newcolThree.insertMany([ { "_id": 3, "name":"George Harrison", "band":"Beatles" }, { "_id": 4, "name":"Ringo Starr", "band":"Beatles" } ]) </cfscript>
db.collection.insertMany
This function inserts multiple documents into a collection.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.newcolThree.drop() // drop the collection db.createCollection("newcolThree") // create a collection // insert a single document db.newcolThree.insert({ "_id": 1, "name":"John Lennon", "band":"Beatles" }) // insert another document db.newcolThree.insertOne({ "_id": 2, "name":"Paul McCartney", "band":"Beatles" }) // insert many documents db.newcolThree.insertMany([ { "_id": 3, "name":"George Harrison", "band":"Beatles" }, { "_id": 4, "name":"Ringo Starr", "band":"Beatles" } ]) </cfscript>
db.collection.isCapped
This function checks if a collection is a capped collection.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db ifCapped=db.cappedLogCollection.isCapped() writeOutput("Is collection capped: "& ifCapped) </cfscript>
db.collection.latencyStats
This function returns the latency statistics of a collection. For more information, see db.collection.latencyStats.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // Members collection latencyStatsResponse=db.members.latencyStats( { histograms: true } ) writedump(latencyStatsResponse) </cfscript>
db.collection.remove
This function removes documents from a collection.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db db.createCollection("mycolone") // create a collection // insert a single document db.mycolone.insert({ "_id": 1, "name":"John Lennon", "band":"Beatles" }) // insert another document db.mycolone.insertOne({ "_id": 2, "name":"Paul McCartney", "band":"Beatles" }) // insert many documents db.mycolone.insertMany([ { "_id": 3, "name":"George Harrison", "band":"Beatles" }, { "_id": 4, "name":"Ringo Starr", "band":"Beatles" } ]) // remove a document try{ db.mycolone.remove({}) writeOutput("Document removed sucessfully") } catch ( any e) { writeDump(e) } </cfscript>
db.collection.renameCollection
This function renames a collection.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // create a collection db.createCollection("coll_old") renameRes=db.coll_old.renameCollection("coll_new") writeDump(renameRes) </cfscript>
db.collection.replaceOne
This function replaces a single document in the collection based on a filter.
<cfscript> db = getmongoservice("mongodb").db("imdb"); //db.restaurant.drop() res = db.restaurant.insertMany([ { "_id" : 1, "name" : "Central Perk Cafe", "Borough" : "Manhattan" }, { "_id" : 2, "name" : "Rock A Feller Bar and Grill", "Borough" : "Queens", "violations" : 2 }, { "_id" : 3, "name" : "Empire State Pub", "Borough" : "Brooklyn", "violations" : 0 }]) // writedump(res) db.restaurant.find().foreach((s) => { writedump(s) }) res = db.restaurant.replaceOne( { "name" : "Central Perk Cafe" }, { "name" : "Central Pork Cafe", "Borough" : "Manhattan", "violations": 10 } ) writedump(res) </cfscript>
db.collection.stats
This function returns statistics of a collection. For more information, see db.collection.stats.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db statsResponse=db.articles.stats() writeDump(statsResponse) </cfscript>
db.collection.storageSize
This function returns the size of the storage of a document in a collection.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); db.log.drop() col = db.createCollection("log", { capped : true, size : 5242880, max : 3 } ).count(); //writedump(col); res = db.log.insertMany([ { _id: 1, category: "café", status: 01 }, { _id: 2, category: "cafe", status: 02 }, { _id: 3, category: "cafE", status: 03 } ]) //writedump(res); writedump(db.log.storageSize()) </cfscript>
db.collection.storageSize
This function returns the total size in bytes of the data in the collection.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); db.log.drop() col = db.createCollection("log", { capped : true, size : 5242880, max : 3 } ).count(); //writedump(col); res = db.log.insertMany([ { _id: 1, category: "café", status: 01 }, { _id: 2, category: "cafe", status: 02 }, { _id: 3, category: "cafE", status: 03 } ]) //writedump(res); writedump(db.log.totalSize()) </cfscript>
db.collection.update
This function modifies a document or documents in a collection.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.colUpdDemo.drop() db.createCollection("colUpdDemo") // create a collection db.colUpdDemo.insertMany([ { "_id":1, "product_name": "sildenafil citrate", "supplier": "Wisozk Inc", "quantity": 261, "unit_cost": "$10.47" }, { "_id":2, "product_name": "Mountain Juniperus ashei", "supplier": "Keebler-Hilpert", "quantity": 292, "unit_cost": "$8.74" }, { "_id":3, "product_name": "Dextromathorphan HBr", "supplier": "Schmitt-Weissnat", "quantity": 211, "unit_cost": "$20.53" } ]) // increment quantity by 10 for _id:1 db.colUpdDemo.update({"_id":1},{$inc:{"quantity":10}}) // update unit cost from 8.74 to 10.74 db.colUpdDemo.update({"_id":2},{$set:{"unit_cost": "$10.74"}}) </cfscript>
db.collection.updateOne
This function modifies a single document in a collection based on a filter.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.colUpdDemo.drop() db.createCollection("colUpdDemo") // create a collection db.colUpdDemo.insertMany([ { "_id":1, "product_name": "sildenafil citrate", "supplier": "Wisozk Inc", "quantity": 261, "unit_cost": "$10.47", "stock":10000 }, { "_id":2, "product_name": "Mountain Juniperus ashei", "supplier": "Keebler-Hilpert", "quantity": 292, "unit_cost": "$8.74", "stock":15000 }, { "_id":3, "product_name": "Dextromathorphan HBr", "supplier": "Schmitt-Weissnat", "quantity": 211, "unit_cost": "$20.53", "stock":20000 } ]) db.colUpdDemo.updateOne({"supplier": "Keebler-Hilpert"},{$set:{"stock":16000}}) </cfscript>
db.collection.updateMany
This function modifies all documents in a collection based on a filter.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.colUpdManyDemo.drop() db.createCollection("colUpdManyDemo") // create a collection db.colUpdManyDemo.insertMany([ { "_id":1, "product_name": "sildenafil citrate", "supplier": "Wisozk Inc", "quantity": 261, "unit_cost": "$10.47", "stock":10000 }, { "_id":2, "product_name": "Mountain Juniperus ashei", "supplier": "Keebler-Hilpert", "quantity": 292, "unit_cost": "$8.74", "stock":15000 }, { "_id":3, "product_name": "Dextromathorphan HBr", "supplier": "Schmitt-Weissnat", "quantity": 211, "unit_cost": "$20.53", "stock":20000 } ]) // update more than one document based on the specified filter db.colUpdManyDemo.updateMany( {"quantity" : {$gt: 250 }}, {$set: { "stock" : 50000 } } ); </cfscript>
db.collection.validate
This function scans a collection and decides if the collection is a valid one.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db db.colUpdManyDemo.drop() db.createCollection("colUpdManyDemo") // create a collection db.colUpdManyDemo.insertMany([ { "_id":1, "product_name": "sildenafil citrate", "supplier": "Wisozk Inc", "quantity": 261, "unit_cost": "$10.47", "stock":10000 }, { "_id":2, "product_name": "Mountain Juniperus ashei", "supplier": "Keebler-Hilpert", "quantity": 292, "unit_cost": "$8.74", "stock":15000 }, { "_id":3, "product_name": "Dextromathorphan HBr", "supplier": "Schmitt-Weissnat", "quantity": 211, "unit_cost": "$20.53", "stock":20000 } ]) // update more than one document based on the specified filter db.colUpdManyDemo.updateMany( {"quantity" : {$gt: 250 }}, {$set: { "stock" : 50000 } } ); isValidate=db.colUpdManyDemo.validate() writeDump(isValidate) </cfscript>
Collection- Advanced methods
db.collection.bulkWrite
This function performs multiple write operations enabling you to define the order of execution.
<cfscript> // Retrieve database db = getmongoservice("mymongodb").db("imdb") db.characters.drop() db.characters.insert([ { "_id" : 1, "char" : "Brisbane", "class" : "monk", "lvl" : 4 }, { "_id" : 2, "char" : "Eldon", "class" : "alchemist", "lvl" : 3 }, { "_id" : 3, "char" : "Meldane", "class" : "ranger", "lvl" : 3 } ]) res = db.characters.bulkWrite([ { insertOne: { "document": { "_id": 4, "char": "Dithras", "class": "barbarian", "lvl": 4 } } }, { insertOne: { "document": { "_id": 5, "char": "Taeln", "class": "fighter", "lvl": 3 } } }, { updateOne : { "filter" : { "char" : "Eldon" }, "update" : { $set : { "status" : "Critical Injury" } } } }, { deleteOne : { "filter" : { "char" : "Brisbane"} } }, { replaceOne : { "filter" : { "char" : "Meldane" }, "replacement" : { "char" : "Tanys", "class" : "oracle", "lvl": 4 } } } ]) writedump(res) </cfscript>
db.collection.findAndModify
This function modifies and returns a single document. For more information, see db.collection.findandmodify.
<cfscript> db = getmongoservice("mymongodb").db("student_db") db.students.drop() // create a collection db.createCollection("students") // Insert many documents // Insert many documents db.students.insertMany([ { enrollno: "1001", name: "John Doe", college: "Amherst", course: { courseName: "Math", duration: "4 Years" }, address: { city: "Any city", state: "Any state", country: "USA" } }, { enrollno: "1002", name: "Jane Doe", college: "Vassar", course: { courseName: "Physics", duration: "4 Years" }, address: { city: "Some city", state: "Some state", country: "USA" } }]) try{ res = db.students.findAndModify({ $and : [{ "enrollno" : {$gt : "1002"}} , {"name" : {$eq:"Jane Smith"}}]}) writeDump(res) writeOutput("Record modified successfully") } catch(any e){ writeDump(e) } </cfscript>
db.collection.findOne
This function returns a single document based on a filter. For more information, see db.collection.findone.
<cfscript> db = getmongoservice("mymongodb").db("newdb") // create a db //db.music.drop() db.createCollection("music") // create a collection db.music.insertMany([ { "_id" : 1, "name" : "Ian Gillan", "instrument" : "Vocals","born": 1945 }, { "_id" : 2, "name" : "Ian Paice", "instrument" : "Drums", "born" : 1948 }, { "_id" : 3, "name" : "Roger Glover", "instrument" : "Bass", "born" : 1945 }, { "_id" : 4, "name" : "Steve Morse", "instrument" : "Guitar", "born" : 1954 }, { "_id" : 5, "name" : "Don Airey", "instrument" : "Keyboards", "born" : 1948 }, { "_id" : 6, "name" : "Jeff Martin", "instrument" : "Vocals", "born" : 1969 }, { "_id" : 7, "name" : "Jeff Burrows", "instrument" : "Drums", "born" : 1968 }, { "_id" : 8, "name" : "Stuart Chatwood", "instrument" : "Bass", "born" : 1969 } ]) try{ res = db.music.findOne( {"name" : {$eq:"Ian Gillan"}}) writeDump(res) writeOutput("Record returned successfully") } catch(any e){ writeDump(e) } </cfscript>
db.collection.findOneAndDelete
This function deletes a single document based on a filter. For more information, see db.collection.findoneanddelete.
<cfscript> db = getmongoservice("mymongodb").db("student_db") db.students.drop() // create a collection db.createCollection("students") // Insert many documents db.students.insertMany([ { enrollno: "1001", name: "John Doe", college: "Amherst", course: { courseName: "Math", duration: "4 Years" }, address: { city: "Any city", state: "Any state", country: "USA" } }, { enrollno: "1002", name: "Jane Doe", college: "Vassar", course: { courseName: "Physics", duration: "4 Years" }, address: { city: "Some city", state: "Some state", country: "USA" } }]) try{ res = db.students.findOneAndDelete({ $and : [{ "enrollno" : {$gt : "1000"}} , {"name" : {$eq:"Jane Doe"}}]}) writeDump(res) writeOutput("Record deleted successfully") } catch(any e){ writeDump(e) } </cfscript>
db.collection.findOneAndReplace
This function replaces a single document based on a filter. For more information, see db.collection.findoneandreplace.
<cfscript> db = getmongoservice("mymongodb").db("newdb") //db.team.drop() // create a collection db.createCollection("team") // Insert many documents db.team.insertMany([ { "_id" : 1521, "team" : "Fearful Mallards", "score" : 25000 }, { "_id" : 2231, "team" : "Tactful Mooses", "score" : 23500 }, { "_id" : 4511, "team" : "Aquatic Ponies", "score" : 19250 }, { "_id" : 5331, "team" : "Cuddly Zebras", "score" : 15235 }, { "_id" : 3412, "team" : "Garrulous Bears", "score" : 22300 } ]) try{ res = db.team.findOneAndReplace( { "score" : { $lt : 30000 } }, { "team" : "Observant Badgers", "score" : 20000 , "owner" : "disney"}, { sort : { "score" : -1 }, projection: { "_id" : 0, "team" : 1 } } ) writeOutput("Record returned successfully") writeDump(res) } catch (any e) { writeDump(e) } </cfscript>
db.collection.findOneAndUpdate
This function updates a single document based on a filter. For more information, see db.collection.findoneandupdate.
<cfscript> db = getmongoservice("mymongodb").db("newdb") //db.grades.drop() db.createCollection("grades") // Insert many documents db.grades.insertMany([ { _id: 6305, name : "A. MacDyver", "assignment" : 5, "points" : 24 }, { _id: 6308, name : "B. Batlock", "assignment" : 3, "points" : 22 }, { _id: 6312, name : "M. Tagnum", "assignment" : 5, "points" : 30 }, { _id: 6319, name : "R. Stiles", "assignment" : 2, "points" : 12 }, { _id: 6322, name : "A. MacDyver", "assignment" : 2, "points" : 14 }, { _id: 6234, name : "R. Stiles", "assignment" : 1, "points" : 10 } ]) // with find records - records exists , use options try{ res = db.grades.findOneAndUpdate( { "name" : "A. MacDyver" }, { $inc : { "points" : 5 } }, { sort : { "points" : 1 }, projection: { "assignment" : 1, "points" : 1 } } ) writeOutput("Record updated successfully") } catch(any e){ writeDump(e) } </cfscript>
Aggregate methods
db.collection.aggregate
This function aggregates values for data in a collection. For more information, see db.collection.aggregate.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db db.scores.drop() // create a collection db.createCollection("scores") db.scores.insertMany([ { _id: 1, student: "Maya", homework: [ 10, 5, 10 ], quiz: [ 10, 8 ], extraCredit: 0 }, { _id: 2, student: "Ryan", homework: [ 5, 6, 5 ], quiz: [ 8, 8 ], extraCredit: 8 } ]) addFieldsResponse=db.scores.aggregate( [ { $addFields: { totalHomework: { $sum: "$homework" } , totalQuiz: { $sum: "$quiz" } } }, { $addFields: { totalScore: { $add: [ "$totalHomework", "$totalQuiz", "$extraCredit" ] } } } ] ) writeDump(addFieldsResponse) </cfscript>
db.collection.distinct
This function returns the distinct values in a collection. For more information, see the official docs.
<cfscript> db = mongoservice("mymongodb").db("db_source") // create a db // Members collection distinctResponse=db.members.distinct("instrument") writeDump(distinctResponse) </cfscript>
db.collection.count
Counts the number of documents in a collection. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // Members collection countResponse=db.members.count() writeDump(countResponse) // Returns all documents in the collection // Count all documents that match a query countResponse1=db.members.count( { born: { $gt: 1950 } } ) writeDump(countResponse1) // Returns documents that match the criteria </cfscript>
db.collection.mapReduce
This function acts as a wrapper for mapReduce function. For more information, see the official docs.
<cfscript> try { db = getmongoservice("mymongodb").db("mrd") collection_orders = db.collection("orders") //writedump(collection_orders); collection_orders.insertmany([ { _id: CreateUUID(), cust_id: "abc123", ord_date:DateFormat("Oct 04, 2012"), status: 'A', price: 25, items: [ { sku: "mmm", qty: 5, price: 2.5 }, { sku: "nnn", qty: 5, price: 2.5 } ] }, { _id: CreateUUID(), cust_id: "def123", ord_date:DateFormat("Oct 04, 2012"), status: 'A', price: 25, items: [ { sku: "mmm", qty: 5, price: 2.5 }, { sku: "nnn", qty: 5, price: 2.5 } ] } ]) mapFunction1 = function() { emit(this.cust_id, this.price); } reduceFunction1 = function(keyCustId, valuesPrices){ return Array.sum(valuesPrices); } res = collection_orders.mapReduce( "#mapFunction1#", "#reduceFunction1#", { out: "sample_output"}) writeoutput("No of records fetched after map-reduce:" & res.len()); writeoutput("<br>Value returned from records:" & res[1].value & "," & res[2].value) } catch(any e){ writedump(e) } finally{ db.orders.drop(); db.runCommand({dropDatabase:1}); } </cfscript>
Stream method
In MongoDB, streams enable applications to stream real-time data changes by using MongoDB’s replication capabilities. Streams help in updating data in real time so that applications access the most recent data. For example, trading systems, IOT data use data streams extensively.
Change streams notify your application of all writes to documents and provide access to information as and when changes occur, without any polling of data.
Collections.watch
This function opens a change stream for a collection. For more information, see db.collection.watch.
<cfscript> // Retrieve database db = getmongoservice("sharded").db("streamtest"); res = db.adminCommand( { enableSharding: "streamtest" } ) collection = db.Students; res = db.adminCommand( { shardCollection: "streamtest.Students", key: { enrollno: 1 } } ); cursor = collection.watch(); // Insert many documents res = collection.insertMany([{ enrollno: "1001", name: "John Doe", college: "Amherst", course: { courseName: "Math", duration: "4 Years" }, address: { city: "Any city", state: "Any state", country: "USA" } }]) streamRes = cursor.Next(); writedump(var=streamRes , label="Cursor.next"); </cfscript>
Query caching
You can implement caching in MongoDB with the help of the following:
CachedAfter: You can cache a MongoDB query using the cachedAfter attribute. If the query was last run after the supplied date, cached data is used. Otherwise the query is re-run.
CachedWithin: The cachedWithin attribute instructs ColdFusion to execute a MongoDB query ONLY if it does not have a result set from that exact query in memory already.
CachedAfter
<cfscript> db = getmongoservice("mymongodb").db("db_cache") // create a db collection = db.students // Insert many documents collection.insertMany([ { enrollno: "1001", name: "John Doe", college: "Amherst", course: { courseName: "Math", duration: "4 Years" }, address: { city: "Any city", state: "Any state", country: "USA" } }, { enrollno: "1002", name: "Jane Doe", college: "Vassar", course: { courseName: "Physics", duration: "4 Years" }, address: { city: "Some city", state: "Some state", country: "USA" } }]) currentDate = now(); res1 = collection.find({ $and : [{ "enrollno" : {$gt : "1000"}} , {"name" : {$eq: "John Doe"}}]}).cachedAfter(DateAdd("s",3,currentDate)).toArray(); writeOutput("<br/>Reading from db... Count is " & ArrayLen(res1)); collection.insertMany([{ enrollno: "1001", name: "John Doe", college: "Amherst", course: { courseName: "Math", duration: "4 Years" }, address: { city: "Any city", state: "Any state", country: "USA" } }]) sleep(1000); res = collection.find({ $and : [{ "enrollno" : {$gt : "1000"}} , {"name" : {$eq: "John Doe"}}]}).cachedAfter(DateAdd("s",3,currentDate)).toArray(); writeOutput("<br/>reading from db before cacheAfter time... Count is " & ArrayLen(res)); </cfscript>
CachedWithin
<cfscript> db = getmongoservice("mymongodb").db("db_cache") // create a db collection = db.students // Insert many documents collection.insertMany([ { enrollno: "1001", name: "John Doe", college: "Amherst", course: { courseName: "Math", duration: "4 Years" }, address: { city: "Any city", state: "Any state", country: "USA" } }, { enrollno: "1002", name: "Jane Doe", college: "Vassar", course: { courseName: "Physics", duration: "4 Years" }, address: { city: "Some city", state: "Some state", country: "USA" } }]) currentDate = now(); res1 = collection.find({ $and : [{ "enrollno" : {$gt : "1000"}} , {"name" : {$eq: "John Doe"}}]}).cachedAfter(DateAdd("s",3,currentDate)).toArray(); writeOutput("<br/>Reading from db... Count is " & ArrayLen(res1)); collection.insertMany([{ enrollno: "1001", name: "John Doe", college: "Amherst", course: { courseName: "Math", duration: "4 Years" }, address: { city: "Any city", state: "Any state", country: "USA" } }]) sleep(1000) res = collection.find({ $and : [{ "enrollno" : {$gt : "1000"}} , {"name" : {$eq: "John Doe"}}]}).cachedWithin(createTimespan(0, 0, 0, 5)).toArray(); writeOutput("<br/>reading from cache... Count is " & ArrayLen(res)); </cfscript>
GRIDFS methods
GridFS stores files in chunks, instead of storing a file in a single document. Each chunk is stored as a separate document. For more information, see GridFS.
Instead of storing a file in a single document, GridFS divides the file into parts, or chunks [1], and stores each chunk as a separate document.
db.createBucket
GridFS stores collections in a bucket. This function creates indexes on a collection.
<cfscript> db=getmongoservice("mymongodb").db("newdb") try{ res=db.createBucket("newbucket") // create bucket writeOutput("Bucket created successfully") writeDump(res) } catch(any e){ writeDump(e) } finally{ res.drop() } </cfscript>
bucket.upload
Upload a file in a bucket.
<cfscript> bucket = getmongoservice("mymongodb").db("newdb").createbucket("bucket3"); try{ returnId = bucket.upload(expandPath(".") & "/exception.log") writeOutput("File uploaded successfully") writeDump(returnId) } catch(any e){ writeDump(e) } </cfscript>
bucket.download
Download a file from a bucket.
<cfscript> bucket = getmongoservice("mymongodb").db("newdb").createbucket("bucket"); // upload a file returnId = bucket.upload(expandPath(".") & "/exception.log") try{ result = bucket.download(expandPath("."), mongoObjectId(returnId)) writeOutput("File downloaded successfully") writeDump(result) } catch(any e){ writeDump(e) } </cfscript>
bucket.rename
Renames a file in a bucket.
<cfscript> bucket = getmongoservice("mymongodb").db("newdb").createbucket("bucket") // upload a file returnId = bucket.upload(expandPath(".") & "/exception.log") // rename the file in the bucket try{ bucket.rename(returnId, "exceptionNew.log") writeOutput("File renamed successfully") } catch(any e){ writeDump(e) } </cfscript>
bucket.find
Searches for a file in a bucket.
<cfscript> bucket = getmongoservice("mymongodb").db("newdb").createbucket("bucket") // upload a file returnId = bucket.upload(expandPath(".") & "/exception.log") // rename the file in the bucket bucket.rename(returnId, "exceptionNew.log") try{ res = bucket.find({filename: "exceptionNew.log"}).toArray() // find the file if(res[1].filename == "exceptionNew.log") { writeoutput("File has been found.") } } catch(any e){ writeDump(e) } </cfscript>
bucket.delete
Deletes a file in a bucket.
<cfscript> bucket = getmongoservice("mymongodb").db("newdb").createbucket("bucket") // upload a file returnId = bucket.upload(expandPath(".") & "/exception.log") try{ res = bucket.delete(returnId) if(res.name == "bucket"){ writeoutput("File deleted successfully") } } catch (any e){ writeDump(e) } </cfscript>
bucket.drop
Deletes a bucket.
<cfscript> bucket = getmongoservice("mymongodb").db("newdb").createbucket("bucket") try{ res = bucket.drop() if(res.name == "bucket"){ writeoutput("Bucket is deleted successfully") } } catch(any e){ writeDump(e) } </cfscript>
Index methods
db.collection.createIndex
This function creates indexes on a collection. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); //db.products.drop() db.createCollection("products") // insert documents db.products.insertMany([ { "_id" : 1, "item" : "apple", "type" : "honey crisp", "price" : 1.99 }, { "_id" : 2, "item" : "apple", "type" : "fuji", "price" : 1.99 }, { "_id" : 3, "item" : "apple", "type" : "jonagold", "price" : 1.29 }, { "_id" : 4, "item" : "apple", "type" : "jonathan", "price" : 1.29 }, { "_id" : 5, "item" : "apple", "type" : "mcintosh", "price" : 1.29 }, { "_id" : 6, "item" : "apple", "type" : "cortland", "price" : 1.29 }, { "_id" : 7, "item" : "orange", "type" : "cara cara", "price" : 2.99 }, { "_id" : 9, "item" : "orange", "type" : "satsuma", "price" : 1.99 }, { "_id" : 8, "item" : "orange", "type" : "valencia", "price" : 0.99 }, { "_id" : 10, "item" : "orange", "type" : "navel", "price" : 1.39 } ]) // create indexes indexRes = db.products.createIndex( [ { "item" : 1, "type" : 1 }, { "item" : 1, "type" : -1 }, { "price" : 1 } ]) writedump(indexRes) </cfscript>
db.collection.createIndexes
This function creates one or more indexes on a collection. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); //db.products.drop() db.createCollection("products") // insert documents db.products.insertMany([ { "_id" : 1, "item" : "apple", "type" : "honey crisp", "price" : 1.99 }, { "_id" : 2, "item" : "apple", "type" : "fuji", "price" : 1.99 }, { "_id" : 3, "item" : "apple", "type" : "jonagold", "price" : 1.29 }, { "_id" : 4, "item" : "apple", "type" : "jonathan", "price" : 1.29 }, { "_id" : 5, "item" : "apple", "type" : "mcintosh", "price" : 1.29 }, { "_id" : 6, "item" : "apple", "type" : "cortland", "price" : 1.29 }, { "_id" : 7, "item" : "orange", "type" : "cara cara", "price" : 2.99 }, { "_id" : 9, "item" : "orange", "type" : "satsuma", "price" : 1.99 }, { "_id" : 8, "item" : "orange", "type" : "valencia", "price" : 0.99 }, { "_id" : 10, "item" : "orange", "type" : "navel", "price" : 1.39 } ]) // create indexes indexRes = db.products.createIndexes( [ { "item" : 1, "type" : 1 }, { "item" : 1, "type" : -1 }, { "price" : 1 } ]) writedump(indexRes) </cfscript>
db.collection.dropIndex
This function removes a specified index from a collection. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); //db.products.drop() db.createCollection("products") // insert documents db.products.insertMany([ { "_id" : 1, "item" : "apple", "type" : "honey crisp", "price" : 1.99 }, { "_id" : 2, "item" : "apple", "type" : "fuji", "price" : 1.99 }, { "_id" : 3, "item" : "apple", "type" : "jonagold", "price" : 1.29 }, { "_id" : 4, "item" : "apple", "type" : "jonathan", "price" : 1.29 }, { "_id" : 5, "item" : "apple", "type" : "mcintosh", "price" : 1.29 }, { "_id" : 6, "item" : "apple", "type" : "cortland", "price" : 1.29 }, { "_id" : 7, "item" : "orange", "type" : "cara cara", "price" : 2.99 }, { "_id" : 9, "item" : "orange", "type" : "satsuma", "price" : 1.99 }, { "_id" : 8, "item" : "orange", "type" : "valencia", "price" : 0.99 }, { "_id" : 10, "item" : "orange", "type" : "navel", "price" : 1.39 } ]) // create indexes createIdx=db.products.createIndex( [ { "item" : 1, "type" : 1 }, { "item" : 1, "type" : -1 }, { "price" : 1 } ]) // drop index db.products.dropIndex(createIdx) </cfscript>
db.collection.dropIndexes
This function removes a specified index or indexes from a collection. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); //db.products.drop() db.createCollection("products") // insert documents db.products.insertMany([ { "_id" : 1, "item" : "apple", "type" : "honey crisp", "price" : 1.99 }, { "_id" : 2, "item" : "apple", "type" : "fuji", "price" : 1.99 }, { "_id" : 3, "item" : "apple", "type" : "jonagold", "price" : 1.29 }, { "_id" : 4, "item" : "apple", "type" : "jonathan", "price" : 1.29 }, { "_id" : 5, "item" : "apple", "type" : "mcintosh", "price" : 1.29 }, { "_id" : 6, "item" : "apple", "type" : "cortland", "price" : 1.29 }, { "_id" : 7, "item" : "orange", "type" : "cara cara", "price" : 2.99 }, { "_id" : 9, "item" : "orange", "type" : "satsuma", "price" : 1.99 }, { "_id" : 8, "item" : "orange", "type" : "valencia", "price" : 0.99 }, { "_id" : 10, "item" : "orange", "type" : "navel", "price" : 1.39 } ]) // create indexes createIdx=db.products.createIndex( [ { "item" : 1, "type" : 1 }, { "item" : 1, "type" : -1 }, { "price" : 1 } ]) // drop index db.products.dropIndexes(createIdx) </cfscript>
db.collection.getIndexes
This function decribes the existing indexes on a collection. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); // db.products.drop() db.createCollection("products") // insert documents db.products.insertMany([ { "_id" : 1, "item" : "apple", "type" : "honey crisp", "price" : 1.99 }, { "_id" : 2, "item" : "apple", "type" : "fuji", "price" : 1.99 }, { "_id" : 3, "item" : "apple", "type" : "jonagold", "price" : 1.29 }, { "_id" : 4, "item" : "apple", "type" : "jonathan", "price" : 1.29 }, { "_id" : 5, "item" : "apple", "type" : "mcintosh", "price" : 1.29 }, { "_id" : 6, "item" : "apple", "type" : "cortland", "price" : 1.29 }, { "_id" : 7, "item" : "orange", "type" : "cara cara", "price" : 2.99 }, { "_id" : 9, "item" : "orange", "type" : "satsuma", "price" : 1.99 }, { "_id" : 8, "item" : "orange", "type" : "valencia", "price" : 0.99 }, { "_id" : 10, "item" : "orange", "type" : "navel", "price" : 1.39 } ]) // create indexes db.products.createIndexes( [ { "item" : 1, "type" : 1 }, { "item" : 1, "type" : -1 }, { "price" : 1 } ]) // get index getRes=db.products.getIndexes() writeDump(getRes) </cfscript>
db.collection.reIndex
This function removes all indexes on a collection and rebuilds them.. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); // db.products.drop() db.createCollection("products") // insert documents db.products.insertMany([ { "_id" : 1, "item" : "apple", "type" : "honey crisp", "price" : 1.99 }, { "_id" : 2, "item" : "apple", "type" : "fuji", "price" : 1.99 }, { "_id" : 3, "item" : "apple", "type" : "jonagold", "price" : 1.29 }, { "_id" : 4, "item" : "apple", "type" : "jonathan", "price" : 1.29 }, { "_id" : 5, "item" : "apple", "type" : "mcintosh", "price" : 1.29 }, { "_id" : 6, "item" : "apple", "type" : "cortland", "price" : 1.29 }, { "_id" : 7, "item" : "orange", "type" : "cara cara", "price" : 2.99 }, { "_id" : 9, "item" : "orange", "type" : "satsuma", "price" : 1.99 }, { "_id" : 8, "item" : "orange", "type" : "valencia", "price" : 0.99 }, { "_id" : 10, "item" : "orange", "type" : "navel", "price" : 1.39 } ]) // create indexes db.products.createIndexes( [ { "item" : 1, "type" : 1 }, { "item" : 1, "type" : -1 }, { "price" : 1 } ]) // re index try{ res=db.products.reIndex() writeOutput("Indexes removed and re-created successfully") writeDump(res) } catch(any e){ writeDump(e) } </cfscript>
db.collection.totalIndexSize
This function returns the total size of all the indexes in a collection.. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("imdb"); // db.products.drop() db.createCollection("products") // insert documents db.products.insertMany([ { "_id" : 1, "item" : "apple", "type" : "honey crisp", "price" : 1.99 }, { "_id" : 2, "item" : "apple", "type" : "fuji", "price" : 1.99 }, { "_id" : 3, "item" : "apple", "type" : "jonagold", "price" : 1.29 }, { "_id" : 4, "item" : "apple", "type" : "jonathan", "price" : 1.29 }, { "_id" : 5, "item" : "apple", "type" : "mcintosh", "price" : 1.29 }, { "_id" : 6, "item" : "apple", "type" : "cortland", "price" : 1.29 }, { "_id" : 7, "item" : "orange", "type" : "cara cara", "price" : 2.99 }, { "_id" : 9, "item" : "orange", "type" : "satsuma", "price" : 1.99 }, { "_id" : 8, "item" : "orange", "type" : "valencia", "price" : 0.99 }, { "_id" : 10, "item" : "orange", "type" : "navel", "price" : 1.39 } ]) // create indexes db.products.createIndexes( [ { "item" : 1, "type" : 1 }, { "item" : 1, "type" : -1 }, { "price" : 1 } ]) totSize=db.products.totalIndexSize() writeDump(totSize) </cfscript>
Database methods
db.adminCommand
The db.adminCommand provides a helper function to run database commands. For more information, see the official docs.
The example below uses db.adminCommand() to execute the renameCollection database command to rename the collection collection1 in the db_source database to collection11.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db renameResponse= db.adminCommand( { renameCollection: "db_source.collection1", to: "db_source.collection11" } ) writeDump(renameResponse) </cfscript>
db.createCollection
Creates a collection. You can also use this method to create a capped collection. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db isSuccessful=db.createCollection("log", { capped : true, size : 5242880, max : 5000 } ) writeDump(isSuccessful) </cfscript>
db.createView
This function Creates a view as the result of the applying the specified aggregation pipeline to the source collection or view. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // create a collection db.createCollection("survey") db.survey.insertMany([ { _id: 1, empNumber: "abc123", feedback: { management: 3, environment: 3 }, department: "A" }, { _id: 2, empNumber: "xyz987", feedback: { management: 2, environment: 3 }, department: "B" }, { _id: 3, empNumber: "ijk555", feedback: { management: 3, environment: 4 }, department: "A" } ]) // create view viewResponse=db.createView( "managementFeedback", "survey", [ { $project: { "management": "$feedback.management", department: 1 } } ] ) writeDump(viewResponse) </cfscript>
db.currentOp
This function Returns a document that contains information on in-progress operations for the database instance. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // The following example returns information on all active operations for // database db_source that have been running longer than 3 seconds currentOpResponse=db.currentOp( { "active" : true, "secs_running" : { "$gt" : 3 }, "ns" : /^db_source\./ } ) writeDump(currentOpResponse) </cfscript>
db.getCollection
This function returns a collection object for any collection in the database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db collectionResponse=db.getCollection("survey") writeDump(collectionResponse) </cfscript>
db.getCollectionInfos
This function returns an array of documents with collection or view information, such as name and options, for the current database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db collInfoResponse=db.getCollectionInfos() writeDump(collInfoResponse) </cfscript>
db.getCollectionNames
This function returns an array containing the names of all collections and views in the current database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db collNamesResponse=db.getCollectionNames() writeDump(collNamesResponse) </cfscript>
db.getMongo
This function returns the current database connection. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db mongoResponse=db.getMongo() writeDump(mongoResponse) </cfscript>
db.getName
This function returns the current name of the database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db nameResponse=db.getName() writeDump(nameResponse) </cfscript>
db.getSiblingDB
This function returns a database object. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db siblingResponse=db.getSiblingDB("db_source") writeDump(siblingResponse) </cfscript>
db.hostInfo
This function returns an array with system information that the mongod or mongos runs on. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db hostInfoResponse=db.hostInfo() writeDump(hostInfoResponse) </cfscript>
db.isMaster
This function returns an array that describes the mongod session. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db isMasterResponse=db.isMaster() writeDump(isMasterResponse) </cfscript>
db.runCommand
This function acts as a helper for the following database commands:
Command |
Description |
---|---|
logout |
Terminates the current authenticated session. |
createUser |
Creates a new user. |
dropAllUsersFromDatabase |
Deletes all users associated with a database. |
dropUser |
Removes a single user. |
grantRolesToUser |
Grants a role and its privileges to a user. |
revokeRolesFromUser |
Removes a role from a user. |
updateUser |
Updates a user’s data. |
usersInfo |
Returns information about the specified users. |
createUser |
Creates a new user. |
dropAllUsersFromDatabase |
Deletes all users associated with a database. |
dropUser |
Removes a single user. |
grantRolesToUser |
Grants a role and its privileges to a user. |
revokeRolesFromUser |
Removes a role from a user. |
updateUser |
Updates a user’s data. |
usersInfo |
Returns information about the specified users. |
createRole |
Creates a role and specifies its privileges. |
dropRole |
Deletes the user-defined role. |
dropAllRolesFromDatabase |
Deletes all user-defined roles from a database. |
grantPrivilegesToRole |
Assigns privileges to a user-defined role. |
grantRolesToRole |
Specifies roles from which a user-defined role inherits privileges. |
invalidateUserCache |
Flushes the in-memory cache of user information, including credentials and roles. |
revokePrivilegesFromRole |
Removes the specified privileges from a user-defined role. |
revokeRolesFromRole |
Removes specified inherited roles from a user-defined role. |
rolesInfo |
Returns information for the specified role or roles. |
updateRole |
Updates a user-defined role. |
delete |
Deletes one or more documents. |
find |
Selects documents in a collection or a view. |
findAndModify |
Returns and modifies a single document. |
getLastError |
Returns the success status of the last operation. |
insert |
Inserts one or more documents. |
resetError |
Resets the last error status. |
update |
Updates one or more documents. |
This command will fail in some cases when unordered structs are sent to it. MongoDB functions accepts keys in a certain order and while sending them via ColdFusion. Ensure that these keys are ordered. Hence for all these commands, use ordered structs .
For example,
res = db.runCommand ([ "createUser" : "mongouser2", "pwd" : "testpassword", "customData" : {"testUser":"ok"}, "roles": [["role":"readWrite","db":dbName]] ])
db.serverBuildInfo
This function returns a document that contains an overview of parameters used to compile this mongod instance. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db buildResponse=db.serverBuildInfo() writeDump(buildResponse) </cfscript>
db.serverStatus
This function returns a struct that provides an overview of the database process’s state. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db serverResponse=db.serverStatus() writeDump(serverResponse) </cfscript>
db.stats
This function returns statistics for a database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db statsResponse=db.stats(1024) // To display kilobytes rather than bytes, specify a scale value of 1024. writeDump(statsResponse) </cfscript>
db.version
This function returns the version of the mongo instance. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db versionResponse=db.version() writeDump(versionResponse) </cfscript>
User Management methods
db.changeUserPassword
This function updates the password of a user.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db db.changeUserPassword("username","password") </cfscript>
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db db.changeUserPassword("username",passwordPrompt()) // Prompt for a new password </cfscript>
db.createUser
This function creates a new user for the database on which the method is run. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db createResponse=db.createUser( { user: "User1", pwd: "admin123", roles: [ "readWrite", "dbAdmin" ] } ) writeDump(createResponse) </cfscript>
db.dropUser
This function removes a user from the current database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db dropResponse=db.dropUser("User1") writeDump(dropResponse) </cfscript>
db.dropAllUsers
This function drops all users in a database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // create three users db.createUser( { user: "User1", pwd: "admin123", roles: [ "readWrite", "dbAdmin" ] } ) db.createUser( { user: "User2", pwd: "admin123", roles: [ "readWrite", "dbAdmin" ] } ) db.createUser( { user: "User3", pwd: "admin123", roles: [ "readWrite", "dbAdmin" ] } ) dropAllResponse=db.dropAllUsers({w: "majority", wtimeout: 5000}) writeDump(dropAllResponse) </cfscript>
db.getUser
This function returns information about a specified user. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // create a user db.createUser( { user: "User1", pwd: "admin123", roles: [ "readWrite", "dbAdmin" ] } ) getUserResponse=db.getUser("User1") writeDump(getUserResponse) </cfscript>
db.getUsers
This function returns information about all users in the database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // create three users db.createUser( { user: "User11", pwd: "admin123", roles: [ "readWrite", "dbAdmin" ] } ) db.createUser( { user: "User12", pwd: "admin123", roles: [ "readWrite", "dbAdmin" ] } ) db.createUser( { user: "User13", pwd: "admin123", roles: [ "readWrite", "dbAdmin" ] } ) getUsersResponse=db.getUsers() writeDump(getUsersResponse) </cfscript>
db.grantRolesToUser
This function grants roles to a user. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db // create a user db.createUser( { user: "User001", pwd: "admin123", roles: ["dbAdmin"] } ) grantRoleResponse=db.grantRolesToUser("User001",["read","readWrite"]) writeDump(grantRoleResponse) </cfscript>
db.revokeRolesFromUser
This function removes a one or more roles from a user on the current database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db revokeRoleResponse=db.revokeRolesFromUser("User001",["read","readWrite"]) writeDump(revokeRoleResponse) </cfscript>
db.updateUser
This function updates the user’s profile on the database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db updateRole={ roles:["read","readWrite"] } updateUserResponse=db.updateUser("User001",updateRole) writeDump(updateUserResponse) </cfscript>
Role Management methods
db.createRole
This function creates a role in the database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db roleDocument={ "role": "newRead", "privileges": [ [ resource: [ db: "db_source" , collection: "" ], actions: [ "find", "createCollection", "dbStats", "collStats" ] ] ], "roles":[] } createRoleResponse=db.createRole(roleDocument) writeDump(createRoleResponse) </cfscript>
db.dropRole
This function deletes a user-defined role from the database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source_1") // create a db // create a user defined role dbName="db_source_1" db.createRole( [ role: "customrole1", privileges: [ [ resource: [ db: dbName , collection: "" ], actions: [ "find", "createCollection", "dbStats", "collStats" ] ], [ resource: [ db: dbName, collection: "logs" ], actions: [ "insert" ] ], [ resource: [ db: dbName, collection: "data" ], actions: [ "insert", "update", "remove", "compact" ] ], [ resource: [ db: dbName, collection: "system.js" ], actions: [ "find" ] ] ], roles : [["role":"userAdmin","db":dbName], ["role":"readWrite","db":dbName] ] ]) dropRoleResponse=db.dropRole("customrole1") writeDump(dropRoleResponse) </cfscript>
db.dropAllRoles
This function deletes all user-defined roles on the database.
<cfscript> db = getmongoservice("mymongodb").db("db_source_1") // create a db dbName="db_source_1" // create three custom roles db.createRole( [ role: "customrole11", privileges: [ [ resource: [ db: dbName , collection: "" ], actions: [ "find", "createCollection", "dbStats", "collStats" ] ], [ resource: [ db: dbName, collection: "logs" ], actions: [ "insert" ] ], [ resource: [ db: dbName, collection: "data" ], actions: [ "insert", "update", "remove", "compact" ] ], [ resource: [ db: dbName, collection: "system.js" ], actions: [ "find" ] ] ], roles : [["role":"userAdmin","db":dbName], ["role":"readWrite","db":dbName] ] ]) db.createRole( [ role: "customrole12", privileges: [ [ resource: [ db: dbName , collection: "" ], actions: [ "find", "createCollection", "dbStats", "collStats" ] ], [ resource: [ db: dbName, collection: "logs" ], actions: [ "insert" ] ], [ resource: [ db: dbName, collection: "data" ], actions: [ "insert", "update", "remove", "compact" ] ], [ resource: [ db: dbName, collection: "system.js" ], actions: [ "find" ] ] ], roles : [["role":"userAdmin","db":dbName], ["role":"readWrite","db":dbName] ] ]) dropAllRolesResponse=db.dropAllRoles({ w: "majority" }) writeDump(dropAllRolesResponse) </cfscript>
db.getRole
This function returns the roles from which this role inherits privileges. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source_1") // create a db getRoleResponse=db.getRole("newRead",{ "showBuiltinRoles":true, "showPrivileges":true }) writeDump(getRoleResponse) </cfscript>
db.getRoles
This function retrieves information of all the roles in the database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source_1") // create a db getAllRolesResponse=db.getRoles( { rolesInfo: 1, showPrivileges:true, showBuiltinRoles: true } ) writeDump(getAllRolesResponse) </cfscript>
db.grantPrivilegesToRole
This function grants additional privileges to a user-defined role. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db dbName="db_source" grantResponse=db.grantPrivilegesToRole("newRead", [ { resource: { db: dbName, collection: "" }, actions: [ "insert" ] }, { resource: { db: dbName, collection: "system.js" }, actions: [ "find" ] } ] ) writeDump(grantResponse) </cfscript>
db.revokePrivilegesFromRole
This function removes specified specified privileges from the user-defined role on the database. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db dbName="db_source" // create a user defined role db.createrole( [ role: "customrole005", privileges: [ [ resource: [ db: dbName , collection: "" ], actions: [ "find", "createCollection", "dbStats", "collStats" ] ], [ resource: [ db: dbName, collection: "logs" ], actions: [ "insert" ] ], [ resource: [ db: dbName, collection: "data" ], actions: [ "insert", "update", "remove", "compact" ] ], [ resource: [ db: dbName, collection: "system.js" ], actions: [ "find" ] ] ], roles : [["role":"userAdmin","db":dbName], ["role":"readWrite","db":dbName] ] ]) revokeResponse=db.revokePrivilegesFromRole("customrole002", [ { resource: { db: dbName, collection: "" }, actions: [ "find","createCollection" ] }, { resource: { db: dbName, collection: "system.js" }, actions: [ "find" ] } ] ) writeDump(revokeResponse) </cfscript>
db.grantRolesToRole
This function grants roles to a user-defined role. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db grantRoleUDR=db.grantRolesToRole("customrole005",["read"]) writeDump(grantRoleUDR) </cfscript>
db.revokeRolesFromRole
This function removes the specified inherited roles from a role. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db revokeRoleUDR=db.revokeRolesFromRole("customrole005",["read"]) writeDump(revokeRoleUDR) </cfscript>
db.updateRole
This function updates a user-defined role. For more information, see the official docs.
<cfscript> db = getmongoservice("mymongodb").db("db_source") // create a db dbName="db_source" roleDocument={ privileges:[ [ resource: [ db: dbName , collection: "" ], actions: [ "find", "createCollection", "dbStats", "collStats" ] ] ], roles:["read","readWrite"] } updateRoleResponse=db.updateRole("customrole005",roleDocument) writeDump(updateRoleResponse) </cfscript>
Limitations
GSSAPI authentication is not supported in MongoDB.